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

feat: use id

Browse Source
This commit is contained in:
karishmas6
2024-10-10 03:05:39 +05:30
parent 2cc07d545c
commit b087688e82
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/src/workflow-management/scheduler/index.ts
View File

@@ -170,9 +170,9 @@ function resetRecordingState(browserId: string, id: string) {
id = ''; id = '';
} }
export async function handleRunRecording(fileName: string, runId: string) { export async function handleRunRecording(id: string) {
try { try {
const result = await runWorkflow(fileName, runId); const result = await runWorkflow(id);
const { browserId, runId: newRunId } = result; const { browserId, runId: newRunId } = result;
if (!browserId || !newRunId) { if (!browserId || !newRunId) {
@@ -184,9 +184,9 @@ export async function handleRunRecording(fileName: string, runId: string) {
rejectUnauthorized: false rejectUnauthorized: false
}); });
socket.on('ready-for-run', () => readyForRunHandler(browserId, fileName, newRunId)); socket.on('ready-for-run', () => readyForRunHandler(browserId, newRunId));
logger.log('info', `Running recording: ${fileName}`); logger.log('info', `Running recording: ${id}`);
socket.on('disconnect', () => { socket.on('disconnect', () => {
cleanupSocketListeners(socket, browserId, newRunId); cleanupSocketListeners(socket, browserId, newRunId);
@@ -197,9 +197,9 @@ export async function handleRunRecording(fileName: string, runId: string) {
} }
} }
function cleanupSocketListeners(socket: Socket, browserId: string, runId: string) { function cleanupSocketListeners(socket: Socket, browserId: string, id: string) {
socket.off('ready-for-run', () => readyForRunHandler(browserId, '', runId)); socket.off('ready-for-run', () => readyForRunHandler(browserId, id));
logger.log('info', `Cleaned up listeners for browserId: ${browserId}, runId: ${runId}`); logger.log('info', `Cleaned up listeners for browserId: ${browserId}, runId: ${id}`);
} }
export { runWorkflow }; export { runWorkflow };