bump(*): all libs

test(node): fix event driven tests

Signed-off-by: Alberto Ricart <[email protected]>

core/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-38",
+  "version": "3.0.0-40",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"

core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-38",
+  "version": "3.0.0-40",
   "files": [
     "lib/",
     "LICENSE",

core/src/version.ts

@@ -1,2 +1,2 @@
 // This file is generated - do not edit
-export const version = "3.0.0-38";
+export const version = "3.0.0-40";

jetstream/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/jetstream",
-  "version": "3.0.0-25",
+  "version": "3.0.0-27",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"
@@ -33,6 +33,6 @@
     "test": "deno test -A --parallel --reload --trace-leaks --quiet tests/ --import-map=import_map.json"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40"
   }
 }

jetstream/import_map.json

@@ -2,8 +2,8 @@
   "imports": {
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-38/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-40/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@std/io": "jsr:@std/[email protected]"
   }

jetstream/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/jetstream",
-  "version": "3.0.0-25",
+  "version": "3.0.0-27",
   "files": [
     "lib/",
     "LICENSE",
@@ -34,7 +34,7 @@
   },
   "description": "jetstream library - this library implements all the base functionality for NATS JetStream for javascript clients",
   "dependencies": {
-    "@nats-io/nats-core": "3.0.0-38"
+    "@nats-io/nats-core": "3.0.0-40"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

kv/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/kv",
-  "version": "3.0.0-19",
+  "version": "3.0.0-21",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"
@@ -33,7 +33,7 @@
     "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-27"
   }
 }

kv/import_map.json

@@ -1,9 +1,9 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-38/internal",
-    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25",
-    "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-25/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-40/internal",
+    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-27",
+    "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-27/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",

kv/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/kv",
-  "version": "3.0.0-19",
+  "version": "3.0.0-21",
   "files": [
     "lib/",
     "LICENSE",
@@ -34,8 +34,8 @@
   },
   "description": "kv library - this library implements all the base functionality for NATS KV javascript clients",
   "dependencies": {
-    "@nats-io/jetstream": "3.0.0-25",
-    "@nats-io/nats-core": "3.0.0-38"
+    "@nats-io/jetstream": "3.0.0-27",
+    "@nats-io/nats-core": "3.0.0-40"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

obj/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/obj",
-  "version": "3.0.0-20",
+  "version": "3.0.0-22",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"
@@ -33,7 +33,7 @@
     "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-27"
   }
 }

obj/import_map.json

@@ -1,9 +1,9 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-38/internal",
-    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25",
-    "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-25/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-40/internal",
+    "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-27",
+    "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-27/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",

obj/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/obj",
-  "version": "3.0.0-20",
+  "version": "3.0.0-22",
   "files": [
     "lib/",
     "LICENSE",
@@ -34,8 +34,8 @@
   },
   "description": "obj library - this library implements all the base functionality for NATS objectstore for javascript clients",
   "dependencies": {
-    "@nats-io/jetstream": "3.0.0-25",
-    "@nats-io/nats-core": "3.0.0-38"
+    "@nats-io/jetstream": "3.0.0-27",
+    "@nats-io/nats-core": "3.0.0-40"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

services/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/services",
-  "version": "3.0.0-14",
+  "version": "3.0.0-16",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"
@@ -33,6 +33,6 @@
     "test": "deno test -A --parallel --reload --quiet tests/ --import-map=import_map.json"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40"
   }
 }

services/import_map.json

@@ -1,7 +1,7 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-38/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-40/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",

services/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/services",
-  "version": "3.0.0-14",
+  "version": "3.0.0-16",
   "files": [
     "lib/",
     "LICENSE",
@@ -34,7 +34,7 @@
   },
   "description": "services library - this library implements all the base functionality for NATS services for javascript clients",
   "dependencies": {
-    "@nats-io/nats-core": "3.0.0-38"
+    "@nats-io/nats-core": "3.0.0-40"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

transport-deno/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/transport-deno",
-  "version": "3.0.0-13",
+  "version": "3.0.0-15",
   "exports": {
     ".": "./src/mod.ts"
   },
@@ -20,7 +20,7 @@
   },
   "imports": {
     "@std/io": "jsr:@std/[email protected]",
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-40",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]"
   }

