Refactor Stream to use eventstream-parser library (#214)

* Use the fetch() function provided in the Stream implementation

* Allow js files to be imported into tests

* Fix types for validateWebhook

* Handle processing chunked event streams

* Await validateWebhook in tests

Author: aron

README.md

@@ -811,3 +811,11 @@ You can call this method directly to make other requests to the API.
 ## TypeScript
 
 The `Replicate` constructor and all `replicate.*` methods are fully typed.
+
+## Vendored Dependencies
+
+We have a few dependencies that have been bundled into the vendor directory rather than adding external npm dependencies.
+
+These have been generated using bundlejs.com and copied into the appropriate directory along with the license and repository information. 
+
+* [eventsource-parser/stream](https://bundlejs.com/?bundle&q=eventsource-parser%40latest%2Fstream&config=%7B%22esbuild%22%3A%7B%22format%22%3A%22cjs%22%2C%22minify%22%3Afalse%2C%22platform%22%3A%22neutral%22%7D%7D)

biome.json

@@ -1,5 +1,8 @@
 {
   "$schema": "https://biomejs.dev/schemas/1.0.0/schema.json",
+  "files": {
+    "ignore": [".wrangler", "vendor/*"]
+  },
   "formatter": {
     "indentStyle": "space",
     "indentWidth": 2

index.d.ts

@@ -279,7 +279,7 @@ declare module "replicate" {
           signature?: string;
         },
     secret: string
-  ): boolean;
+  ): Promise<boolean>;
 
   export function parseProgressFromLogs(logs: Prediction | string): {
     percentage: number;

index.js

@@ -1,6 +1,6 @@
 const ApiError = require("./lib/error");
 const ModelVersionIdentifier = require("./lib/identifier");
-const { Stream } = require("./lib/stream");
+const { createReadableStream } = require("./lib/stream");
 const {
   withAutomaticRetries,
   validateWebhook,
@@ -291,7 +291,11 @@ class Replicate {
 
     if (prediction.urls && prediction.urls.stream) {
       const { signal } = options;
-      const stream = new Stream(prediction.urls.stream, { signal });
+      const stream = createReadableStream({
+        url: prediction.urls.stream,
+        fetch: this.fetch,
+        options: { signal },
+      });
       yield* stream;
     } else {
       throw new Error("Prediction does not support streaming");