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

Merge e0ca073f82 into 2133d7226f

Browse source
This commit is contained in:
Chris Chen 2026-04-17 08:06:52 +10:00 • committed by GitHub
commit 988a460673
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 14 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
apps/cli/src/application/lib/bus.ts
View file

@ -29,7 +29,8 @@ export class InMemoryBus implements IBus {
}
this.subscribers.get(runId)!.push(handler);
return () => {
this.subscribers.get(runId)!.splice(this.subscribers.get(runId)!.indexOf(handler), 1);
const idx = this.subscribers.get(runId)!.indexOf(handler);
if (idx !== -1) this.subscribers.get(runId)!.splice(idx, 1);
};
}
}

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

@ -10,6 +10,15 @@ export async function GET(request: Request, props: { params: Promise<{ streamId:
// get user data
const user = await requireAuth();
// Validate auth token
const apiKey = request.headers.get("Authorization")?.split(" ")[1];
if (!apiKey) {
return new Response(JSON.stringify({ error: "Missing or invalid Authorization header" }), {
status: 401,
headers: { "Content-Type": "application/json" },
});
}
const runCopilotCachedTurnController = container.resolve<IRunCopilotCachedTurnController>("runCopilotCachedTurnController");
const encoder = new TextEncoder();
@ -21,7 +30,7 @@ export async function GET(request: Request, props: { params: Promise<{ streamId:
for await (const event of runCopilotCachedTurnController.execute({
caller: "user",
userId: user.id,
apiKey: request.headers.get("Authorization")?.split(" ")[1],
apiKey,
key: params.streamId,
})) {
// Check if this is a content event

3
apps/x/packages/core/src/application/lib/bus.ts
View file

@ -29,7 +29,8 @@ export class InMemoryBus implements IBus {
}
this.subscribers.get(runId)!.push(handler);
return () => {
this.subscribers.get(runId)!.splice(this.subscribers.get(runId)!.indexOf(handler), 1);
const idx = this.subscribers.get(runId)!.indexOf(handler);
if (idx !== -1) this.subscribers.get(runId)!.splice(idx, 1);
};
}
}