From 528c776e1b54fb047f1ccf3d6ecef57dacb0d1b3 Mon Sep 17 00:00:00 2001
From: creatixchu <creatixchu@deepseek.com>
Date: Mon, 10 Aug 2026 19:11:06 +0800
Subject: [PATCH] fix(e2b): release bounded read stream locks

Release the Web Stream reader after either completion or cancellation. Strengthen the oversized-file test so a regression that downloads content before applying the stat bound fails directly.
---
 packages/e2b/fs-e2b/src/index.ts             | 1 +
 packages/e2b/fs-e2b/tests/filesystem.spec.ts | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/packages/e2b/fs-e2b/src/index.ts b/packages/e2b/fs-e2b/src/index.ts
index 75005fa3ad..eda6866116 100644
--- a/packages/e2b/fs-e2b/src/index.ts
+++ b/packages/e2b/fs-e2b/src/index.ts
@@ -274,6 +274,7 @@ export class E2BFileSystem extends FileSystem {
           // remote stream adds nothing actionable for the caller.
         }
       }
+      reader.releaseLock()
     }
     const whole = new Uint8Array(bytes)
     let offset = 0
diff --git a/packages/e2b/fs-e2b/tests/filesystem.spec.ts b/packages/e2b/fs-e2b/tests/filesystem.spec.ts
index 648db7b105..a2a494911f 100644
--- a/packages/e2b/fs-e2b/tests/filesystem.spec.ts
+++ b/packages/e2b/fs-e2b/tests/filesystem.spec.ts
@@ -40,6 +40,7 @@ class FakeRemote {
   readonly links: Array<{ from: string; to: string }> = []
   readonly removals: string[] = []
   readonly commands: string[] = []
+  readonly reads: Array<{ path: string; format: 'bytes' | 'stream' }> = []
   streamChunks: Uint8Array[] | undefined
   streamKeepOpen = false
   readonly streamCancel = vi.fn()
@@ -157,6 +158,7 @@ class FakeRemote {
       },
       read: async (path: string, options: { format: 'bytes' | 'stream'; signal?: AbortSignal }): Promise<Uint8Array | ReadableStream<Uint8Array> | string> => {
         this.checkAbort(options)
+        this.reads.push({ path, format: options.format })
         if (this.nextReadError !== undefined) {
           const error = this.nextReadError
           this.nextReadError = undefined
@@ -478,7 +480,10 @@ describe('E2BFileSystem identity, metadata, and reads', () => {
     const { fs } = await setup(remote)
     const target = await fs.resolve('img.bin')
     expect(Array.from(await fs.readBytes(target, undefined, 4))).toEqual([0x89, 0, 0xff, 0x47])
+    expect(remote.reads).toEqual([{ path: '/workspace/img.bin', format: 'stream' }])
+    remote.reads.length = 0
     await expectCode(fs.readBytes(target, undefined, 3), 'FS_TOO_LARGE')
+    expect(remote.reads).toEqual([])
     await expectCode(fs.readBytes(await fs.resolve('missing'), undefined, 4), 'FS_NOT_FOUND')
     await expectCode(fs.readBytes(await fs.resolve('directory'), undefined, 4), 'FS_NOT_REGULAR_FILE')