const agent = new Agent({
  name: "assistant",
  model: openai("gpt-4o"),
});

agent.eventBus.on("run.start", ({ input }) => {
  console.log("User asked:", input);
});

agent.eventBus.on("run.complete", ({ output }) => {
  console.log("Answer:", output.text);
});

await agent.run("Hello");

agent.eventBus.onAny((event, data) => {
  console.log(event, data);
});

// Option A
new Agent({ name: "a", model, sharedEventBus: true });
new Agent({ name: "b", model, sharedEventBus: true });

// Option B
new Agent({ name: "a", model, eventBus: EventBus.shared });

import { EventBus } from "@agentium/core";

EventBus.shared.onAny((event, data) => {
  // every entity in this Node process
});

import { LIFECYCLE_EVENTS } from "@agentium/core";