Function GET

apps/cursor/src/app/api/queue/plugin-scans/drain/route.ts:56–159

(request: NextRequest)

}

export async function GET(request: NextRequest) {
  const unauthorized = requireCronAuth(request);
  if (unauthorized) return unauthorized;

  let msg: Awaited<ReturnType<typeof readNextPluginScan>>;
  try {
    msg = await readNextPluginScan(VT_SECONDS);
  } catch (err) {
    logError("readNextPluginScan failed", err);
    return NextResponse.json(
      { ok: false, error: "queue_read_failed" },
      { status: 500 },
    );
  }

  if (!msg) {
    return NextResponse.json({
      ok: true,
      queue: PLUGIN_SCAN_QUEUE,
      drained: 0,
    });
  }

  const { msg_id, read_ct, message } = msg;
  const pluginId = message.plugin_id;

  if (!pluginId || typeof pluginId !== "string") {
    // Malformed payload — archive it so it doesn't keep getting retried.
    logError(
      "malformed message; archiving",
      new Error(JSON.stringify(message)),
    );
    await archivePluginScan(msg_id).catch((err) =>
      logError("archive (malformed) failed", err),
    );
    return NextResponse.json(
      { ok: false, archived: msg_id, reason: "malformed_message" },
      { status: 200 },
    );
  }

  if (read_ct > MAX_ATTEMPTS) {
    logInfo("exceeded MAX_ATTEMPTS; burying", {
      pluginId,
      msg_id,
      read_ct,
      max: MAX_ATTEMPTS,
    });
    await markScanFailed(pluginId, `Exceeded ${MAX_ATTEMPTS} scan attempts`);
    await archivePluginScan(msg_id);
    invalidatePluginCaches();
    return NextResponse.json({
      ok: true,
      buried: pluginId,
      msg_id,
      read_ct,
    });
  }