node:zlib: move deflate and gzip into native code (#11770)

Co-authored-by: Jarred Sumner <[email protected]>

packages/bun-types/globals.d.ts

@@ -1918,6 +1918,9 @@ declare global {
      * closely to the `BodyMixin` API.
      */
     formData(): Promise<FormData>;
+
+    arrayBuffer(): Promise<ArrayBuffer>;
+
     /**
      * Returns a promise that resolves to the contents of the blob as a Uint8Array (array of bytes) its the same as `new Uint8Array(await blob.arrayBuffer())`
      */

scripts/runner.node.mjs

@@ -233,6 +233,8 @@ async function runTests() {
     reportOutputToGitHubAction("failing_tests", markdown);
   }
 
+  if (!isCI) console.log("-------");
+  if (!isCI) console.log("passing", results.length - failedTests.length, "/", results.length);
   return results;
 }
 

src/brotli.zig

@@ -181,17 +181,28 @@ pub const BrotliCompressionStream = struct {
     state: State = State.Inflating,
     total_out: usize = 0,
     total_in: usize = 0,
-
-    pub fn init() !BrotliCompressionStream {
+    flushOp: BrotliEncoder.Operation,
+    finishFlushOp: BrotliEncoder.Operation,
+    fullFlushOp: BrotliEncoder.Operation,
+
+    pub fn init(
+        flushOp: BrotliEncoder.Operation,
+        finishFlushOp: BrotliEncoder.Operation,
+        fullFlushOp: BrotliEncoder.Operation,
+    ) !BrotliCompressionStream {
         const instance = BrotliEncoder.createInstance(&BrotliAllocator.alloc, &BrotliAllocator.free, null) orelse return error.BrotliFailedToCreateInstance;
 
         return BrotliCompressionStream{
             .brotli = instance,
+            .flushOp = flushOp,
+            .finishFlushOp = finishFlushOp,
+            .fullFlushOp = fullFlushOp,
         };
     }
 
     pub fn writeChunk(this: *BrotliCompressionStream, input: []const u8, last: bool) ![]const u8 {
-        const result = this.brotli.compressStream(if (last) BrotliEncoder.Operation.finish else .process, input);
+        this.total_in += input.len;
+        const result = this.brotli.compressStream(if (last) this.finishFlushOp else this.flushOp, input);
 
         if (!result.success) {
             this.state = .Error;