We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 03c26e4 commit 8e7e0c3Copy full SHA for 8e7e0c3
2 files changed
src/server.ts
@@ -14,8 +14,9 @@ import {
14
isRequestMessage,
15
isResponseMessage,
16
} from "./jsonrpc.js";
17
-
18
import { serializeSseEvent, serializeSseKeepAlive } from "./sse.js";
+import { handleWebSocketConnection } from "./ws-server.js";
19
+import type { WebSocketServerSocket } from "./ws-server.js";
20
21
import type {
22
ConnectionState,
@@ -53,6 +54,13 @@ export class AcpServer {
53
54
return textResponse("Method Not Allowed", 405);
55
}
56
57
+ handleWebSocket(socket: WebSocketServerSocket): void {
58
+ handleWebSocketConnection(socket, {
59
+ registry: this.registry,
60
+ createAgent: this.createAgent,
61
+ });
62
+ }
63
+
64
async close(): Promise<void> {
65
this.registry.closeAll();
66
0 commit comments