diff --git a/src/cli/index.ts b/src/cli/index.ts index b4a31c8..fc02f81 100644 --- a/src/cli/index.ts +++ b/src/cli/index.ts @@ -11,6 +11,7 @@ import { CoordinationServer } from '../server/index.js'; import { GracefulShutdown } from '../server/shutdown.js'; import { ProcessManager, ProcessRegistry } from '../process/index.js'; import { LogManager } from '../logging/index.js'; +import { createEventBus } from '../events/index.js'; import { createDefaultTrpcClient } from './trpc-client.js'; /** Environment variable for custom port */ @@ -27,14 +28,16 @@ async function startServer(port?: number): Promise { // Create dependencies const registry = new ProcessRegistry(); - const processManager = new ProcessManager(registry); + const eventBus = createEventBus(); + const processManager = new ProcessManager(registry, eventBus); const logManager = new LogManager(); // Create and start server const server = new CoordinationServer( { port: serverPort }, processManager, - logManager + logManager, + eventBus ); try {