feat: support application/octet-stream req/res bodies

e2e/openapi.yaml

@@ -323,6 +323,24 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/ProductOrder'
+  /media-types/octet-stream:
+    post:
+      tags:
+        - media types
+      requestBody:
+        content:
+          application/octet-stream:
+            schema:
+              type: string
+              format: binary
+      responses:
+        200:
+          description: ok
+          content:
+            application/octet-stream:
+              schema:
+                type: string
+                format: binary
 
   /escape-hatches/plain-text:
     get:

e2e/src/index.axios.spec.ts

@@ -430,6 +430,20 @@ describe.each(
     })
   })
 
+  describe("POST /media-types/octet-stream", () => {
+    it("can send and parse application/octet-stream request bodies", async () => {
+      const blob = new Blob([new Uint8Array([0xde, 0xad, 0xbe, 0xef])], {
+        type: "application/octet-stream",
+      })
+      const res = await client.postMediaTypesOctetStream({
+        requestBody: blob,
+      })
+      expect(res.status).toBe(200)
+
+      await expect(res.data).toEqualBlob(blob)
+    })
+  })
+
   describe("query parameters", () => {
     it("GET /params/simple-query", async () => {
       const {status, data} = await client.getParamsSimpleQuery({

e2e/src/index.fetch.spec.ts

@@ -431,6 +431,20 @@ describe.each(
     })
   })
 
+  describe("POST /media-types/octet-stream", () => {
+    it("can send and parse application/octet-stream request bodies", async () => {
+      const blob = new Blob([new Uint8Array([0xde, 0xad, 0xbe, 0xef])], {
+        type: "application/octet-stream",
+      })
+      const res = await client.postMediaTypesOctetStream({
+        requestBody: blob,
+      })
+      expect(res.status).toBe(200)
+
+      await expect(await res.blob()).toEqualBlob(blob)
+    })
+  })
+
   describe("query parameters", () => {
     it("GET /params/simple-query", async () => {
       const res = await client.getParamsSimpleQuery({

e2e/src/jest.d.ts

@@ -0,0 +1,10 @@
+import type {CustomMatcherResult} from "expect"
+
+declare module "expect" {
+  interface AsymmetricMatchers {
+    toEqualBlob(this: R, expected: Blob): Promise<CustomMatcherResult>
+  }
+  interface Matchers<R> {
+    toEqualBlob(this: R, expected: Blob): Promise<CustomMatcherResult>
+  }
+}

e2e/src/routes/express/media-types.ts

@@ -1,6 +1,7 @@
 import {SkipResponse} from "@nahkies/typescript-express-runtime/server"
 import {
   createRouter,
+  type PostMediaTypesOctetStream,
   type PostMediaTypesText,
   type PostMediaTypesXWwwFormUrlencoded,
 } from "../../generated/server/express/routes/media-types.ts"
@@ -23,9 +24,20 @@ const postMediaTypesXWwwFormUrlencoded: PostMediaTypesXWwwFormUrlencoded =
     return respond.with200().body(body)
   }
 
+const postMediaTypesOctetStream: PostMediaTypesOctetStream = async (
+  {body},
+  respond,
+) => {
+  const arrayBuffer = await body.arrayBuffer()
+  const hex = Buffer.from(arrayBuffer).toString("hex")
+  console.log(hex)
+  return respond.with200().body(body)
+}
+
 export function createMediaTypesRouter() {
   return createRouter({
     postMediaTypesText,
     postMediaTypesXWwwFormUrlencoded,
+    postMediaTypesOctetStream,
   })
 }

e2e/src/routes/koa/media-types.ts

@@ -1,6 +1,7 @@
 import {SkipResponse} from "@nahkies/typescript-koa-runtime/server"
 import {
   createRouter,
+  type PostMediaTypesOctetStream,
   type PostMediaTypesText,
   type PostMediaTypesXWwwFormUrlencoded,
 } from "../../generated/server/koa/routes/media-types.ts"
@@ -24,9 +25,17 @@ const postMediaTypesXWwwFormUrlencoded: PostMediaTypesXWwwFormUrlencoded =
     return respond.with200().body(body)
   }
 
+const postMediaTypesOctetStream: PostMediaTypesOctetStream = async (
+  {body},
+  respond,
+) => {
+  return respond.with200().body(body)
+}
+
 export function createMediaTypesRouter() {
   return createRouter({
     postMediaTypesText,
     postMediaTypesXWwwFormUrlencoded,
+    postMediaTypesOctetStream,
   })
 }

e2e/src/test-utils.ts

@@ -1,3 +1,5 @@
+import {Blob} from "node:buffer"
+import {expect} from "@jest/globals"
 import {AsymmetricMatcher} from "expect"
 
 class NumberInRange extends AsymmetricMatcher<number> {
@@ -23,3 +25,42 @@ class NumberInRange extends AsymmetricMatcher<number> {
 
 export const numberBetween = (min: number, max: number) =>
   new NumberInRange(min, max)
+
+expect.extend({
+  async toEqualBlob(received: Blob, expected: Blob) {
+    if (!(received instanceof Blob)) {
+      return {
+        pass: false,
+        message: () =>
+          "received is not a blob:\n" +
+          `received: '${this.utils.printReceived(received)}'` +
+          `expected: '${this.utils.printExpected(expected)}'`,
+      }
+    }
+
+    const [bufA, bufB] = await Promise.all([
+      received.arrayBuffer(),
+      expected.arrayBuffer(),
+    ])
+
+    const a = new Uint8Array(bufA)
+    const b = new Uint8Array(bufB)
+
+    const pass = a.length === b.length && a.every((v, i) => v === b[i])
+
+    if (pass) {
+      return {
+        pass: true,
+        message: () => "expected blobs not to be equal",
+      }
+    } else {
+      return {
+        pass: false,
+        message: () =>
+          `expected blobs to be equal, but got:\n` +
+          `received: ${[...a].map((x) => x.toString(16).padStart(2, "0")).join(" ")}\n` +
+          `expected: ${[...b].map((x) => x.toString(16).padStart(2, "0")).join(" ")}`,
+      }
+    }
+  },
+})