The agent loop.

// Module 05: Minimal agent loop
import Anthropic from '@anthropic-ai/sdk';
import { browseMarkets, browseMarketsTool } from './tools.js';

const client = new Anthropic();
const MAX_ITERS = 10;

async function runAgent(userMessage: string) {
  const messages: Anthropic.MessageParam[] = [{ role: 'user', content: userMessage }];

  for (let i = 0; i < MAX_ITERS; i++) {
    const resp = await client.messages.create({
      model:      'claude-opus-4-8',
      max_tokens: 1024,
      system:     'You are a Limitless trading research agent. Use tools to investigate markets.',
      tools:      [browseMarketsTool],
      messages,
    });

    // Terminal: model returned plain text, no more tool calls.
    if (resp.stop_reason === 'end_turn') {
      const text = resp.content.find(c => c.type === 'text');
      console.log('Final:', text?.text);
      return;
    }

    // Execute any tool calls and feed results back.
    const toolUses = resp.content.filter(c => c.type === 'tool_use');
    messages.push({ role: 'assistant', content: resp.content });
    const toolResults = await Promise.all(toolUses.map(async (tu: any) => ({
      type:        'tool_result' as const,
      tool_use_id: tu.id,
      content:     await browseMarkets(tu.input),
    })));
    messages.push({ role: 'user', content: toolResults });
  }

  console.warn('Max iterations reached');
}

runAgent('Find me 5 active markets.').catch(console.error);

# Module 05: Minimal agent loop
import asyncio
from openai import AsyncOpenAI
from tools import browse_markets, browse_markets_tool

client = AsyncOpenAI()
MAX_ITERS = 10


async def run_agent(user_message: str) -> None:
    messages = [
        {"role": "system", "content": "You are a Limitless trading research agent. Use tools to investigate markets."},
        {"role": "user",   "content": user_message},
    ]

    for _ in range(MAX_ITERS):
        resp = await client.chat.completions.create(
            model    = "gpt-4o",
            messages = messages,
            tools    = [browse_markets_tool],
        )
        msg = resp.choices[0].message
        messages.append(msg.model_dump(exclude_none=True))

        # Terminal: no tool calls means model is done.
        if not msg.tool_calls:
            print("Final:", msg.content)
            return

        for call in msg.tool_calls:
            args = __import__("json").loads(call.function.arguments)
            result = await browse_markets(**args)
            messages.append({
                "role":         "tool",
                "tool_call_id": call.id,
                "content":      result,
            })

    print("Max iterations reached")


if __name__ == "__main__":
    asyncio.run(run_agent("Find me 5 active markets."))