From 3028e787ace5e9b3748c00e05472bd6b54426206 Mon Sep 17 00:00:00 2001
From: Agent <agent@mcp-hub>
Date: Fri, 13 Mar 2026 11:30:19 +0000
Subject: [PATCH] Initial commit: mcp-hub project

---
 src/event-bus.js | 12 ++++++++++++
 src/ws-server.js |  2 ++
 2 files changed, 14 insertions(+)
 create mode 100644 src/event-bus.js

diff --git a/src/event-bus.js b/src/event-bus.js
new file mode 100644
index 0000000..6d8e37a
--- /dev/null
+++ b/src/event-bus.js
@@ -0,0 +1,12 @@
+const { EventEmitter } = require('events');
+
+const eventBus = new EventEmitter();
+eventBus.setMaxListeners(50);
+
+function log(level, message) {
+  console[level]?.(message) ?? console.log(message);
+  eventBus.emit('log', { level, message, ts: new Date().toISOString() });
+}
+
+module.exports = eventBus;
+module.exports.log = log;
diff --git a/src/ws-server.js b/src/ws-server.js
index 8e08c82..9f4be65 100644
--- a/src/ws-server.js
+++ b/src/ws-server.js
@@ -2,6 +2,8 @@ const WebSocket = require('ws');
 const config = require('./config');
 const registry = require('./backend-registry');
 const relay = require('./relay');
+const eventBus = require('./event-bus');
+const { log } = require('./event-bus');
 
 const PING_INTERVAL_MS = 30000;
 const MAX_MISSED_PONGS = 2;