diff --git a/core/deno.json b/core/deno.json index ef43265d..928199e3 100644 --- a/core/deno.json +++ b/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" diff --git a/core/package.json b/core/package.json index ffb26b6c..4603584d 100644 --- a/core/package.json +++ b/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", diff --git a/core/src/version.ts b/core/src/version.ts index 0b969a5b..e4c5506f 100644 --- a/core/src/version.ts +++ b/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"; diff --git a/jetstream/deno.json b/jetstream/deno.json index b181435d..9fba6ed2 100644 --- a/jetstream/deno.json +++ b/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" } } diff --git a/jetstream/import_map.json b/jetstream/import_map.json index f37339eb..21ecb6aa 100644 --- a/jetstream/import_map.json +++ b/jetstream/import_map.json @@ -2,8 +2,8 @@ "imports": { "@nats-io/nkeys": "jsr:@nats-io/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", - "@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/io@0.224.0" } diff --git a/jetstream/package.json b/jetstream/package.json index b8deec13..0904c61b 100644 --- a/jetstream/package.json +++ b/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", diff --git a/kv/deno.json b/kv/deno.json index 5eecc8f1..920f0fc1 100644 --- a/kv/deno.json +++ b/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" } } diff --git a/kv/import_map.json b/kv/import_map.json index 51166175..651e0564 100644 --- a/kv/import_map.json +++ b/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/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/kv/package.json b/kv/package.json index 98f73156..1e0fa052 100644 --- a/kv/package.json +++ b/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", diff --git a/obj/deno.json b/obj/deno.json index 4d8066fb..d8265c1f 100644 --- a/obj/deno.json +++ b/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" } } diff --git a/obj/import_map.json b/obj/import_map.json index 51166175..651e0564 100644 --- a/obj/import_map.json +++ b/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/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/obj/package.json b/obj/package.json index 64ff20b4..329c0f5e 100644 --- a/obj/package.json +++ b/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", diff --git a/services/deno.json b/services/deno.json index d8fc6de9..c24cc904 100644 --- a/services/deno.json +++ b/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" } } diff --git a/services/import_map.json b/services/import_map.json index f9ef962f..55321f01 100644 --- a/services/import_map.json +++ b/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/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2", diff --git a/services/package.json b/services/package.json index 6e222a05..0becf5d2 100644 --- a/services/package.json +++ b/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", diff --git a/transport-deno/deno.json b/transport-deno/deno.json index cb3f817f..f81f79ee 100644 --- a/transport-deno/deno.json +++ b/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/io@0.225.0", - "@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/nkeys@1.2.0-4", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2" } diff --git a/transport-deno/src/version.ts b/transport-deno/src/version.ts index d952964f..7e38d46f 100644 --- a/transport-deno/src/version.ts +++ b/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"; diff --git a/transport-node/package.json b/transport-node/package.json index f8d1ae16..00044dfa 100644 --- a/transport-node/package.json +++ b/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" } } diff --git a/transport-node/src/version.ts b/transport-node/src/version.ts index d6ef21e9..14b3fbc8 100644 --- a/transport-node/src/version.ts +++ b/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"; diff --git a/transport-node/tests/noiptls_test.js b/transport-node/tests/noiptls_test.js index db446aa0..bb56153a 100644 --- a/transport-node/tests/noiptls_test.js +++ b/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(); } } diff --git a/transport-node/tests/reconnect_test.js b/transport-node/tests/reconnect_test.js index d4ecce4e..5160a2f6 100644 --- a/transport-node/tests/reconnect_test.js +++ b/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; }