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

feat: queue stop and interpret workflow jobs

Browse Source
This commit is contained in:
Rohit
2025-03-11 21:56:12 +05:30
parent 7b940ab965
commit 10e1e8a87c
1 changed files with 77 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

83
server/src/routes/record.ts
View File

@@ -148,6 +148,7 @@ router.get('/stop/:browserId', requireSignIn, async (req: AuthenticatedRequest,
const jobId = await pgBoss.send('destroy-browser', {
browserId: req.params.browserId,
userId: req.user.id,
timestamp: new Date().toISOString()
});
@@ -224,14 +225,84 @@ router.get('/active/tabs', requireSignIn, (req: AuthenticatedRequest, res) => {
* GET endpoint for starting an interpretation of the currently generated workflow.
*/
router.get('/interpret', requireSignIn, async (req: AuthenticatedRequest, res) => {
if (!req.user) {
return res.status(401).send('User not authenticated');
}
try {
if (!req.user) {
return res.status(401).send('User not authenticated');
await pgBoss.createQueue('interpret-workflow');
const jobId = await pgBoss.send('interpret-workflow', {
userId: req.user.id,
timestamp: new Date().toISOString()
});
if (!jobId) {
logger.log('warn', 'pgBoss.send returned null, falling back to direct destruction');
await interpretWholeWorkflow(req.user?.id);
return res.send('interpretation done');
}
await interpretWholeWorkflow(req.user?.id);
return res.send('interpretation done');
} catch (e) {
return res.send('interpretation failed');
logger.log('info', `Queued interpret workflow job: ${jobId}, waiting for completion...`);
try {
const result = await waitForJobCompletion(jobId, 'interpret-workflow', 15000);
if (result) {
logger.log('info', `Browser destruction job completed with result: ${result.success}`);
return res.send('interpretation done');
} else {
logger.log('warn', 'Job completed but returned unexpected result');
return res.send('interpretation failed');
}
} catch (waitError: any) {
logger.log('warn', `Error waiting for job completion: ${waitError.message}`);
return res.send('interpretation failed');
}
} catch (error: any) {
logger.log('error', `Failed to stop browser: ${error.message}`);
return res.status(500).send('interpretation failed');
}
});
router.get('/interpret/stop', requireSignIn, async (req: AuthenticatedRequest, res) => {
if (!req.user) {
return res.status(401).send('User not authenticated');
}
try {
await pgBoss.createQueue('stop-interpretation');
const jobId = await pgBoss.send('stop-interpretation', {
userId: req.user.id,
timestamp: new Date().toISOString()
});
if (!jobId) {
logger.log('warn', 'pgBoss.send returned null, falling back to direct destruction');
await interpretWholeWorkflow(req.user?.id);
return res.send('interpretation done');
}
logger.log('info', `Queued stop interpret workflow job: ${jobId}, waiting for completion...`);
try {
const result = await waitForJobCompletion(jobId, 'stop-interpretation', 15000);
if (result) {
logger.log('info', `Browser destruction job completed with result: ${result.success}`);
return res.send('interpretation stopped');
} else {
logger.log('warn', 'Job completed but returned unexpected result');
return res.send('interpretation failed to stop');
}
} catch (waitError: any) {
logger.log('warn', `Error waiting for job completion: ${waitError.message}`);
return res.send('interpretation failed to stop');
}
} catch (error: any) {
logger.log('error', `Failed to stop browser: ${error.message}`);
return res.status(500).send('interpretation failed to stop');
}
});