Schedules

import { readFile } from 'node:fs/promises'
import { Nika, NikaOperationError } from '@supernovae-st/nika'

const token = (await readFile('.nika/serve.token', 'utf8')).trim()
const nika = new Nika({ url: 'http://127.0.0.1:8787', token, allowInsecureHttp: true })

const declaration = {
  id: 'weekday-hello',
  when: { kind: 'cadence', expression: 'TZ=Europe/Paris 0 9 * * 1-5' },
  maxCostUsd: 0.01,
  missed: 'catch-up-once',
  overlap: 'skip',
  afterSkip: 'next_slot',
} as const

// 1 · Create it. Applying the same declaration again changes nothing.
const applied = await nika.schedule('workflows/hello.nika', declaration)
console.log(applied.changed, applied.status.next[0]?.scheduledFor)

// 2 · Read it: the next slots, in UTC, and the revision to change it by.
const status = await nika.scheduleStatus('weekday-hello')
console.log(status.revision, status.due)

// 3 · Pause it: send the whole declaration again, with the revision you read.
await nika.schedule('workflows/hello.nika', {
  ...declaration,
  revision: status.revision,
  active: false,
  pauseReason: 'maintenance',
  pauseUntil: '2026-12-01',
})

// 4 · A writer holding a stale revision is refused, and told the current one.
try {
  await nika.schedule('workflows/hello.nika', { ...declaration, revision: status.revision })
} catch (error) {
  if (error instanceof NikaOperationError && error.code === 'schedule_conflict') {
    console.log(error.status, error.currentRevision)
  } else throw error
}