Function deleteStaleRequests

packages/insomnia/src/konnect/sync.ts:364–421

* Deletes stale konnect-managed requests (route removed from Konnect) and * any user-added requests (no konnectRouteKey) found in the workspace.

(
  existingData: ExistingRequestData,
  incomingKeys: Set<string>,
  incomingRouteIds: Set<string>,
  routeCounts: SyncCounts,
)

 * any user-added requests (no konnectRouteKey) found in the workspace.
 */
async function deleteStaleRequests(
  existingData: ExistingRequestData,
  incomingKeys: Set<string>,
  incomingRouteIds: Set<string>,
  routeCounts: SyncCounts,
): Promise<void> {
  // Delete konnect-managed requests whose key no longer matches an incoming route
  const stale: (() => Promise<void>)[] = [
    ...[...existingData.maps.http.values()]
      .filter(r => !incomingKeys.has(r.konnectRouteKey!))
      .map(r => () => insoservices.request.remove(r)),
    ...[...existingData.maps.ws.values()]
      .filter(r => !incomingKeys.has(r.konnectRouteKey!))
      .map(r => () => insoservices.webSocketRequest.remove(r)),
    ...[...existingData.maps.grpc.values()]
      .filter(r => !incomingKeys.has(r.konnectRouteKey!))
      .map(r => () => insoservices.grpcRequest.remove(r)),
  ];

  // Delete user-added requests (no konnectRouteKey) that live in the workspace or its folders.
  const noKeyQuery = {
    parentId: { $in: existingData.parentIds },
    $or: [{ konnectRouteKey: null }, { konnectRouteKey: { $exists: false } }],
  };
  const userHttp = await db.find<Request>(models.request.type, noKeyQuery);
  const userWs = await db.find<WebSocketRequest>(models.webSocketRequest.type, noKeyQuery);
  const userGrpc = await db.find<GrpcRequest>(models.grpcRequest.type, noKeyQuery);
  stale.push(
    ...userHttp.map(r => () => insoservices.request.remove(r)),
    ...userWs.map(r => () => insoservices.webSocketRequest.remove(r)),
    ...userGrpc.map(r => () => insoservices.grpcRequest.remove(r)),
  );

  for (const remove of stale) {
    await remove();
    routeCounts.deleted++;
  }

  // Delete orphaned folders (route removed from Konnect) and empty sub-folders
  // (path/protocol renamed — requests were already deleted above, leaving the sub-folder empty).
  const folderIds = existingData.folders.map(f => f._id);
  const foldersWithChildren = new Set<string>([
    ...(await db.find<Request>(models.request.type, { parentId: { $in: folderIds } })).map(r => r.parentId),
    ...(await db.find<WebSocketRequest>(models.webSocketRequest.type, { parentId: { $in: folderIds } })).map(
      r => r.parentId,
    ),
    ...(await db.find<GrpcRequest>(models.grpcRequest.type, { parentId: { $in: folderIds } })).map(r => r.parentId),
    ...(await db.find<RequestGroup>(models.requestGroup.type, { parentId: { $in: folderIds } })).map(f => f.parentId),
  ]);
  for (const folder of existingData.folders) {
    if (!folder.konnectRouteId) {
      continue;
    }
    if (!incomingRouteIds.has(folder.konnectRouteId) || !foldersWithChildren.has(folder._id)) {
      await insoservices.requestGroup.remove(folder);
    }
  }
}