.github/workflows/test.yml

@@ -16,7 +16,7 @@ jobs:
 
     strategy:
       matrix:
-        deno-version: [1.4.0]
+        deno-version: [1.4.2]
 
     steps:
       - name: Git Checkout Deno Module

examples/bench.js

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.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.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.0/flags/mod.ts";
 import { ConnectionOptions, connect } 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.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.0/flags/mod.ts";
 import { ConnectionOptions, connect, StringCodec } from "../src/mod.ts";
 import { headers, MsgHdrs } from "../nats-base-client/mod.ts";
 import { delay } from "../nats-base-client/internal_mod.ts";

examples/nats-rep.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.0/flags/mod.ts";
 import { ConnectionOptions, connect, StringCodec } from "../src/mod.ts";
 import { headers } from "../nats-base-client/mod.ts";
 

examples/nats-req.ts

@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.0/flags/mod.ts";
 import { ConnectionOptions, connect, StringCodec } from "../src/mod.ts";
 import { delay } from "../nats-base-client/internal_mod.ts";
 

examples/nats-sub.ts

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

nats-base-client/protocol.ts

@@ -69,21 +69,38 @@ export class Connect {
   echo?: boolean;
   no_responders?: boolean;
   protocol: number = 1;
+  verbose?: boolean;
+  pedantic?: boolean;
+  jwt?: string;
+  nkey?: string;
+  sig?: string;
+  user?: string;
+  pass?: string;
+  auth_token?: string;
+  tls_required?: boolean;
+  name?: string;
+  lang: string;
+  version: string;
+  headers?: boolean;
 
   constructor(
     transport: { version: string; lang: string },
     opts: ConnectionOptions,
     nonce?: string,
   ) {
-    if (opts.noEcho) {
-      this.echo = false;
-    }
-    if (opts.noResponders) {
-      this.no_responders = true;
-    }
+    this.version = transport.version;
+    this.lang = transport.lang;
+    this.echo = opts.noEcho ? false : undefined;
+    this.no_responders = opts.noResponders ? true : undefined;
+    this.verbose = opts.verbose;
+    this.pedantic = opts.pedantic;
+    this.tls_required = opts.tls ? true : undefined;
+    this.name = opts.name;
+    this.headers = opts.headers;
+
     const creds =
       (opts && opts.authenticator ? opts.authenticator(nonce) : {}) || {};
-    extend(this, opts, transport, creds);
+    extend(this, creds);
   }
 }
 

src/deno_transport.ts

