Add workflow dispatch throttling

Author: teimurjan

workspaces/functions/api/deploy-webhook.ts

@@ -5,6 +5,9 @@ const HYGRAPH_SECRET = process.env.HYGRAPH_SECRET!
 const GITHUB_WORKFLOW_URL = process.env.GITHUB_WORKFLOW_URL!
 const GITHUB_TOKEN = process.env.GITHUB_TOKEN!
 
+// Global timer to accumulate webhook requests
+let timer: NodeJS.Timeout | null = null
+const TIMEOUT = 30000
 
 export default async function handler(req: VercelRequest, res: VercelResponse) {
   if (req.method !== 'POST') {
@@ -31,23 +34,34 @@ export default async function handler(req: VercelRequest, res: VercelResponse) {
     return res.status(403).json({ message: 'Invalid signature' })
   }
 
-  try {
-    const response = await fetch(GITHUB_WORKFLOW_URL, {
-      method: 'POST',
-      headers: {
-        Authorization: `Bearer ${GITHUB_TOKEN}`,
-        Accept: 'application/vnd.github+json',
-        'X-GitHub-Api-Version': '2022-11-28',
-      },
-      body: JSON.stringify({ ref: 'main' }),
-    })
-
-    if (!response.ok) {
-      throw new Error(`Failed to trigger workflow: ${response.statusText}`)
+  if (timer) {
+    return res.status(200).json({ message: 'Deployment already scheduled' })
+  }
+
+  timer = setTimeout(async () => {
+    try {
+      const response = await fetch(GITHUB_WORKFLOW_URL, {
+        method: 'POST',
+        headers: {
+          Authorization: `Bearer ${GITHUB_TOKEN}`,
+          Accept: 'application/vnd.github+json',
+          'X-GitHub-Api-Version': '2022-11-28',
+        },
+        body: JSON.stringify({ ref: 'main' }),
+      })
+
+      if (!response.ok) {
+        console.error(`Failed to trigger workflow: ${response.statusText}`)
+      } else {
+        console.log('Deployment triggered')
+      }
+    } catch (error) {
+      console.error('Error triggering deployment:', error)
+    } finally {
+      // Reset the timer so that future requests can schedule a new dispatch.
+      timer = null
     }
+  }, TIMEOUT)
 
-    return res.status(200).json({ message: 'Deployment triggered' })
-  } catch (error) {
-    return res.status(500).json({ error: (error as unknown as Error).message })
-  }
+  return res.status(200).json({ message: 'Deployment scheduled' })
 }