chore(transport-node): normalize use of require/import in the module,…

… and reference node libs with `node:`

internal(core): changed delay to resolve to a boolean to true unless canceled

core/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-26",
+  "version": "3.0.0-27",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"

core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-26",
+  "version": "3.0.0-27",
   "files": [
     "lib/",
     "LICENSE",

core/src/util.ts

@@ -94,19 +94,20 @@ export function timeout<T>(ms: number, asyncTraces = true): Timeout<T> {
   return Object.assign(p, methods) as Timeout<T>;
 }
 
-export interface Delay extends Promise<void>, Cancelable {
+export interface Delay extends Promise<boolean>, Cancelable {
   cancel: () => void;
 }
 
 export function delay(ms = 0): Delay {
   let methods;
-  const p = new Promise<void>((resolve) => {
+  const p = new Promise<boolean>((resolve) => {
     const timer = setTimeout(() => {
-      resolve();
+      resolve(true);
     }, ms);
     const cancel = (): void => {
       if (timer) {
         clearTimeout(timer);
+        resolve(false);
       }
     };
     methods = { cancel };

core/src/version.ts

@@ -1,2 +1,2 @@
 // This file is generated - do not edit
-export const version = "3.0.0-26";
+export const version = "3.0.0-27";

jetstream/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-26"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27"
   }
 }

jetstream/examples/util.ts

@@ -14,7 +14,7 @@
  */
 
 import { createConsumer, fill, initStream } from "../tests/jstest_util.ts";
-import type { NatsConnection } from "jsr:@nats-io/[email protected]17";
+import type { NatsConnection } from "jsr:@nats-io/[email protected]26";
 import { nuid } from "jsr:@nats-io/[email protected]";
 
 export async function setupStreamAndConsumer(

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-26",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-26/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-27/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@std/io": "jsr:@std/[email protected]"
   }

jetstream/package.json

@@ -32,7 +32,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-26"
+    "@nats-io/nats-core": "~3.0.0-27"
   },
   "devDependencies": {
     "@types/node": "^22.0.0",

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-26",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-10"
   }
 }

kv/import_map.json

@@ -1,7 +1,7 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-26",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-26/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-27/internal",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-10",
     "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-10/internal",
     "test_helpers": "../test_helpers/mod.ts",

kv/package.json

@@ -33,7 +33,7 @@
   "description": "kv library - this library implements all the base functionality for NATS KV javascript clients",
   "dependencies": {
     "@nats-io/jetstream": "~3.0.0-10",
-    "@nats-io/nats-core": "~3.0.0-26"
+    "@nats-io/nats-core": "~3.0.0-27"
   },
   "devDependencies": {
     "@types/node": "^22.0.0",

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-26",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-10"
   }
 }

obj/import_map.json

@@ -1,7 +1,7 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-26",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-26/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-27/internal",
     "@nats-io/jetstream": "jsr:@nats-io/jetstream@~3.0.0-10",
     "@nats-io/jetstream/internal": "jsr:@nats-io/jetstream@~3.0.0-10/internal",
     "test_helpers": "../test_helpers/mod.ts",

obj/package.json

@@ -33,7 +33,7 @@
   "description": "obj library - this library implements all the base functionality for NATS objectstore for javascript clients",
   "dependencies": {
     "@nats-io/jetstream": "~3.0.0-10",
-    "@nats-io/nats-core": "~3.0.0-26"
+    "@nats-io/nats-core": "~3.0.0-27"
   },
   "devDependencies": {
     "@types/node": "^22.0.0",

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-26"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27"
   }
 }

services/import_map.json

@@ -1,7 +1,7 @@
 {
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-26",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-26/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-27/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",

services/package.json

@@ -32,7 +32,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-26"
+    "@nats-io/nats-core": "~3.0.0-27"
   },
   "devDependencies": {
     "@types/node": "^22.0.0",

transport-deno/deno.json

@@ -20,7 +20,7 @@
   },
   "imports": {
     "@std/io": "jsr:@std/[email protected]",
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-26",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]"
   }

transport-node/examples/bench.js

@@ -3,6 +3,7 @@
 const parse = require("minimist");
 const { Nuid, connect } = require("../index");
 const { Bench, Metric } = require("../lib/nats-base-client/bench");
+const { process } = require("node:process");
 
 const defaults = {
   s: "127.0.0.1:4222",

transport-node/examples/nats-events.js

@@ -1,5 +1,6 @@
 #!/usr/bin/env node
 
+const { process } = require("node:process");
 const parse = require("minimist");
 const { connect } = require("../index");
 

transport-node/examples/nats-pub.js

@@ -5,7 +5,8 @@ const { connect, StringCodec, headers, credsAuthenticator } = require(
   "../index",
 );
 const { delay } = require("./util");
-const fs = require("fs");
+const fs = require("node:fs");
+const { process } = require("node:process");
 
 const argv = parse(
   process.argv.slice(2),

transport-node/examples/nats-rep.js

@@ -4,7 +4,8 @@ const parse = require("minimist");
 const { connect, StringCodec, headers, credsAuthenticator } = require(
   "../index",
 );
-const fs = require("fs");
+const fs = require("node:fs");
+const { process } = require("node:process");
 
 const argv = parse(
   process.argv.slice(2),

transport-node/examples/nats-req.js

@@ -5,7 +5,8 @@ const { connect, StringCodec, headers, credsAuthenticator } = require(
   "../index",
 );
 const { delay } = require("./util");
-const fs = require("fs");
+const fs = require("node:fs");
+const { process } = require("node:process");
 
 const argv = parse(
   process.argv.slice(2),

transport-node/examples/nats-sub.js

@@ -2,7 +2,8 @@
 
 const parse = require("minimist");
 const { connect, StringCodec, credsAuthenticator } = require("../index");
-const fs = require("fs");
+const fs = require("node:fs");
+const { process } = require("node:process");
 
 const argv = parse(
   process.argv.slice(2),

transport-node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/transport-node",
-  "version": "3.0.0-11",
+  "version": "3.0.0-12",
   "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-26",
+    "@nats-io/nats-core": "~3.0.0-27",
     "@nats-io/nkeys": "^1.2.0-4",
     "@nats-io/nuid": "^2.0.1-2"
   },

transport-node/src/node_transport.ts

@@ -28,12 +28,13 @@ import {
 } from "./nats-base-client";
 
 import type { ConnectionOptions } from "./nats-base-client";
-import { createConnection, Socket } from "net";
-import { connect as tlsConnect, TlsOptions, TLSSocket } from "tls";
-const { resolve } = require("path");
-const { readFile, existsSync } = require("fs");
-const dns = require("dns");
-const { version } = require("./version");
+import { createConnection, Socket } from "node:net";
+import { connect as tlsConnect, TlsOptions, TLSSocket } from "node:tls";
+import { resolve } from "node:path";
+import { existsSync, readFile } from "node:fs";
+import dns from "node:dns";
+import { Buffer } from "node:buffer";
+import { version } from "./version";
 export const VERSION = version;
 const LANG = "nats.js";
 

transport-node/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-12";

transport-node/tests/helpers/launcher.js

@@ -12,8 +12,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-const path = require("path");
-const http = require("http");
+const path = require("node:path");
+const http = require("node:http");
+const process = require("node:process");
+const { spawn } = require("node:child_process");
+const fs = require("node:fs");
+const os = require("node:os");
 const { check } = require("./delay");
 const {
   deferred,
@@ -22,10 +26,6 @@ const {
   nuid,
 } = require("@nats-io/nats-core/internal");
 
-const { spawn } = require("child_process");
-
-const fs = require("fs");
-const os = require("os");
 const { Lock } = require("./lock");
 
 const ServerSignals = new Map();

transport-node/tests/noiptls_test.js

@@ -20,7 +20,8 @@ const {
   "../index",
 );
 
-const { resolve, join } = require("path");
+const process = require("node:process");
+const { resolve, join } = require("node:path");
 const { Lock } = require("./helpers/lock");
 const { NatsServer } = require("./helpers/launcher");
 

transport-node/tests/tls_test.js

@@ -20,8 +20,9 @@ const {
 } = require(
   "../index",
 );
-const { resolve, join } = require("path");
-const { readFileSync } = require("fs");
+const process = require("node:process");
+const { resolve, join } = require("node:path");
+const { readFileSync } = require("node:fs");
 const { Lock } = require("./helpers/lock");
 const { NatsServer } = require("./helpers/launcher");
 const { buildAuthenticator, extend, Connect } = require(