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

feat: use binaryOutputService

Browse Source
This commit is contained in:
karishmas6
2024-10-15 22:22:03 +05:30
parent 6d85bac44a
commit 17f0e29b04
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -8,6 +8,7 @@ import { googleSheetUpdateTasks, processGoogleSheetUpdates } from "../integratio
import Robot from "../../models/Robot"; import Robot from "../../models/Robot";
import Run from "../../models/Run"; import Run from "../../models/Run";
import { getDecryptedProxyConfig } from "../../routes/proxy"; import { getDecryptedProxyConfig } from "../../routes/proxy";
import { BinaryOutputService } from "../../storage/mino";
async function createWorkflowAndStoreMetadata(id: string, userId: string) { async function createWorkflowAndStoreMetadata(id: string, userId: string) {
try { try {
@@ -114,6 +115,9 @@ async function executeRun(id: string) {
const interpretationInfo = await browser.interpreter.InterpretRecording( const interpretationInfo = await browser.interpreter.InterpretRecording(
recording.recording, currentPage, plainRun.interpreterSettings); recording.recording, currentPage, plainRun.interpreterSettings);
const binaryOutputService = new BinaryOutputService('maxun-run-screenshots');
const uploadedBinaryOutput = await binaryOutputService.uploadAndStoreBinaryOutput(run, interpretationInfo.binaryOutput);
await destroyRemoteBrowser(plainRun.browserId); await destroyRemoteBrowser(plainRun.browserId);
@@ -124,7 +128,7 @@ async function executeRun(id: string) {
browserId: plainRun.browserId, browserId: plainRun.browserId,
log: interpretationInfo.log.join('\n'), log: interpretationInfo.log.join('\n'),
serializableOutput: interpretationInfo.serializableOutput, serializableOutput: interpretationInfo.serializableOutput,
binaryOutput: interpretationInfo.binaryOutput, binaryOutput: uploadedBinaryOutput,
}); });
googleSheetUpdateTasks[id] = { googleSheetUpdateTasks[id] = {