Merge pull request #19 from tungv/release/v0.3.1

chore: add logging for CLI
tungv · Jul 13, 2024 · 862c3c1 · 862c3c1
2 parents 05ba90a + d5d689a
commit 862c3c1
Show file tree

Hide file tree

Showing 5 changed files with 16 additions and 7 deletions.
diff --git a/packages/jerni/jsr.json b/packages/jerni/jsr.json
@@ -1,6 +1,6 @@
 {
   "name": "@jerni/jerni-3",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "exports": {
     ".": "./src/createJourney.ts",
     "./types": "./src/lib/exported_types.ts",

diff --git a/packages/jerni/package.json b/packages/jerni/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@jerni/jerni-3",
-  "version": "v0.3.0",
+  "version": "v0.3.1",
   "type": "module",
   "main": "src/index.ts",
   "bin": {

diff --git a/packages/jerni/scripts/download-binary.js b/packages/jerni/scripts/download-binary.js
@@ -31,13 +31,17 @@ const download = (dest) =>
   new Promise((resolve, reject) => {
     // check if the file exists
     if (fs.existsSync(dest)) {
+      console.log("Binary already exists");
+
       return resolve();
     }
 
     // read the version from jsr.json relative to this script using `fs`
     const JsrJson = fs.readFileSync(_resolve(__dirname, "../jsr.json"), "utf-8");
     const { version } = JSON.parse(JsrJson);
 
+    console.log(`Downloading Binary v${version} for ${os} ${currentArch}`);
+
     const url = `https://github.com/tungv/jerni-3/releases/download/v${version}/mycli-${suffix}`;
 
     const file = fs.createWriteStream(dest);
@@ -54,6 +58,8 @@ const download = (dest) =>
         if (response.statusCode === 200) {
           response.pipe(file);
           file.on("finish", () => {
+            console.log("Download completed");
+
             file.close(resolve);
           });
 

diff --git a/packages/jerni/src/events-storage/injectDatabase.ts b/packages/jerni/src/events-storage/injectDatabase.ts
@@ -16,12 +16,15 @@ export interface EventDatabase {
 
 async function getDB() {
   if (process.env.EVENTS_DB_MONGODB_URL && process.env.EVENTS_DB_MONGODB_NAME) {
+    console.log("Using MongoDB as event storage");
+
     return getMongodbDatabase({
       url: process.env.EVENTS_DB_MONGODB_URL,
       dbName: process.env.EVENTS_DB_MONGODB_NAME,
     });
   }
 
+  console.log("Using SQLite as event storage");
   return getSqliteDb();
 }
 

diff --git a/packages/jerni/src/worker.ts b/packages/jerni/src/worker.ts
@@ -36,6 +36,11 @@ export default async function initWorker(filePath: string | undefined, port: num
 
     const ctrl = new AbortController();
 
+    // call server.stop when process is killed
+    process.on("SIGINT", () => {
+      ctrl.abort();
+    });
+
     const job: Job = {
       async start() {
         startHealthCheckServer(port, ctrl.signal);
@@ -89,9 +94,4 @@ async function startHealthCheckServer(port: number, signal: AbortSignal) {
       once: true,
     },
   );
-
-  // call server.stop when process is killed
-  process.on("SIGINT", () => {
-    server.stop(closeAllActiveConnections);
-  });
 }