monorepo tests enablement

core/deno.json

@@ -11,6 +11,9 @@
  "./unsafe_tests/**/*"
  ]
  },
+ "tasks": {
+ "clean": "rm -rf ./lib ./cjs ./esm"
+ },
  "imports": {
  "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
  "@nats-io/nuid": "jsr:@nats-io/[email protected]"

core/src/core.ts

@@ -341,7 +341,14 @@ export interface Server {
  tlsName: string;
 
  resolve(
- opts: Partial<{ fn: DnsResolveFn; randomize: boolean; debug?: boolean, resolve?: boolean }>,
+ opts: Partial<
+ {
+ fn: DnsResolveFn;
+ randomize: boolean;
+ debug?: boolean;
+ resolve?: boolean;
+ }
+ >,
  ): Promise<Server[]>;
 }
 
@@ -1050,11 +1057,11 @@ export interface ConnectionOptions {
  noAsyncTraces?: boolean;
 
  /**
- * When false, the connect function will not perform any hostname resolution. Note that
- * by default this option will be true if the client supports hostname resolution.
- * Note that on clients that don't supported (mainly the websocket client, setting this
- * option to true, will throw an exception as this option is not available.
- */
+  * When false, the connect function will not perform any hostname resolution. Note that
+  * by default this option will be true if the client supports hostname resolution.
+  * Note that on clients that don't supported (mainly the websocket client, setting this
+  * option to true, will throw an exception as this option is not available.
+  */
  resolve?: boolean;
 }
 

core/src/internal_mod.ts

@@ -4,7 +4,7 @@ export { Nuid, nuid } from "./nuid.ts";
 export type { TypedSubscriptionOptions } from "./types.ts";
 
 export { MsgImpl } from "./msg.ts";
-export { setTransportFactory, getResolveFn } from "./transport.ts";
+export { getResolveFn, setTransportFactory } from "./transport.ts";
 export type { Transport, TransportFactory } from "./transport.ts";
 export { Connect, INFO, ProtocolHandler } from "./protocol.ts";
 export type { Backoff, Deferred, Delay, Perf, Timeout } from "./util.ts";

core/src/protocol.ts

@@ -594,7 +594,7 @@ export class ProtocolHandler implements Dispatcher<ParserEvent> {
  fn: getResolveFn(),
  debug: this.options.debug,
  randomize: !this.options.noRandomize,
- resolve
+ resolve,
  });
 
  let lastErr: Error | null = null;

core/tests/auth_test.ts

