Function syncGrpcRoute

packages/insomnia/src/konnect/sync.ts:143–213

(
  route: KonnectRoute,
  workspaceId: string,
  existingByKey: Map<string, GrpcRequest>,
  routeCounts: SyncCounts,
  incomingKeys: Set<string>,
)

}

async function syncGrpcRoute(
  route: KonnectRoute,
  workspaceId: string,
  existingByKey: Map<string, GrpcRequest>,
  routeCounts: SyncCounts,
  incomingKeys: Set<string>,
): Promise<void> {
  const grpcProtocols = route.protocols.filter(p => p === 'grpc' || p === 'grpcs') as ('grpc' | 'grpcs')[];
  const multiProtocol = grpcProtocols.length > 1;
  const paths = route.paths ?? [null];
  const metadata = Object.entries(route.headers ?? {}).map(([n, values]: [string, string[]]) => ({
    name: n.toLowerCase(),
    value: values[0],
  }));

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

  for (const rawPath of paths) {
    const protoMethodName = resolvePath(rawPath).path;
    const baseName = protoMethodName || routeDisplayName(route);

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

      const pathSegment = rawPath ?? '';
      const key = `${route.id}:grpc:${pathSegment}:${protocol}`;
      incomingKeys.add(key);
      routeCounts.total++;

      const proxyHostVar = protocol === 'grpcs' ? '_.grpcs_proxy_host' : '_.grpc_proxy_host';
      const url = `${protocol}://{{ ${proxyHostVar} }}`;
      const name = baseName;
      const existing = existingByKey.get(key);

      const konnectManagedHeaderNames = metadata.map(h => h.name);
      if (existing) {
        const merged = mergeHeaders(existing.metadata ?? [], metadata, existing.konnectManagedHeaderNames ?? []);
        if (
          existing.url !== url ||
          existing.name !== name ||
          existing.protoMethodName !== protoMethodName ||
          konnectHeadersChanged(existing.metadata ?? [], metadata, existing.konnectManagedHeaderNames ?? [])
        ) {
          await insoservices.grpcRequest.update(existing, {
            url,
            name,
            protoMethodName,
            metadata: merged,
            konnectManagedHeaderNames,
          });
          routeCounts.updated++;
        }
      } else {
        await insoservices.grpcRequest.create({