[BUMP] deno to 1.42.1, and std to 0.221.0

nats-io · Apr 3, 2024 · d32538f · d32538f
1 parent 88face5
commit d32538f
Show file tree

Hide file tree

Showing 74 changed files with 114 additions and 104 deletions.
diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml
@@ -16,7 +16,7 @@ jobs:
     environment: CI
     strategy:
       matrix:
-        deno-version: [1.41.3]
+        deno-version: [1.42.1]
 
     steps:
       - name: Git Checkout Deno Module

diff --git a/Makefile b/Makefile
@@ -5,7 +5,7 @@ export DENO_JOBS=4
 build: test
 
 lint:
-	deno lint --unstable --ignore=docs/
+	deno lint --ignore=docs/
 
 test: clean
 	deno test --allow-all --unstable --parallel --reload --quiet --coverage=coverage tests/ jetstream/tests

diff --git a/bin/dependencies.ts b/bin/dependencies.ts
@@ -17,7 +17,7 @@ import {
   extname,
   join,
   resolve,
-} from "https://deno.land/std@0.200.0/path/mod.ts";
+} from "https://deno.land/std@0.221.0/path/mod.ts";
 
 // resolve the specified directories to fq
 // let dirs = ["src", "nats-base-client", "jetstream", "bin"].map((n) => {

