Merge branch 'main' into fix-125

nats-io · Nov 9, 2024 · 61aa521 · 61aa521
2 parents af0f6eb + e234d22
commit 61aa521
Show file tree

Hide file tree

Showing 30 changed files with 53 additions and 53 deletions.
diff --git a/core/deno.json b/core/deno.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-36",
+  "version": "3.0.0-38",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"

diff --git a/core/package.json b/core/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-36",
+  "version": "3.0.0-38",
   "files": [
     "lib/",
     "LICENSE",

diff --git 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-36";
+export const version = "3.0.0-38";
diff --git 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-36"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38"
   }
 }
diff --git a/jetstream/examples/01_consumers.ts b/jetstream/examples/01_consumers.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/02_next.ts b/jetstream/examples/02_next.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/03_batch.ts b/jetstream/examples/03_batch.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/04_consume.ts b/jetstream/examples/04_consume.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/05_consume.ts b/jetstream/examples/05_consume.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/06_heartbeats.ts b/jetstream/examples/06_heartbeats.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { ConsumerEvents, jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { ConsumerEvents, jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/07_consume_jobs.ts b/jetstream/examples/07_consume_jobs.ts
@@ -13,10 +13,10 @@
  * limitations under the License.
  */
 
-import { connect, delay } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { SimpleMutex } from "jsr:@nats-io/nats-core@3.0.0-17/internal";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
-import type { JsMsg } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, delay } from "@nats-io/transport-deno";
+import { SimpleMutex } from "@nats-io/nats-core/internal";
+import { jetstream } from "@nats-io/jetstream";
+import type { JsMsg } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/08_consume_process.ts b/jetstream/examples/08_consume_process.ts
@@ -13,9 +13,9 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
+import { connect } from "@nats-io/transport-deno";
 import { setupStreamAndConsumer } from "./util.ts";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { jetstream } from "@nats-io/jetstream";
 
 // create a connection
 const nc = await connect();

diff --git a/jetstream/examples/js_readme_publish_examples.ts b/jetstream/examples/js_readme_publish_examples.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect, Empty } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream, jetstreamManager } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, Empty } from "@nats-io/transport-deno";
+import { jetstream, jetstreamManager } from "@nats-io/jetstream";
 import type { PubAck } from "../src/mod.ts";
 
 const nc = await connect();

diff --git a/jetstream/examples/jsm_readme_jsm_example.ts b/jetstream/examples/jsm_readme_jsm_example.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect, Empty } from "jsr:@nats-io/nats-transport-deno@3.0.0-5";
-import { AckPolicy, jetstreamManager } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, Empty } from "@nats-io/transport-deno";
+import { AckPolicy, jetstreamManager } from "@nats-io/jetstream";
 
 const nc = await connect();
 const jsm = await jetstreamManager(nc);
@@ -48,7 +48,7 @@ await jsm.streams.update(name, si.config);
 // get a particular stored message in the stream by sequence
 // this is not associated with a consumer
 const sm = await jsm.streams.getMessage("mystream", { seq: 1 });
-console.log(sm.seq);
+console.log(sm?.seq);
 
 // delete the 5th message in the stream, securely erasing it
 await jsm.streams.deleteMessage("mystream", 5);

diff --git a/jetstream/examples/util.ts b/jetstream/examples/util.ts
@@ -14,8 +14,8 @@
  */
 
 import { createConsumer, fill, initStream } from "../tests/jstest_util.ts";
-import type { NatsConnection } from "jsr:@nats-io/nats-core@3.0.0-31";
-import { nuid } from "jsr:@nats-io/nats-core@3.0.0-31";
+import type { NatsConnection } from "@nats-io/nats-core";
+import { nuid } from "@nats-io/nats-core";
 
 export async function setupStreamAndConsumer(
   nc: NatsConnection,

diff --git a/jetstream/import_map.json b/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-36",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal",
+    "@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",
     "test_helpers": "../test_helpers/mod.ts",
     "@std/io": "jsr:@std/[email protected]"
   }

diff --git 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-36"
+    "@nats-io/nats-core": "3.0.0-38"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

diff --git 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-36",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25"
   }
 }
diff --git 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-36",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal",
+    "@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",
     "test_helpers": "../test_helpers/mod.ts",

diff --git 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-25",
-    "@nats-io/nats-core": "3.0.0-36"
+    "@nats-io/nats-core": "3.0.0-38"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

diff --git 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-36",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-25"
   }
 }
diff --git 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-36",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal",
+    "@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",
     "test_helpers": "../test_helpers/mod.ts",

diff --git 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-25",
-    "@nats-io/nats-core": "3.0.0-36"
+    "@nats-io/nats-core": "3.0.0-38"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

diff --git 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-36"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38"
   }
 }
diff --git 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-36",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-36/internal",
+    "@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",
     "test_helpers": "../test_helpers/mod.ts",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",

diff --git 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-36"
+    "@nats-io/nats-core": "3.0.0-38"
   },
   "devDependencies": {
     "@types/node": "^22.7.6",

diff --git a/transport-deno/deno.json b/transport-deno/deno.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/transport-deno",
-  "version": "3.0.0-11",
+  "version": "3.0.0-13",
   "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-36",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-38",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]"
   }

diff --git 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-11";
+export const version = "3.0.0-13";
diff --git a/transport-node/package.json b/transport-node/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/transport-node",
-  "version": "3.0.0-22",
+  "version": "3.0.0-24",
   "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-36",
+    "@nats-io/nats-core": "3.0.0-38",
     "@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-24",
-    "@nats-io/kv": "3.0.0-18",
-    "@nats-io/obj": "3.0.0-19"
+    "@nats-io/jetstream": "3.0.0-25",
+    "@nats-io/kv": "3.0.0-19",
+    "@nats-io/obj": "3.0.0-20"
   }
 }
diff --git 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-22";
+export const version = "3.0.0-24";