Fixup

Author: w1am

package.json

@@ -24,14 +24,15 @@
   "devDependencies": {
     "@tsconfig/node18": "^18.2.4",
     "@types/node": "18.19.76",
+    "@types/semver": "^7.7.0",
     "@typescript-eslint/eslint-plugin": "^8.10.0",
     "@typescript-eslint/parser": "^8.10.0",
     "cross-env": "^7.0.3",
     "eslint": "^8.56.0",
     "eslint-plugin-tsdoc": "^0.2.17",
     "nx": "20.1.3",
     "prettier": "^2.8.8",
-    "semver": "^7.6.3",
+    "semver": "^7.7.2",
     "typescript": "^5.6.3"
   }
 }

packages/db-client/package.json

@@ -52,6 +52,7 @@
     "@types/node": "^22.10.2",
     "debug": "^4.4.0",
     "google-protobuf": "^3.21.4",
+    "semver": "^7.7.2",
     "uuid": "11.0.3"
   },
   "devDependencies": {

packages/db-client/src/persistentSubscription/utils/settingsToGRPC.ts

@@ -8,6 +8,7 @@ import semver from "semver";
 import {
   DISPATCH_TO_SINGLE,
   PINNED,
+  PINNED_BY_CORRELATION,
   ROUND_ROBIN,
   UNBOUNDED,
 } from "../../constants";
@@ -16,6 +17,7 @@ import type {
   PersistentSubscriptionToStreamSettings,
   PersistentSubscriptionToAllSettings,
 } from "./persistentSubscriptionSettings";
+import { UnsupportedError } from "../../utils";
 
 type GRPCSettings = typeof CreateReq.Settings | typeof UpdateReq.Settings;
 
@@ -75,6 +77,9 @@ export const settingsToGRPC = <T extends GRPCSettings>(
         );
         break;
       }
+      case PINNED_BY_CORRELATION: {
+        throw new UnsupportedError(PINNED_BY_CORRELATION, "25.10.1");
+      }
       default: {
         console.warn(
           `Unknown consumerStrategyName ${settings.consumerStrategyName}.`

packages/test/src/persistentSubscription/createPersistentSubscriptionToAll.test.ts

@@ -15,7 +15,6 @@ import {
   START,
   UnsupportedError,
   PINNED_BY_CORRELATION,
-  StreamNotFoundError,
 } from "@kurrent/kurrentdb-client";
 
 describe("createPersistentSubscriptionToAll", () => {
@@ -100,9 +99,13 @@ describe("createPersistentSubscriptionToAll", () => {
           )
         ).resolves.toBeUndefined();
 
-        const persistentSubscriptions =
+        let persistentSubscriptions =
           await client.listAllPersistentSubscriptions();
 
+        persistentSubscriptions = persistentSubscriptions.filter(
+          (ps) => ps.groupName === GROUP_NAME
+        );
+
         expect(persistentSubscriptions).toHaveLength(1);
         expect(persistentSubscriptions[0].groupName).toBe(GROUP_NAME);
         expect(persistentSubscriptions[0].settings.consumerStrategyName).toBe(

packages/test/src/persistentSubscription/createPersistentSubscriptionToStream.test.ts

@@ -76,9 +76,13 @@ describe("createPersistentSubscriptionToStream", () => {
         )
       ).resolves.toBeUndefined();
 
-      const persistentSubscriptions =
+      let persistentSubscriptions =
         await client.listAllPersistentSubscriptions();
 
+      persistentSubscriptions = persistentSubscriptions.filter(
+        (ps) => ps.groupName === GROUP_NAME && ps.eventSource === STREAM_NAME
+      );
+
       expect(persistentSubscriptions).toHaveLength(1);
       expect(persistentSubscriptions[0].eventSource).toBe(STREAM_NAME);
       expect(persistentSubscriptions[0].settings.consumerStrategyName).toBe(

yarn.lock

@@ -1137,6 +1137,7 @@ __metadata:
     grpc-tools: "npm:^1.12.4"
     grpc_tools_node_protoc_ts: "npm:^5.3.3"
     nx: "npm:20.1.3"
+    semver: "npm:^7.7.2"
     shx: "npm:^0.3.4"
     uuid: "npm:11.0.3"
   languageName: unknown
@@ -7177,14 +7178,15 @@ __metadata:
   dependencies:
     "@tsconfig/node18": "npm:^18.2.4"
     "@types/node": "npm:18.19.76"
+    "@types/semver": "npm:^7.7.0"
     "@typescript-eslint/eslint-plugin": "npm:^8.10.0"
     "@typescript-eslint/parser": "npm:^8.10.0"
     cross-env: "npm:^7.0.3"
     eslint: "npm:^8.56.0"
     eslint-plugin-tsdoc: "npm:^0.2.17"
     nx: "npm:20.1.3"
     prettier: "npm:^2.8.8"
-    semver: "npm:^7.6.3"
+    semver: "npm:^7.7.2"
     typescript: "npm:^5.6.3"
   languageName: unknown
   linkType: soft
@@ -9585,6 +9587,15 @@ __metadata:
   languageName: node
   linkType: hard
 
+"semver@npm:^7.7.2":
+  version: 7.7.2
+  resolution: "semver@npm:7.7.2"
+  bin:
+    semver: bin/semver.js
+  checksum: 10c0/aca305edfbf2383c22571cb7714f48cadc7ac95371b4b52362fb8eeffdfbc0de0669368b82b2b15978f8848f01d7114da65697e56cd8c37b0dab8c58e543f9ea
+  languageName: node
+  linkType: hard
+
 "set-blocking@npm:^2.0.0":
   version: 2.0.0
   resolution: "set-blocking@npm:2.0.0"