Rename dubug namespace

Author: w1am

Diff for: packages/db-client/src/Client/index.ts

@@ -525,7 +525,7 @@ export class Client {
     return [
       // Server is unavailable to take request
       error instanceof UnavailableError ||
-        // Server has cancelled a long running request
+        // Server has cancelled a long-running request
         error instanceof CancelledError,
     ];
   };

Diff for: packages/db-client/src/utils/CommandError.ts

@@ -436,9 +436,9 @@ export type CommandError =
 export const convertToCommandError = (error: Error): CommandError | Error => {
   if (isCommandError(error) || !isServiceError(error)) return error;
 
-  const exeption = error.metadata?.getMap()["exception"]?.toString();
+  const exception = error.metadata?.getMap()["exception"]?.toString();
 
-  switch (exeption) {
+  switch (exception) {
     case ErrorType.NOT_LEADER:
       return new NotLeaderError(error);
     case ErrorType.STREAM_NOT_FOUND:
@@ -492,7 +492,7 @@ export const convertToCommandError = (error: Error): CommandError | Error => {
     }
   }
 
-  // This is a temporary workaround for a bug in node js. Must be removed when the bug is fixed.
+  // This is a temporary workaround for a bug in Node.js. Must be removed when the bug is fixed.
   // https://github.com/grpc/grpc-node/issues/2502
   // and https://github.com/nodejs/node/issues/49147
   if (error.details.includes("write after end")) {

Diff for: packages/db-client/src/utils/debug.ts

@@ -13,7 +13,7 @@ createDebug.formatters.h = function ({ Authorization, ...rest }) {
   return createDebug.formatters.O.call(this, headers);
 };
 
-const base = createDebug("esdb");
+const base = createDebug("kdb");
 const command = base.extend("command");
 const command_grpc = command.extend("grpc");
 const connection = base.extend("connection");

Diff for: packages/opentelemetry/src/instrumentation.ts

@@ -110,10 +110,7 @@ export class Instrumentation extends InstrumentationBase {
     return (moduleExports: typeof kdb) => {
       this._diag.debug("un-patching");
 
-      this._unwrap(
-        moduleExports.KurrentDBClient.prototype,
-        "appendToStream"
-      );
+      this._unwrap(moduleExports.KurrentDBClient.prototype, "appendToStream");
       this._unwrap(
         moduleExports.KurrentDBClient.prototype,
         "subscribeToStream"
@@ -237,11 +234,9 @@ export class Instrumentation extends InstrumentationBase {
       const subscriptionId = subscription.id;
 
       const attributes: Attributes = {
-        [KurrentDBAttributes.KURRENT_DB_STREAM]:
-          resolvedEvent?.event?.streamId,
+        [KurrentDBAttributes.KURRENT_DB_STREAM]: resolvedEvent?.event?.streamId,
         [KurrentDBAttributes.KURRENT_DB_EVENT_ID]: resolvedEvent?.event?.id,
-        [KurrentDBAttributes.KURRENT_DB_EVENT_TYPE]:
-          resolvedEvent?.event?.type,
+        [KurrentDBAttributes.KURRENT_DB_EVENT_TYPE]: resolvedEvent?.event?.type,
         [KurrentDBAttributes.KURRENT_DB_SUBSCRIPTION_ID]: subscriptionId,
         [KurrentDBAttributes.SERVER_ADDRESS]: hostname,
         [KurrentDBAttributes.SERVER_PORT]: port,

Diff for: packages/test/src/connection/deadline/deadline-effects.test.ts

@@ -1,8 +1,5 @@
 import { createTestCluster, jsonTestEvents } from "@test-utils";
-import {
-  KurrentDBClient,
-  DeadlineExceededError,
-} from "@eventstore/db-client";
+import { KurrentDBClient, DeadlineExceededError } from "@eventstore/db-client";
 
 describe("deadline", () => {
   const cluster = createTestCluster();

Diff for: packages/test/src/extra/write-after-end.test.ts

@@ -35,13 +35,14 @@ const neverEndingEvents: Array<EventData> = (function* neverEndingEvents() {
 const isArray = Array.isArray;
 Array.isArray = (arg): arg is never[] => {
   if (isArray(arg)) return true;
-  if (arg === neverEndingEvents) return true;
-  return false;
+  return arg === neverEndingEvents;
 };
 
+jest.retryTimes(5, { logErrorsBeforeRetry: true });
+
 describe("write after end", () => {
   test("Should not write after end", async () => {
-    // We are going to do a huge append, so tell eventstore not to reject it
+    // We are going to do a huge append, so tell KurrentDB not to reject it
     const node = createTestNode().setOption(
       "EVENTSTORE_MAX_APPEND_SIZE",
       10_000_000
@@ -101,7 +102,7 @@ describe("write after end", () => {
         new Promise((resolve) => {
           const writeOnLoop = (): Promise<never> =>
             client
-              .appendToStream(STREAM_NAME, jsonTestEvents(30_000))
+              .appendToStream(STREAM_NAME, jsonTestEvents(5000))
               .then(writeOnLoop);
 
           writeOnLoop().catch((e) => {

Diff for: packages/test/src/opentelemetry/instrumentation.test.ts

@@ -106,8 +106,7 @@ describe("instrumentation", () => {
         const expectedAttributes = {
           [KurrentDBAttributes.KURRENT_DB_STREAM]: STREAM,
           [KurrentDBAttributes.SERVER_ADDRESS]: node.endpoints[0].address,
-          [KurrentDBAttributes.SERVER_PORT]:
-            node.endpoints[0].port.toString(),
+          [KurrentDBAttributes.SERVER_PORT]: node.endpoints[0].port.toString(),
           [KurrentDBAttributes.DATABASE_SYSTEM]: moduleName,
           [KurrentDBAttributes.DATABASE_OPERATION]: "appendToStream",
         };

Diff for: packages/test/src/streams/setStreamMetadata.test.ts

@@ -1,9 +1,5 @@
 import { createTestNode, jsonTestEvents } from "@test-utils";
-import {
-  KurrentDBClient,
-  StreamMetadata,
-  START,
-} from "@eventstore/db-client";
+import { KurrentDBClient, StreamMetadata, START } from "@eventstore/db-client";
 
 describe("setStreamMetadata", () => {
   const node = createTestNode();

Diff for: packages/test/src/utils/Cluster.ts

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

Diff for: packages/test/src/utils/debug.ts

@@ -1,3 +1,3 @@
 import createDebug from "debug";
 
-export const testDebug = createDebug("esdb").extend("tests");
+export const testDebug = createDebug("kdb").extend("tests");