import type { Metadata } from 'next';
import Link from 'next/link';
import { PageHeader, Section, Note } from '@/components/ui/section';
import { EmptyState } from '@/components/ui/empty-state';
import { Badge, StatusBadge } from '@/components/ui/badge';
import { connectorStates, recentIngests } from '@/lib/queries/pulse';
import { fmtDate, fmtDateTime, fmtDuration, fmtInt, humanize, relativeTime } from '@/lib/format';

export const metadata: Metadata = { title: 'Data update log', description: 'Every connector run of the last 60 days with records created, updated and rejected, dataset versions, and the health and last successful import of each source.' };
export const revalidate = 600;

/** Stale = an active scheduled connector without a success in the last 14 days (the worker uses 2× its interval; 14 days is the display rule here). */
const STALE_DAYS = 14;

export default async function DataUpdatesPage() {
  const [runs, states] = await Promise.all([recentIngests(60, 400), connectorStates()]);
  const byDay = new Map<string, typeof runs>();
  for (const r of runs) {
    const d = String(r.started_at).slice(0, 10);
    byDay.set(d, [...(byDay.get(d) ?? []), r]);
  }
  const now = Date.now();
  return (
    <div className="pb-8">
      <PageHeader kicker="Data" title="Data update log" lede="Transparency on freshness (SPEC §61-62): each source is versioned and every ingestion is a run with counters; historical values are never silently replaced. Runs marked partial stopped on their time budget and resume from a cursor." />

      <Section id="sources" kicker="Sources" title="Connector state" description="Health from the hourly probe, last successful import, schedule (UTC cron) and the dataset version the source reported last. Sources under license review or awaiting credentials never run.">
        <div className="ci-table-wrap">
          <table className="ci-table">
            <thead>
              <tr>
                <th>Source</th>
                <th>Category</th>
                <th>Status</th>
                <th>Health</th>
                <th>Last successful import</th>
                <th>Schedule</th>
                <th>Dataset version</th>
                <th className="num">Source records</th>
              </tr>
            </thead>
            <tbody>
              {states.map((s) => {
                const stale = s.status === 'active' && !!s.schedule && (!s.last_success_at || now - new Date(s.last_success_at).getTime() > STALE_DAYS * 86_400_000);
                return (
                  <tr key={s.connector_id}>
                    <td>
                      <Link href={`/source/${s.connector_id}`} className="ci-link">
                        {s.source_name ?? s.connector_id}
                      </Link>
                    </td>
                    <td className="text-[12.5px]">{humanize(s.category)}</td>
                    <td>
                      <StatusBadge status={s.status} />
                      {s.paused ? <Badge tone="warn" className="ml-1">paused</Badge> : null}
                    </td>
                    <td>
                      <StatusBadge status={s.health} />
                      {stale ? (
                        <Badge tone="warn" className="ml-1" title={`No successful run in ${STALE_DAYS} days`}>
                          stale
                        </Badge>
                      ) : null}
                    </td>
                    <td className="whitespace-nowrap text-[12.5px]" title={s.last_success_at ? fmtDateTime(s.last_success_at) : ''}>
                      {s.last_success_at ? `${fmtDate(s.last_success_at)} (${relativeTime(s.last_success_at)})` : <span className="text-ink-4">never</span>}
                    </td>
                    <td className="ci-mono text-[11.5px]">{s.schedule ?? '—'}</td>
                    <td className="ci-mono text-[11.5px]">{s.last_dataset_version ?? '—'}</td>
                    <td className="num">{fmtInt(s.record_count)}</td>
                  </tr>
                );
              })}
            </tbody>
          </table>
        </div>
      </Section>

      <Section id="runs" kicker="Runs" title={`Ingestion runs, last 60 days (${fmtInt(runs.length)})`} description="Most recent first, grouped by day. Created / updated / unchanged / rejected are source records; the anomaly column shows refused destructive updates.">
        {runs.length ? (
          <div className="space-y-6">
            {[...byDay.entries()].map(([day, rows]) => (
              <div key={day}>
                <h3 className="mb-1 text-[15px]">{fmtDate(day)}</h3>
                <div className="ci-table-wrap">
                  <table className="ci-table">
                    <thead>
                      <tr>
                        <th>Started</th>
                        <th>Source</th>
                        <th>Mode</th>
                        <th>Status</th>
                        <th className="num">Fetched</th>
                        <th className="num">Created</th>
                        <th className="num">Updated</th>
                        <th className="num">Unchanged</th>
                        <th className="num">Rejected</th>
                        <th>Duration</th>
                        <th>Dataset version</th>
                        <th>Anomaly</th>
                      </tr>
                    </thead>
                    <tbody>
                      {rows.map((r) => (
                        <tr key={r.id}>
                          <td className="whitespace-nowrap text-[12px]">{fmtDateTime(r.started_at)}</td>
                          <td>
                            <Link href={`/source/${r.connector_id}`} className="ci-link">
                              {r.source_name ?? r.connector_id}
                            </Link>
                          </td>
                          <td className="text-[12px]">{r.mode}</td>
                          <td>
                            <StatusBadge status={r.status} />
                          </td>
                          <td className="num">{fmtInt(r.records_fetched)}</td>
                          <td className="num">{fmtInt(r.records_created)}</td>
                          <td className="num">{fmtInt(r.records_updated)}</td>
                          <td className="num text-ink-3">{fmtInt(r.records_unchanged)}</td>
                          <td className={`num ${r.records_rejected > 0 ? 'text-warn' : ''}`}>{fmtInt(r.records_rejected)}</td>
                          <td className="whitespace-nowrap text-[12px]">{fmtDuration(r.duration_ms)}</td>
                          <td className="ci-mono text-[11.5px]">{r.dataset_version ?? '—'}</td>
                          <td className="text-[12px] text-danger">{r.anomaly ?? ''}</td>
                        </tr>
                      ))}
                    </tbody>
                  </table>
                </div>
              </div>
            ))}
          </div>
        ) : (
          <EmptyState title="No ingestion run in the last 60 days" />
        )}
      </Section>
      <div className="mt-6">
        <Note>Run identifiers are `ING-&lt;CONNECTOR&gt;-YYYYMMDD-nnnnnn`; operators can open a run on the admin console. Derived layers (counters, intelligence, rankings) are recomputed after every run that changed records, then daily at 06:00, 06:15 and 06:30 UTC.</Note>
      </div>
    </div>
  );
}