From 40066e975a07fb63abffaba5bee688baf925e036 Mon Sep 17 00:00:00 2001 From: Enrico Ros Date: Wed, 22 Apr 2026 01:14:17 -0700 Subject: [PATCH] AIX: Dispatch: cleanup router --- src/modules/aix/server/api/aix.router.ts | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/modules/aix/server/api/aix.router.ts b/src/modules/aix/server/api/aix.router.ts index 6bc7b81b8..9fa2318bc 100644 --- a/src/modules/aix/server/api/aix.router.ts +++ b/src/modules/aix/server/api/aix.router.ts @@ -28,28 +28,28 @@ export const aixRouter = createTRPCRouter({ })) .mutation(async function* ({ input, ctx }) { const _d = _createDebugConfig(input.access, input.connectionOptions, input.context.name); - const chatGenerateDispatchCreator = () => createChatGenerateDispatch(input.access, input.model, input.chatGenerate, input.streaming, !!input.connectionOptions?.enableResumability); + const dispatchCreator = () => createChatGenerateDispatch(input.access, input.model, input.chatGenerate, input.streaming, !!input.connectionOptions?.enableResumability); - yield* executeChatGenerateWithContinuation(chatGenerateDispatchCreator, input.streaming, ctx.reqSignal, _d); + yield* executeChatGenerateWithContinuation(dispatchCreator, input.streaming, ctx.reqSignal, _d); }), /** - * Chat content generation RESUME, streaming only. - * Reconnects to an in-progress response by its ID - OpenAI Responses API only. + * Chat content generation - reattach to an in-progress upstream run by handle, streaming only. + * Today: OpenAI Responses API (network-disconnect recovery) and Gemini Interactions (Deep Research across reloads). */ reattachContent: edgeProcedure .input(z.object({ access: AixWire_API.Access_schema, - resumeHandle: AixWire_API.ResumeHandle_schema, // resume has a handle instead of 'model + chatGenerate' + resumeHandle: AixWire_API.ResumeHandle_schema, // reattach uses a handle instead of 'model + chatGenerate' context: AixWire_API.ContextChatGenerate_schema, - streaming: z.literal(true), // resume is always streaming + streaming: z.literal(true), // reattach is always streaming connectionOptions: AixWire_API.ConnectionOptionsChatGenerate_schema.pick({ debugDispatchRequest: true }).optional(), // debugDispatchRequest })) .mutation(async function* ({ input, ctx }) { const _d = _createDebugConfig(input.access, input.connectionOptions, input.context.name); - const resumeDispatchCreator = () => createChatGenerateResumeDispatch(input.access, input.resumeHandle, input.streaming); + const dispatchCreator = () => createChatGenerateResumeDispatch(input.access, input.resumeHandle, input.streaming); - yield* executeChatGenerateWithContinuation(resumeDispatchCreator, input.streaming, ctx.reqSignal, _d); + yield* executeChatGenerateWithContinuation(dispatchCreator, input.streaming, ctx.reqSignal, _d); }), });