Function watchJob

public/js/aiChat.js:1301–1376

(jobId, options = {})

  };

  const watchJob = (jobId, options = {}) => {
    const numericJobId = Number(jobId || 0);
    if (!Number.isFinite(numericJobId) || numericJobId <= 0) return;
    if (watchedJobs.has(numericJobId)) return;

    const state = {
      done: false,
      timer: 0,
      lastProgressKey: '',
      lastStatus: '',
      messageHandle: options.messageHandle || null,
      workflow: (options.workflow && typeof options.workflow === 'object') ? { ...options.workflow } : null
    };
    watchedJobs.set(numericJobId, state);

    const poll = async () => {
      if (state.done) return;
      try {
        const detail = await apiGet(`/api/pro/automation/jobs/get.php?id=${encodeURIComponent(numericJobId)}`);
        const job = (detail && typeof detail === 'object' && detail.job && typeof detail.job === 'object') ? detail.job : null;
        const status = String(job?.status || '').toLowerCase();
        const payload = (job && job.payload && typeof job.payload === 'object') ? job.payload : null;
        const progress = (payload && payload.aiProgress && typeof payload.aiProgress === 'object') ? payload.aiProgress : null;
        const progressKey = progress
          ? `${Number(progress.processedCount || 0)}|${Number(progress.filteredOutCount || 0)}|${Number(progress.failedCount || 0)}|${String(progress.lastFile || '')}`
          : '';
        const workflowDetail = buildAutomationWorkflowFromDetail(state.workflow, detail);

        if ((status === 'queued' || status === 'running') && progress && progressKey !== '' && progressKey !== state.lastProgressKey) {
          state.lastProgressKey = progressKey;
          if (state.messageHandle) {
            state.messageHandle.setWorkflow(workflowDetail);
            state.messageHandle.setText(`Job #${numericJobId} is running.`);
          } else {
            appendMessage(
              'assistant',
              `Job #${numericJobId} running: processed ${Number(progress.processedCount || 0)}, filtered ${Number(progress.filteredOutCount || 0)}, failed ${Number(progress.failedCount || 0)}${progress.lastFile ? `, last file ${String(progress.lastFile)}` : ''}.`,
              { workflow: workflowDetail }
            );
          }
        } else if ((status === 'queued' || status === 'running') && state.lastStatus !== status) {
          state.lastStatus = status;
          if (state.messageHandle) {
            state.messageHandle.setWorkflow(workflowDetail);
            state.messageHandle.setText(`Job #${numericJobId} ${status}.`);
          } else {
            appendMessage('assistant', `Job #${numericJobId} ${status}.`, { workflow: workflowDetail });
          }
        }

        if (status === 'succeeded' || status === 'failed' || status === 'dead' || status === 'canceled') {
          state.done = true;
          watchedJobs.delete(numericJobId);
          const result = (payload && payload.aiResult && typeof payload.aiResult === 'object') ? payload.aiResult : null;
          const saved = (result?.savedOutputFile && typeof result.savedOutputFile === 'object') ? result.savedOutputFile : null;
          const summary = describeJobCompletion(detail);
          if (state.messageHandle) {
            state.messageHandle.setWorkflow(workflowDetail);