Scheduling

import { Theazo } from 'theazo'

const theazo = new Theazo({ apiKey: 'th_live_...' })

const schedule = await theazo.schedules.create({
  name: 'daily-digest',
  agent: 'digest-writer',
  userId: 'user_123',
  cron: '0 9 * * 1-5',       // 9am Monday–Friday
  timezone: 'America/New_York',
  input: {
    sources: ['hackernews', 'producthunt', 'arxiv'],
    topics:  ['AI', 'infrastructure', 'developer tools'],
    format:  'markdown',
  },
})

console.log(schedule.id)       // 'sch_abc123'
console.log(schedule.enabled)  // true

'0 * * * *'       // every hour at :00
'*/15 * * * *'    // every 15 minutes
'0 9 * * 1-5'     // 9am weekdays
'0 0 * * 0'       // midnight every Sunday
'0 8 1 * *'       // 8am on the 1st of each month
'30 17 * * 5'     // 5:30pm every Friday

// List all schedules
const schedules = await theazo.schedules.list()

// Pause — stops future runs, preserves history
await theazo.schedules.pause('sch_abc123')

// Resume
await theazo.schedules.resume('sch_abc123')

// Delete — removes schedule entirely
await theazo.schedules.delete('sch_abc123')

// Run history for a schedule
const history = await theazo.schedules.history('sch_abc123')
// Returns array of { id, agentId, status, cost, startedAt, completedAt }

// Schedule object shape:
// {
//   id:        'sch_abc123',
//   name:      'daily-digest',
//   agent:     'digest-writer',
//   userId:    'user_123',
//   cron:      '0 9 * * 1-5',
//   timezone:  'America/New_York',
//   status:    'active',        // 'active' | 'paused'
//   createdAt: '2024-01-15T14:00:00Z',
// }

const trigger = await theazo.triggers.create({
  name: 'new-signup-onboarding',
  agent: 'onboarding-agent',
  userId: 'user_123',        // the session userId for each run
  type: 'webhook',
})

console.log(trigger.id)     // 'trg_xyz789'
console.log(trigger.url)    // 'https://api.theazo.com/triggers/trg_xyz789/fire'
console.log(trigger.secret) // 'whsec_...' — shown ONCE, store it now

// Your external system calls the trigger
const body = JSON.stringify({
  userId:   'new_user_456',
  email:    'alice@acme.com',
  plan:     'pro',
  signedUp: new Date().toISOString(),
})

const signature = createHmac('sha256', triggerSecret)
  .update(body)
  .digest('hex')

await fetch(trigger.url, {
  method: 'POST',
  headers: {
    'Content-Type':         'application/json',
    'x-trigger-signature':  signature,
  },
  body,
})

// Theazo launches the agent with input = parsed body
// Agent runs: "Onboard new user alice@acme.com on the pro plan"

// List all triggers
const triggers = await theazo.triggers.list()

// Delete a trigger (URL stops accepting requests immediately)
await theazo.triggers.delete('trg_xyz789')

// Trigger object shape:
// {
//   id:      'trg_xyz789',
//   name:    'new-signup-onboarding',
//   url:     'https://api.theazo.com/triggers/trg_xyz789/fire',
//   secret:  'whsec_...',      // shown on create — store it now
//   agent:   'onboarding-agent',
//   userId:  'user_123',
// }

// 1. Subscribe an agent to an event (optionally filtered)
const trigger = await theazo.triggers.on('email_received', {
  agent:  'email-classifier',
  userId: 'user_123',
  filter: { from: '*@company.com' },   // only company email fires it
})

// 2. Later, emit the event from your app — matching triggers fire
await theazo.events.emit('email_received', {
  userId:  'user_123',                 // scope to this user's triggers
  payload: { from: 'alice@company.com', subject: 'Invoice #42' },
})
// → the classifier agent runs with input = payload

// Schedule history includes skipped runs
const history = await theazo.schedules.history('sch_abc123')

// history[0] = { id: 'exec_2', agentId: null, status: 'skipped', startedAt: '...', completedAt: null }
// history[1] = { id: 'exec_1', agentId: 'agt_...', status: 'completed', cost: { amount: 120, currency: 'usd' }, startedAt: '...', completedAt: '...' }

// Trigger endpoints do NOT enforce overlap — each call launches an
// independent run. Enforce concurrency in your own backend before
// calling the trigger URL if you need it.
const trigger = await theazo.triggers.create({
  name:   'stripe-webhook',
  agent:  'payment-handler',
  userId: 'system',
  type:   'webhook',
})

// Simplified tick loop (internal — runs every 60s)
// 1. Acquire Redis lock: SET scheduling:tick:lock <workerId> NX EX 55
// 2. Query: SELECT * FROM schedules WHERE status = 'active' AND next_run_at <= NOW()
// 3. For each due schedule:
//    a. Check if previous run is still active (overlap prevention)
//    b. Create ephemeral session + agent
//    c. Enqueue to 'agent-run' BullMQ queue
//    d. UPDATE schedules SET next_run_at = <next occurrence> WHERE id = <scheduleId>
// 4. Release lock on completion

// Example: what happens when a run overlaps
//
// Schedule: '*/5 * * * *' (every 5 minutes)
//
// 10:00 — tick fires, run_1 starts           → status: 'running'
// 10:05 — tick fires, run_1 still running    → status: 'skipped', reason: 'previous_run_active'
// 10:10 — tick fires, run_1 completed at 10:07 → run_2 starts normally
//
// history = [
//   { id: 'exec_2', agentId: 'agt_2', status: 'running',   startedAt: '...T10:10:00Z', completedAt: null },
//   { id: 'exec_s', agentId: null,    status: 'skipped',   startedAt: '...T10:05:00Z', completedAt: null },
//   { id: 'exec_1', agentId: 'agt_1', status: 'completed', startedAt: '...T10:00:00Z', completedAt: '...T10:07:00Z', cost: { amount: 85, currency: 'usd' } },
// ]

// Ephemeral session lifecycle (internal)
//
// 1. Tick worker creates session:
//    { userId: schedule.userId, ephemeral: true, scheduleId: 'sch_abc123' }
//
// 2. Agent is created inside the session and dispatched to agent-run queue
//
// 3. Agent completes (or fails) → session auto-terminates
//    - Sandbox is destroyed
//    - Usage event recorded: { platformId, scheduleId, cost, tokens, duration }
//
// 4. Session is marked 'terminated' — never reused