transport-deno/src/version.ts

@@ -1,2 +1,2 @@
 // This file is generated - do not edit
-export const version = "3.0.0-13";
+export const version = "3.0.0-15";

transport-node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/transport-node",
-  "version": "3.0.0-24",
+  "version": "3.0.0-26",
   "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
   "keywords": [
     "nats",
@@ -54,7 +54,7 @@
     "node": ">= 18.0.0"
   },
   "dependencies": {
-    "@nats-io/nats-core": "3.0.0-38",
+    "@nats-io/nats-core": "3.0.0-40",
     "@nats-io/nkeys": "1.2.0-7",
     "@nats-io/nuid": "2.0.1-2"
   },
@@ -64,8 +64,8 @@
     "nats-jwt": "^0.0.9",
     "shx": "^0.3.3",
     "typescript": "5.6.3",
-    "@nats-io/jetstream": "3.0.0-25",
-    "@nats-io/kv": "3.0.0-19",
-    "@nats-io/obj": "3.0.0-20"
+    "@nats-io/jetstream": "3.0.0-27",
+    "@nats-io/kv": "3.0.0-21",
+    "@nats-io/obj": "3.0.0-22"
   }
 }

transport-node/src/version.ts

@@ -1,2 +1,2 @@
 // This file is generated - do not edit
-export const version = "3.0.0-24";
+export const version = "3.0.0-26";

transport-node/tests/noiptls_test.js

@@ -15,7 +15,6 @@
 const { describe, it } = require("node:test");
 const {
   connect,
-  Events,
 } = require(
   "../index",
 );
@@ -58,7 +57,7 @@ describe("tls", { timeout: 20_000, concurrency: true, forceExit: true }, () => {
     const iter = nc.status();
     (async () => {
       for await (const e of iter) {
-        if (e.type === Events.Reconnect) {
+        if (e.type === "reconnect") {
           lock.unlock();
         }
       }

transport-node/tests/reconnect_test.js

@@ -20,9 +20,7 @@ const {
 const { NatsServer } = require("./helpers/launcher");
 const {
   createInbox,
-  Events,
   deferred,
-  DebugEvents,
 } = require("@nats-io/nats-core/internal");
 const { Lock } = require("./helpers/lock");
 
@@ -97,10 +95,10 @@ describe(
       (async () => {
         for await (const e of nc.status()) {
           switch (e.type) {
-            case Events.Disconnect:
+            case "disconnect":
               disconnects++;
               break;
-            case DebugEvents.Reconnecting:
+            case "reconnecting":
               t.fail("shouldn't have emitted reconnecting");
               break;
           }
@@ -126,7 +124,7 @@ describe(
       (async () => {
         for await (const e of nc.status()) {
           switch (e.type) {
-            case DebugEvents.Reconnecting:
+            case "reconnecting":
               dt.resolve(Date.now() - serverLastConnect);
               break;
           }
@@ -153,14 +151,14 @@ describe(
       (async () => {
         for await (const e of nc.status()) {
           switch (e.type) {
-            case Events.Disconnect:
+            case "disconnect":
               disconnects++;
               break;
-            case Events.Reconnect:
+            case "reconnect":
               reconnect = true;
               nc.close();
               break;
-            case DebugEvents.Reconnecting:
+            case "reconnecting":
               reconnects++;
               break;
           }
@@ -227,13 +225,13 @@ describe(
       (async () => {
         for await (const e of nc.status()) {
           switch (e.type) {
-            case DebugEvents.StaleConnection:
+            case "staleConnection":
               stale = true;
               break;
-            case Events.Disconnect:
+            case "disconnect":
               disconnect = true;
               break;
-            case Events.Reconnect:
+            case "reconnect":
               lock.unlock();
               break;
           }