1import { NextResponse } from 'next/server';2import { dashboard, connectorsOverview } from '@/lib/admin/queries';3import { queueDepths } from '@/lib/admin/queue';45export const runtime = 'nodejs';6export const dynamic = 'force-dynamic';78/** Machine-readable pipeline status for monitors (admin cookie required by the proxy). */9export async function GET() {10 const [d, connectors, queues] = await Promise.all([dashboard(), connectorsOverview(), queueDepths()]);11 return NextResponse.json({12 counts: d.counts,13 queues,14 connectors: connectors.map((c) => ({ id: c.id, status: c.status, health: c.health_status, lastRun: c.last_started_at, lastRunStatus: c.last_run_status, lastError: c.last_error, records24h: c.records_24h })),15 as_of: new Date().toISOString(),16 });17}18