Function kickDrainAfterResponse

apps/cursor/src/lib/plugins/queue.ts:87–106

()

 * still in the queue and gets drained on the next tick.
 */
export function kickDrainAfterResponse(): void {
  const cronSecret = process.env.CRON_SECRET;
  if (!cronSecret) {
    // In dev without CRON_SECRET we silently skip the kick. The drain route
    // would 500 anyway (requireCronAuth fail-closes when CRON_SECRET is unset).
    return;
  }

  after(async () => {
    try {
      await fetch(`${drainBaseUrl()}${DRAIN_PATH}`, {
        headers: { Authorization: `Bearer ${cronSecret}` },
      });
    } catch (err) {
      // Best-effort kick; the cron will retry. Logging keeps us honest about
      // how often the kick path fails so we can spot regressions.
      console.error("[queue] kick drain failed (cron will retry)", err);
    }
  });
}