apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-06-03 19:25:19 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

improve stream err handling

Browse source
This commit is contained in:
Ramnique Singh 2025-08-12 06:45:35 +05:30
parent ef885fc831
commit dd6b032caf
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
apps/rowboat/app/api/stream-response/[streamId]/route.ts
View file

@ -1,6 +1,8 @@
import { container } from "@/di/container"; import { container } from "@/di/container";
import { IRunCachedTurnController } from "@/src/interface-adapters/controllers/conversations/run-cached-turn.controller"; import { IRunCachedTurnController } from "@/src/interface-adapters/controllers/conversations/run-cached-turn.controller";
import { requireAuth } from "@/app/lib/auth"; import { requireAuth } from "@/app/lib/auth";
import { z } from "zod";
import { TurnEvent } from "@/src/entities/models/turn";
export async function GET(request: Request, props: { params: Promise<{ streamId: string }> }) { export async function GET(request: Request, props: { params: Promise<{ streamId: string }> }) {
const params = await props.params; const params = await props.params;
@ -23,10 +25,18 @@ export async function GET(request: Request, props: { params: Promise<{ streamId:
})) { })) {
controller.enqueue(encoder.encode(`event: message\ndata: ${JSON.stringify(event)}\n\n`)); controller.enqueue(encoder.encode(`event: message\ndata: ${JSON.stringify(event)}\n\n`));
} }
controller.close();
} catch (error) { } catch (error) {
console.error('Error processing stream:', error); console.error('Error processing stream:', error);
controller.error(error); const errMessage: z.infer<typeof TurnEvent> = {
type: "error",
error: `Error processing stream: ${error}`,
isBillingError: false,
};
controller.enqueue(encoder.encode(`event: message\ndata: ${JSON.stringify(errMessage)}\n\n`));
} finally {
console.log("closing stream");
controller.enqueue(encoder.encode("event: end\n\n"));
controller.close();
} }
}, },
}); });