diff --git a/bin/exports.ts b/bin/exports.ts
@@ -13,13 +13,13 @@
  * limitations under the License.
  */
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import {
   basename,
   extname,
   join,
   resolve,
-} from "https://deno.land/std@0.200.0/path/mod.ts";
+} from "https://deno.land/std@0.221.0/path/mod.ts";
 
 const argv = parse(
   Deno.args,

diff --git a/bin/fix-os.ts b/bin/fix-os.ts
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import { ObjectStoreImpl, ServerObjectInfo } from "../jetstream/objectstore.ts";
 import {
   connect,

diff --git a/dependencies.md b/dependencies.md
@@ -4,7 +4,7 @@ This file lists the dependencies used in this repository.
 
 | Dependency                           | License     |
 | ------------------------------------ | ----------- |
-| https://deno.land/std@0.200.0        | MIT License |
+| https://deno.land/std@0.221.0        | MIT License |
 | https://deno.land/x/cobra            | MIT License |
 | https://deno.land/x/progress         | MIT License |
 | https://deno.land/x/emit             | MIT License |

diff --git a/examples/bench.js b/examples/bench.js
@@ -1,5 +1,5 @@
 #!/usr/bin/env deno run --allow-all --unstable
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import { Bench, connect, Metric, Nuid } from "../src/mod.ts";
 const defaults = {
   s: "127.0.0.1:4222",

diff --git a/examples/nats-events.ts b/examples/nats-events.ts
@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import { connect, ConnectionOptions } from "../src/mod.ts";
 
 const argv = parse(

diff --git a/examples/nats-pub.ts b/examples/nats-pub.ts
@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

diff --git a/examples/nats-rep.ts b/examples/nats-rep.ts
@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

diff --git a/examples/nats-req.ts b/examples/nats-req.ts
@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

diff --git a/examples/nats-sub.ts b/examples/nats-sub.ts
@@ -1,6 +1,6 @@
 #!/usr/bin/env deno run --allow-all --unstable
 
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import {
   connect,
   ConnectionOptions,

diff --git a/examples/services/01_services.ts b/examples/services/01_services.ts
@@ -23,7 +23,7 @@ import {
   ServiceMsg,
   ServiceStats,
 } from "../../src/mod.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/mod.ts";
+import { assertEquals } from "https://deno.land/std@0.221.0/assert/mod.ts";
 
 // connect to NATS on demo.nats.io
 const nc = await connect({ servers: ["demo.nats.io"] });

diff --git a/examples/services/03_bigdata-client.ts b/examples/services/03_bigdata-client.ts
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { parse } from "https://deno.land/std@0.200.0/flags/mod.ts";
+import { parse } from "https://deno.land/std@0.221.0/flags/mod.ts";
 import { connect, ConnectionOptions, RequestStrategy } from "../../src/mod.ts";
 import { humanizeBytes } from "./03_util.ts";
 

diff --git a/jetstream/tests/consumeropts_test.ts b/jetstream/tests/consumeropts_test.ts
@@ -17,7 +17,7 @@ import {
   assert,
   assertEquals,
   assertThrows,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 
 import {
   ConsumerOpts,

diff --git a/jetstream/tests/consumers_consume_test.ts b/jetstream/tests/consumers_consume_test.ts
@@ -24,7 +24,7 @@ import {
   assertEquals,
   assertExists,
   assertRejects,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { consumerHbTest } from "./consumers_test.ts";
 import { initStream } from "./jstest_util.ts";
 import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts";

diff --git a/jetstream/tests/consumers_fetch_test.ts b/jetstream/tests/consumers_fetch_test.ts
@@ -20,15 +20,17 @@ import {
 } from "../../tests/helpers/mod.ts";
 import { initStream } from "./jstest_util.ts";
 import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts";
+import {
+  assertEquals,
+  assertExists,
+  assertRejects,
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
 import { StringCodec } from "../../nats-base-client/codec.ts";
 import { delay } from "../../nats-base-client/util.ts";
-import { assertRejects } from "https://deno.land/std@0.200.0/assert/assert_rejects.ts";
 import { nanos } from "../jsutil.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
 import { syncIterator } from "../../nats-base-client/core.ts";
-import { assertExists } from "https://deno.land/std@0.200.0/assert/assert_exists.ts";
 import { PullConsumerMessagesImpl } from "../consumer.ts";
 
 Deno.test("consumers - fetch no messages", async () => {

diff --git a/jetstream/tests/consumers_next_test.ts b/jetstream/tests/consumers_next_test.ts
@@ -20,10 +20,12 @@ import {
 } from "../../tests/helpers/mod.ts";
 import { initStream } from "./jstest_util.ts";
 import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts";
+import {
+  assertEquals,
+  assertRejects,
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { nanos } from "../jsutil.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
-import { assertRejects } from "https://deno.land/std@0.200.0/assert/assert_rejects.ts";
 import { delay } from "../../nats-base-client/util.ts";
 
 Deno.test("consumers - next", async () => {

diff --git a/jetstream/tests/consumers_ordered_test.ts b/jetstream/tests/consumers_ordered_test.ts
@@ -19,7 +19,7 @@ import {
   assertExists,
   assertRejects,
   assertStringIncludes,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { DeliverPolicy, JsMsg } from "../mod.ts";
 import {
   OrderedConsumerMessages,

diff --git a/jetstream/tests/consumers_test.ts b/jetstream/tests/consumers_test.ts
@@ -18,7 +18,7 @@ import {
   assertExists,
   assertRejects,
   assertStringIncludes,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { deferred } from "../../nats-base-client/mod.ts";
 import {
   AckPolicy,

diff --git a/jetstream/tests/jetream409_test.ts b/jetstream/tests/jetream409_test.ts
@@ -28,7 +28,7 @@ import {
 import {
   assertRejects,
   assertStringIncludes,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { initStream } from "./jstest_util.ts";
 import {
   cleanup,

diff --git a/jetstream/tests/jetstream_fetchconsumer_test.ts b/jetstream/tests/jetstream_fetchconsumer_test.ts
@@ -21,13 +21,16 @@ import {
 } from "../../tests/helpers/mod.ts";
 import { initStream, time } from "./jstest_util.ts";
 import { AckPolicy, StorageType } from "../jsapi_types.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts";
+import {
+  assert,
+  assertEquals,
+  assertExists,
+  assertRejects,
+  assertThrows,
+  fail,
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
-import { assertThrows } from "https://deno.land/std@0.200.0/assert/assert_throws.ts";
-import { fail } from "https://deno.land/std@0.200.0/assert/fail.ts";
-import { assert } from "../../nats-base-client/denobuffer.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
-import { assertRejects } from "https://deno.land/std@0.200.0/assert/assert_rejects.ts";
 import {
   DebugEvents,
   Events,
@@ -37,7 +40,6 @@ import {
 import { Js409Errors } from "../jsutil.ts";
 import { nuid } from "../../nats-base-client/nuid.ts";
 import { deferred } from "../../nats-base-client/util.ts";
-import { assertExists } from "https://deno.land/std@0.200.0/assert/assert_exists.ts";
 import { consume } from "./jstest_util.ts";
 
 Deno.test("jetstream - fetch expires waits", async () => {

diff --git a/jetstream/tests/jetstream_pullconsumer_test.ts b/jetstream/tests/jetstream_pullconsumer_test.ts
@@ -28,9 +28,16 @@ import {
   DeliverPolicy,
   StorageType,
 } from "../jsapi_types.ts";
-import { assertRejects } from "https://deno.land/std@0.200.0/assert/assert_rejects.ts";
+import {
+  assert,
+  assertArrayIncludes,
+  assertEquals,
+  assertExists,
+  assertRejects,
+  assertThrows,
+  fail,
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts";
 import { checkJsError, nanos } from "../jsutil.ts";
 import { JSONCodec, StringCodec } from "../../nats-base-client/codec.ts";
 import {
@@ -39,7 +46,6 @@ import {
   JetStreamSubscriptionInfoable,
   PubAck,
 } from "../types.ts";
-import { assert } from "../../nats-base-client/denobuffer.ts";
 import { deferred, delay } from "../../nats-base-client/util.ts";
 import {
   DebugEvents,
@@ -48,15 +54,11 @@ import {
   NatsError,
   syncIterator,
 } from "../../nats-base-client/core.ts";
-import { fail } from "https://deno.land/std@0.200.0/assert/fail.ts";
 import { JsMsg } from "../jsmsg.ts";
 import { connect } from "../../src/connect.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
 import { JetStreamClientImpl } from "../jsclient.ts";
-import { assertThrows } from "https://deno.land/std@0.200.0/assert/assert_throws.ts";
 import { nuid } from "../../nats-base-client/nuid.ts";
-import { assertExists } from "https://deno.land/std@0.200.0/assert/assert_exists.ts";
-import { assertArrayIncludes } from "https://deno.land/std@0.200.0/assert/assert_array_includes.ts";
 import { callbackConsume } from "./jetstream_test.ts";
 
 Deno.test("jetstream - pull no messages", async () => {

diff --git a/jetstream/tests/jetstream_pushconsumer_test.ts b/jetstream/tests/jetstream_pushconsumer_test.ts
@@ -38,17 +38,22 @@ import {
   JsHeaders,
   PubAck,
 } from "../types.ts";
-import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts";
+import {
+  assert,
+  assertArrayIncludes,
+  assertEquals,
+  assertExists,
+  assertIsError,
+  assertRejects,
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { callbackConsume } from "./jetstream_test.ts";
-import { assertRejects } from "https://deno.land/std@0.200.0/assert/assert_rejects.ts";
 import {
   AckPolicy,
   DeliverPolicy,
   RetentionPolicy,
   StorageType,
 } from "../jsapi_types.ts";
 import { JSONCodec, StringCodec } from "../../nats-base-client/codec.ts";
-import { assert } from "../../nats-base-client/denobuffer.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
 import { deferred, delay } from "../../nats-base-client/util.ts";
 import { nuid } from "../../nats-base-client/nuid.ts";
@@ -61,9 +66,6 @@ import {
   nanos,
 } from "../jsutil.ts";
 import { JetStreamSubscriptionImpl } from "../jsclient.ts";
-import { assertIsError } from "https://deno.land/std@0.200.0/assert/assert_is_error.ts";
-import { assertExists } from "https://deno.land/std@0.200.0/assert/assert_exists.ts";
-import { assertArrayIncludes } from "https://deno.land/std@0.200.0/assert/assert_array_includes.ts";
 
 Deno.test("jetstream - ephemeral push", async () => {
   const { ns, nc } = await setup(jetstreamServerConf({}, true));

diff --git a/jetstream/tests/jetstream_test.ts b/jetstream/tests/jetstream_test.ts
@@ -52,7 +52,7 @@ import {
   assertRejects,
   assertThrows,
   fail,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 
 import { assert } from "../../nats-base-client/denobuffer.ts";
 import {

diff --git a/jetstream/tests/jsm_test.ts b/jetstream/tests/jsm_test.ts
@@ -20,7 +20,7 @@ import {
   assertRejects,
   assertThrows,
   fail,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
 import {

diff --git a/jetstream/tests/jsmsg_test.ts b/jetstream/tests/jsmsg_test.ts
@@ -16,7 +16,7 @@ import {
   assertEquals,
   assertRejects,
   fail,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import {
   AckPolicy,
   connect,

diff --git a/jetstream/tests/jstest_util.ts b/jetstream/tests/jstest_util.ts
@@ -21,7 +21,7 @@ import {
   QueuedIterator,
   StreamConfig,
 } from "../../src/mod.ts";
-import { assert } from "https://deno.land/std@0.200.0/assert/mod.ts";
+import { assert } from "https://deno.land/std@0.221.0/assert/mod.ts";
 import {
   Empty,
   NatsConnection,

diff --git a/jetstream/tests/kv_test.ts b/jetstream/tests/kv_test.ts
@@ -45,7 +45,7 @@ import {
   assertExists,
   assertRejects,
   assertThrows,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 
 import {
   Base64KeyCodec,

diff --git a/jetstream/tests/objectstore_test.ts b/jetstream/tests/objectstore_test.ts
@@ -25,12 +25,12 @@ import {
   assertExists,
   assertRejects,
   equal,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import { DataBuffer } from "../../nats-base-client/databuffer.ts";
-import { crypto } from "https://deno.land/std@0.200.0/crypto/mod.ts";
+import { crypto } from "https://deno.land/std@0.221.0/crypto/mod.ts";
 import { ObjectInfo, ObjectStoreMeta, StorageType } from "../mod.ts";
 import { Empty, headers, nanos, StringCodec } from "../../src/mod.ts";
-import { equals } from "https://deno.land/std@0.200.0/bytes/mod.ts";
+import { equals } from "https://deno.land/std@0.221.0/bytes/mod.ts";
 import { SHA256 } from "../../nats-base-client/sha256.js";
 import { Base64UrlPaddedCodec } from "../../nats-base-client/base64.ts";
 import { digestType } from "../objectstore.ts";

diff --git a/jetstream/tests/streams_test.ts b/jetstream/tests/streams_test.ts
@@ -20,7 +20,7 @@ import {
   assertEquals,
   assertExists,
   assertRejects,
-} from "https://deno.land/std@0.200.0/assert/mod.ts";
+} from "https://deno.land/std@0.221.0/assert/mod.ts";
 import {
   cleanup,
   jetstreamServerConf,

diff --git a/src/deno_transport.ts b/src/deno_transport.ts
@@ -18,7 +18,7 @@ import {
   deferred,
   TlsOptions,
 } from "../nats-base-client/internal_mod.ts";
-import { writeAll } from "https://deno.land/std@0.200.0/streams/write_all.ts";
+import { writeAll } from "https://deno.land/std@0.221.0/io/write_all.ts";
 import {
   checkOptions,
   checkUnsupportedOption,