Merge pull request #687 from nats-io/move-nanos

[CHANGE] moved `nanos()` and `millis()` to nats-base-client as they are referenced by the base library

.github/workflows/test.yml

@@ -30,7 +30,7 @@ jobs:
           deno-version: ${{ matrix.deno-version }}
 
       - name: Set NATS Server Version
-        run: echo "NATS_VERSION=v2.10.12" >> $GITHUB_ENV
+        run: echo "NATS_VERSION=v2.10.14" >> $GITHUB_ENV
 
       # this here because dns seems to be wedged on gha
 #      - name: Add hosts to /etc/hosts

jetstream/consumer.ts

@@ -16,12 +16,13 @@ import {
   backoff,
   deferred,
   delay,
+  nanos,
   Timeout,
   timeout,
 } from "../nats-base-client/util.ts";
 import { ConsumerAPI, ConsumerAPIImpl } from "./jsmconsumer_api.ts";
 import { nuid } from "../nats-base-client/nuid.ts";
-import { isHeartbeatMsg, nanos } from "./jsutil.ts";
+import { isHeartbeatMsg } from "./jsutil.ts";
 import { QueuedIteratorImpl } from "../nats-base-client/queued_iterator.ts";
 import {
   createInbox,

jetstream/internal_mod.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 The NATS Authors
+ * Copyright 2023-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -12,13 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-export {
-  checkJsError,
-  isFlowControlMsg,
-  isHeartbeatMsg,
-  millis,
-  nanos,
-} from "./jsutil.ts";
+export { checkJsError, isFlowControlMsg, isHeartbeatMsg } from "./jsutil.ts";
 
 export {
   AdvisoryKind,

jetstream/jsapi_types.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 The NATS Authors
+ * Copyright 2023-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -14,7 +14,8 @@
  */
 
 import { ApiError, Nanos } from "../nats-base-client/core.ts";
-import { nanos } from "./jsutil.ts";
+
+import { nanos } from "../nats-base-client/util.ts";
 
 export interface ApiPaged {
   total: number;

jetstream/jsclient.ts

@@ -21,8 +21,6 @@ import {
   isHeartbeatMsg,
   isTerminal409,
   Js409Errors,
-  millis,
-  nanos,
   newJsErrorMsg,
   validateDurableName,
   validateStreamName,
@@ -39,7 +37,13 @@ import {
   IngestionFilterFnResult,
   QueuedIteratorImpl,
 } from "../nats-base-client/queued_iterator.ts";
-import { delay, Timeout, timeout } from "../nats-base-client/util.ts";
+import {
+  delay,
+  millis,
+  nanos,
+  Timeout,
+  timeout,
+} from "../nats-base-client/util.ts";
 import { headers } from "../nats-base-client/headers.ts";
 import { Bucket } from "./kv.ts";
 import { Feature } from "../nats-base-client/semver.ts";

jetstream/jsmsg.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2021-2023 The NATS Authors
+ * Copyright 2021-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -17,10 +17,10 @@ import { JSONCodec, StringCodec } from "../nats-base-client/codec.ts";
 import { MsgImpl } from "../nats-base-client/msg.ts";
 import { ProtocolHandler } from "../nats-base-client/protocol.ts";
 import { RequestOne } from "../nats-base-client/request.ts";
-import { nanos } from "./jsutil.ts";
 import { Msg, MsgHdrs, RequestOptions } from "../nats-base-client/core.ts";
 import { DeliveryInfo, PullOptions } from "./jsapi_types.ts";
 import { deferred } from "../nats-base-client/mod.ts";
+import { nanos } from "../nats-base-client/util.ts";
 
 export const ACK = Uint8Array.of(43, 65, 67, 75);
 const NAK = Uint8Array.of(45, 78, 65, 75);

jetstream/jsutil.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2021-2023 The NATS Authors
+ * Copyright 2021-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -19,7 +19,6 @@ import { MsgImpl } from "../nats-base-client/msg.ts";
 import {
   ErrorCode,
   Msg,
-  Nanos,
   NatsError,
   Publisher,
 } from "../nats-base-client/core.ts";
@@ -89,22 +88,6 @@ export function validName(name = ""): string {
   return "";
 }
 
-/**
- * Converts the specified millis into Nanos
- * @param millis
- */
-export function nanos(millis: number): Nanos {
-  return millis * 1000000;
-}
-
-/**
- * Convert the specified Nanos into millis
- * @param ns
- */
-export function millis(ns: Nanos) {
-  return Math.floor(ns / 1000000);
-}
-
 /**
  * Returns true if the message is a flow control message
  * @param msg

jetstream/kv.ts

@@ -21,7 +21,6 @@ import {
   Payload,
   QueuedIterator,
 } from "../nats-base-client/core.ts";
-import { millis, nanos } from "./jsutil.ts";
 import { QueuedIteratorImpl } from "../nats-base-client/queued_iterator.ts";
 import { headers } from "../nats-base-client/headers.ts";
 import {
@@ -47,7 +46,7 @@ import {
   StoredMsg,
 } from "./types.ts";
 import { compare, Feature, parseSemVer } from "../nats-base-client/semver.ts";
-import { deferred } from "../nats-base-client/util.ts";
+import { deferred, millis, nanos } from "../nats-base-client/util.ts";
 import { Empty } from "../nats-base-client/encoders.ts";
 import {
   AckPolicy,

jetstream/mod.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 The NATS Authors
+ * Copyright 2023-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -16,8 +16,6 @@ export {
   checkJsError,
   isFlowControlMsg,
   isHeartbeatMsg,
-  millis,
-  nanos,
 } from "./internal_mod.ts";
 
 export {

jetstream/tests/consume_test.ts

@@ -28,8 +28,12 @@ import {
 } from "https://deno.land/[email protected]/assert/mod.ts";
 import { initStream } from "./jstest_util.ts";
 import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts";
-import { deadline, deferred, delay } from "../../nats-base-client/util.ts";
-import { nanos } from "../jsutil.ts";
+import {
+  deadline,
+  deferred,
+  delay,
+  nanos,
+} from "../../nats-base-client/util.ts";
 import {
   ConsumerEvents,
   ConsumerStatus,

jetstream/tests/consumers_test.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2022-2023 The NATS Authors
+ * Copyright 2022-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -19,13 +19,12 @@ import {
   assertRejects,
   assertStringIncludes,
 } from "https://deno.land/[email protected]/assert/mod.ts";
-import { deferred } from "../../nats-base-client/mod.ts";
+import { deferred, nanos } from "../../nats-base-client/mod.ts";
 import {
   AckPolicy,
   Consumer,
   ConsumerMessages,
   DeliverPolicy,
-  nanos,
   PullOptions,
 } from "../mod.ts";
 import { NatsServer } from "../../tests/helpers/launcher.ts";

jetstream/tests/fetch_test.ts

@@ -27,8 +27,7 @@ import {
 } from "https://deno.land/[email protected]/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 { nanos } from "../jsutil.ts";
+import { delay, nanos } from "../../nats-base-client/util.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
 import { syncIterator } from "../../nats-base-client/core.ts";
 import { PullConsumerMessagesImpl } from "../consumer.ts";

jetstream/tests/jetream409_test.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2022-2023 The NATS Authors
+ * Copyright 2022-2024 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -13,9 +13,10 @@
  * limitations under the License.
  */
 
-import { Js409Errors, nanos, setMaxWaitingToFail } from "../jsutil.ts";
+import { Js409Errors, setMaxWaitingToFail } from "../jsutil.ts";
 import {
   deferred,
+  nanos,
   NatsError,
   StringCodec,
 } from "../../nats-base-client/mod.ts";

jetstream/tests/jetstream_pullconsumer_test.ts

@@ -38,15 +38,15 @@ import {
   fail,
 } from "https://deno.land/[email protected]/assert/mod.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
-import { checkJsError, nanos } from "../jsutil.ts";
+import { checkJsError } from "../jsutil.ts";
 import { JSONCodec, StringCodec } from "../../nats-base-client/codec.ts";
 import {
   consumerOpts,
   ConsumerOptsBuilderImpl,
   JetStreamSubscriptionInfoable,
   PubAck,
 } from "../types.ts";
-import { deferred, delay } from "../../nats-base-client/util.ts";
+import { deferred, delay, nanos } from "../../nats-base-client/util.ts";
 import {
   DebugEvents,
   ErrorCode,

jetstream/tests/jetstream_pushconsumer_test.ts

@@ -55,16 +55,11 @@ import {
 } from "../jsapi_types.ts";
 import { JSONCodec, StringCodec } from "../../nats-base-client/codec.ts";
 import { Empty } from "../../nats-base-client/encoders.ts";
-import { deferred, delay } from "../../nats-base-client/util.ts";
+import { deferred, delay, nanos } from "../../nats-base-client/util.ts";
 import { nuid } from "../../nats-base-client/nuid.ts";
 import { JsMsg } from "../jsmsg.ts";
 import { connect } from "../../src/connect.ts";
-import {
-  isFlowControlMsg,
-  isHeartbeatMsg,
-  Js409Errors,
-  nanos,
-} from "../jsutil.ts";
+import { isFlowControlMsg, isHeartbeatMsg, Js409Errors } from "../jsutil.ts";
 import { JetStreamSubscriptionImpl } from "../jsclient.ts";
 
 Deno.test("jetstream - ephemeral push", async () => {

jetstream/tests/jetstream_test.ts

@@ -23,7 +23,6 @@ import {
   JsHeaders,
   JsMsg,
   JsMsgCallback,
-  nanos,
   PubAck,
   RepublishHeaders,
   RetentionPolicy,
@@ -41,6 +40,7 @@ import {
   ErrorCode,
   headers,
   JSONCodec,
+  nanos,
   NatsError,
   nuid,
   StringCodec,

jetstream/tests/jsm_test.ts

@@ -30,6 +30,7 @@ import {
   headers,
   JSONCodec,
   jwtAuthenticator,
+  nanos,
   NatsConnection,
   NatsError,
   nkeys,
@@ -43,7 +44,6 @@ import {
   ConsumerInfo,
   DiscardPolicy,
   Lister,
-  nanos,
   PubAck,
   RetentionPolicy,
   StorageType,

jetstream/tests/jsmsg_test.ts

@@ -23,10 +23,10 @@ import {
   createInbox,
   Empty,
   Msg,
+  nanos,
   StorageType,
   StringCodec,
 } from "../../src/mod.ts";
-import { nanos } from "../jsutil.ts";
 import { JsMsgImpl, parseInfo, toJsMsg } from "../jsmsg.ts";
 import {
   cleanup,

jetstream/tests/kv_test.ts

@@ -19,6 +19,7 @@ import {
   deferred,
   delay,
   Empty,
+  nanos,
   NatsConnection,
   NatsConnectionImpl,
   nuid,
@@ -34,7 +35,6 @@ import {
   KV,
   KvEntry,
   KvOptions,
-  nanos,
   StorageType,
 } from "../mod.ts";
 

jetstream/tests/next_test.ts

@@ -24,9 +24,8 @@ import {
   assertEquals,
   assertRejects,
 } from "https://deno.land/[email protected]/assert/mod.ts";
-import { nanos } from "../jsutil.ts";
 import { NatsConnectionImpl } from "../../nats-base-client/nats.ts";
-import { delay } from "../../nats-base-client/util.ts";
+import { delay, nanos } from "../../nats-base-client/util.ts";
 
 Deno.test("next - basics", async () => {
   const { ns, nc } = await setup(jetstreamServerConf());
@@ -161,6 +160,7 @@ Deno.test("next - deleted consumer", async () => {
   const js = nc.jetstream();
   const c = await js.consumers.get("A", "a");
 
+  (nc as NatsConnectionImpl).options.debug = true;
   const exited = assertRejects(
     () => {
       return c.next({ expires: 4000 });
@@ -191,7 +191,9 @@ Deno.test("next - stream not found", async () => {
   const js = nc.jetstream();
   const c = await js.consumers.get("A", "a");
 
+  (nc as NatsConnectionImpl).options.debug = true;
   await jsm.streams.delete("A");
+  await delay(1000);
 
   await assertRejects(
     () => {

jetstream/types.ts

@@ -58,8 +58,9 @@ import {
 import { JsMsg } from "./jsmsg.ts";
 import { BaseApiClient } from "./jsbaseclient_api.ts";
 import { ConsumerAPI } from "./jsmconsumer_api.ts";
-import { nanos, validateDurableName } from "./jsutil.ts";
+import { validateDurableName } from "./jsutil.ts";
 import { Lister } from "./jslister.ts";
+import { nanos } from "../nats-base-client/util.ts";
 
 /**
  * The response returned by the JetStream server when a message is added to a stream.

nats-base-client/internal_mod.ts

@@ -15,6 +15,8 @@ export {
   deferred,
   delay,
   extend,
+  millis,
+  nanos,
   render,
   timeout,
 } from "./util.ts";

nats-base-client/mod.ts

@@ -17,7 +17,9 @@ export {
   jwtAuthenticator,
   Match,
   Metric,
+  millis,
   MsgHdrsImpl,
+  nanos,
   NatsError,
   nkeyAuthenticator,
   nkeys,