fix: use duplex: half for resourceRequest with ReadableStream body input

Author: panva

src/index.ts

@@ -2877,6 +2877,8 @@ async function resourceRequest(
   headers.set('authorization', `${headers.has('dpop') ? 'DPoP' : 'Bearer'} ${accessToken}`)
 
   const response = await (options?.[customFetch] || fetch)(url.href, {
+    // @ts-ignore
+    duplex: looseInstanceOf(body, ReadableStream) ? 'half' : undefined,
     // @ts-ignore
     body,
     headers: Object.fromEntries(headers.entries()),

test/protected_resource.test.ts

@@ -22,3 +22,26 @@ test('protectedResource()', async (t) => {
   const response = await lib.protectedResourceRequest('token', 'GET', url)
   t.true(response instanceof Response)
 })
+
+test('protectedResource() w/ POST and ReadableStream body', async (t) => {
+  const payload = 'stream body content'
+  t.context.mock
+    .get('https://rs.example.com')
+    .intercept({
+      path: '/resource',
+      method: 'POST',
+      headers: {
+        authorization: 'Bearer token',
+      },
+    })
+    .reply(200, '')
+  const url = new URL('https://rs.example.com/resource')
+  const body = new ReadableStream({
+    start(controller) {
+      controller.enqueue(new TextEncoder().encode(payload))
+      controller.close()
+    },
+  })
+  const response = await lib.protectedResourceRequest('token', 'POST', url, undefined, body)
+  t.true(response instanceof Response)
+})