Merge pull request #79 from tungv/release/v0.10.2

Release/v0.10.2

Author: votrungquan1999

packages/jerni/jsr.json

@@ -1,6 +1,6 @@
 {
   "name": "@jerni/jerni-3",
-  "version": "0.10.1",
+  "version": "0.10.2",
   "exports": {
     ".": "./src/createJourney.ts",
     "./types": "./src/lib/exported_types.ts",
@@ -14,5 +14,10 @@
     "./dev-cli/rewriteChecksum": "./src/dev-cli/rewriteChecksum.ts",
     "./dev-cli/ensureMarkdownFileExists": "./src/dev-cli/ensureMarkDownFileExists.ts"
   },
-  "exclude": ["src/tests", "src/worker.ts", "src/cli.ts", "src/begin.ts"]
-}
+  "exclude": [
+    "src/tests",
+    "src/worker.ts",
+    "src/cli.ts",
+    "src/begin.ts"
+  ]
+}

packages/jerni/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@jerni/jerni-3",
-  "version": "0.10.1",
+  "version": "v0.10.2",
   "type": "module",
   "main": "src/index.ts",
   "bin": {
@@ -52,4 +52,4 @@
     "@types/ms": "^0.7.34",
     "@types/pretty-ms": "^5.0.1"
   }
-}
+}

packages/jerni/src/getEventStream.ts

@@ -157,6 +157,10 @@ async function* retrieveJourneyCommittedEvents(
   signal: AbortSignal,
 ): AsyncGenerator<EventStreamReturnType, void, unknown> {
   signal.throwIfAborted();
+
+  const innerController = new AbortController();
+  signal.addEventListener("abort", () => innerController.abort());
+
   try {
     // passing signal to fetch will throw uncatchable error, instead, add the signal to body.pipeThrough
     const resp = await fetch(url.toString(), {
@@ -165,6 +169,7 @@ async function* retrieveJourneyCommittedEvents(
         "burst-count": String(batchSize),
         "last-event-id": String(lastSeenId),
       },
+      signal: innerController.signal,
     });
 
     if (!resp.ok) {
@@ -180,7 +185,7 @@ async function* retrieveJourneyCommittedEvents(
       connected_at: Date.now(),
     };
 
-    const stream = resp.body.pipeThrough(new TextDecoderStream(), { signal });
+    const stream = resp.body.pipeThrough(new TextDecoderStream(), { signal: innerController.signal });
 
     const pending = [] as string[];
 
@@ -259,6 +264,7 @@ async function* retrieveJourneyCommittedEvents(
       }
     }
   } finally {
+    innerController.abort();
     Bun.gc(true);
   }
 }