@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { BufWriter } from "https://deno.land/std@0.69.0/io/mod.ts";
-import { Deferred, deferred } from "https://deno.land/std@0.69.0/async/mod.ts";
+import { BufWriter } from "https://deno.land/std@0.71.0/io/mod.ts";
+import { Deferred, deferred } from "https://deno.land/std@0.71.0/async/mod.ts";
 import Conn = Deno.Conn;
 import {
   ConnectionOptions,
@@ -30,7 +30,7 @@ import {
 } from "../nats-base-client/internal_mod.ts";
 import type { TlsOptions } from "../nats-base-client/types.ts";
 
-const VERSION = "1.0.0-8";
+const VERSION = "1.0.0-9";
 const LANG = "nats.deno";
 
 // if trying to simply write to the connection for some reason

tests/auth_test.ts

@@ -15,7 +15,7 @@
 
 import {
   fail,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import {
   connect,
   ErrorCode,

tests/autounsub_test.ts

@@ -14,7 +14,7 @@
  */
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 import {
   ErrorCode,

tests/basics_test.ts

@@ -16,7 +16,7 @@ import {
   assert,
   assertEquals,
   fail,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import {
   connect,
   Msg,

tests/binary_test.ts

@@ -15,7 +15,7 @@
 
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import {
   connect,
   Msg,

tests/buffer_test.ts

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

tests/clobber_test.ts

@@ -21,7 +21,7 @@ import {
 import { connect } from "../src/mod.ts";
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 function makeBuffer(N: number): Uint8Array {
   const buf = new Uint8Array(N);

tests/codec_test.ts

@@ -15,7 +15,7 @@
 import { StringCodec, JSONCodec } from "../nats-base-client/codec.ts";
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 Deno.test("codec - string", () => {
   const sc = StringCodec();

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.69.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import { DataBuffer } from "../nats-base-client/internal_mod.ts";
 
 Deno.test("databuffer - empty", () => {

tests/doublesubs_test.ts

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

tests/drain_test.ts

@@ -19,7 +19,7 @@ import {
   assertThrows,
   assertThrowsAsync,
   fail,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import {
   connect,
   createInbox,

tests/events_test.ts

@@ -2,7 +2,7 @@ import { NatsServer, Lock, ServerSignals } from "../tests/helpers/mod.ts";
 import { connect, Events, ServersChanged } from "../src/mod.ts";
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import { delay, NatsConnectionImpl } from "../nats-base-client/internal_mod.ts";
 
 Deno.test("events - close on close", async () => {

tests/headers_test.ts

@@ -14,7 +14,7 @@ import {
   assertArrayContains,
   assert,
   fail,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 Deno.test("headers - option", async () => {
   const srv = await NatsServer.start();

tests/heartbeats_test.ts

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

tests/helpers/asserts.ts

@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-import { assert, fail } from "https://deno.land/std@0.69.0/testing/asserts.ts";
+import { assert, fail } from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 export function assertErrorCode(err: Error, ...codes: string[]) {
   const { code } = err as { code?: string };

tests/helpers/cluster.ts

@@ -16,7 +16,7 @@
 import {
   NatsServer,
 } from "./mod.ts";
-import { parse } from "https://deno.land/std@0.69.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.71.0/flags/mod.ts";
 
 const defaults = {
   c: 2,

tests/helpers/conf_test.ts

@@ -14,7 +14,7 @@
  */
 
 import { toConf } from "./launcher.ts";
-import { assertEquals } from "https://deno.land/std@0.69.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 Deno.test("conf - serializing simple", () => {
   let x = {

tests/helpers/launcher.ts

@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import * as path from "https://deno.land/std@0.69.0/path/mod.ts";
+import * as path from "https://deno.land/std@0.71.0/path/mod.ts";
 import { check } from "./mod.ts";
 import {
   deferred,
@@ -21,7 +21,7 @@ import {
   nuid,
   Deferred,
 } from "../../nats-base-client/internal_mod.ts";
-import { assert } from "https://deno.land/std@0.69.0/testing/asserts.ts";
+import { assert } from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 export const ServerSignals = Object.freeze({
   QUIT: Deno.Signal.SIGQUIT,

tests/iterators_test.ts

@@ -15,7 +15,7 @@
 import { connect, createInbox, ErrorCode, NatsError } from "../src/mod.ts";
 import {
   assertEquals,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import { assertErrorCode, Lock, NatsServer } from "./helpers/mod.ts";
 import { assert } from "../nats-base-client/denobuffer.ts";
 

tests/json_test.ts

@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-import { assertEquals } from "https://deno.land/std@0.69.0/testing/asserts.ts";
+import { assertEquals } from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import {
   connect,
   createInbox,

tests/msgheaders_test.ts

@@ -17,7 +17,7 @@ import {
   assertEquals,
   assertThrows,
   assertArrayContains,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import { NatsError, MsgHdrsImpl } from "../nats-base-client/internal_mod.ts";
 
 Deno.test("msgheaders - basics", () => {

tests/noresponders_test.ts

@@ -19,7 +19,7 @@ import {
   assertEquals,
   assert,
   fail,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 
 Deno.test("noresponders - option", async () => {
   const srv = await NatsServer.start();

tests/parser_test.ts

@@ -30,7 +30,7 @@ import {
   assertEquals,
   assertThrows,
   assert,
-} from "https://deno.land/std@0.69.0/testing/asserts.ts";
+} from "https://deno.land/std@0.71.0/testing/asserts.ts";
 import type { Publisher } from "../nats-base-client/protocol.ts";
 
 let te = new TextEncoder();