src/webhooks/middleware/webhooks.ts

import express from 'express'
import { getWebhook } from '../lib/index'
import { allVersions } from '@/versions/lib/all-versions'
import { defaultCacheControl } from '@/frame/middleware/cache-control'

const router = express.Router()

// Returns a webhook for the given category and version
//
// Example request:
//
//   /api/webhooks/v1?category=check_run&version=free-pro-team%40latest
router.get('/v1', async function webhooks(req, res) {
  if (!req.query.category) {
    res.status(400).json({ error: "Missing 'category' in query string" })
    return
  }
  if (!req.query.version) {
    res.status(400).json({ error: "Missing 'version' in query string" })
    return
  }

  const webhookVersion = Object.values(allVersions).find(
    (version) => version.version === req.query.version,
  )?.version
  const notFoundError = 'No webhook found for given category and version'

  if (!webhookVersion) {
    res.status(404).json({ error: notFoundError })
    return
  }

  const webhook = await getWebhook(webhookVersion, req.query.category as string)

  if (webhook) {
    if (process.env.NODE_ENV !== 'development') {
      defaultCacheControl(res)
    }
    res.status(200).send(webhook)
  } else {
    res.status(404).json({ error: notFoundError })
  }
})

export default router