@@ -12,12 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import {
- _setup,
- assertErrorCode,
- cleanup,
- NatsServer,
-} from "../../test_helpers/mod.ts";
+import { _setup, assertErrorCode, cleanup, NatsServer } from "test_helpers";
 import {
  assert,
  assertArrayIncludes,

core/tests/authenticator_test.ts

@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 import { connect } from "./connect.ts";
 
 import {
@@ -28,7 +28,12 @@ import {
  tokenAuthenticator,
  usernamePasswordAuthenticator,
 } from "../src/internal_mod.ts";
-import type { NatsConnectionImpl, Auth, Authenticator, NatsConnection } from "../src/internal_mod.ts";
+import type {
+ Auth,
+ Authenticator,
+ NatsConnection,
+ NatsConnectionImpl,
+} from "../src/internal_mod.ts";
 
 import { assertEquals } from "jsr:@std/assert";
 import {
@@ -37,7 +42,7 @@ import {
  encodeUser,
  fmtCreds,
 } from "jsr:@nats-io/[email protected]";
-import { assertBetween } from "../../test_helpers/mod.ts";
+import { assertBetween } from "test_helpers";
 
 function disconnectReconnect(nc: NatsConnection): Promise<void> {
  const done = deferred<void>();

core/tests/autounsub_test.ts

@@ -16,7 +16,7 @@ import { assert, assertEquals } from "jsr:@std/assert";
 
 import { createInbox, Empty, ErrorCode } from "../src/internal_mod.ts";
 import type { NatsConnectionImpl, Subscription } from "../src/internal_mod.ts";
-import { _setup, cleanup, Lock } from "../../test_helpers/mod.ts";
+import { _setup, cleanup, Lock } from "test_helpers";
 import { connect } from "./connect.ts";
 
 Deno.test("autounsub - max option", async () => {

core/tests/basics_test.ts

@@ -45,11 +45,11 @@ import type {
  Msg,
  MsgHdrs,
  NatsConnectionImpl,
+ NatsError,
  Payload,
  Publisher,
  PublishOptions,
  SubscriptionImpl,
- NatsError,
 } from "../src/internal_mod.ts";
 import {
  _setup,
@@ -58,7 +58,7 @@ import {
  disabled,
  Lock,
  NatsServer,
-} from "../../test_helpers/mod.ts";
+} from "test_helpers";
 import { connect } from "./connect.ts";
 
 Deno.test("basics - connect port", async () => {
@@ -1207,7 +1207,7 @@ Deno.test("basics - msg typed payload", async () => {
  const nc = await connect({ port: ns.port });
 
  nc.subscribe("echo", {
- callback: (_err: Error|null, msg: Msg) => {
+ callback: (_err: Error | null, msg: Msg) => {
  msg.respond(msg.data);
  },
  });
@@ -1423,12 +1423,11 @@ Deno.test("basics - respond message", async () => {
  await cleanup(ns, nc);
 });
 
-
 Deno.test("basics - resolve", async () => {
  const token = Deno.env.get("NGS_CI_USER");
  if (token === undefined) {
  disabled(
-  `skipping: NGS_CI_USER is not available in the environment`,
+ `skipping: NGS_CI_USER is not available in the environment`,
  );
  return;
  }

core/tests/binary_test.ts

@@ -16,7 +16,7 @@
 import { assertEquals } from "jsr:@std/assert";
 import { createInbox, deferred } from "../src/internal_mod.ts";
 import type { Msg } from "../src/internal_mod.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 import { connect } from "./connect.ts";
 
 function macro(input: Uint8Array) {

core/tests/buffer_test.ts

@@ -8,7 +8,12 @@
 // in a browser environment
 
 import { assert, assertEquals, assertThrows } from "jsr:@std/assert";
-import { DenoBuffer, MAX_SIZE, readAll, writeAll } from "../src/internal_mod.ts";
+import {
+ DenoBuffer,
+ MAX_SIZE,
+ readAll,
+ writeAll,
+} from "../src/internal_mod.ts";
 
 // N controls how many iterations of certain checks are performed.
 const N = 100;

core/tests/disconnect_test.ts

@@ -14,7 +14,7 @@
  */
 
 import { connect } from "./connect.ts";
-import { Lock, NatsServer } from "../../test_helpers/mod.ts";
+import { Lock, NatsServer } from "test_helpers";
 import type { NatsConnectionImpl } from "../src/internal_mod.ts";
 
 Deno.test("disconnect - close handler is called on close", async () => {

core/tests/drain_test.ts

@@ -13,18 +13,14 @@
  * limitations under the License.
  */
 import { assert, assertEquals, fail } from "jsr:@std/assert";
-import {
- createInbox,
- ErrorCode,
- StringCodec,
-} from "../src/internal_mod.ts";
+import { createInbox, ErrorCode, StringCodec } from "../src/internal_mod.ts";
 import type { Msg } from "../src/internal_mod.ts";
 import {
  assertThrowsAsyncErrorCode,
  assertThrowsErrorCode,
  Lock,
-} from "../../test_helpers/mod.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+} from "test_helpers";
+import { _setup, cleanup } from "test_helpers";
 import { connect } from "./connect.ts";
 
 Deno.test("drain - connection drains when no subs", async () => {

core/tests/events_test.ts

@@ -12,12 +12,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { Lock, NatsServer, ServerSignals } from "../../test_helpers/mod.ts";
+import { Lock, NatsServer, ServerSignals } from "test_helpers";
 import { connect } from "./connect.ts";
 import { assertEquals } from "jsr:@std/assert";
-import { delay, Events } from "../src/internal_mod.ts";
-import type { NatsConnectionImpl, ServersChanged } from "../src/internal_mod.ts";
-import { _setup } from "../../test_helpers/mod.ts";
+import { delay, Events } from "../src/internal_mod.ts";
+import type {
+ NatsConnectionImpl,
+ ServersChanged,
+} from "../src/internal_mod.ts";
+import { _setup } from "test_helpers";
 
 Deno.test("events - close on close", async () => {
  const { ns, nc } = await _setup(connect);

core/tests/headers_test.ts

@@ -33,7 +33,7 @@ import type {
 import { NatsServer } from "../../test_helpers/launcher.ts";
 import { assert, assertEquals, assertThrows } from "jsr:@std/assert";
 import { TestDispatcher } from "./parser_test.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 
 Deno.test("headers - illegal key", () => {
  const h = headers();

core/tests/heartbeats_test.ts

@@ -20,7 +20,7 @@ import {
  delay,
  Heartbeat,
 } from "../src/internal_mod.ts";
-import type { Status, PH } from "../src/internal_mod.ts";
+import type { PH, Status } from "../src/internal_mod.ts";
 
 function pm(
  lag: number,

core/tests/iterators_test.ts

@@ -14,7 +14,7 @@
  */
 import { connect } from "./connect.ts";
 import { assert, assertEquals, assertRejects } from "jsr:@std/assert";
-import { assertErrorCode, Lock, NatsServer } from "../../test_helpers/mod.ts";
+import { assertErrorCode, Lock, NatsServer } from "test_helpers";
 import {
  createInbox,
  delay,
@@ -24,7 +24,7 @@ import {
  syncIterator,
 } from "../src/internal_mod.ts";
 import type { NatsConnectionImpl } from "../src/internal_mod.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 
 Deno.test("iterators - unsubscribe breaks and closes", async () => {
  const { ns, nc } = await _setup(connect);

core/tests/json_test.ts

@@ -14,15 +14,11 @@
  */
 import { connect } from "./connect.ts";
 import { assertEquals } from "jsr:@std/assert";
-import {
- createInbox,
- ErrorCode,
- JSONCodec,
-} from "../src/internal_mod.ts";
+import { createInbox, ErrorCode, JSONCodec } from "../src/internal_mod.ts";
 import type { Msg, NatsError } from "../src/internal_mod.ts";
-import { Lock } from "../../test_helpers/mod.ts";
+import { Lock } from "test_helpers";
 import { assertThrowsErrorCode } from "../../test_helpers/asserts.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 
 Deno.test("json - bad json error in callback", () => {
  const o = {};

core/tests/mrequest_test.ts

@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 import { connect } from "./connect.ts";
 import type { NatsConnectionImpl } from "../src/internal_mod.ts";
 import {

core/tests/noresponders_test.ts

@@ -14,13 +14,8 @@
  */
 
 import { connect } from "./connect.ts";
-import {
- createInbox,
- Empty,
- ErrorCode,
- headers,
-} from "@nats-io/nats-core";
-import { assertErrorCode, Lock, NatsServer } from "../../test_helpers/mod.ts";
+import { createInbox, Empty, ErrorCode, headers } from "@nats-io/nats-core";
+import { assertErrorCode, Lock, NatsServer } from "test_helpers";
 import { assert, assertEquals, fail } from "jsr:@std/assert";
 
 Deno.test("noresponders - option", async () => {

core/tests/protocol_test.ts

@@ -23,7 +23,7 @@ import {
  Subscriptions,
 } from "../src/internal_mod.ts";
 import type { Msg, ProtocolHandler } from "../src/internal_mod.ts";
-import { assertErrorCode } from "../../test_helpers/mod.ts";
+import { assertErrorCode } from "test_helpers";
 import { assertEquals, equal } from "jsr:@std/assert";
 
 Deno.test("protocol - mux subscription unknown return null", async () => {

core/tests/queues_test.ts

@@ -17,7 +17,7 @@ import { createInbox } from "../src/internal_mod.ts";
 import type { Subscription } from "../src/internal_mod.ts";
 import { assertEquals } from "jsr:@std/assert";
 import { connect } from "./connect.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 
 Deno.test("queues - deliver to single queue", async () => {
  const { ns, nc } = await _setup(connect);

core/tests/reconnect_test.ts

@@ -14,7 +14,7 @@
  */
 import { assert, assertEquals, fail } from "jsr:@std/assert";
 import { connect } from "./connect.ts";
-import { assertErrorCode, Lock, NatsServer } from "../../test_helpers/mod.ts";
+import { assertErrorCode, Lock, NatsServer } from "test_helpers";
 import {
  createInbox,
  DataBuffer,
@@ -27,7 +27,7 @@ import {
 } from "../src/internal_mod.ts";
 import type { NatsConnectionImpl, NatsError } from "../src/internal_mod.ts";
 
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 import { deadline } from "jsr:@std/async";
 
 Deno.test("reconnect - should receive when some servers are invalid", async () => {

core/tests/resub_test.ts

@@ -14,7 +14,7 @@
  */
 
 import { connect } from "./connect.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 import { createInbox } from "../src/internal_mod.ts";
 import type {
  Msg,

core/tests/semver_test.ts

@@ -13,7 +13,12 @@
  * limitations under the License.
  */
 
-import { compare, Feature, Features, parseSemVer } from "../src/internal_mod.ts";
+import {
+ compare,
+ Feature,
+ Features,
+ parseSemVer,
+} from "../src/internal_mod.ts";
 import {
  assert,
  assertEquals,

core/tests/sub_extensions_test.ts

@@ -16,7 +16,7 @@ import { assert, assertEquals } from "jsr:@std/assert";
 import { createInbox, deferred, StringCodec } from "../src/internal_mod.ts";
 import type { Msg, SubscriptionImpl } from "../src/internal_mod.ts";
 import { connect } from "./connect.ts";
-import { _setup, cleanup } from "../../test_helpers/mod.ts";
+import { _setup, cleanup } from "test_helpers";
 
 Deno.test("extensions - cleanup fn called at auto unsub", async () => {
  const { ns, nc } = await _setup(connect);

core/tests/tls_test.ts

@@ -21,12 +21,7 @@ import {
 import { connect } from "./connect.ts";
 import { ErrorCode } from "../src/internal_mod.ts";
 import type { NatsConnectionImpl } from "../src/internal_mod.ts";
-import {
- assertErrorCode,
- cleanup,
- Lock,
- NatsServer,
-} from "../../test_helpers/mod.ts";
+import { assertErrorCode, cleanup, Lock, NatsServer } from "test_helpers";
 
 Deno.test("tls - fail if server doesn't support TLS", async () => {
  const ns = await NatsServer.start();