Function createWorkflowAndStoreMetadata

server/src/api/record.ts:552–654

(id: string, userId: string, runSource: 'api' | 'sdk' | 'mcp' | 'cli', requestedFormats?: OutputFormats[], promptInstructions?: string)

});

async function createWorkflowAndStoreMetadata(id: string, userId: string, runSource: 'api' | 'sdk' | 'mcp' | 'cli', requestedFormats?: OutputFormats[], promptInstructions?: string) {
    try {
        const recording = await Robot.findOne({
            where: {
                'recording_meta.id': id,
                userId: userId,
            },
            raw: true
        });

        if (!recording || !recording.recording_meta || !recording.recording_meta.id) {
            return {
                success: false,
                error: 'Recording not found'
            };
        }

        const robotType = (recording.recording_meta as any).type || (recording.recording_meta as any).robotType;
        const isDocRobot = robotType === 'doc-extract' || robotType === 'doc-parse';

        const proxyConfig = await getDecryptedProxyConfig(userId);
        let proxyOptions: any = {};

        if (proxyConfig.proxy_url) {
            proxyOptions = {
                server: proxyConfig.proxy_url,
                ...(proxyConfig.proxy_username && proxyConfig.proxy_password && {
                    username: proxyConfig.proxy_username,
                    password: proxyConfig.proxy_password,
                }),
            };
        }

        const browserId = isDocRobot ? uuid() : createRemoteBrowserForRun(userId);

        const runId = uuid();

        const run = await Run.create({
            status: 'running',
            name: recording.recording_meta.name,
            robotId: recording.id,
            robotMetaId: recording.recording_meta.id,
            startedAt: new Date().toLocaleString(),
            finishedAt: '',
            browserId,
            interpreterSettings: { maxConcurrency: 1, maxRepeats: 1, debug: true, formats: requestedFormats, promptInstructions, ...(isDocRobot && { robotType }) },
            log: '',
            runId,
            runByUserId: userId,
            runByAPI: runSource === 'api',
            runBySDK: runSource === 'sdk',
            runByMCP: runSource === 'mcp',
            runByCLI: runSource === 'cli',
            serializableOutput: {},
            binaryOutput: {},
            retryCount: 0
        });