Function loadExistingRequestData

packages/insomnia/src/konnect/sync.ts:117–141

(workspaceId: string)

}

async function loadExistingRequestData(workspaceId: string): Promise<ExistingRequestData> {
  // Include requests up to 2 levels deep (workspace → route folders → path×protocol sub-folders).
  const topFolders = await db.find<RequestGroup>(models.requestGroup.type, { parentId: workspaceId });
  const subFolders =
    topFolders.length > 0
      ? await db.find<RequestGroup>(models.requestGroup.type, { parentId: { $in: topFolders.map(f => f._id) } })
      : [];
  const allFolders = [...topFolders, ...subFolders];
  const parentIds = [workspaceId, ...allFolders.map(f => f._id)];
  const query = { parentId: { $in: parentIds }, konnectRouteKey: { $ne: null } };
  const httpDocs = (await db.find<Request>(models.request.type, query)).filter(r => r.konnectRouteKey != null);
  const wsDocs = (await db.find<WebSocketRequest>(models.webSocketRequest.type, query)).filter(
    r => r.konnectRouteKey != null,
  );
  const grpcDocs = (await db.find<GrpcRequest>(models.grpcRequest.type, query)).filter(r => r.konnectRouteKey != null);
  return {
    maps: {
      http: new Map(httpDocs.map(r => [r.konnectRouteKey!, r])),
      ws: new Map(wsDocs.map(r => [r.konnectRouteKey!, r])),
      grpc: new Map(grpcDocs.map(r => [r.konnectRouteKey!, r])),
    },
    parentIds,
    folders: allFolders,
  };
}

async function syncGrpcRoute(
  route: KonnectRoute,