Skip to content

Commit c59b1a7

Browse files
committed
Improved X-Resume-From-Chunk header parsing
1 parent 3b912cd commit c59b1a7

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

apps/webapp/app/routes/realtime.v1.streams.$runId.$target.$streamId.ts

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,16 @@ const { action } = createActionApiRoute(
9494
}
9595

9696
const resumeFromChunk = request.headers.get("X-Resume-From-Chunk");
97-
const resumeFromChunkNumber = resumeFromChunk ? parseInt(resumeFromChunk, 10) : undefined;
97+
let resumeFromChunkNumber: number | undefined = undefined;
98+
if (resumeFromChunk) {
99+
const parsed = parseInt(resumeFromChunk, 10);
100+
if (isNaN(parsed) || parsed < 0) {
101+
return new Response(`Invalid X-Resume-From-Chunk header value: ${resumeFromChunk}`, {
102+
status: 400,
103+
});
104+
}
105+
resumeFromChunkNumber = parsed;
106+
}
98107

99108
const realtimeStream = getRealtimeStreamInstance(authentication.environment, streamVersion);
100109

0 commit comments

Comments
 (0)