fix(appendToStream): validate event ids to be uuids before appending

src/__test__/streams/appendToStream-errors.test.ts

@@ -1,6 +1,7 @@
 /** @jest-environment ./src/__test__/utils/enableVersionCheck.ts */
 
 import {
+  binaryTestEvents,
   createTestNode,
   jsonTestEvents,
   matchServerVersion,
@@ -16,6 +17,7 @@ import {
   AccessDeniedError,
   DeadlineExceededError,
 } from "@eventstore/db-client";
+import { IsNotUUIDError } from "../../utils";
 
 describe("appendToStream - errors", () => {
   const node = createTestNode();
@@ -143,5 +145,25 @@ describe("appendToStream - errors", () => {
         }
       }
     });
+
+    optionalTest(supported)("InvalidId", async () => {
+      const STREAM_NAME = `${prefix}_invalid_id`;
+
+      // json event
+      await expect(
+        client.appendToStream(STREAM_NAME, {
+          ...jsonTestEvents(1)[0],
+          id: "an_invalid_id_example_1",
+        })
+      ).rejects.toThrowError(IsNotUUIDError);
+
+      // binary event
+      await expect(
+        client.appendToStream(STREAM_NAME, {
+          ...binaryTestEvents(1)[0],
+          id: "an_invalid_id_example_2",
+        })
+      ).rejects.toThrowError(IsNotUUIDError);
+    });
   });
 });

src/streams/appendToStream/index.ts

@@ -9,6 +9,7 @@ import type {
   EventData,
   EventType,
 } from "../../types";
+import { validateEventIds } from "../../utils";
 
 import { append } from "./append";
 import { batchAppend } from "./batchAppend";
@@ -56,6 +57,8 @@ Client.prototype.appendToStream = async function <
 ): Promise<AppendResult> {
   const events = Array.isArray(event) ? event : [event];
 
+  validateEventIds(events);
+
   if (
     !baseOptions.credentials &&
     (await this.supports(StreamsService.batchAppend))

src/utils/IsNotUUIDError.ts

@@ -0,0 +1,5 @@
+export class IsNotUUIDError extends Error {
+  constructor(id: string) {
+    super(`Id ${id} is not a valid UUID`);
+  }
+}

src/utils/index.ts

@@ -7,3 +7,5 @@ export * from "./grpcStreamIdentifier";
 export * from "./grpcUUID";
 export * from "./utilityTypes";
 export * from "./isClientCancellationError";
+export * from "./IsNotUUIDError";
+export * from "./validateEventIds";

src/utils/validateEventIds.ts

@@ -0,0 +1,10 @@
+import { validate as validateUUID } from "uuid";
+
+import type { EventData, EventType } from "../types";
+import { IsNotUUIDError } from "./IsNotUUIDError";
+
+export const validateEventIds = (events: EventData<EventType>[]): void => {
+  events.forEach((event) => {
+    if (!validateUUID(event.id)) throw new IsNotUUIDError(event.id);
+  });
+};