Introduce agent.observer package.

examples/javascript-developer/src/runDeveloperAgent.ts

@@ -80,7 +80,7 @@ export async function runDeveloperAgent({
         }),
       ],
     }),
-    observer: $.agent.showRunInConsole({
+    observer: $.agent.observer.showRunInConsole({
       name: "JavaScript Developer Agent",
     }),
   });

examples/wikipedia/src/runWikipediaAgent.ts

@@ -80,8 +80,6 @@ export async function runWikipediaAgent({
       }),
     }),
     controller: $.agent.controller.maxSteps(20),
-    observer: $.agent.showRunInConsole({
-      name: "Wikipedia Agent",
-    }),
+    observer: $.agent.observer.showRunInConsole({ name: "Wikipedia Agent" }),
   });
 }

packages/agent/src/agent/Run.ts

@@ -4,7 +4,7 @@ import { Step } from "../step/Step";
 import { StepResult } from "../step/StepResult";
 import { createNextId } from "../util/createNextId";
 import { GenerateCall } from "./GenerateCall";
-import { RunObserver } from "./RunObserver";
+import { RunObserver } from "./observer/RunObserver";
 
 export class Run {
   private readonly observer?: RunObserver;

packages/agent/src/agent/index.ts

@@ -1,5 +1,6 @@
+export * from "./GenerateCall";
 export * from "./Run";
-export * from "./RunObserver";
+export * from "./RunContext";
 export * as controller from "./controller/index";
+export * as observer from "./observer/index";
 export * from "./runAgent";
-export * from "./showRunInConsole";

packages/agent/src/agent/RunObserver.ts → packages/agent/src/agent/observer/RunObserver.ts

@@ -1,7 +1,7 @@
-import { StepResult } from "../step";
-import { Loop } from "../step/Loop";
-import { Step } from "../step/Step";
-import { Run } from "./Run";
+import { StepResult } from "../../step";
+import { Loop } from "../../step/Loop";
+import { Step } from "../../step/Step";
+import { Run } from "../Run";
 
 export type RunObserver = {
   onRunStarted?: ({}: { run: Run }) => void;

packages/agent/src/agent/observer/index.ts

@@ -0,0 +1,2 @@
+export * from "./RunObserver";
+export * from "./showRunInConsole";

packages/agent/src/agent/showRunInConsole.ts → packages/agent/src/agent/observer/showRunInConsole.ts

@@ -1,7 +1,7 @@
 import chalk from "chalk";
-import { Step, StepResult } from "../step";
-import { ToolStep } from "../tool/ToolStep";
-import { Run } from "./Run";
+import { Step, StepResult } from "../../step";
+import { ToolStep } from "../../tool/ToolStep";
+import { Run } from "../Run";
 import { RunObserver } from "./RunObserver";
 
 const log = console.log;

packages/agent/src/agent/runAgent.ts

@@ -2,7 +2,7 @@ import { StepFactory } from "../step/StepFactory";
 import { maxSteps } from "./controller/maxSteps";
 import { Run } from "./Run";
 import { RunController } from "./controller/RunController";
-import { RunObserver } from "./RunObserver";
+import { RunObserver } from "./observer/RunObserver";
 
 export const runAgent = async ({
   agent,