Function syncServiceWorkspace

packages/insomnia/src/konnect/sync.ts:423–525

(
  ctx: ServiceSyncContext,
  service: KonnectService,
  existingWorkspace: Workspace | undefined,
  counts: { services: SyncCounts; routes: SyncCounts },
  skippedRoutes: SkippedRoute[],
)

}

async function syncServiceWorkspace(
  ctx: ServiceSyncContext,
  service: KonnectService,
  existingWorkspace: Workspace | undefined,
  counts: { services: SyncCounts; routes: SyncCounts },
  skippedRoutes: SkippedRoute[],
): Promise<void> {
  const { pat, controlPlane, project, region, globalEnvironmentId, signal, onProgress } = ctx;

  const serviceName = service.name ?? `Gateway Service ${service.id}`;

  // Upsert workspace for this service
  let workspace: Workspace;
  if (existingWorkspace) {
    if (existingWorkspace.name !== serviceName) {
      workspace = await insoservices.workspace.update(existingWorkspace, { name: serviceName });
      counts.services.updated++;
    } else {
      workspace = existingWorkspace;
    }
  } else {
    workspace = await insoservices.workspace.create({
      parentId: project._id,
      name: serviceName,
      scope: 'collection',
      konnectServiceId: service.id,
    });
    counts.services.created++;
  }
  counts.services.total++;

  // Set project-level env as the active global env for this workspace
  const workspaceMeta = await insoservices.workspaceMeta.getOrCreateByParentId(workspace._id);
  if (workspaceMeta.activeGlobalEnvironmentId !== globalEnvironmentId) {
    await insoservices.workspaceMeta.update(workspaceMeta, { activeGlobalEnvironmentId: globalEnvironmentId });
  }
  await insoservices.cookieJar.getOrCreateForParentId(workspace._id);

  const incomingRoutes = (await fetchRoutesForService(pat, controlPlane.id, service.id, region, signal)).map(
    sanitizeRoute,
  );
  const existingData = await loadExistingRequestData(workspace._id);
  const incomingKeys = new Set<string>();
  const incomingRouteIds = new Set<string>();

  for (const route of incomingRoutes) {
    signal?.throwIfAborted();
    incomingRouteIds.add(route.id);

    const expressionResult = applyExpressionFields(route);
    if (!expressionResult.syncable) {
      counts.routes.skipped++;
      skippedRoutes.push({ routeName: expressionResult.routeName, reason: expressionResult.reason, serviceName });
      continue;
    }
    const effectiveRoute = expressionResult.route;

    const isL4 = effectiveRoute.protocols.every(p => L4_PROTOCOLS.has(p));