External/SnapOtter
1
0
Fork 0
mirror of https://github.com/snapotter-hq/SnapOtter.git synced 2026-08-03 07:46:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: accept clientJobId in batch endpoint for SSE progress correlation

Browse Source
This commit is contained in:
Siddharth Kumar Sah
2026-03-23 14:03:56 +08:00
parent 6521d70238
commit 2514078ea1
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/routes/batch.ts
+5 -1
View File
@@ -42,6 +42,7 @@ export async function registerBatchRoutes(
// Parse multipart: collect all files and the settings field // Parse multipart: collect all files and the settings field
const files: ParsedFile[] = []; const files: ParsedFile[] = [];
let settingsRaw: string | null = null; let settingsRaw: string | null = null;
let clientJobId: string | null = null;
try { try {
const parts = request.parts(); const parts = request.parts();
@@ -60,6 +61,8 @@ export async function registerBatchRoutes(
} }
} else if (part.fieldname === "settings") { } else if (part.fieldname === "settings") {
settingsRaw = part.value as string; settingsRaw = part.value as string;
} else if (part.fieldname === "clientJobId") {
clientJobId = part.value as string;
} }
} }
} catch (err) { } catch (err) {
@@ -102,7 +105,7 @@ export async function registerBatchRoutes(
} }
// Create a job ID for progress tracking // Create a job ID for progress tracking
const jobId = randomUUID(); const jobId = clientJobId || randomUUID();
const progress: JobProgress = { const progress: JobProgress = {
jobId, jobId,
@@ -120,6 +123,7 @@ export async function registerBatchRoutes(
"Content-Disposition": `attachment; filename="batch-${toolId}-${jobId.slice(0, 8)}.zip"`, "Content-Disposition": `attachment; filename="batch-${toolId}-${jobId.slice(0, 8)}.zip"`,
"Transfer-Encoding": "chunked", "Transfer-Encoding": "chunked",
"X-Job-Id": jobId, "X-Job-Id": jobId,
"X-File-Order": files.map(f => f.filename).join(","),
}); });
// Create ZIP archive that pipes directly to the response // Create ZIP archive that pipes directly to the response