fix: add chat surface endpoints setup for handling incoming messages

Author: NoOne7135

endpoints/chatSurfaces.ts

@@ -0,0 +1,37 @@
+import type {
+  IAdminForthEndpointHandlerInput,
+  IHttpServer,
+} from "adminforth";
+import type { ChatSurfaceEndpointsContext } from "./context.js";
+
+export function setupChatSurfaceEndpoints(ctx: ChatSurfaceEndpointsContext, server: IHttpServer) {
+  for (const adapter of ctx.options.chatSurfaceAdapters ?? []) {
+    server.endpoint({
+      method: "POST",
+      noAuth: true,
+      path: `/agent/surface/${adapter.name}/webhook`,
+      handler: async (endpointInput: IAdminForthEndpointHandlerInput) => {
+        const surfaceContext = {
+          body: endpointInput.body,
+          headers: endpointInput.headers,
+          abortSignal: endpointInput.abortSignal,
+          rawRequest: endpointInput._raw_express_req,
+          rawResponse: endpointInput._raw_express_res,
+        };
+
+        const incoming = await adapter.parseIncomingMessage(surfaceContext);
+        if (!incoming) return { ok: true };
+
+        const sink = await adapter.createEventSink(surfaceContext, incoming);
+
+        try {
+          await ctx.handleChatSurfaceMessage(adapter, incoming, sink);
+        } finally {
+          await sink.close?.();
+        }
+
+        return { ok: true };
+      },
+    });
+  }
+}

index.ts

@@ -13,6 +13,7 @@ import { AdminForthCheckpointSaver } from "./agent/checkpointer.js";
 import { appendCustomSystemPrompt, buildAgentSystemPrompt, DEFAULT_AGENT_SYSTEM_PROMPT} from "./agent/systemPrompt.js";
 import { setupCoreEndpoints } from "./endpoints/core.js";
 import { setupSessionEndpoints } from "./endpoints/sessions.js";
+import { setupChatSurfaceEndpoints } from "./endpoints/chatSurfaces.js";
 import type { AgentEndpointsContext } from "./endpoints/context.js";
 import { AgentSessionStore } from "./sessionStore.js";
 import { ChatSurfaceService } from "./chatSurfaceService.js";
@@ -155,5 +156,6 @@ export default class AdminForthAgentPlugin extends AdminForthPlugin {
 
     setupCoreEndpoints(endpointContext, server);
     setupSessionEndpoints(endpointContext, server);
+    setupChatSurfaceEndpoints(endpointContext, server);
   }
 }