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

chore: add telemetry for scrape robots and runs

Browse Source
This commit is contained in:
Rohit Rajan
2025-11-20 19:40:48 +05:30
parent 6477feeaea
commit b2b5a914e7
4 changed files with 51 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -761,6 +761,14 @@ async function executeRun(id: string, userId: string, requestedFormats?: string[
); );
} }
capture("maxun-oss-run-created-api", {
runId: plainRun.runId,
user_id: userId,
status: "success",
robot_type: "scrape",
formats
});
await destroyRemoteBrowser(plainRun.browserId, userId); await destroyRemoteBrowser(plainRun.browserId, userId);
return { return {
@@ -800,6 +808,14 @@ async function executeRun(id: string, userId: string, requestedFormats?: string[
); );
} }
capture("maxun-oss-run-created-api", {
runId: plainRun.runId,
user_id: userId,
status: "failed",
robot_type: "scrape",
formats
});
await destroyRemoteBrowser(plainRun.browserId, userId); await destroyRemoteBrowser(plainRun.browserId, userId);
throw error; throw error;

16
server/src/pgboss-worker.ts
View File

@@ -268,6 +268,14 @@ async function processRunExecution(job: Job<ExecuteRunData>) {
logger.log('warn', `Failed to send webhooks for markdown robot run ${data.runId}: ${webhookError.message}`); logger.log('warn', `Failed to send webhooks for markdown robot run ${data.runId}: ${webhookError.message}`);
} }
capture("maxun-oss-run-created-manual", {
runId: data.runId,
user_id: data.userId,
status: "success",
robot_type: "scrape",
formats,
});
await destroyRemoteBrowser(browserId, data.userId); await destroyRemoteBrowser(browserId, data.userId);
return { success: true }; return { success: true };
@@ -296,6 +304,14 @@ async function processRunExecution(job: Job<ExecuteRunData>) {
logger.log('warn', `Failed to send run-failed notification for markdown robot run ${data.runId}: ${socketError.message}`); logger.log('warn', `Failed to send run-failed notification for markdown robot run ${data.runId}: ${socketError.message}`);
} }
capture("maxun-oss-run-created-manual", {
runId: data.runId,
user_id: data.userId,
status: "failed",
robot_type: "scrape",
formats,
});
await destroyRemoteBrowser(browserId, data.userId); await destroyRemoteBrowser(browserId, data.userId);
throw error; throw error;

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

@@ -500,12 +500,12 @@ router.post('/recordings/scrape', requireSignIn, async (req: AuthenticatedReques
logger.log('info', `Markdown robot created with id: ${newRobot.id}`); logger.log('info', `Markdown robot created with id: ${newRobot.id}`);
capture( capture(
'maxun-oss-markdown-robot-created', 'maxun-oss-robot-created',
{ {
robot_meta: newRobot.recording_meta, robot_meta: newRobot.recording_meta,
url: url, recording: newRobot.recording,
} }
); )
return res.status(201).json({ return res.status(201).json({
message: 'Markdown robot created successfully.', message: 'Markdown robot created successfully.',

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

@@ -321,6 +321,14 @@ async function executeRun(id: string, userId: string) {
); );
} }
capture("maxun-oss-run-created-scheduled", {
runId: plainRun.runId,
user_id: userId,
status: "success",
robot_type: "scrape",
formats
});
await destroyRemoteBrowser(plainRun.browserId, userId); await destroyRemoteBrowser(plainRun.browserId, userId);
return true; return true;
@@ -352,6 +360,14 @@ async function executeRun(id: string, userId: string) {
); );
} }
capture("maxun-oss-run-created-scheduled", {
runId: plainRun.runId,
user_id: userId,
status: "failed",
robot_type: "scrape",
formats
});
await destroyRemoteBrowser(plainRun.browserId, userId); await destroyRemoteBrowser(plainRun.browserId, userId);
throw error; throw error;