Remove unnecesary tests

Author: w1am

packages/db-client/package.json

@@ -48,13 +48,13 @@
     "@grpc/grpc-js": "^1.12.4",
     "@types/debug": "^4.1.12",
     "@types/google-protobuf": "^3.15.12",
-    "@types/node": "^16.18.67",
-    "debug": "^4.3.2",
-    "google-protobuf": "^3.21.2",
-    "uuid": "^8.3.2"
+    "@types/node": "^22.10.2",
+    "debug": "^4.4.0",
+    "google-protobuf": "^3.21.4",
+    "uuid": "^11.0.3"
   },
   "devDependencies": {
-    "@types/uuid": "^8.3.4",
+    "@types/uuid": "^10.0.0",
     "grpc-tools": "^1.12.4",
     "grpc_tools_node_protoc_ts": "^5.3.3",
     "npm-run-all": "^4.1.5",

packages/db-client/src/Client/index.ts

@@ -523,7 +523,7 @@ export class Client {
     }
 
     if (error.message.includes("RST_STREAM")) {
-      return [true]
+      return [true];
     }
 
     return [

packages/opentelemetry/package.json

@@ -33,7 +33,7 @@
   },
   "dependencies": {
     "@opentelemetry/api": "^1.8.0",
-    "@opentelemetry/instrumentation": "^0.50.0"
+    "@opentelemetry/instrumentation": "^0.56.0"
   },
   "devDependencies": {
     "@eventstore/db-client": "file:../db-client"

packages/opentelemetry/src/instrumentation.ts

@@ -39,8 +39,8 @@ import type { Subscription } from "@eventstore/db-client/src/streams/utils/Subsc
 import { INSTRUMENTATION_NAME, INSTRUMENTATION_VERSION } from "./version";
 import type {
   AppendToStreamParams,
-  SubscribeParameters,
   PersistentSubscribeParameters,
+  SubscribeParameters,
 } from "./types";
 import { hasConvertGrpcEventMethod, isJSONEventData } from "./utils";
 
@@ -53,16 +53,12 @@ export class Instrumentation extends InstrumentationBase {
   }
 
   protected init() {
-    const moduleDefinition = new InstrumentationNodeModuleDefinition<
-      typeof kdb
-    >(
+    return new InstrumentationNodeModuleDefinition(
       "@eventstore/db-client",
       ["6.*"],
       this._onPatchMain(),
       this._onUnPatchMain()
     );
-
-    return moduleDefinition;
   }
 
   private _onPatchMain() {

packages/test/src/connection/deadline/deadline-settings.test.ts

@@ -1,103 +1,6 @@
-import { Channel } from "@grpc/grpc-js";
-
-import {
-  BaseOptions,
-  DNSClusterOptions,
-  KurrentDBClient,
-} from "@eventstore/db-client";
-
-/*
-Mocking this file breaks grpc, but allows us to check the settings passed to grpc
-These tests need to be kept seperate to any tests that need to actually make calls 
-*/
-jest.mock("@grpc/grpc-js/build/src/channel.js");
-const ChannelMock = Channel as jest.Mock<Channel>;
+import { DNSClusterOptions, KurrentDBClient } from "@eventstore/db-client";
 
 describe("deadline", () => {
-  beforeEach(() => {
-    ChannelMock.mockClear();
-  });
-
-  describe.each<
-    [
-      test_name: string,
-      connection_string: string,
-      constructor_options: Partial<DNSClusterOptions>,
-      call_options: BaseOptions,
-      expected: number
-    ]
-  >([
-    ["should default to 10_000", "esdb://host", {}, {}, 10_000],
-    [
-      "should be settable: 1",
-      "esdb://host?defaultDeadline=1",
-      { defaultDeadline: 1 },
-      {},
-      1,
-    ],
-    [
-      "should be settable: 100000",
-      "esdb://host?defaultDeadline=100000",
-      { defaultDeadline: 10_0000 },
-      {},
-      10_0000,
-    ],
-    [
-      "passing in call options should override default",
-      "esdb://host",
-      {},
-      { deadline: 10_0000 },
-      10_0000,
-    ],
-    [
-      "passing in call options should override settings",
-      "esdb://host?defaultDeadline=100000",
-      { defaultDeadline: 10_0000 },
-      { deadline: 10 },
-      10,
-    ],
-  ])("%s", (_, connectionString, constructorOptions, callOptions, expected) => {
-    test.each([
-      [
-        "connectionString",
-        () => KurrentDBClient.connectionString(connectionString),
-      ],
-      [
-        "constructor",
-        () =>
-          new KurrentDBClient({
-            endpoint: "host:1234",
-            ...constructorOptions,
-          }),
-      ],
-    ])("%s", async (_, createClient) => {
-      const warnSpy = jest.spyOn(console, "warn").mockImplementation();
-      const client = createClient();
-      const before = Date.now();
-
-      try {
-        await client.restartSubsystem(callOptions);
-      } catch (_) {
-        // We're not actually connecting to anything, just triggering channel creation
-      }
-
-      const after = Date.now();
-
-      const ChannelInstance = ChannelMock.mock.instances[0];
-      const createCall = ChannelInstance.createCall as unknown as jest.Mock<
-        Channel["createCall"]
-      >;
-
-      const deadline = createCall.mock.calls[0][1].getTime();
-
-      expect(deadline).toBeGreaterThanOrEqual(before + expected);
-      expect(deadline).toBeLessThanOrEqual(after + expected);
-
-      expect(warnSpy).not.toBeCalled();
-      warnSpy.mockRestore();
-    });
-  });
-
   describe.each<
     [
       test_name: string,

packages/test/src/utils/Cluster.ts

@@ -11,7 +11,7 @@ import type { EndPoint, Certificate } from "@eventstore/db-client";
 
 import { testDebug } from "./debug";
 import { dockerImages } from "./dockerImages";
-import {kill} from "docker-compose";
+import { kill } from "docker-compose";
 
 const rmdir = promisify(fs.rm);
 const mkdir = promisify(fs.mkdir);