Supervise another agent

[
  {
    "id": "4b7c1e0a-…",
    "supervisorAgentId": "<supervisor-agent-id>",
    "targetAgentId": "<target-agent-id>",
    "actions": ["observe", "act"],
    "dataCollections": ["tickets", "escalations"],
    "createdByUserId": "<your-user-id>",
    "createdAt": "2026-09-28T09:12:44.120Z"
  }
]

import { LuaJob, Agents, env } from 'lua-cli';

export default new LuaJob({
  name: 'review-support-agent',
  description: 'Summarise the support agent’s errors and failed runs from the last day',
  schedule: { type: 'cron', expression: '0 7 * * *', timezone: 'Europe/London' },
  timeout: 120,
  async execute() {
    const target = env('SUPPORT_AGENT_ID');
    if (!target) throw new Error('SUPPORT_AGENT_ID is not set');

    const errors = await Agents.logs(target, { level: 'error', limit: 100 });
    const failedRuns = await Agents.runs(target).list({ status: 'failed', limit: 20 });
    const openEscalations = await Agents.data(target).query('escalations', { status: { $eq: 'open' } });

    return {
      errors: errors.length,
      failingTools: [...new Set(errors.map((row) => row.toolName).filter(Boolean))],
      failedRuns: failedRuns.map((run) => ({ runId: run.runId, workflow: run.workflowName, reason: run.reason })),
      openEscalations,
    };
  },
});

import { LuaTool, Lua, Data, env } from 'lua-cli';
import { z } from 'zod';

const SUPERVISOR_FIELDS = new Set(['threshold', 'quietHours']);

function listFromEnv(key: string): string[] {
  return (env(key) ?? '').split(',').map((s) => s.trim()).filter(Boolean);
}

function mayWrite(fields: string[]): { ok: true } | { ok: false; reason: string } {
  const caller = Lua.request.invokedBy;
  if (caller) {
    if (!caller.supervisor) return { ok: false, reason: 'the calling agent is not a supervisor of this agent' };
    if (!listFromEnv('SUPERVISOR_AGENT_IDS').includes(caller.agentId)) {
      return { ok: false, reason: 'the calling agent is not a trusted supervisor' };
    }
    const denied = fields.filter((f) => !SUPERVISOR_FIELDS.has(f));
    if (denied.length) return { ok: false, reason: `a supervisor may not change ${denied.join(', ')}` };
    return { ok: true };
  }
  const owners = listFromEnv('OWNER_USER_IDS');
  return Lua.request.userId && owners.includes(Lua.request.userId)
    ? { ok: true }
    : { ok: false, reason: 'only the owner may change the escalation policy' };
}

export default class UpdateEscalationPolicyTool implements LuaTool {
  name = 'update_escalation_policy';
  description = 'Change the escalation threshold, quiet hours or on-call contact';
  inputSchema = z.object({
    threshold: z.number().int().min(1).optional(),
    quietHours: z.string().optional(),
    onCallEmail: z.string().email().optional(),
  });

  async execute(input: z.infer<typeof this.inputSchema>) {
    const fields = Object.keys(input).filter((k) => input[k as keyof typeof input] !== undefined);
    const decision = mayWrite(fields);
    if (!decision.ok) return { updated: false, reason: decision.reason };
    const entry = await Data.create('escalation_policy', { ...input, changedAt: Date.now() });
    return { updated: true, id: entry.id };
  }
}