Add support for CloudFlare workers

Author: aron

index.js

@@ -47,7 +47,9 @@ class Replicate {
    * @param {Function} [options.fetch] - Fetch function to use. Defaults to `globalThis.fetch`
    */
   constructor(options = {}) {
-    this.auth = options.auth || process.env.REPLICATE_API_TOKEN;
+    this.auth =
+      options.auth ||
+      (typeof process !== "undefined" ? process.env.REPLICATE_API_TOKEN : null);
     this.userAgent =
       options.userAgent || `replicate-javascript/${packageJSON.version}`;
     this.baseUrl = options.baseUrl || "https://api.replicate.com/v1";

lib/util.js

@@ -42,16 +42,12 @@ async function validateWebhook(requestData, secret) {
 
   if (body instanceof ReadableStream || body.readable) {
     try {
-      const chunks = [];
-      for await (const chunk of body) {
-        chunks.push(Buffer.from(chunk));
-      }
-      body = Buffer.concat(chunks).toString("utf8");
+      body = await new Response(body).text();
     } catch (err) {
       throw new Error(`Error reading body: ${err.message}`);
     }
-  } else if (body instanceof Buffer) {
-    body = body.toString("utf8");
+  } else if (isTypedArray(body)) {
+    body = await new Blob([body]).text();
   } else if (typeof body !== "string") {
     throw new Error("Invalid body type");
   }
@@ -231,9 +227,9 @@ async function transformFileInputs(inputs) {
       // a JavaScript implenentation like base64-js.
       // See: https://developer.mozilla.org/en-US/docs/Glossary/Base64
       // See: https://github.com/beatgammit/base64-js
-      buffer = Buffer.from(await value.arrayBuffer());
+      buffer = await value.arrayBuffer();
       mime = value.type;
-    } else if (Buffer.isBuffer(value)) {
+    } else if (isTypedArray(value)) {
       buffer = value;
     } else {
       return value;
@@ -246,7 +242,7 @@ async function transformFileInputs(inputs) {
       );
     }
 
-    const data = buffer.toString("base64");
+    const data = bytesToBase64(buffer);
     mime = mime ?? "application/octet-stream";
 
     return `data:${mime};base64,${data}`;
@@ -276,6 +272,20 @@ async function transform(value, mapper) {
   return await mapper(value);
 }
 
+function isTypedArray(arr) {
+  return (
+    arr instanceof Int8Array ||
+    arr instanceof Int16Array ||
+    arr instanceof Int32Array ||
+    arr instanceof Uint8Array ||
+    arr instanceof Uint8ClampedArray ||
+    arr instanceof Uint16Array ||
+    arr instanceof Uint32Array ||
+    arr instanceof Float32Array ||
+    arr instanceof Float64Array
+  );
+}
+
 // Test for a plain JS object.
 // Source: lodash.isPlainObject
 function isPlainObject(value) {