Function enqueuePluginScan

apps/cursor/src/lib/plugins/queue.ts:15–29

(pluginId: string)

};

export async function enqueuePluginScan(pluginId: string): Promise<void> {
  const supabase = await createAdminClient();
  const { error } = await supabase
    // biome-ignore lint/suspicious/noExplicitAny: pgmq_public is not in the generated types
    .schema("pgmq_public" as any)
    .rpc("send", {
      queue_name: PLUGIN_SCAN_QUEUE,
      message: { plugin_id: pluginId } satisfies PluginScanMessage,
      sleep_seconds: 0,
    });

  if (error) {
    throw new Error(`pgmq_public.send failed: ${error.message}`);
  }
}

export async function readNextPluginScan(
  vtSeconds: number,