Your own
Viktor.
Built by you.

// lib/agent.ts — the main agent loop
// Cloudflare Worker compatible, no Node.js dependencies

const CLAUDE_API = 'https://api.anthropic.com/v1/messages';
const MODEL      = 'claude-sonnet-4-6';

export async function runAgent(env: Env, trigger: AgentTrigger) {

  // 1. Assemble context from D1
  const [tasks, decisions, entities] = await Promise.all([
    env.DB.prepare("SELECT * FROM tasks WHERE status='open' ORDER BY created_at DESC LIMIT 20").all(),
    env.DB.prepare("SELECT * FROM decisions ORDER BY created_at DESC LIMIT 10").all(),
    env.DB.prepare("SELECT * FROM entities ORDER BY updated_at DESC LIMIT 30").all(),
  ]);

  const contextBlock = [
    `TRIGGER: ${trigger.type} — ${JSON.stringify(trigger.payload)}`,
    `OPEN TASKS (${tasks.results.length}):\n` +
      tasks.results.map((t: any) => `- [${t.priority}] ${t.title}`).join('\n'),
    `RECENT DECISIONS:\n` +
      decisions.results.map((d: any) => `- ${d.action}: ${d.reasoning}`).join('\n'),
    `KNOWN ENTITIES:\n` +
      entities.results.map((e: any) => `- ${e.name} (${e.type}): ${e.facts}`).join('\n'),
  ].join('\n\n');

  // 2. Tools Claude can call
  const tools = [
    {
      name: 'create_task',
      description: 'Add a task to track. Use when something needs follow-up.',
      input_schema: {
        type: 'object', required: ['title'],
        properties: {
          title:    { type: 'string' },
          priority: { type: 'string', enum: ['low','normal','high'] },
          context:  { type: 'string' }
        }
      }
    },
    {
      name: 'send_notification',
      description: 'Send Ryan a Slack DM. Use for anything action-needed.',
      input_schema: {
        type: 'object', required: ['message'],
        properties: {
          message: { type: 'string' },
          urgency: { type: 'string', enum: ['info','action_needed','urgent'] }
        }
      }
    },
    {
      name: 'draft_email',
      description: 'Draft an email. Saves to R2 and notifies Ryan to review.',
      input_schema: {
        type: 'object', required: ['to','subject','body'],
        properties: {
          to:      { type: 'string' },
          subject: { type: 'string' },
          body:    { type: 'string' }
        }
      }
    },
    {
      name: 'no_action',
      description: 'Nothing needs doing this run.',
      input_schema: {
        type: 'object',
        properties: { reason: { type: 'string' } }
      }
    }
  ];

  // 3. Call Claude
  const res = await fetch(CLAUDE_API, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'x-api-key': env.ANTHROPIC_API_KEY,
      'anthropic-version': '2023-06-01'
    },
    body: JSON.stringify({
      model: MODEL, max_tokens: 1024,
      system: systemPrompt(),
      messages: [{ role: 'user', content: contextBlock }],
      tools
    })
  });

  const data = await res.json();

  // 4. Execute tool calls + log decisions
  for (const block of data.content) {
    if (block.type !== 'tool_use') continue;
    await executeTool(env, block.name, block.input);
    await env.DB.prepare(
      `INSERT INTO decisions (id,trigger,action,reasoning,created_at)
       VALUES (?,?,?,?,datetime('now'))`
    ).bind(crypto.randomUUID(), trigger.type, block.name,
           block.input.reason ?? JSON.stringify(block.input))
     .run();
  }
}

function systemPrompt() {
  return `You are Ryan's personal AI agent. Ryan is President of GTMpact Solutions,
runs Client Success and Operations at Independence Pet Group, and develops
OrgCanvas and AgentIzzy. Based in Milton, GA.

Review incoming information. Take action or note no action needed.
Be decisive — Ryan prefers action over deliberation.

Use create_task for follow-ups, send_notification when Ryan needs to
know something now, draft_email when a reply is needed, no_action
when nothing warrants attention. Always give brief reasoning.`;
}