smartbotic/nodes/ocr/ocr-retry-job.js

/**
 * @node ocr-retry-job
 * @name OCR Retry Job
 * @category ocr
 * @version 1.0.1
 * @description Retry a failed OCR job
 * @icon refresh-cw
 */

const configSchema = {
    type: 'object',
    properties: {
        baseUrl: {
            type: 'string',
            title: 'API Base URL',
            default: 'http://localhost:3000',
            description: 'Base URL of the OCR API'
        },
        credentialId: {
            type: 'string',
            title: 'Credential',
            description: 'Bearer or API Key credential for authentication',
            dynamicOptions: {
                source: 'credentials',
                filter: { type: 'api_key' }
            }
        },
        jobId: {
            type: 'string',
            title: 'Job ID',
            description: 'The ID of the job to retry (can be provided from input)'
        }
    },
    required: ['baseUrl']
};

const inputSchema = {
    type: 'object',
    properties: {
        jobId: {
            type: 'string',
            description: 'Job ID to retry (overrides config)'
        }
    }
};

const outputSchema = {
    type: 'object',
    properties: {
        job: {
            type: 'object',
            properties: {
                id: { type: 'string' },
                status: { type: 'string' },
                filename: { type: 'string' },
                created_at: { type: 'string' }
            }
        }
    }
};

const outputs = [
    { name: 'main', displayName: 'Retried', type: 'object', color: '#8b5cf6' }
];

module.exports = {
    configSchema,
    inputSchema,
    outputSchema,
    outputs,

    async execute(config, input, context) {
        const baseUrl = (config.baseUrl || 'http://localhost:3000').replace(/\/$/, '');
        const jobId = input.jobId || config.jobId;

        if (!jobId) {
            throw new Error('Job ID is required');
        }

        const headers = {};

        if (config.credentialId) {
            const auth = smartbotic.credentials.get(config.credentialId);
            if (!auth.success) {
                throw new Error(`Failed to load credential: ${auth.error}`);
            }
            headers[auth.headerName] = auth.headerValue;
        }

        smartbotic.log.info(`OCR Retry Job: ${jobId}`);

        const response = smartbotic.http.request({
            method: 'POST',
            url: `${baseUrl}/api/jobs/${encodeURIComponent(jobId)}/retry`,
            headers: headers,
            timeout: 30000
        });

        if (response.status === 404) {
            throw new Error(`Job not found: ${jobId}`);
        }

        if (response.status < 200 || response.status >= 300) {
            const errorMsg = typeof response.data === 'string' ? response.data : JSON.stringify(response.data);
            if (response.status === 401 && !config.credentialId) { throw new Error('Authentication required - please select a credential in node settings'); } throw new Error(`OCR API error (${response.status}): ${errorMsg}`);
        }

        const data = typeof response.data === 'string' ? JSON.parse(response.data) : response.data;

        return {
            job: data.job || data
        };
    }
};