fix: Fix fetch method for multipart request (box/box-codegen#545) (#303)

Co-authored-by: box-sdk-build <[email protected]>

Author: box-sdk-build

.codegen.json

@@ -1 +1 @@
-{ "engineHash": "d1cb68d", "specHash": "9919482", "version": "1.3.0" }
+{ "engineHash": "ab2fc63", "specHash": "9919482", "version": "1.3.0" }

src/internal/utils.ts

@@ -186,7 +186,7 @@ export function decodeBase64ByteStream(data: string): Readable {
     : eval('require')('stream').Readable.from(Buffer.from(data, 'base64'));
 }
 
-export async function readByteStream(byteStream: Readable) {
+export async function readByteStream(byteStream: Readable): Promise<Buffer> {
   const buffers: Buffer[] = [];
   for await (const data of byteStream) {
     buffers.push(data);

src/networking/fetch.ts

@@ -226,8 +226,15 @@ export async function fetch(
         options
       )
     : options;
-
-  const requestInit = await createRequestInit(fetchOptions);
+  const fileStreamBuffer = fetchOptions.fileStream
+    ? await readByteStream(fetchOptions.fileStream)
+    : void 0;
+  const requestInit = await createRequestInit({
+    ...fetchOptions,
+    fileStream: fileStreamBuffer
+      ? generateByteStreamFromBuffer(fileStreamBuffer)
+      : void 0,
+  });
 
   const { params = {} } = fetchOptions;
   const response = await nodeFetch(
@@ -287,7 +294,13 @@ export async function fetch(
       await fetchOptions.auth.refreshToken(fetchOptions.networkSession);
 
       // retry the request right away
-      return fetch(resource, { ...fetchOptions, numRetries: numRetries + 1 });
+      return fetch(resource, {
+        ...fetchOptions,
+        numRetries: numRetries + 1,
+        fileStream: fileStreamBuffer
+          ? generateByteStreamFromBuffer(fileStreamBuffer)
+          : void 0,
+      });
     }
 
     const isRetryable =