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

feat: emit socket event on succesful run

Browse Source
This commit is contained in:
karishmas6
2024-09-19 09:38:25 +05:30
parent 22047cd814
commit 8251394b32
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/routes/storage.ts
View File

@@ -7,7 +7,7 @@ import logger from "../logger";
import { deleteFile, readFile, readFiles, saveFile } from "../workflow-management/storage"; import { deleteFile, readFile, readFiles, saveFile } from "../workflow-management/storage";
import { createRemoteBrowserForRun, destroyRemoteBrowser } from "../browser-management/controller"; import { createRemoteBrowserForRun, destroyRemoteBrowser } from "../browser-management/controller";
import { chromium } from "playwright"; import { chromium } from "playwright";
import { browserPool } from "../server"; import { browserPool, io } from "../server";
import fs from "fs"; import fs from "fs";
import { uuid } from "uuidv4"; import { uuid } from "uuidv4";
import { workflowQueue } from '../workflow-management/scheduler'; import { workflowQueue } from '../workflow-management/scheduler';
@@ -182,6 +182,7 @@ router.post('/runs/run/:fileName/:runId', async (req, res) => {
`../storage/runs/${parsedRun.name}_${req.params.runId}.json`, `../storage/runs/${parsedRun.name}_${req.params.runId}.json`,
JSON.stringify(run_meta, null, 2) JSON.stringify(run_meta, null, 2)
); );
io.emit('run-finished', { success: true });
return res.send(true); return res.send(true);
} else { } else {
throw new Error('Could not destroy browser'); throw new Error('Could not destroy browser');