From 111a695dfd55f5f07931a2777941f94c2e2c06f0 Mon Sep 17 00:00:00 2001 From: Alberto Ricart Date: Wed, 20 Nov 2024 17:25:42 -0600 Subject: [PATCH 1/3] change(core): requestMany() JitterTimer and its associated `jitter` property is now called "stall" change(core): requestMany() `RequestStrategy` is now a simple string "timer" | "count" | "stall" | "sentinel" Signed-off-by: Alberto Ricart --- core/deno.json | 2 +- core/package.json | 2 +- core/src/core.ts | 9 ++------- core/src/internal_mod.ts | 3 ++- core/src/mod.ts | 2 +- core/src/nats.ts | 10 ++++----- core/src/request.ts | 9 ++++----- core/src/version.ts | 2 +- core/tests/basics_test.ts | 13 ++++++------ core/tests/mrequest_test.ts | 28 ++++++++++---------------- jetstream/deno.json | 2 +- jetstream/import_map.json | 4 ++-- jetstream/package.json | 2 +- kv/deno.json | 2 +- kv/import_map.json | 4 ++-- kv/package.json | 2 +- obj/deno.json | 2 +- obj/import_map.json | 4 ++-- obj/package.json | 2 +- services/deno.json | 4 ++-- services/examples/03_bigdata-client.ts | 8 ++------ services/import_map.json | 4 ++-- services/package.json | 4 ++-- services/src/serviceclient.ts | 8 ++------ transport-deno/deno.json | 2 +- transport-node/package.json | 2 +- 26 files changed, 58 insertions(+), 78 deletions(-) diff --git a/core/deno.json b/core/deno.json index 06596aa7..cad1b722 100644 --- a/core/deno.json +++ b/core/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-42", + "version": "3.0.0-43", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" diff --git a/core/package.json b/core/package.json index ca2f7adb..dc21970a 100644 --- a/core/package.json +++ b/core/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-42", + "version": "3.0.0-43", "files": [ "lib/", "LICENSE", diff --git a/core/src/core.ts b/core/src/core.ts index f2903ae2..28af9b46 100644 --- a/core/src/core.ts +++ b/core/src/core.ts @@ -299,12 +299,7 @@ export interface RequestOptions { reply?: string; } -export enum RequestStrategy { - Timer = "timer", - Count = "count", - JitterTimer = "jitterTimer", - SentinelMsg = "sentinelMsg", -} +export type RequestStrategy = "timer" | "count" | "stall" | "sentinel"; export interface RequestManyOptions { strategy: RequestStrategy; @@ -312,7 +307,7 @@ export interface RequestManyOptions { headers?: MsgHdrs; maxMessages?: number; noMux?: boolean; - jitter?: number; + stall?: number; } export interface Stats { diff --git a/core/src/internal_mod.ts b/core/src/internal_mod.ts index 252b6a8c..9e30c852 100644 --- a/core/src/internal_mod.ts +++ b/core/src/internal_mod.ts @@ -109,6 +109,7 @@ export type { Request, RequestManyOptions, RequestOptions, + RequestStrategy, ReviverFn, Server, ServerErrorStatus, @@ -126,7 +127,7 @@ export type { TokenAuth, UserPass, } from "./core.ts"; -export { createInbox, Match, RequestStrategy, syncIterator } from "./core.ts"; +export { createInbox, Match, syncIterator } from "./core.ts"; export { SubscriptionImpl, Subscriptions } from "./protocol.ts"; export type { diff --git a/core/src/mod.ts b/core/src/mod.ts index 08a0310b..88bb0168 100644 --- a/core/src/mod.ts +++ b/core/src/mod.ts @@ -48,7 +48,6 @@ export { PermissionViolationError, ProtocolError, RequestError, - RequestStrategy, syncIterator, TimeoutError, tokenAuthenticator, @@ -88,6 +87,7 @@ export type { ReconnectStatus, RequestManyOptions, RequestOptions, + RequestStrategy, ReviverFn, ServerErrorStatus, ServerInfo, diff --git a/core/src/nats.ts b/core/src/nats.ts index 2e54f291..30ab96f2 100644 --- a/core/src/nats.ts +++ b/core/src/nats.ts @@ -41,7 +41,7 @@ import type { Subscription, SubscriptionOptions, } from "./core.ts"; -import { createInbox, RequestStrategy } from "./core.ts"; +import { createInbox } from "./core.ts"; import { errors, InvalidArgumentError, TimeoutError } from "./errors.ts"; export class NatsConnectionImpl implements NatsConnection { @@ -182,7 +182,7 @@ export class NatsConnectionImpl implements NatsConnection { return Promise.reject(err); } - opts.strategy = opts.strategy || RequestStrategy.Timer; + opts.strategy = opts.strategy || "timer"; opts.maxWait = opts.maxWait || 1000; if (opts.maxWait < 1) { return Promise.reject( @@ -236,19 +236,19 @@ export class NatsConnectionImpl implements NatsConnection { // push the message callback(null, msg); // see if the m request is completed - if (opts.strategy === RequestStrategy.Count) { + if (opts.strategy === "count") { max--; if (max === 0) { cancel(); } } - if (opts.strategy === RequestStrategy.JitterTimer) { + if (opts.strategy === "stall") { clearTimers(); timer = setTimeout(() => { cancel(); }, 300); } - if (opts.strategy === RequestStrategy.SentinelMsg) { + if (opts.strategy === "sentinel") { if (msg && msg.data.length === 0) { cancel(); } diff --git a/core/src/request.ts b/core/src/request.ts index 2b1c4e24..65587f31 100644 --- a/core/src/request.ts +++ b/core/src/request.ts @@ -22,7 +22,6 @@ import type { RequestManyOptions, RequestOptions, } from "./core.ts"; -import { RequestStrategy } from "./core.ts"; import { errors, RequestError, TimeoutError } from "./errors.ts"; export class BaseRequest { @@ -105,22 +104,22 @@ export class RequestMany extends BaseRequest implements Request { this.cancel(err as Error); } else { this.callback(null, msg); - if (this.opts.strategy === RequestStrategy.Count) { + if (this.opts.strategy === "count") { this.max--; if (this.max === 0) { this.cancel(); } } - if (this.opts.strategy === RequestStrategy.JitterTimer) { + if (this.opts.strategy === "stall") { clearTimeout(this.timer); // @ts-ignore: node is not a number this.timer = setTimeout(() => { this.cancel(); - }, this.opts.jitter || 300); + }, this.opts.stall || 300); } - if (this.opts.strategy === RequestStrategy.SentinelMsg) { + if (this.opts.strategy === "sentinel") { if (msg && msg.data.length === 0) { this.cancel(); } diff --git a/core/src/version.ts b/core/src/version.ts index ad89dca5..37bf0b16 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-42"; +export const version = "3.0.0-43"; diff --git a/core/tests/basics_test.ts b/core/tests/basics_test.ts index dbbc86d7..e5a9c746 100644 --- a/core/tests/basics_test.ts +++ b/core/tests/basics_test.ts @@ -32,7 +32,6 @@ import { headers, isIP, nuid, - RequestStrategy, syncIterator, } from "../src/internal_mod.ts"; import type { @@ -1036,7 +1035,7 @@ Deno.test("basics - request many count", async () => { const lock = Lock(5, 2000); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Count, + strategy: "count", maxWait: 2000, maxMessages: 5, }); @@ -1067,7 +1066,7 @@ Deno.test("basics - request many jitter", async () => { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.JitterTimer, + strategy: "stall", maxWait: 5000, }); for await (const mer of iter) { @@ -1099,7 +1098,7 @@ Deno.test("basics - request many sentinel", async () => { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.SentinelMsg, + strategy: "sentinel", maxWait: 2000, }); for await (const mer of iter) { @@ -1130,7 +1129,7 @@ Deno.test("basics - request many sentinel - partial response", async () => { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.SentinelMsg, + strategy: "sentinel", maxWait: 2000, }); for await (const mer of iter) { @@ -1159,7 +1158,7 @@ Deno.test("basics - request many wait for timer - no respone", async () => { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Timer, + strategy: "timer", maxWait: 2000, }); for await (const mer of iter) { @@ -1189,7 +1188,7 @@ Deno.test("basics - request many waits for timer late response", async () => { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Timer, + strategy: "timer", maxWait: 2000, }); for await (const mer of iter) { diff --git a/core/tests/mrequest_test.ts b/core/tests/mrequest_test.ts index d5ce6e8a..a6923986 100644 --- a/core/tests/mrequest_test.ts +++ b/core/tests/mrequest_test.ts @@ -18,13 +18,7 @@ import type { NatsConnectionImpl, QueuedIteratorImpl, } from "../src/internal_mod.ts"; -import { - createInbox, - deferred, - delay, - Empty, - RequestStrategy, -} from "../src/internal_mod.ts"; +import { createInbox, deferred, delay, Empty } from "../src/internal_mod.ts"; import { assert, assertEquals, assertRejects, fail } from "jsr:@std/assert"; import { errors } from "../src/errors.ts"; @@ -47,7 +41,7 @@ async function requestManyCount(noMux = false): Promise { }); const iter = await nci.requestMany(subj, "hello", { - strategy: RequestStrategy.Count, + strategy: "count", maxWait: 2000, maxMessages: 5, noMux, @@ -89,7 +83,7 @@ async function requestManyJitter(noMux = false): Promise { const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.JitterTimer, + strategy: "stall", maxWait: 5000, noMux, }); @@ -133,7 +127,7 @@ async function requestManySentinel( const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.SentinelMsg, + strategy: "sentinel", maxWait: 2000, noMux, }); @@ -180,7 +174,7 @@ async function requestManyTimerNoResponse(noMux = false): Promise { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Timer, + strategy: "timer", maxWait: 2000, noMux, }); @@ -219,7 +213,7 @@ async function requestTimerLateResponse(noMux = false): Promise { let count = 0; const start = Date.now(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Timer, + strategy: "timer", maxWait: 2000, noMux, }); @@ -250,7 +244,7 @@ async function requestManyStopsOnError(noMux = false): Promise { const subj = createInbox(); const iter = await nci.requestMany(subj, Empty, { - strategy: RequestStrategy.Timer, + strategy: "timer", maxWait: 2000, noMux, }); @@ -299,7 +293,7 @@ Deno.test("mreq - pub permission error", async () => { })().then(); const iter = await nc.requestMany("q", Empty, { - strategy: RequestStrategy.Count, + strategy: "count", maxMessages: 3, maxWait: 2000, }); @@ -351,7 +345,7 @@ Deno.test("mreq - sub permission error", async () => { await assertRejects( async () => { const iter = await nc.requestMany("q", Empty, { - strategy: RequestStrategy.Count, + strategy: "count", maxMessages: 3, maxWait: 2000, noMux: true, @@ -412,9 +406,9 @@ Deno.test("mreq - lost sub permission", async () => { })().then(); const iter = await nc.requestMany("q", Empty, { - strategy: RequestStrategy.Count, + strategy: "count", maxMessages: 100, - jitter: 2000, + stall: 2000, maxWait: 2000, noMux: true, }) as QueuedIteratorImpl; diff --git a/jetstream/deno.json b/jetstream/deno.json index 99d26b90..71001a01 100644 --- a/jetstream/deno.json +++ b/jetstream/deno.json @@ -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-42" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43" } } diff --git a/jetstream/import_map.json b/jetstream/import_map.json index 59259918..fd3cb352 100644 --- a/jetstream/import_map.json +++ b/jetstream/import_map.json @@ -2,8 +2,8 @@ "imports": { "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/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 14802392..12c8ad1a 100644 --- a/jetstream/package.json +++ b/jetstream/package.json @@ -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-42" + "@nats-io/nats-core": "3.0.0-43" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/kv/deno.json b/kv/deno.json index bf5dc963..dd2dd6c5 100644 --- a/kv/deno.json +++ b/kv/deno.json @@ -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-42", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29" } } diff --git a/kv/import_map.json b/kv/import_map.json index aa1ab048..67c8a5bb 100644 --- a/kv/import_map.json +++ b/kv/import_map.json @@ -1,7 +1,7 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/internal", "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29", "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-29/internal", "test_helpers": "../test_helpers/mod.ts", diff --git a/kv/package.json b/kv/package.json index d34228df..b0b8d094 100644 --- a/kv/package.json +++ b/kv/package.json @@ -35,7 +35,7 @@ "description": "kv library - this library implements all the base functionality for NATS KV javascript clients", "dependencies": { "@nats-io/jetstream": "3.0.0-29", - "@nats-io/nats-core": "3.0.0-42" + "@nats-io/nats-core": "3.0.0-43" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/obj/deno.json b/obj/deno.json index 3b8f52de..5e22904d 100644 --- a/obj/deno.json +++ b/obj/deno.json @@ -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-42", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29" } } diff --git a/obj/import_map.json b/obj/import_map.json index aa1ab048..67c8a5bb 100644 --- a/obj/import_map.json +++ b/obj/import_map.json @@ -1,7 +1,7 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/internal", "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29", "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-29/internal", "test_helpers": "../test_helpers/mod.ts", diff --git a/obj/package.json b/obj/package.json index fe3a7917..92ebc84e 100644 --- a/obj/package.json +++ b/obj/package.json @@ -35,7 +35,7 @@ "description": "obj library - this library implements all the base functionality for NATS objectstore for javascript clients", "dependencies": { "@nats-io/jetstream": "3.0.0-29", - "@nats-io/nats-core": "3.0.0-42" + "@nats-io/nats-core": "3.0.0-43" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/services/deno.json b/services/deno.json index caa4442d..a41ad362 100644 --- a/services/deno.json +++ b/services/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-18", + "version": "3.0.0-19", "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-42" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43" } } diff --git a/services/examples/03_bigdata-client.ts b/services/examples/03_bigdata-client.ts index f8ad7c1e..461b90a1 100644 --- a/services/examples/03_bigdata-client.ts +++ b/services/examples/03_bigdata-client.ts @@ -13,11 +13,7 @@ * limitations under the License. */ import { parse } from "jsr:@std/flags"; -import { - connect, - RequestStrategy, -} from "jsr:@nats-io/nats-transport-deno@3.0.0-5"; -import type { ConnectionOptions } from "jsr:@nats-io/nats-transport-deno@3.0.0-5"; +import { connect, type ConnectionOptions } from "@nats-io/transport-deno"; import { humanizeBytes } from "./03_util.ts"; @@ -50,7 +46,7 @@ const iter = await nc.requestMany( "data", JSON.stringify({ max_chunk, size }), { - strategy: RequestStrategy.SentinelMsg, + strategy: "sentinel", maxWait: 10000, }, ); diff --git a/services/import_map.json b/services/import_map.json index c7300feb..6aa9b919 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-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", diff --git a/services/package.json b/services/package.json index 07d8e3f7..02641e49 100644 --- a/services/package.json +++ b/services/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-18", + "version": "3.0.0-19", "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-42" + "@nats-io/nats-core": "3.0.0-43" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/services/src/serviceclient.ts b/services/src/serviceclient.ts index 92493102..e8615904 100644 --- a/services/src/serviceclient.ts +++ b/services/src/serviceclient.ts @@ -12,11 +12,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -import { - Empty, - QueuedIteratorImpl, - RequestStrategy, -} from "@nats-io/nats-core/internal"; +import { Empty, QueuedIteratorImpl } from "@nats-io/nats-core/internal"; import type { NatsConnection, @@ -41,7 +37,7 @@ export class ServiceClientImpl implements ServiceClient { constructor( nc: NatsConnection, opts: RequestManyOptions = { - strategy: RequestStrategy.JitterTimer, + strategy: "stall", maxWait: 2000, }, prefix?: string, diff --git a/transport-deno/deno.json b/transport-deno/deno.json index e34c7022..9dad2458 100644 --- a/transport-deno/deno.json +++ b/transport-deno/deno.json @@ -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-42", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2" } diff --git a/transport-node/package.json b/transport-node/package.json index f6705b9f..8d33131f 100644 --- a/transport-node/package.json +++ b/transport-node/package.json @@ -54,7 +54,7 @@ "node": ">= 18.0.0" }, "dependencies": { - "@nats-io/nats-core": "3.0.0-42", + "@nats-io/nats-core": "3.0.0-43", "@nats-io/nkeys": "2.0.0-2", "@nats-io/nuid": "2.0.1-2" }, From f8f29e20a929cb60acfe1d8727d864a9d0ebe5bf Mon Sep 17 00:00:00 2001 From: Alberto Ricart Date: Wed, 20 Nov 2024 17:40:26 -0600 Subject: [PATCH 2/3] change(core): requestMany() JitterTimer and its associated `jitter` property is now called "stall" change(core): requestMany() `RequestStrategy` is now a simple string "timer" | "count" | "stall" | "sentinel" Signed-off-by: Alberto Ricart --- core/deno.json | 2 +- core/package.json | 2 +- core/src/version.ts | 2 +- jetstream/deno.json | 2 +- jetstream/import_map.json | 4 ++-- jetstream/package.json | 2 +- kv/deno.json | 2 +- kv/import_map.json | 8 ++++---- kv/package.json | 4 ++-- migration.md | 3 +++ obj/deno.json | 4 ++-- obj/import_map.json | 8 ++++---- obj/package.json | 4 ++-- services/deno.json | 2 +- services/import_map.json | 4 ++-- services/package.json | 2 +- transport-deno/deno.json | 4 ++-- transport-deno/src/version.ts | 2 +- transport-node/package.json | 4 ++-- transport-node/src/version.ts | 2 +- 20 files changed, 35 insertions(+), 32 deletions(-) diff --git a/core/deno.json b/core/deno.json index cad1b722..35c6b281 100644 --- a/core/deno.json +++ b/core/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-43", + "version": "3.0.0-44", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" diff --git a/core/package.json b/core/package.json index dc21970a..3d2589aa 100644 --- a/core/package.json +++ b/core/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-43", + "version": "3.0.0-44", "files": [ "lib/", "LICENSE", diff --git a/core/src/version.ts b/core/src/version.ts index 37bf0b16..7b33c71c 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-43"; +export const version = "3.0.0-44"; diff --git a/jetstream/deno.json b/jetstream/deno.json index fa1d5540..71b72d84 100644 --- a/jetstream/deno.json +++ b/jetstream/deno.json @@ -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-43" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44" } } diff --git a/jetstream/import_map.json b/jetstream/import_map.json index fd3cb352..5dbc1df1 100644 --- a/jetstream/import_map.json +++ b/jetstream/import_map.json @@ -2,8 +2,8 @@ "imports": { "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-43", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/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 71d375a3..b9c468de 100644 --- a/jetstream/package.json +++ b/jetstream/package.json @@ -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-43" + "@nats-io/nats-core": "3.0.0-44" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/kv/deno.json b/kv/deno.json index 291959d8..0c1398c7 100644 --- a/kv/deno.json +++ b/kv/deno.json @@ -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-42", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31" } } diff --git a/kv/import_map.json b/kv/import_map.json index aa1ab048..7278ee24 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-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-29/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", diff --git a/kv/package.json b/kv/package.json index c7e23b2e..5d3c3161 100644 --- a/kv/package.json +++ b/kv/package.json @@ -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-29", - "@nats-io/nats-core": "3.0.0-42" + "@nats-io/jetstream": "3.0.0-31", + "@nats-io/nats-core": "3.0.0-44" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/migration.md b/migration.md index d498f293..3eec70f4 100644 --- a/migration.md +++ b/migration.md @@ -99,6 +99,9 @@ these modules for cross-runtime consumption. [Lifecycle and Informational and Events](core/README.md#lifecycle-and-informational-events) - Subscription#closed now resolves to void or an Error (it doesn't throw). The error is the reason why the subscription closed. +- RequestStrategy "Jitter" is now called "stall" to adopt the term used by new + implementations in other clients and the RequestStrategy enum is now a type + alias to simple strings "timer", "count", "stall", "sentinel". ## Changes in JetStream diff --git a/obj/deno.json b/obj/deno.json index c9c6bea2..deadc25e 100644 --- a/obj/deno.json +++ b/obj/deno.json @@ -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-42", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31" } } diff --git a/obj/import_map.json b/obj/import_map.json index aa1ab048..7278ee24 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-42", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-42/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-29", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-29/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", diff --git a/obj/package.json b/obj/package.json index 6f7bb84a..16a35503 100644 --- a/obj/package.json +++ b/obj/package.json @@ -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-29", - "@nats-io/nats-core": "3.0.0-42" + "@nats-io/jetstream": "3.0.0-31", + "@nats-io/nats-core": "3.0.0-44" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/services/deno.json b/services/deno.json index a41ad362..38cb1dfb 100644 --- a/services/deno.json +++ b/services/deno.json @@ -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-43" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44" } } diff --git a/services/import_map.json b/services/import_map.json index 6aa9b919..a7610fad 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-43", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-43/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", "test_helpers": "../test_helpers/mod.ts", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", diff --git a/services/package.json b/services/package.json index 02641e49..0de9bc13 100644 --- a/services/package.json +++ b/services/package.json @@ -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-43" + "@nats-io/nats-core": "3.0.0-44" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/transport-deno/deno.json b/transport-deno/deno.json index 9dad2458..32472742 100644 --- a/transport-deno/deno.json +++ b/transport-deno/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-deno", - "version": "3.0.0-16", + "version": "3.0.0-17", "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-43", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", "@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 0873af67..df709f1a 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-16"; +export const version = "3.0.0-17"; diff --git a/transport-node/package.json b/transport-node/package.json index 4aeb218a..dc3b9db4 100644 --- a/transport-node/package.json +++ b/transport-node/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-node", - "version": "3.0.0-27", + "version": "3.0.0-28", "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-43", + "@nats-io/nats-core": "3.0.0-44", "@nats-io/nkeys": "2.0.0-2", "@nats-io/nuid": "2.0.1-2" }, diff --git a/transport-node/src/version.ts b/transport-node/src/version.ts index e9228cee..e26f0ee9 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-27"; +export const version = "3.0.0-28"; From 7def2b9287156cd459b29645d23436f16a638ddd Mon Sep 17 00:00:00 2001 From: Alberto Ricart Date: Wed, 20 Nov 2024 18:06:10 -0600 Subject: [PATCH 3/3] change(core): requestMany() JitterTimer and its associated `jitter` property is now called "stall" change(core): requestMany() `RequestStrategy` is now a simple string "timer" | "count" | "stall" | "sentinel" Signed-off-by: Alberto Ricart --- core/deno.json | 4 ++-- core/package.json | 4 ++-- core/src/version.ts | 2 +- deno.json | 2 +- jetstream/deno.json | 4 ++-- jetstream/import_map.json | 6 +++--- jetstream/package.json | 4 ++-- kv/deno.json | 6 +++--- kv/import_map.json | 10 +++++----- kv/package.json | 6 +++--- obj/deno.json | 6 +++--- obj/import_map.json | 10 +++++----- obj/package.json | 6 +++--- package.json | 5 ++++- services/deno.json | 4 ++-- services/import_map.json | 6 +++--- services/package.json | 4 ++-- transport-deno/deno.json | 6 +++--- transport-deno/src/version.ts | 2 +- transport-node/package-lock.json | 4 ++-- transport-node/package.json | 13 ++++++------- transport-node/src/version.ts | 2 +- 22 files changed, 59 insertions(+), 57 deletions(-) diff --git a/core/deno.json b/core/deno.json index 35c6b281..d2e58d9a 100644 --- a/core/deno.json +++ b/core/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-44", + "version": "3.0.0-45", "exports": { ".": "./src/mod.ts", "./internal": "./src/internal_mod.ts" @@ -35,7 +35,7 @@ "test": "deno test -A --parallel --reload tests/ --import-map=./import_map.json" }, "imports": { - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@nats-io/nuid": "jsr:@nats-io/nuid@2.0.1-2" } } diff --git a/core/package.json b/core/package.json index 3d2589aa..b14000ff 100644 --- a/core/package.json +++ b/core/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/nats-core", - "version": "3.0.0-44", + "version": "3.0.0-45", "files": [ "lib/", "LICENSE", @@ -34,7 +34,7 @@ }, "description": "nats-core library - this library implements all the base functionality for NATS javascript clients", "dependencies": { - "@nats-io/nkeys": "2.0.0-2", + "@nats-io/nkeys": "2.0.0-3", "@nats-io/nuid": "2.0.1-2" }, "devDependencies": { diff --git a/core/src/version.ts b/core/src/version.ts index 7b33c71c..a5db8198 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-44"; +export const version = "3.0.0-45"; diff --git a/deno.json b/deno.json index 3e4dc712..de3234a0 100644 --- a/deno.json +++ b/deno.json @@ -71,5 +71,5 @@ "./obj", "./services" ], - "nodeModulesDir": "auto" + "nodeModulesDir": "none" } diff --git a/jetstream/deno.json b/jetstream/deno.json index 71b72d84..10058731 100644 --- a/jetstream/deno.json +++ b/jetstream/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/jetstream", - "version": "3.0.0-31", + "version": "3.0.0-32", "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-44" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45" } } diff --git a/jetstream/import_map.json b/jetstream/import_map.json index 5dbc1df1..d35f0154 100644 --- a/jetstream/import_map.json +++ b/jetstream/import_map.json @@ -1,9 +1,9 @@ { "imports": { - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/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 b9c468de..ea2ea203 100644 --- a/jetstream/package.json +++ b/jetstream/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/jetstream", - "version": "3.0.0-31", + "version": "3.0.0-32", "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-44" + "@nats-io/nats-core": "3.0.0-45" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/kv/deno.json b/kv/deno.json index 0c1398c7..f2300a6d 100644 --- a/kv/deno.json +++ b/kv/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/kv", - "version": "3.0.0-25", + "version": "3.0.0-26", "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-44", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32" } } diff --git a/kv/import_map.json b/kv/import_map.json index 7278ee24..18d35cf9 100644 --- a/kv/import_map.json +++ b/kv/import_map.json @@ -1,11 +1,11 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-32/internal", "test_helpers": "../test_helpers/mod.ts", - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", "@std/io": "jsr:@std/io@0.224.0" } diff --git a/kv/package.json b/kv/package.json index 5d3c3161..4ce7a37c 100644 --- a/kv/package.json +++ b/kv/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/kv", - "version": "3.0.0-25", + "version": "3.0.0-26", "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-31", - "@nats-io/nats-core": "3.0.0-44" + "@nats-io/jetstream": "3.0.0-32", + "@nats-io/nats-core": "3.0.0-45" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/obj/deno.json b/obj/deno.json index deadc25e..018bdbe2 100644 --- a/obj/deno.json +++ b/obj/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/obj", - "version": "3.0.0-26", + "version": "3.0.0-27", "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-44", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32" } } diff --git a/obj/import_map.json b/obj/import_map.json index 7278ee24..18d35cf9 100644 --- a/obj/import_map.json +++ b/obj/import_map.json @@ -1,11 +1,11 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", - "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-31", - "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-31/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal", + "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-32", + "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-32/internal", "test_helpers": "../test_helpers/mod.ts", - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", "@std/io": "jsr:@std/io@0.224.0" } diff --git a/obj/package.json b/obj/package.json index 16a35503..06a5d7a9 100644 --- a/obj/package.json +++ b/obj/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/obj", - "version": "3.0.0-26", + "version": "3.0.0-27", "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-31", - "@nats-io/nats-core": "3.0.0-44" + "@nats-io/jetstream": "3.0.0-32", + "@nats-io/nats-core": "3.0.0-45" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/package.json b/package.json index e8951e30..df6eed6a 100644 --- a/package.json +++ b/package.json @@ -6,5 +6,8 @@ "./obj", "./services", "./transport-node" - ] + ], + "dependencies": { + "tweetnacl": "^1.0.3" + } } diff --git a/services/deno.json b/services/deno.json index 38cb1dfb..e0be7992 100644 --- a/services/deno.json +++ b/services/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-19", + "version": "3.0.0-20", "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-44" + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45" } } diff --git a/services/import_map.json b/services/import_map.json index a7610fad..64df2ea5 100644 --- a/services/import_map.json +++ b/services/import_map.json @@ -1,9 +1,9 @@ { "imports": { - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", - "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-44/internal", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-45/internal", "test_helpers": "../test_helpers/mod.ts", - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@nats-io/nuid": "jsr:@nats-io/nuid@~2.0.1-2", "@std/io": "jsr:@std/io@0.224.0" } diff --git a/services/package.json b/services/package.json index 0de9bc13..b687f247 100644 --- a/services/package.json +++ b/services/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/services", - "version": "3.0.0-19", + "version": "3.0.0-20", "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-44" + "@nats-io/nats-core": "3.0.0-45" }, "devDependencies": { "@types/node": "^22.7.6", diff --git a/transport-deno/deno.json b/transport-deno/deno.json index 32472742..e85a839e 100644 --- a/transport-deno/deno.json +++ b/transport-deno/deno.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-deno", - "version": "3.0.0-17", + "version": "3.0.0-18", "exports": { ".": "./src/mod.ts" }, @@ -20,8 +20,8 @@ }, "imports": { "@std/io": "jsr:@std/io@0.225.0", - "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-44", - "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-2", + "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-45", + "@nats-io/nkeys": "jsr:@nats-io/nkeys@~2.0.0-3", "@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 df709f1a..35419336 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-17"; +export const version = "3.0.0-18"; diff --git a/transport-node/package-lock.json b/transport-node/package-lock.json index b6cb81c2..f68840b9 100644 --- a/transport-node/package-lock.json +++ b/transport-node/package-lock.json @@ -1,12 +1,12 @@ { "name": "@nats-io/transport-node", - "version": "3.0.0-27", + "version": "3.0.0-29", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@nats-io/transport-node", - "version": "3.0.0-27", + "version": "3.0.0-29", "license": "Apache-2.0", "dependencies": { "@nats-io/nats-core": "~3.0.0-20", diff --git a/transport-node/package.json b/transport-node/package.json index dc3b9db4..30968861 100644 --- a/transport-node/package.json +++ b/transport-node/package.json @@ -1,6 +1,6 @@ { "name": "@nats-io/transport-node", - "version": "3.0.0-28", + "version": "3.0.0-30", "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system", "keywords": [ "nats", @@ -54,18 +54,17 @@ "node": ">= 18.0.0" }, "dependencies": { - "@nats-io/nats-core": "3.0.0-44", - "@nats-io/nkeys": "2.0.0-2", + "@nats-io/nats-core": "3.0.0-45", + "@nats-io/nkeys": "2.0.0-3", "@nats-io/nuid": "2.0.1-2" }, "devDependencies": { "@types/node": "^22.7.6", "minimist": "^1.2.8", - "nats-jwt": "^0.0.9", "shx": "^0.3.3", "typescript": "5.6.3", - "@nats-io/jetstream": "3.0.0-31", - "@nats-io/kv": "3.0.0-25", - "@nats-io/obj": "3.0.0-26" + "@nats-io/jetstream": "3.0.0-32", + "@nats-io/kv": "3.0.0-26", + "@nats-io/obj": "3.0.0-27" } } diff --git a/transport-node/src/version.ts b/transport-node/src/version.ts index e26f0ee9..14911460 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-28"; +export const version = "3.0.0-30";