@kyro/actor

new Actor(personalityPath: string, provider: AIProvider)

async run(
  scenarioPath: string,
  connection: Connection
): Promise<Transcript>

interface Connection {
  send(message: string): Promise<void>;
  waitForMessage(): Promise<string>;
  close(): Promise<void>;
}

new WebSocketConnection(url: string, options?: WebSocketOptions)

interface WebSocketOptions {
  timeout?: number;       // Message wait timeout in ms (default: 30000)
  reconnect?: boolean;    // Auto-reconnect on disconnect (default: false)
}

new LangChainConnection(runnable: Runnable, options?: LangChainOptions)

interface Transcript {
  messages: Array<{
    role: 'actor' | 'agent';
    content: string;
    timestamp: Date;
  }>;
  turns: number;
  completed: boolean;
  success: boolean;
  exitReason: 'success' | 'failure' | 'exit_condition' | 'max_turns';
  durationMs: number;
}