chore: updated copyrights, and optimized imports (#16)

messagepipeline/deno.json

@@ -14,7 +14,7 @@
     "cover": "deno coverage  ./coverage --lcov > ./coverage/out.lcov && genhtml -o ./coverage/html ./coverage/out.lcov && open ./coverage/html/index.html"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@^3.0.0-19",
-    "@nats-io/services": "jsr:@nats-io/services@^3.0.0-2"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@^3.0.0-25",
+    "@nats-io/services": "jsr:@nats-io/services@^3.0.0-5"
   }
 }

messagepipeline/examples/example.ts

@@ -1,3 +1,17 @@
+/*
+ * Copyright 2024 Synadia Communications, Inc
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 import { MutableMsg, Pipeline } from "../mod.ts";
 import { connect, Empty, headers } from "jsr:@nats-io/[email protected]";
 import type { Msg } from "jsr:@nats-io/[email protected]";
@@ -52,7 +66,7 @@ const nc2 = await connect({ servers: ["demo.nats.io"] });
 let i = 0;
 setInterval(() => {
   nc2.request("hello", `hello ${++i}`)
-    .then((r) => {
+    .then((r: Msg) => {
       console.log(r.string());
     });
 }, 1000);

messagepipeline/mod.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia-IO Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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

messagepipeline/mod_test.ts

@@ -1,3 +1,17 @@
+/*
+ * Copyright 2024 Synadia Communications, Inc
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 import { connect } from "jsr:@nats-io/[email protected]";
 import { headers } from "@nats-io/nats-core";
 import type { Msg } from "./mod.ts";
@@ -13,7 +27,7 @@ Deno.test("mm - copies values", async () => {
   const nc = await connect({ servers: "demo.nats.io" });
   const subj = nuid.next();
   const reply = subj.split("").reverse().join();
-  const sub = syncIterator(nc.subscribe(subj));
+  const sub = syncIterator<Msg>(nc.subscribe(subj));
   const h = headers();
   h.set("test", "a");
   nc.publish(subj, JSON.stringify({ hello: "world" }), { reply, headers: h });

nhgc/credentials.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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

nhgc/examples/nats.ts

@@ -1,3 +1,17 @@
+/*
+ * Copyright 2024 Synadia Communications, Inc
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 import { newNHG } from "../mod.ts";
 import { getConnectionDetails } from "../credentials.ts";
 

nhgc/kv.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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,20 +13,21 @@
  * limitations under the License.
  */
 
-import {
+import type {
   Kv,
   KvBucketInfo,
   KvEntry,
   KvOperation,
   KvWatchFn,
   KvWatchOpts,
   ReviverFn,
-  toKvChangeEvent,
   Value,
   Watcher,
 } from "./types.ts";
+import { toKvChangeEvent } from "./types.ts";
 import { HttpImpl } from "./nhgc.ts";
-import { addEventSource, Deferred, deferred } from "./util.ts";
+import { addEventSource, deferred } from "./util.ts";
+import type { Deferred } from "./util.ts";
 
 type KvE = {
   bucket: string;

nhgc/kv_test.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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,18 +12,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 import {
   assert,
   assertArrayIncludes,
   assertEquals,
   assertExists,
   assertRejects,
   fail,
-} from "https://deno.land/[email protected]/assert/mod.ts";
+} from "jsr:@std/assert";
 import { newNHG } from "./mod.ts";
 import { getConnectionDetails, randomKvName } from "./credentials.ts";
-import { deferred } from "https://deno.land/[email protected]/async/deferred.ts";
-import { KvChangeEvent } from "./types.ts";
+import type { KvChangeEvent } from "./types.ts";
+import { deferred } from "./util.ts";
 
 Deno.test("kv - cleanup test buckets", async () => {
   const nhg = newNHG(getConnectionDetails());

nhgc/kvm.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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,7 +12,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { Kv, KvBucketConfig, KvBucketInfo, Kvm } from "./types.ts";
+
+import type { Kv, KvBucketConfig, KvBucketInfo, Kvm } from "./types.ts";
 import { HttpImpl } from "./nhgc.ts";
 import { KvImpl } from "./kv.ts";
 

nhgc/kvm_test.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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,12 +12,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 import { newNHG } from "./mod.ts";
 import {
   assertArrayIncludes,
   assertEquals,
   assertRejects,
-} from "https://deno.land/[email protected]/assert/mod.ts";
+} from "jsr:@std/assert";
 import { getConnectionDetails, randomKvName } from "./credentials.ts";
 
 Deno.test("kvm - add", async () => {

nhgc/mod.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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,7 +12,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { Kvm, Nats } from "./types.ts";
+
+import type { Kvm, Nats } from "./types.ts";
 import { KvmImpl } from "./kvm.ts";
 import { NatsImpl } from "./nats.ts";
 

nhgc/nats.ts

@@ -1,5 +1,5 @@
 import { HttpImpl } from "./nhgc.ts";
-import {
+import type {
   Msg,
   MsgCallback,
   Nats,

nhgc/nats_test.ts

@@ -1,12 +1,22 @@
+/*
+ * Copyright 2024 Synadia Communications, Inc
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 import { newNHG } from "./mod.ts";
-import { delay } from "https://deno.land/[email protected]/async/delay.ts";
+import { delay } from "jsr:@std/async";
 import { getConnectionDetails } from "./credentials.ts";
-import {
-  assert,
-  assertEquals,
-  assertExists,
-  fail,
-} from "https://deno.land/[email protected]/assert/mod.ts";
+import { assert, assertEquals, assertExists, fail } from "jsr:@std/assert";
 
 Deno.test("nats - pub", async () => {
   const nhg = newNHG(getConnectionDetails());

nhgc/nhgc.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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

nhgc/types.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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

nhgc/util.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2024 The Synadia Authors
+ * Copyright 2024 Synadia Communications, Inc
  * 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