feat(hub): register RPC handlers for hub, agent, and gateway operations

Add 5 new RPC methods (getHubInfo, listAgents, createAgent, deleteAgent,
updateGateway) mirroring the existing Console HTTP API, enabling pure
WebSocket communication from the frontend.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

src/hub/hub.ts

@@ -12,6 +12,11 @@ import { getHubId } from "./hub-identity.js";
 import { loadAgentRecords, addAgentRecord, removeAgentRecord } from "./agent-store.js";
 import { RpcDispatcher, RpcError } from "./rpc/dispatcher.js";
 import { createGetAgentMessagesHandler } from "./rpc/handlers/get-agent-messages.js";
+import { createGetHubInfoHandler } from "./rpc/handlers/get-hub-info.js";
+import { createListAgentsHandler } from "./rpc/handlers/list-agents.js";
+import { createCreateAgentHandler } from "./rpc/handlers/create-agent.js";
+import { createDeleteAgentHandler } from "./rpc/handlers/delete-agent.js";
+import { createUpdateGatewayHandler } from "./rpc/handlers/update-gateway.js";
 
 export class Hub {
   private readonly agents = new Map<string, AsyncAgent>();
@@ -34,6 +39,11 @@ export class Hub {
 
     this.rpc = new RpcDispatcher();
     this.rpc.register("getAgentMessages", createGetAgentMessagesHandler());
+    this.rpc.register("getHubInfo", createGetHubInfoHandler(this));
+    this.rpc.register("listAgents", createListAgentsHandler(this));
+    this.rpc.register("createAgent", createCreateAgentHandler(this));
+    this.rpc.register("deleteAgent", createDeleteAgentHandler(this));
+    this.rpc.register("updateGateway", createUpdateGatewayHandler(this));
 
     this.client = this.createClient(this.url);
     this.client.connect();

src/hub/rpc/handlers/create-agent.ts

@@ -0,0 +1,13 @@
+import type { RpcHandler } from "../dispatcher.js";
+
+interface HubLike {
+  createAgent(id?: string): { sessionId: string };
+}
+
+export function createCreateAgentHandler(hub: HubLike): RpcHandler {
+  return (params: unknown) => {
+    const { id } = (params ?? {}) as { id?: string };
+    const agent = hub.createAgent(id);
+    return { id: agent.sessionId };
+  };
+}

src/hub/rpc/handlers/delete-agent.ts

@@ -0,0 +1,19 @@
+import { RpcError, type RpcHandler } from "../dispatcher.js";
+
+interface HubLike {
+  closeAgent(id: string): boolean;
+}
+
+export function createDeleteAgentHandler(hub: HubLike): RpcHandler {
+  return (params: unknown) => {
+    if (!params || typeof params !== "object") {
+      throw new RpcError("INVALID_PARAMS", "params must be an object");
+    }
+    const { id } = params as { id?: string };
+    if (!id) {
+      throw new RpcError("INVALID_PARAMS", "Missing required param: id");
+    }
+    const ok = hub.closeAgent(id);
+    return { ok };
+  };
+}

src/hub/rpc/handlers/get-hub-info.ts

@@ -0,0 +1,17 @@
+import type { RpcHandler } from "../dispatcher.js";
+
+interface HubLike {
+  hubId: string;
+  url: string;
+  connectionState: string;
+  listAgents(): string[];
+}
+
+export function createGetHubInfoHandler(hub: HubLike): RpcHandler {
+  return () => ({
+    hubId: hub.hubId,
+    url: hub.url,
+    connectionState: hub.connectionState,
+    agentCount: hub.listAgents().length,
+  });
+}

src/hub/rpc/handlers/list-agents.ts

@@ -0,0 +1,16 @@
+import type { RpcHandler } from "../dispatcher.js";
+
+interface HubLike {
+  listAgents(): string[];
+  getAgent(id: string): { closed: boolean } | undefined;
+}
+
+export function createListAgentsHandler(hub: HubLike): RpcHandler {
+  return () => {
+    const agents = hub.listAgents().map((id) => {
+      const agent = hub.getAgent(id);
+      return { id, closed: agent?.closed ?? true };
+    });
+    return { agents };
+  };
+}

src/hub/rpc/handlers/update-gateway.ts

@@ -0,0 +1,21 @@
+import { RpcError, type RpcHandler } from "../dispatcher.js";
+
+interface HubLike {
+  url: string;
+  connectionState: string;
+  reconnect(url: string): void;
+}
+
+export function createUpdateGatewayHandler(hub: HubLike): RpcHandler {
+  return (params: unknown) => {
+    if (!params || typeof params !== "object") {
+      throw new RpcError("INVALID_PARAMS", "params must be an object");
+    }
+    const { url } = params as { url?: string };
+    if (!url) {
+      throw new RpcError("INVALID_PARAMS", "Missing required param: url");
+    }
+    hub.reconnect(url);
+    return { url: hub.url, connectionState: hub.connectionState };
+  };
+}

src/hub/rpc/index.ts

@@ -1,2 +1,7 @@
 export { RpcDispatcher, RpcError, type RpcHandler } from "./dispatcher.js";
 export { createGetAgentMessagesHandler } from "./handlers/get-agent-messages.js";
+export { createGetHubInfoHandler } from "./handlers/get-hub-info.js";
+export { createListAgentsHandler } from "./handlers/list-agents.js";
+export { createCreateAgentHandler } from "./handlers/create-agent.js";
+export { createDeleteAgentHandler } from "./handlers/delete-agent.js";
+export { createUpdateGatewayHandler } from "./handlers/update-gateway.js";