Function syncControlPlane

packages/insomnia/src/konnect/sync.ts:597–689

Syncs a single control plane: upserts its project + env, syncs all services, deletes stale workspaces.

(
  controlPlane: KonnectControlPlane,
  syncCtx: SyncContext,
  acc: ControlPlaneSyncAccumulators,
)

/** Syncs a single control plane: upserts its project + env, syncs all services, deletes stale workspaces. */
async function syncControlPlane(
  controlPlane: KonnectControlPlane,
  syncCtx: SyncContext,
  acc: ControlPlaneSyncAccumulators,
): Promise<void> {
  const { pat, organizationId, existingProjectsByKonnectId, signal, onProgress } = syncCtx;
  acc.controlPlaneCounts.total++;
  const region = controlPlane.region;

  // Upsert project for this control plane
  let project = existingProjectsByKonnectId.get(controlPlane.id);
  if (project) {
    if (
      project.name !== controlPlane.name ||
      project.konnectClusterType !== controlPlane.config.cluster_type ||
      getKonnectDeploymentType(controlPlane) !== project.konnectDeploymentType ||
      project.konnectRegion !== controlPlane.region
    ) {
      project = await insoservices.project.update(project, {
        name: controlPlane.name,
        konnectClusterType: controlPlane.config.cluster_type,
        konnectDeploymentType: getKonnectDeploymentType(controlPlane),
        konnectRegion: controlPlane.region,
      });
      acc.controlPlaneCounts.updated++;
    }
  } else {
    project = await insoservices.project.create({
      parentId: organizationId,
      name: controlPlane.name,
      konnectControlPlaneId: controlPlane.id,
      konnectClusterType: controlPlane.config.cluster_type,
      konnectDeploymentType: getKonnectDeploymentType(controlPlane),
      konnectRegion: controlPlane.region,
    });
    existingProjectsByKonnectId.set(controlPlane.id, project);
    acc.controlPlaneCounts.created++;
  }

  const globalEnvironmentId = await upsertProjectEnvVars(controlPlane, project);

  onProgress?.(`Fetching services for ${controlPlane.name}...`);
  const services = await fetchAllServices(pat, controlPlane.id, region, signal);

  // Load existing Konnect workspaces for this project once, keyed by service id
  const existingWorkspaces = (
    await db.find<Workspace>(models.workspace.type, {
      parentId: project._id,
      konnectServiceId: { $ne: null },
    })
  ).filter(w => w.konnectServiceId != null);
  const existingWorkspaceByServiceId = new Map(existingWorkspaces.map(w => [w.konnectServiceId!, w]));
  const incomingServiceIds = new Set(services.map(s => s.id));

  const ctx: ServiceSyncContext = { pat, controlPlane, project, region, globalEnvironmentId, signal, onProgress };
  const CONCURRENCY = 5;
  const bufferId = await db.bufferChanges();
  try {