Zip streaming on Cloudflare Workers - WritableStream has been closed

[petrzelka]

I'm trying to set up downloading and zipping multiple files on-the-fly with Cloudflare Workers.

This library seems to be the only one out there that supports Web standards, is not dependent on node.js libs and supports zip streaming, which is awesome, thank you!

With my code, the files are zipped and downloaded correctly, but for every file added to the archive, these errors show up in the console:

✘ [ERROR] Uncaught (in promise) TypeError: This WritableStream has been closed.
✘ [ERROR] Uncaught (async) TypeError: This WritableStream has been closed.

They are generated by Cloudflare's own implementation of Streams, see below for more details:
https://github.com/cloudflare/workerd/blob/main/src/workerd/api/streams/writable.c%2B%2B

I haven't been successful to identify the issue, nor I don't know if it's a problem on zip.js side or Cloudflare's, but I thought I'll give it a try and ask here if you can take a look.

Here is a simple example of my code: https://github.com/petrzelka/zip-cloudflare-repro

I was following CF example of usage streaming with request/response:
https://developers.cloudflare.com/workers/examples/openai-sdk-streaming/

  async fetch(request, env, ctx) {
    const { readable, writable } = new TransformStream();
    const zipWriter = new ZipWriter(writable);

    zipWriter.add("hello.txt", new TextReader("Hello world!"));
    zipWriter.add("hello2.txt", new TextReader("Hello world!"));
    zipWriter.close();

    return new Response(readable, {
      headers: {
        "Content-Disposition": 'attachment; filename="file.zip"',
        "Content-Type": "application/zip",
        "Cache-Control": "no-cache",
      },
    });
  },

It doesn't matter if I use await for add() and close() or not, it always downloads the zip correctly and throws the error to the console.
Without waitUntil() it works without awaiting - that seems to me like the proper way but I was just following the example (and trying everything).
I tried to debug it, but I haven't found any suspicious place where TransformStream would be created and closed twice. Not sure it would be happening due to writing to closed stream because the file itself looks ok.
Writing or closing closed stream are the only ways how to get this error according to the workerd code.

Anyway, it's quite surprising to me that I did not find any attempts to zip files on-the-fly within Cloudflare Workers and that no one has reported such error that I'm seeing.

Thanks for any help!
Honza

[gildas-lormeau]

Thank you for the report, I will try to reproduce the issue. Could you meanwhile tell me if it works when replacing new ZipWriter(writable) with new ZipWriter(writable, { bufferedWrite: false, useWebWorkers: false })?

[petrzelka]

Thank you!
With the additional params, it behaves the same (zip ok, errors in console).
Also I forgot to mention that the behavior is the same in both local env and when deployed to cloudflare.

To reproduce, just clone my repo, npm install, npm start, open browser at localhost:8787, file.zip is downloaded, errors are in the npm console.

[gildas-lormeau]

I've had a look at the issue and I think it's specific to the CloudFlare Workers execution environment. As it happens, I can get around it by passing { useCompressionStream: false } as second parameter of ZipWriter, which is an unexpected result. This means that the bug is related to the use of the native CompressionStream API, but I can't find the source of the error when I debug the code step by step. I just know that it is raised when pipeThroughCommpressionStream is called in zip-empty-stream.js with useCompressionStream set to true. It also seems impossible to catch the error with try/catch.

