[UPDATE] updated deno stand to 0.125.0

[CHORE] had to change all assertThrows, assertThrowsAsync with the new apis provided by deno

bin/exports.ts

@@ -1,10 +1,10 @@
-import { parse } from "https://deno.land/std@0.103.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import {
   basename,
   extname,
   join,
   resolve,
-} from "https://deno.land/std@0.103.0/path/mod.ts";
+} from "https://deno.land/std@0.125.0/path/mod.ts";
 
 const argv = parse(
   Deno.args,

dependencies.md

@@ -2,7 +2,7 @@
 
 This file lists the dependencies used in this repository.
 
-| Dependency                                | License     |
-| ----------------------------------------- | ----------- |
-| https://deno.land/std@0.95.0/flags/mod.ts | MIT License |
-| http://github.com/nats-io/nkeys.js        | Apache-2.0  |
+| Dependency                                 | License     |
+| ------------------------------------------ | ----------- |
+| https://deno.land/std@0.125.0/flags/mod.ts | MIT License |
+| http://github.com/nats-io/nkeys.js         | Apache-2.0  |

examples/bench.js

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import { connect, Nuid } from "../src/mod.ts";
 import { Bench, Metric } from "../nats-base-client/bench.ts";
 const defaults = {

examples/nats-events.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import { connect, ConnectionOptions } from "../src/mod.ts";
 
 const argv = parse(

examples/nats-pub.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

examples/nats-rep.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

examples/nats-req.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

examples/nats-sub.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.95.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.125.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

src/deno_transport.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { BufWriter } from "https://deno.land/std@0.95.0/io/mod.ts";
-import { Deferred, deferred } from "https://deno.land/std@0.95.0/async/mod.ts";
+import { BufWriter } from "https://deno.land/std@0.125.0/io/mod.ts";
+import { Deferred, deferred } from "https://deno.land/std@0.125.0/async/mod.ts";
 import Conn = Deno.Conn;
 import {
   checkOptions,

tests/auth_test.ts

@@ -16,7 +16,7 @@
 import {
   assertEquals,
   fail,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import {
   connect,
   credsAuthenticator,

tests/autounsub_test.ts

@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 
 import { createInbox, Empty, ErrorCode, Subscription } from "../src/mod.ts";
 import { Lock } from "./helpers/mod.ts";

tests/basics_test.ts

@@ -15,10 +15,13 @@
 import {
   assert,
   assertEquals,
+  assertRejects,
   assertThrows,
-  assertThrowsAsync,
   fail,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
+
+import { assertThrowsAsyncErrorCode } from "./helpers/asserts.ts";
+
 import {
   connect,
   createInbox,
@@ -363,21 +366,19 @@ Deno.test("basics - request", async () => {
 Deno.test("basics - request no responders", async () => {
   const { ns, nc } = await setup();
   const s = createInbox();
-  const err = await assertThrowsAsync(async () => {
+  await assertThrowsAsyncErrorCode(async () => {
     await nc.request(s, Empty, { timeout: 100 });
-  });
-  assertErrorCode(err, ErrorCode.NoResponders);
+  }, ErrorCode.NoResponders);
   await cleanup(ns, nc);
 });
 
 Deno.test("basics - request timeout", async () => {
   const { ns, nc } = await setup();
   const s = createInbox();
   nc.subscribe(s, { callback: () => {} });
-  const err = await assertThrowsAsync(async () => {
+  await assertThrowsAsyncErrorCode(async () => {
     await nc.request(s, Empty, { timeout: 100 });
-  });
-  assertErrorCode(err, ErrorCode.Timeout);
+  }, ErrorCode.Timeout);
   await cleanup(ns, nc);
 });
 
@@ -449,13 +450,14 @@ Deno.test("basics - request with custom subject", async () => {
 
 Deno.test("basics - request requires a subject", async () => {
   const { ns, nc } = await setup();
-  await assertThrowsAsync(
+  await assertRejects(
     async () => {
       //@ts-ignore: subject missing on purpose
       await nc.request();
     },
     NatsError,
     "BAD_SUBJECT",
+    undefined,
   );
   await cleanup(ns, nc);
 });
@@ -867,11 +869,12 @@ Deno.test("basics - resolve", async () => {
 });
 
 Deno.test("basics - port and server are mutually exclusive", async () => {
-  await assertThrowsAsync(
+  await assertRejects(
     async () => {
       await connect({ servers: "localhost", port: 4222 });
     },
     NatsError,
     "port and servers options are mutually exclusive",
+    undefined,
   );
 });

tests/bench_test.ts

@@ -16,7 +16,7 @@ import {
   assert,
   assertEquals,
   assertThrows,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import { Bench, connect, createInbox } from "../src/mod.ts";
 import { BenchOpts, Metric } from "../nats-base-client/bench.ts";
 

tests/binary_test.ts

@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import { createInbox, Msg } from "../src/mod.ts";
 import { deferred } from "../nats-base-client/internal_mod.ts";
 import { cleanup, setup } from "./jstest_util.ts";

tests/buffer_test.ts

@@ -11,7 +11,7 @@ import {
   assert,
   assertEquals,
   assertThrows,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import {
   DenoBuffer,
   MAX_SIZE,

tests/clobber_test.ts

@@ -16,7 +16,7 @@
 import { NatsServer } from "./helpers/launcher.ts";
 import { createInbox, DataBuffer } from "../nats-base-client/internal_mod.ts";
 import { connect } from "../src/mod.ts";
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 
 function makeBuffer(N: number): Uint8Array {
   const buf = new Uint8Array(N);

tests/codec_test.ts

@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 import { JSONCodec, StringCodec } from "../nats-base-client/codec.ts";
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 
 Deno.test("codec - string", () => {
   const sc = StringCodec();

tests/consumeropts_test.ts

@@ -17,7 +17,7 @@ import {
   assert,
   assertEquals,
   assertThrows,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 
 import {
   consumerOpts,

tests/databuffer_test.ts

@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import { DataBuffer } from "../nats-base-client/internal_mod.ts";
 
 Deno.test("databuffer - empty", () => {

tests/doublesubs_test.ts

@@ -25,9 +25,9 @@ import {
 import {
   assertArrayIncludes,
   assertEquals,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import { extend } from "../nats-base-client/util.ts";
-import { join, resolve } from "https://deno.land/std@0.95.0/path/mod.ts";
+import { join, resolve } from "https://deno.land/std@0.125.0/path/mod.ts";
 
 async function runDoubleSubsTest(tls: boolean) {
   const cwd = Deno.cwd();

tests/drain_test.ts

@@ -17,9 +17,11 @@ import {
   assert,
   assertEquals,
   assertThrows,
-  assertThrowsAsync,
   fail,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
+import {
+  assertThrowsAsyncErrorCode,
+} from "./helpers/asserts.ts";
 import {
   connect,
   createInbox,
@@ -126,14 +128,15 @@ Deno.test("drain - publish after drain fails", async () => {
   nc.subscribe(subj);
   await nc.drain();
 
-  const err = assertThrows(() => {
+  assertThrows(() => {
     nc.publish(subj);
+  }, (err: Error) => {
+    assertErrorCode(
+      err,
+      ErrorCode.ConnectionClosed,
+      ErrorCode.ConnectionDraining,
+    );
   });
-  assertErrorCode(
-    err,
-    ErrorCode.ConnectionClosed,
-    ErrorCode.ConnectionDraining,
-  );
   await ns.stop();
 });
 
@@ -187,21 +190,19 @@ Deno.test("drain - reject reqrep during connection drain", async () => {
 Deno.test("drain - reject drain on closed", async () => {
   const { ns, nc } = await setup();
   await nc.close();
-  const err = await assertThrowsAsync(async () => {
+  await assertThrowsAsyncErrorCode(async () => {
     await nc.drain();
-  });
-  assertErrorCode(err, ErrorCode.ConnectionClosed);
+  }, ErrorCode.ConnectionClosed);
   await ns.stop();
 });
 
 Deno.test("drain - reject drain on draining", async () => {
   const { ns, nc } = await setup();
   const done = nc.drain();
-  const err = await assertThrowsAsync(() => {
+  await assertThrowsAsyncErrorCode(() => {
     return nc.drain();
-  });
+  }, ErrorCode.ConnectionDraining);
   await done;
-  assertErrorCode(err, ErrorCode.ConnectionDraining);
   await ns.stop();
 });
 
@@ -219,11 +220,10 @@ Deno.test("drain - reject subscription drain on closed sub", async () => {
   const { ns, nc } = await setup();
   const sub = nc.subscribe("foo");
   sub.unsubscribe();
-  const err = await assertThrowsAsync(() => {
+  await assertThrowsAsyncErrorCode(() => {
     return sub.drain();
-  });
+  }, ErrorCode.SubClosed);
   await nc.close();
-  assertErrorCode(err, ErrorCode.SubClosed);
   await ns.stop();
 });
 
@@ -239,10 +239,9 @@ Deno.test("drain - reject subscription drain on closed", async () => {
   const { ns, nc } = await setup();
   const sub = nc.subscribe("foo");
   await nc.close();
-  const err = await assertThrowsAsync(() => {
+  await assertThrowsAsyncErrorCode(() => {
     return sub.drain();
-  });
-  assertErrorCode(err, ErrorCode.ConnectionClosed);
+  }, ErrorCode.ConnectionClosed);
   await ns.stop();
 });
 

tests/events_test.ts

@@ -14,7 +14,7 @@
  */
 import { Lock, NatsServer, ServerSignals } from "../tests/helpers/mod.ts";
 import { connect, Events, ServersChanged } from "../src/mod.ts";
-import { assertEquals } from "https://deno.land/std@0.95.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import { delay, NatsConnectionImpl } from "../nats-base-client/internal_mod.ts";
 import { setup } from "./jstest_util.ts";
 

tests/headers_test.ts

@@ -29,7 +29,7 @@ import {
   assert,
   assertEquals,
   assertThrows,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 import {
   MsgHdrsImpl,
   MsgImpl,

tests/heartbeats_test.ts

@@ -16,7 +16,7 @@ import {
   assert,
   assertEquals,
   fail,
-} from "https://deno.land/std@0.95.0/testing/asserts.ts";
+} from "https://deno.land/std@0.125.0/testing/asserts.ts";
 
 import {
   DebugEvents,