Function poll

public/js/aiChat.js:1316–1373

()

    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);
            if (summary !== '') {
              state.messageHandle.setText(summary);
            }
          } else if (summary !== '') {
            appendMessage('assistant', summary, { workflow: workflowDetail });
          }
          refreshVisibleFolderForOutputFile(saved);
          refreshVisibleFolderForAutomationDetail(detail);
          return;
        }
      } catch (err) {
        // Ignore transient polling errors; next poll will retry.
      }
      state.timer = window.setTimeout(poll, 2500);
    };