Function syncHttpRoute

packages/insomnia/src/konnect/sync.ts:284–358

(
  route: KonnectRoute,
  workspaceId: string,
  headers: { name: string; value: string }[],
  existingByKey: Map<string, Request>,
  routeCounts: SyncCounts,
  incomingKeys: Set<string>,
)

}

async function syncHttpRoute(
  route: KonnectRoute,
  workspaceId: string,
  headers: { name: string; value: string }[],
  existingByKey: Map<string, Request>,
  routeCounts: SyncCounts,
  incomingKeys: Set<string>,
): Promise<void> {
  const methods = route.methods ?? ['GET', 'POST', 'PUT', 'DELETE', 'PATCH'];
  const paths = route.paths ?? [null];
  const httpProtocols = route.protocols.filter(p => p === 'http' || p === 'https') as ('http' | 'https')[];
  const multiProtocol = httpProtocols.length > 1;
  const needsSubFolders = multiProtocol || paths.length > 1;

  const routeFolderId = await upsertRouteFolder(workspaceId, routeDisplayName(route), route.id);

  for (const routePath of paths) {
    const { path: resolvedPath, pathParameters } = resolvePath(routePath);
    const pathSegment = routePath ?? '';
    const baseName = buildRequestName({ ...route, paths: routePath !== null ? [routePath] : null });

    for (const protocol of httpProtocols) {
      let parentId = routeFolderId;
      if (needsSubFolders) {
        const subFolderName = multiProtocol ? `${protocol.toUpperCase()} ${baseName}` : baseName;
        parentId = await upsertFolder(routeFolderId, subFolderName, route.id);
      }

      for (const method of methods) {
        const key = `${route.id}:${method}:${pathSegment}:${protocol}`;
        incomingKeys.add(key);
        routeCounts.total++;

        const url = `${protocol}://{{ _.proxy_host }}${resolvedPath}`;
        const name = baseName;
        const existing = existingByKey.get(key);

        const konnectManagedHeaderNames = headers.map(h => h.name);
        if (existing) {
          const merged = mergeHeaders(existing.headers ?? [], headers, existing.konnectManagedHeaderNames ?? []);
          const mergedPathParams = mergePathParameters(existing.pathParameters ?? [], pathParameters);
          if (
            existing.method !== method ||
            existing.url !== url ||
            existing.name !== name ||
            konnectHeadersChanged(existing.headers ?? [], headers, existing.konnectManagedHeaderNames ?? []) ||
            pathParametersChanged(existing.pathParameters ?? [], pathParameters)
          ) {
            await insoservices.request.update(existing, {
              method,
              url,
              name,
              headers: merged,
              pathParameters: mergedPathParams,
              konnectManagedHeaderNames,
            });
            routeCounts.updated++;
          }