vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: requested formats override

Browse Source
This commit is contained in:
Rohit Rajan
2026-01-04 19:14:41 +05:30
parent 0785a264a2
commit b4e85a7924
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/api/record.ts
View File

@@ -601,9 +601,9 @@ async function triggerIntegrationUpdates(runId: string, robotMetaId: string): Pr
} }
} }
async function readyForRunHandler(browserId: string, id: string, userId: string, socket: Socket){ async function readyForRunHandler(browserId: string, id: string, userId: string, socket: Socket, requestedFormats?: string[]){
try { try {
const result = await executeRun(id, userId); const result = await executeRun(id, userId, requestedFormats);
if (result && result.success) { if (result && result.success) {
logger.log('info', `Interpretation of ${id} succeeded`); logger.log('info', `Interpretation of ${id} succeeded`);
@@ -1192,7 +1192,7 @@ async function executeRun(id: string, userId: string, requestedFormats?: string[
} }
} }
export async function handleRunRecording(id: string, userId: string, isSDK: boolean = false) { export async function handleRunRecording(id: string, userId: string, isSDK: boolean = false, requestedFormats?: string[]) {
let socket: Socket | null = null; let socket: Socket | null = null;
try { try {
@@ -1211,7 +1211,7 @@ export async function handleRunRecording(id: string, userId: string, isSDK: bool
timeout: CONNECTION_TIMEOUT, timeout: CONNECTION_TIMEOUT,
}); });
const readyHandler = () => readyForRunHandler(browserId, newRunId, userId, socket!); const readyHandler = () => readyForRunHandler(browserId, newRunId, userId, socket!, requestedFormats);
socket.on('ready-for-run', readyHandler); socket.on('ready-for-run', readyHandler);
@@ -1375,7 +1375,8 @@ router.post("/robots/:id/runs", requireAPIKey, async (req: AuthenticatedRequest,
return res.status(401).json({ ok: false, error: 'Unauthorized' }); return res.status(401).json({ ok: false, error: 'Unauthorized' });
} }
const runId = await handleRunRecording(req.params.id, req.user.id); const requestedFormats = req.body?.formats;
const runId = await handleRunRecording(req.params.id, req.user.id, false, requestedFormats);
if (!runId) { if (!runId) {
throw new Error('Run ID is undefined'); throw new Error('Run ID is undefined');