puter/paseo
1
0
Fork 0
mirror of https://github.com/getpaseo/paseo.git synced 2026-10-30 13:13:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(lint): parallelize workspace registry bootstrap upserts

Browse Source 
Collect per-workspace upsert inputs in a sync pass, then run registry
writes via Promise.all to eliminate no-await-in-loop warnings.
This commit is contained in:
Mohamed Boudra
2026-04-24 03:19:09 +07:00
parent 7e16fd6b4d
commit 97d9035371
1 changed files with 49 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/server/workspace-registry-bootstrap.ts
+49 -27
View File
@@ -95,6 +95,14 @@ export async function bootstrapWorkspaceRegistries(options: {
}
const projectRanges = new Map<string, { createdAt: string | null; updatedAt: string | null }>();
type Placement = Awaited<ReturnType<typeof buildProjectPlacementForCwd>>;
const workspaceUpsertInputs: {
workspaceId: string;
placement: Placement;
workspaceCwd: string;
createdAt: string;
updatedAt: string;
}[] = [];
for (const [workspaceId, entry] of recordsByWorkspaceId.entries()) {
const { placement, records: workspaceRecords } = entry;
@@ -108,20 +116,6 @@ export async function bootstrapWorkspaceRegistries(options: {
const createdAt = workspaceCreatedAt ?? new Date().toISOString();
const updatedAt = workspaceUpdatedAt ?? createdAt;
await options.workspaceRegistry.upsert(
createPersistedWorkspaceRecord({
workspaceId,
projectId: placement.projectKey,
cwd: workspaceCwd,
kind: deriveWorkspaceKind(placement.checkout),
displayName: deriveWorkspaceDisplayName({
cwd: workspaceCwd,
checkout: placement.checkout,
}),
createdAt,
updatedAt,
}),
);
const existingProjectRange = projectRanges.get(placement.projectKey) ?? {
createdAt: null,
@@ -131,21 +125,49 @@ export async function bootstrapWorkspaceRegistries(options: {
existingProjectRange.updatedAt = maxIsoDate(existingProjectRange.updatedAt, updatedAt);
projectRanges.set(placement.projectKey, existingProjectRange);
await options.projectRegistry.upsert(
createPersistedProjectRecord({
projectId: placement.projectKey,
rootPath: deriveProjectRootPath({
cwd: workspaceCwd,
checkout: placement.checkout,
}),
kind: deriveProjectKind(placement.checkout),
displayName: placement.projectName,
createdAt: existingProjectRange.createdAt ?? createdAt,
updatedAt: existingProjectRange.updatedAt ?? updatedAt,
}),
);
workspaceUpsertInputs.push({ workspaceId, placement, workspaceCwd, createdAt, updatedAt });
}
await Promise.all(
workspaceUpsertInputs.flatMap(
({ workspaceId, placement, workspaceCwd, createdAt, updatedAt }) => {
const projectRange = projectRanges.get(placement.projectKey) ?? {
createdAt: null,
updatedAt: null,
};
return [
options.workspaceRegistry.upsert(
createPersistedWorkspaceRecord({
workspaceId,
projectId: placement.projectKey,
cwd: workspaceCwd,
kind: deriveWorkspaceKind(placement.checkout),
displayName: deriveWorkspaceDisplayName({
cwd: workspaceCwd,
checkout: placement.checkout,
}),
createdAt,
updatedAt,
}),
),
options.projectRegistry.upsert(
createPersistedProjectRecord({
projectId: placement.projectKey,
rootPath: deriveProjectRootPath({
cwd: workspaceCwd,
checkout: placement.checkout,
}),
kind: deriveProjectKind(placement.checkout),
displayName: placement.projectName,
createdAt: projectRange.createdAt ?? createdAt,
updatedAt: projectRange.updatedAt ?? updatedAt,
}),
),
];
},
),
);
options.logger.info(
{
projectsFile: path.join(options.paseoHome, "projects", "projects.json"),