(phase, payload = {})
| 3759 | } |
| 3760 | |
| 3761 | function getAutoRunStatusPayload(phase, payload = {}) { |
| 3762 | const normalizedPayload = { |
| 3763 | ...payload, |
| 3764 | currentRun: payload.currentRun ?? autoRunCurrentRun, |
| 3765 | totalRuns: payload.totalRuns ?? autoRunTotalRuns, |
| 3766 | attemptRun: payload.attemptRun ?? autoRunAttemptRun, |
| 3767 | }; |
| 3768 | if (typeof loggingStatus !== 'undefined' && loggingStatus?.getAutoRunStatusPayload) { |
| 3769 | return loggingStatus.getAutoRunStatusPayload(phase, normalizedPayload); |
| 3770 | } |
| 3771 | return { |
| 3772 | autoRunning: phase === 'scheduled' |
| 3773 | || phase === 'running' |
| 3774 | || phase === 'waiting_step' |
| 3775 | || phase === 'waiting_email' |
| 3776 | || phase === 'retrying' |
| 3777 | || phase === 'waiting_interval', |
| 3778 | autoRunPhase: phase, |
| 3779 | autoRunCurrentRun: normalizedPayload.currentRun ?? 0, |
| 3780 | autoRunTotalRuns: normalizedPayload.totalRuns ?? 1, |
| 3781 | autoRunAttemptRun: normalizedPayload.attemptRun ?? 0, |
| 3782 | scheduledAutoRunAt: Number.isFinite(Number(normalizedPayload.scheduledAt)) ? Number(normalizedPayload.scheduledAt) : null, |
| 3783 | autoRunCountdownAt: Number.isFinite(Number(normalizedPayload.countdownAt)) ? Number(normalizedPayload.countdownAt) : null, |
| 3784 | autoRunCountdownTitle: normalizedPayload.countdownTitle === undefined ? '' : String(normalizedPayload.countdownTitle || ''), |
| 3785 | autoRunCountdownNote: normalizedPayload.countdownNote === undefined ? '' : String(normalizedPayload.countdownNote || ''), |
| 3786 | }; |
| 3787 | } |
| 3788 | |
| 3789 | async function broadcastAutoRunStatus(phase, payload = {}, extraState = {}) { |
| 3790 | const rawScheduledAt = phase === 'scheduled' |
no outgoing calls
no test coverage detected