bump bundles, fix bundle names for transport, fix imports for process…

… in node

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

core/README.md

@@ -107,7 +107,7 @@ is working.
 
 ```typescript
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]4";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 const servers = [
   {},
@@ -179,7 +179,7 @@ the server.
 
 ```typescript
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]4";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io:4222" });
@@ -241,8 +241,8 @@ All subscriptions are independent. If two different subscriptions match a
 subject, both will get to process the message:
 
 ```typescript
-import { connect } from "jsr:@nats-io/nats-[email protected]4";
-import type { Subscription } from "jsr:@nats-io/nats-[email protected]4";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import type { Subscription } from "jsr:@nats-io/[email protected]7";
 const nc = await connect({ servers: "demo.nats.io:4222" });
 
 // subscriptions can have wildcard subjects
@@ -418,11 +418,11 @@ independent unit. Note that non-queue subscriptions are also independent of
 subscriptions in a queue group.
 
 ```typescript
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 import type {
   NatsConnection,
   Subscription,
-} from "jsr:@nats-io/nats-[email protected]4";
+} from "jsr:@nats-io/[email protected]7";
 
 async function createService(
   name: string,
@@ -541,29 +541,33 @@ If you send a request for which there's no interest, the request will be
 immediately rejected:
 
 ```typescript
-import { connect, ErrorCode } from "jsr:@nats-io/[email protected]";
-import type { NatsError } from "jsr:@nats-io/[email protected]";
-
-const nc = await connect(
-  {
-    servers: `demo.nats.io`,
-  },
-);
+import { connect } from "jsr:@nats-io/[email protected]";
+import {
+  NoRespondersError,
+  RequestError,
+  TimeoutError,
+} from "jsr:@nats-io/[email protected]";
+
+const nc = await connect({
+  servers: `demo.nats.io`,
+});
 
 try {
   const m = await nc.request("hello.world");
   console.log(m.data);
 } catch (err) {
-  const nerr = err as NatsError;
-  switch (nerr.code) {
-    case ErrorCode.NoResponders:
-      console.log("no one is listening to 'hello.world'");
-      break;
-    case ErrorCode.Timeout:
+  if (err instanceof RequestError) {
+    if (err.cause instanceof TimeoutError) {
       console.log("someone is listening but didn't respond");
-      break;
-    default:
-      console.log("request failed", err);
+    } else if (err.cause instanceof NoRespondersError) {
+      console.log("no one is listening to 'hello.world'");
+    } else {
+      console.log(
+        `failed due to unknown error: ${(err.cause as Error)?.message}`,
+      );
+    }
+  } else {
+    console.log(`request failed: ${(err as Error).message}`);
   }
 }
 
@@ -591,7 +595,7 @@ Setting the `user`/`pass` or `token` options, simply initializes an
 ```typescript
 // if the connection requires authentication, provide `user` and `pass` or
 // `token` options in the NatsConnectionOptions
-import { connect } from "jsr:@nats-io/nats-[email protected]";
+import { connect } from "jsr:@nats-io/[email protected]";
 
 const nc1 = await connect({
   servers: "127.0.0.1:4222",
@@ -680,8 +684,8 @@ You can specify several options when creating a subscription:
 - `timeout`: how long to wait for the first message
 - `queue`: the [queue group](#queue-groups) name the subscriber belongs to
 - `callback`: a function with the signature
-  `(err: NatsError|null, msg: Msg) => void;` that should be used for handling
-  the message. Subscriptions with callbacks are NOT iterators.
+  `(err: Error|null, msg: Msg) => void;` that should be used for handling the
+  message. Subscriptions with callbacks are NOT iterators.
 
 #### Auto Unsubscribe
 

core/examples/snippets/autounsub.ts

@@ -14,8 +14,8 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import type { Subscription } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import type { Subscription } from "jsr:@nats-io/[email protected]7";
 
 // create a connection
 const nc = await connect({ servers: "demo.nats.io:4222" });

core/examples/snippets/basics.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io:4222" });

core/examples/snippets/connect.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 const servers = [
   {},

core/examples/snippets/headers.ts

@@ -19,7 +19,7 @@ import {
   Empty,
   headers,
   nuid,
-} from "jsr:@nats-io/nats-[email protected]5";
+} from "jsr:@nats-io/[email protected]7";
 
 const nc = await connect(
   {

core/examples/snippets/json.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io:4222" });
@@ -30,7 +30,7 @@ const sub = nc.subscribe("people");
   for await (const m of sub) {
     // typescript will see this as a Person
     const p = m.json<Person>();
-    console.log(`[${sub.getProcessed()}]: ${p.name}`);
+    console.log(p);
   }
 })();
 

core/examples/snippets/no_responders.ts

@@ -1,5 +1,24 @@
-import { connect, ErrorCode } from "jsr:@nats-io/[email protected]";
-import type { NatsError } from "jsr:@nats-io/[email protected]";
+/*
+ * Copyright 2024 Synadia Communications, Inc
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { connect } from "jsr:@nats-io/[email protected]";
+import {
+  NoRespondersError,
+  RequestError,
+  TimeoutError,
+} from "jsr:@nats-io/[email protected]";
 
 const nc = await connect(
   {
@@ -11,16 +30,18 @@ try {
   const m = await nc.request("hello.world");
   console.log(m.data);
 } catch (err) {
-  const nerr = err as NatsError;
-  switch (nerr.code) {
-    case ErrorCode.NoResponders:
-      console.log("no one is listening to 'hello.world'");
-      break;
-    case ErrorCode.Timeout:
+  if (err instanceof RequestError) {
+    if (err.cause instanceof TimeoutError) {
       console.log("someone is listening but didn't respond");
-      break;
-    default:
-      console.log("request failed", err);
+    } else if (err.cause instanceof NoRespondersError) {
+      console.log("no one is listening to 'hello.world'");
+    } else {
+      console.log(
+        `failed due to unknown error: ${(err.cause as Error)?.message}`,
+      );
+    }
+  } else {
+    console.log(`request failed: ${(err as Error).message}`);
   }
 }
 

core/examples/snippets/queuegroups.ts

@@ -12,11 +12,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 import type {
   NatsConnection,
   Subscription,
-} from "jsr:@nats-io/nats-[email protected]4";
+} from "jsr:@nats-io/[email protected]7";
 
 async function createService(
   name: string,

core/examples/snippets/service.ts

@@ -14,8 +14,8 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import type { Subscription } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import type { Subscription } from "jsr:@nats-io/[email protected]7";
 
 // create a connection
 const nc = await connect({ servers: "demo.nats.io" });

core/examples/snippets/service_client.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect, Empty } from "jsr:@nats-io/nats-[email protected]5";
+import { connect, Empty } from "jsr:@nats-io/[email protected]7";
 
 // create a connection
 const nc = await connect({ servers: "demo.nats.io:4222" });

core/examples/snippets/stream.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io" });

core/examples/snippets/sub_timeout.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect, ErrorCode } from "jsr:@nats-io/nats-[email protected]5";
+import { connect, TimeoutError } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io:4222" });
@@ -27,7 +27,7 @@ const sub = nc.subscribe("hello", { timeout: 1000 });
     // handle the messages
   }
 })().catch((err) => {
-  if (err.code === ErrorCode.Timeout) {
+  if (err instanceof TimeoutError) {
     console.log(`sub timed out!`);
   } else {
     console.log(`sub iterator got an error!`);

core/examples/snippets/unsub.ts

@@ -14,7 +14,7 @@
  */
 
 // import the connect function from a transport
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
 
 // to create a connection to a nats-server:
 const nc = await connect({ servers: "demo.nats.io:4222" });
@@ -38,9 +38,9 @@ const manual = nc.subscribe("hello");
 const done = (async () => {
   console.log("waiting for a message on `hello` with a payload of `stop`");
   for await (const m of manual) {
-    const d = sc.decode(m.data);
-    console.log("manual", manual.getProcessed(), d);
-    if (d === "stop") {
+    const payload = m.string();
+    console.log("manual", manual.getProcessed(), payload);
+    if (payload === "stop") {
       manual.unsubscribe();
     }
   }

core/examples/snippets/wildcard_subscriptions.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import type { Subscription } from "jsr:@nats-io/nats-[email protected]5";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import type { Subscription } from "jsr:@nats-io/[email protected]7";
 
 const nc = await connect({ servers: "demo.nats.io:4222" });
 

jetstream/examples/01_consumers.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

jetstream/examples/02_next.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

jetstream/examples/03_batch.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

jetstream/examples/04_consume.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection
@@ -39,6 +39,6 @@ while (true) {
       m.ack();
     }
   } catch (err) {
-    console.log(`consume failed: ${err.message}`);
+    console.log(`consume failed: ${(err as Error).message}`);
   }
 }

jetstream/examples/05_consume.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

jetstream/examples/06_heartbeats.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/nats-[email protected]5";
-import { ConsumerEvents, jetstream } from "../src/mod.ts";
+import { connect } from "jsr:@nats-io/[email protected]7";
+import { ConsumerEvents, jetstream } from "jsr:@nats-io/[email protected]";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection