scriptoriumadmin/Roo-Code
1
0
Fork 0
mirror of https://github.com/RooVetGit/Roo-Code.git synced 2026-08-28 05:27:24 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

revert to main

Browse source
This commit is contained in:
Steven T. Cramer 2025-06-13 16:03:02 +07:00
parent 7a3d2039af
commit a25adf8bbe
1 changed files with 3 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
apps/web-evals/src/app/api/runs/[id]/stream/route.ts
View file

@ -25,7 +25,7 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
try {
const taskEvent = taskEventSchema.parse(JSON.parse(data))
console.log(`[stream#${requestId}] task event -> ${taskEvent.eventName}`)
// console.log(`[stream#${requestId}] task event -> ${taskEvent.eventName}`)
const writeSuccess = await stream.write(JSON.stringify(taskEvent))
if (!writeSuccess) {
@ -59,18 +59,9 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
await redis.subscribe(channelName, onMessage)
// Add a timeout to close the stream after a period of inactivity or errors
const timeoutDuration = 300000; // 5 minutes
const timeoutId = setTimeout(() => {
console.log(`[stream#${requestId}] timeout after ${timeoutDuration}ms`);
disconnect().catch((error) => {
console.error(`[stream#${requestId}] timeout cleanup error:`, error)
});
}, timeoutDuration);
request.signal.addEventListener("abort", () => {
console.log(`[stream#${requestId}] abort`);
clearTimeout(timeoutId);
console.log(`[stream#${requestId}] abort`)
disconnect().catch((error) => {
console.error(`[stream#${requestId}] cleanup error:`, error)
})