sync.ts

import type { SqliteDatabase } from "@r_masseater/ops-harbor-core";
import { ControlPlaneClient } from "./control-plane-client";
import type { OpsHarborConfig } from "./config";
import { replaceSnapshot } from "./local-db";

export async function syncFromControlPlane(
  db: SqliteDatabase,
  config: OpsHarborConfig,
): Promise<{ workItems: number; events: number; synchronized?: number }> {
  const client = new ControlPlaneClient(config);
  let synchronized: number | undefined;
  if (config.authorLogin) {
    try {
      const result = await client.triggerSync(config.authorLogin);
      synchronized = result.synchronized;
    } catch (e) {
      // triggerSync is best-effort; network/control-plane errors should not abort the sync
      console.error("[ops-harbor] syncFromControlPlane: triggerSync failed:", e);
      synchronized = undefined;
    }
  }

  const [workItems, events] = await Promise.all([client.listWorkItems(), client.listActivity()]);
  replaceSnapshot(db, workItems, events);
  return {
    workItems: workItems.length,
    events: events.length,
    ...(synchronized !== undefined ? { synchronized } : {}),
  };
}