Skip to content

Commit

Permalink
bump(*): all libs
Browse files Browse the repository at this point in the history 
test(node): fix event driven tests

Signed-off-by: Alberto Ricart <alberto@synadia.com>
  • Loading branch information
@aricart
aricart committed Nov 13, 2024
1 parent ab296de commit 6f1db09
Show file tree
Hide file tree
Showing 21 changed files with 54 additions and 57 deletions.
2 changes: 1 addition & 1 deletion core/deno.json
View file
Original file line number Diff line number Diff line change
@@ -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"
Expand Down
2 changes: 1 addition & 1 deletion core/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/nats-core",
"version": "3.0.0-38",
"version": "3.0.0-40",
"files": [
"lib/",
"LICENSE",
Expand Down
2 changes: 1 addition & 1 deletion core/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -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";
4 changes: 2 additions & 2 deletions jetstream/deno.json
View file
Original file line number Diff line number Diff line change
@@ -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"
Expand Down Expand Up @@ -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"
}
}
4 changes: 2 additions & 2 deletions jetstream/import_map.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
}
Expand Down
4 changes: 2 additions & 2 deletions jetstream/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/jetstream",
"version": "3.0.0-25",
"version": "3.0.0-27",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -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",
Expand Down
6 changes: 3 additions & 3 deletions kv/deno.json
View file
Original file line number Diff line number Diff line change
@@ -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"
Expand Down Expand Up @@ -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"
}
}
8 changes: 4 additions & 4 deletions kv/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -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",
Expand Down
6 changes: 3 additions & 3 deletions kv/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/kv",
"version": "3.0.0-19",
"version": "3.0.0-21",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -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",
Expand Down
6 changes: 3 additions & 3 deletions obj/deno.json
View file
Original file line number Diff line number Diff line change
@@ -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"
Expand Down Expand Up @@ -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"
}
}
8 changes: 4 additions & 4 deletions obj/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -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",
Expand Down
6 changes: 3 additions & 3 deletions obj/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/obj",
"version": "3.0.0-20",
"version": "3.0.0-22",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -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",
Expand Down
4 changes: 2 additions & 2 deletions services/deno.json
View file
Original file line number Diff line number Diff line change
@@ -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"
Expand Down Expand Up @@ -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"
}
}
4 changes: 2 additions & 2 deletions services/import_map.json
View file
Original file line number Diff line number Diff line change
@@ -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",
Expand Down
4 changes: 2 additions & 2 deletions services/package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/services",
"version": "3.0.0-14",
"version": "3.0.0-16",
"files": [
"lib/",
"LICENSE",
Expand Down Expand Up @@ -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",
Expand Down
4 changes: 2 additions & 2 deletions transport-deno/deno.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@nats-io/transport-deno",
"version": "3.0.0-13",
"version": "3.0.0-15",
"exports": {
".": "./src/mod.ts"
},
Expand All @@ -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"
}
Expand Down
2 changes: 1 addition & 1 deletion transport-deno/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -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";
10 changes: 5 additions & 5 deletions transport-node/package.json
View file
Original file line number Diff line number Diff line change
@@ -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",
Expand Down Expand Up @@ -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"
},
Expand All @@ -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"
}
}
2 changes: 1 addition & 1 deletion transport-node/src/version.ts
View file
Original file line number Diff line number Diff line change
@@ -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";
3 changes: 1 addition & 2 deletions transport-node/tests/noiptls_test.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
const { describe, it } = require("node:test");
const {
connect,
Events,
} = require(
"../index",
);
Expand Down Expand Up @@ -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();
}
}
Expand Down
20 changes: 9 additions & 11 deletions transport-node/tests/reconnect_test.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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");

Expand Down Expand Up @@ -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;
}
Expand All @@ -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;
}
Expand All @@ -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;
}
Expand Down Expand Up @@ -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;
}
Expand Down

0 comments on commit 6f1db09

Please sign in to comment.