Class UnixSystemScheduler

src/fork/module/Cron/UnixSystemScheduler.ts:18–355

} from './utils'

export class UnixSystemScheduler {
  constructor(private cronRoot: string) {}

  private runLogPath(jobId: string): string {
    return runLogPath(this.cronRoot, jobId)
  }

  private taskScriptPath(jobId: string): string {
    return taskScriptPath(this.cronRoot, jobId, 'sh')
  }

  private resolveShell(): string {
    const fallback = isMacOS() ? '/bin/zsh' : '/bin/bash'
    const shell = process.env.SHELL || fallback
    return existsSync(shell) ? shell : fallback
  }

  private async resolvePath(): Promise<string> {
    try {
      const env = (await EnvSync.sync()) ?? {}
      return `${env.PATH || env.Path || process.env.PATH || ''}`
    } catch {
      return process.env.PATH || ''
    }
  }

  private async writeWrapper(job: CronJob): Promise<string> {
    const file = this.taskScriptPath(job.id)
    const workDir = job.workDir || homePath()
    const runDir = join(this.cronRoot, 'tmp')
    const logFile = this.runLogPath(job.id)
    const shell = this.resolveShell()
    const envPath = await this.resolvePath()
    const scope = job.scope ?? (job.hostId ? 'host' : 'global')
    const shellHostId = '${HOST_ID:-null}'

    const content = `#!/bin/sh
JOB_ID=${shellQuote(job.id)}
HOST_ID=${shellQuote(job.hostId ? `${job.hostId}` : '')}
SCOPE=${shellQuote(scope)}
COMMAND=${shellQuote(job.command)}
WORK_DIR=${shellQuote(workDir)}
RUN_DIR=${shellQuote(runDir)}
LOG_FILE=${shellQuote(logFile)}
RUN_SHELL=${shellQuote(shell)}
PATH=${shellQuote(envPath)}
export PATH
LOCK_DIR="$RUN_DIR/$JOB_ID.lock"

mkdir -p "$RUN_DIR" "$(dirname "$LOG_FILE")"
if ! mkdir "$LOCK_DIR" 2>/dev/null; then
  exit 0
fi

RUN_ID="$(date +%Y%m%d%H%M%S)-$$"
OUT_FILE="$RUN_DIR/$JOB_ID-$RUN_ID.out"
ERR_FILE="$RUN_DIR/$JOB_ID-$RUN_ID.err"
STARTED_AT=$(($(date +%s) * 1000))