chore: more renames

Author: w1am

benchmark-output.txt

@@ -1,8 +1,12 @@
 {
   "targetDefaults": {
     "build": {
-      "dependsOn": ["^build"],
-      "outputs": ["{projectRoot}/dist"],
+      "dependsOn": [
+        "^build"
+      ],
+      "outputs": [
+        "{projectRoot}/dist"
+      ],
       "cache": true
     },
     "test": {
@@ -14,4 +18,4 @@
   },
   "defaultBase": "main",
   "useInferencePlugins": false
-}
+}

nx.json

@@ -1,10 +1,11 @@
 {
   "name": "benchmark",
   "packageManager": "yarn@4.6.0",
+  "private": true,
   "scripts": {
-    "benchmark": "yarn benchmark:eventstoreClient && yarn benchmark:kurrentClient && yarn benchmark:bridge",
-    "benchmark:eventstoreClient": "node ./eventstoreClient/readStream.js",
-    "benchmark:kurrentClient": "node ./kurrentClient/readStream.js",
+    "benchmark": "yarn benchmark:legacy && yarn benchmark:kurrent && yarn benchmark:bridge",
+    "benchmark:legacy": "node ./legacy/readStream.js",
+    "benchmark:kurrent": "node ./kurrent/readStream.js",
     "benchmark:bridge": "node ./bridge/readStream.js",
     "loadEvents": "node ./load"
   },

…es/benchmark/kurrentClient/readStream.js packages/benchmark/kurrent/readStream.jspackages/benchmark/kurrentClient/readStream.js renamed to packages/benchmark/kurrent/readStream.js packages/benchmark/kurrentClient/readStream.js renamed to packages/benchmark/kurrent/readStream.js

@@ -1,10 +1,11 @@
 {
   "name": "@kurrent/opentelemetry",
   "version": "1.0.0-alpha.1",
-  "description": "Kurrent NodeJS Client SDK interceptors for tracing with OpenTelemetry",
+  "description": "KurrentDB NodeJS Client SDK interceptors for tracing with OpenTelemetry",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "license": "Apache-2.0",
+  "author": "Kurrent, Inc",
   "scripts": {
     "build": "yarn build:ts",
     "build:ts": "tsc --build",

…benchmark/eventstoreClient/readStream.js packages/benchmark/legacy/readStream.jspackages/benchmark/eventstoreClient/readStream.js renamed to packages/benchmark/legacy/readStream.js packages/benchmark/eventstoreClient/readStream.js renamed to packages/benchmark/legacy/readStream.js

@@ -17,7 +17,7 @@ import {
   InstrumentationConfig,
   InstrumentationNodeModuleDefinition,
 } from "@opentelemetry/instrumentation";
-import type * as kdb from "@kurrent/kurrentdb-client";
+import type * as kurrentdb from "@kurrent/kurrentdb-client";
 import type {
   AppendResult,
   BinaryEventType,
@@ -61,7 +61,7 @@ export class Instrumentation extends InstrumentationBase {
   }
 
   private _onPatchMain() {
-    return (moduleExports: typeof kdb) => {
+    return (moduleExports: typeof kurrentdb) => {
       this.wrap(
         moduleExports.KurrentDBClient.prototype,
         "appendToStream",
@@ -102,7 +102,7 @@ export class Instrumentation extends InstrumentationBase {
   }
 
   private _onUnPatchMain() {
-    return (moduleExports: typeof kdb) => {
+    return (moduleExports: typeof kurrentdb) => {
       this._diag.debug("un-patching");
 
       this._unwrap(moduleExports.KurrentDBClient.prototype, "appendToStream");
@@ -123,17 +123,17 @@ export class Instrumentation extends InstrumentationBase {
 
   private _patchAppendToStream(): (
     original: Function,
-    operation: keyof kdb.KurrentDBClient
+    operation: keyof kurrentdb.KurrentDBClient
   ) => (...args: AppendToStreamParams) => Promise<AppendResult> {
     const instrumentation = this;
     const tracer = instrumentation.tracer;
 
     return function appendToStream(
       original: Function,
-      operation: keyof kdb.KurrentDBClient
+      operation: keyof kurrentdb.KurrentDBClient
     ) {
       return async function (
-        this: kdb.KurrentDBClient,
+        this: kurrentdb.KurrentDBClient,
         ...args: AppendToStreamParams
       ): Promise<AppendResult> {
         const [streamName, events, options] = [...args];
@@ -261,17 +261,17 @@ export class Instrumentation extends InstrumentationBase {
 
   private _patchCatchUpSubscription(): (
     original: Function,
-    operation: keyof kdb.KurrentDBClient
+    operation: keyof kurrentdb.KurrentDBClient
   ) => (...args: any) => any {
     const instrumentation = this;
     const tracer = instrumentation.tracer;
 
     return function subscribe<KnownEventType extends EventType = EventType>(
       original: Function,
-      operation: keyof kdb.KurrentDBClient
+      operation: keyof kurrentdb.KurrentDBClient
     ) {
       return function (
-        this: kdb.KurrentDBClient,
+        this: kurrentdb.KurrentDBClient,
         ...args: SubscribeParameters
       ) {
         let options:
@@ -308,17 +308,17 @@ export class Instrumentation extends InstrumentationBase {
 
   private _patchPersistentSubscription(): (
     original: Function,
-    operation: keyof kdb.KurrentDBClient
+    operation: keyof kurrentdb.KurrentDBClient
   ) => (...args: any) => any {
     const instrumentation = this;
     const tracer = instrumentation.tracer;
 
     return function subscribe<E>(
       original: Function,
-      operation: keyof kdb.KurrentDBClient
+      operation: keyof kurrentdb.KurrentDBClient
     ) {
       return function (
-        this: kdb.KurrentDBClient,
+        this: kurrentdb.KurrentDBClient,
         ...args: PersistentSubscribeParameters
       ) {
         let options:
@@ -353,7 +353,7 @@ export class Instrumentation extends InstrumentationBase {
   }
 
   private static restoreContext = (
-    metadata: kdb.MetadataType,
+    metadata: kurrentdb.MetadataType,
     isRemote = true
   ): Context => {
     const traceId = metadata[TRACE_ID] as string;