fix(matrix): use JSON-specific idle-timeout diagnostic on bounded JSON read

Alix-007 · Alix-007 · commit 6277cb34ddd8 · 2026-06-23T15:40:29.000+08:00
The non-raw JSON read in performMatrixRequest fell back to the bound
reader's default media idle-timeout message ('Matrix media download
stalled: ...'), which is misleading for a JSON control-plane read. Pass
a JSON-specific onIdleTimeout so a stalled JSON stream now rejects with
'Matrix JSON response stalled: no data received for {ms}ms', letting the
timeout diagnostic distinguish a stalled JSON read from a stalled
raw/media read. Update the regression assertion accordingly.
diff --git a/extensions/matrix/src/matrix/sdk/transport.test.ts b/extensions/matrix/src/matrix/sdk/transport.test.ts
@@ -261,7 +261,7 @@ describe("performMatrixRequest", () => {
     );
   });
 
-  it("uses the configured idle-timeout error for stalled JSON downloads", async () => {
+  it("uses the JSON-specific idle-timeout error for stalled JSON downloads", async () => {
     vi.useFakeTimers();
     try {
       const stream = new ReadableStream<Uint8Array>({
@@ -291,7 +291,7 @@ describe("performMatrixRequest", () => {
       });
 
       const rejection = expect(requestPromise).rejects.toThrow(
-        "Matrix media download stalled: no data received for 50ms",
+        "Matrix JSON response stalled: no data received for 50ms",
       );
       await vi.advanceTimersByTimeAsync(60);
       await rejection;
diff --git a/extensions/matrix/src/matrix/sdk/transport.ts b/extensions/matrix/src/matrix/sdk/transport.ts
@@ -364,6 +364,8 @@ export async function performMatrixRequest(params: {
           `Matrix JSON response exceeds configured size limit (${size} bytes > ${maxBytes} bytes)`,
         ),
       chunkTimeoutMs: params.readIdleTimeoutMs,
+      onIdleTimeout: ({ chunkTimeoutMs }) =>
+        new Error(`Matrix JSON response stalled: no data received for ${chunkTimeoutMs}ms`),
     });
     return {
       response,