For the record, here is the stack trace of the error below (commit: https://github.com/gildas-lormeau/zip.js/tree/9c06f4f6c95acc77e49da5400aac59c6d8bbe984).

pipeThrough			@	zip-entry-stream.js:164
pipeThroughCommpressionStream	@	zip-entry-stream.js:148
DeflateStream			@	zip-entry-stream.js:62
CodecStream			@	codec-stream.js:86
runWorker			@	codec-worker.js:161
run				@	codec-worker.js:135
runWorker2			@	codec-pool.js:65
await in runWorker2			(async)		
createFileEntry			@	zip-writer.js:615
await in createFileEntry		(async)		
getFileEntry			@	zip-writer.js:437
await in getFileEntry			(async)		
addFile				@	zip-writer.js:367
await in addFile			(async)		
add				@	zip-writer.js:146
(anonymous)			@	worker.js:10
fetch				@	worker.js:12

[gildas-lormeau]

I confirm there is something strange with the native CompressionStream API. The code below works fine whereas it's just defining a fake CompressionStream API which itself is just simply using the native CompressionStream API under the hood.

On paper, this code should not be able to fix any bug, but it does.

globalThis.CompressionStream = class {
  constructor(format) {
    const compressionStream = new CompressionStream(format);
    const writer = compressionStream.writable.getWriter();
    return new TransformStream({
      async transform(chunk) {
        await writer.write(chunk);
      },
      async flush() {
        await writer.close();
      }
    });
  }
}

const { TextReader, ZipWriter } = await import("@zip.js/zip.js");

export default {
  async fetch(request, env, ctx) {
    const { readable, writable } = new TransformStream();
    const zipWriter = new ZipWriter(writable);

    ctx.waitUntil(
      (async () => {
        await zipWriter.add("hello.txt", new TextReader("Hello world!"));
        await zipWriter.close();
      })()
    );

    return new Response(readable, {
      headers: {
        "Content-Disposition": 'attachment; filename="file.zip"',
        "Content-Type": "application/zip",
        "Cache-Control": "no-cache",
      },
    });
  },
};

A way to circumvent this bug in a "cleaner" way would be to use configure() in zip.js and pass the fake API, see the code below.

import { TextReader, ZipWriter, configure } from "@zip.js/zip.js";

configure({
  useCompressionStream: false,
  CompressionStream: class {
    constructor(format) {
      const compressionStream = new CompressionStream(format);
      const writer = compressionStream.writable.getWriter();
      return new TransformStream({
        async transform(chunk) {
          await writer.write(chunk);
        },
        async flush() {
          await writer.close();
        }
      });
    }
  }
});

export default {
  async fetch(request, env, ctx) {
    const { readable, writable } = new TransformStream();
    const zipWriter = new ZipWriter(writable);

    ctx.waitUntil(
      (async () => {
        await zipWriter.add("hello.txt", new TextReader("Hello world!"));
        await zipWriter.close();
      })()
    );

    return new Response(readable, {
      headers: {
        "Content-Disposition": 'attachment; filename="file.zip"',
        "Content-Type": "application/zip",
        "Cache-Control": "no-cache",
      },
    });
  },
};

[gildas-lormeau]

Finally, I can confirm this is not a bug in zip.js. I can reproduce it with the code below which does not depend on zip.js. I don't know if it's a bug in Node.js or the Worker environment.

export default {
  async fetch() {
    const { readable, writable } = new CompressionStream("deflate-raw");
    const helloWorldStream = new ReadableStream({
      start(controller) {
        controller.enqueue(new TextEncoder().encode("Hello, World!"));
        controller.close();
      }
    });

    helloWorldStream.pipeTo(writable);
    
    return new Response(readable, {
      headers: {
        "Content-Disposition": 'attachment; filename="file.raw"',
        "Content-Type": "application/octet-stream",
        "Cache-Control": "no-cache",
      },
    });
  }
};

[gildas-lormeau]

It's probably a bug in the Worker environment since the code below runs fine in Node.js.

const { readable, writable } = new CompressionStream("deflate-raw");
const helloWorldStream = new ReadableStream({
  start(controller) {
    controller.enqueue(new TextEncoder().encode("Hello, World!"));
    controller.close();
  }
});

helloWorldStream.pipeTo(writable);

const result = new Response(readable, {
  headers: {
    "Content-Disposition": 'attachment; filename="file.raw"',
    "Content-Type": "application/octet-stream",
    "Cache-Control": "no-cache",
  },
});

result.blob().then(console.log);

[gildas-lormeau]

I've found the bug, see cloudflare/workerd#992