PIN-6093 - Add client SQL splitters

packages/readmodel/src/authorization/clientSplitters.ts

@@ -0,0 +1,71 @@
+import { Client, dateToString } from "pagopa-interop-models";
+import {
+  ClientKeySQL,
+  ClientPurposeSQL,
+  ClientSQL,
+  ClientUserSQL,
+} from "pagopa-interop-readmodel-models";
+
+export const splitClientIntoObjectsSQL = (
+  {
+    id,
+    consumerId,
+    name,
+    purposes,
+    description,
+    users,
+    kind,
+    createdAt,
+    keys,
+    ...rest
+  }: Client,
+  metadataVersion: number
+): {
+  clientSQL: ClientSQL;
+  clientUsersSQL: ClientUserSQL[];
+  clientPurposesSQL: ClientPurposeSQL[];
+  clientKeysSQL: ClientKeySQL[];
+} => {
+  void (rest satisfies Record<string, never>);
+
+  const clientSQL: ClientSQL = {
+    id,
+    metadataVersion,
+    consumerId,
+    name,
+    description: description || null,
+    kind,
+    createdAt: dateToString(createdAt),
+  };
+
+  const clientUsersSQL: ClientUserSQL[] = users.map((userId) => ({
+    metadataVersion,
+    clientId: id,
+    userId,
+  }));
+
+  const clientPurposesSQL: ClientPurposeSQL[] = purposes.map((purposeId) => ({
+    metadataVersion,
+    clientId: id,
+    purposeId,
+  }));
+
+  const clientKeysSQL: ClientKeySQL[] = keys.map((key) => ({
+    metadataVersion,
+    clientId: id,
+    userId: key.userId,
+    kid: key.kid,
+    name: key.name,
+    encodedPem: key.encodedPem,
+    algorithm: key.algorithm,
+    use: key.use,
+    createdAt: dateToString(key.createdAt),
+  }));
+
+  return {
+    clientSQL,
+    clientUsersSQL,
+    clientPurposesSQL,
+    clientKeysSQL,
+  };
+};

packages/readmodel/test/clientSplitter.test.ts

@@ -0,0 +1,91 @@
+import { getMockClient, getMockKey } from "pagopa-interop-commons-test";
+import { Client, generateId, PurposeId, UserId } from "pagopa-interop-models";
+import { describe, it, expect } from "vitest";
+import {
+  ClientKeySQL,
+  ClientPurposeSQL,
+  ClientSQL,
+  ClientUserSQL,
+} from "pagopa-interop-readmodel-models";
+import { splitClientIntoObjectsSQL } from "../src/authorization/clientSplitters.js";
+
+describe("Client splitter", () => {
+  it("should convert a client into client SQL objects", () => {
+    const userId1 = generateId<UserId>();
+    const userId2 = generateId<UserId>();
+    const purposeId1 = generateId<PurposeId>();
+    const purposeId2 = generateId<PurposeId>();
+    const key1 = getMockKey();
+    const key2 = getMockKey();
+
+    const client: Client = {
+      ...getMockClient(),
+      users: [userId1, userId2],
+      purposes: [purposeId1, purposeId2],
+      keys: [key1, key2],
+      description: undefined,
+    };
+
+    const { clientSQL, clientUsersSQL, clientPurposesSQL, clientKeysSQL } =
+      splitClientIntoObjectsSQL(client, 1);
+
+    const expectedClientSQL: ClientSQL = {
+      id: client.id,
+      consumerId: client.consumerId,
+      name: client.name,
+      createdAt: client.createdAt.toISOString(),
+      description: null,
+      kind: client.kind,
+      metadataVersion: 1,
+    };
+
+    const expectedClientUserSQL1: ClientUserSQL = {
+      metadataVersion: 1,
+      clientId: client.id,
+      userId: userId1,
+    };
+    const expectedClientUserSQL2: ClientUserSQL = {
+      metadataVersion: 1,
+      clientId: client.id,
+      userId: userId2,
+    };
+
+    const expectedClientEServicesSQL1: ClientPurposeSQL = {
+      metadataVersion: 1,
+      clientId: client.id,
+      purposeId: purposeId1,
+    };
+    const expectedClientEServicesSQL2: ClientPurposeSQL = {
+      metadataVersion: 1,
+      clientId: client.id,
+      purposeId: purposeId2,
+    };
+
+    const expectedClientKeySQL1: ClientKeySQL = {
+      ...key1,
+      metadataVersion: 1,
+      clientId: client.id,
+      createdAt: key1.createdAt.toISOString(),
+    };
+    const expectedClientKeySQL2: ClientKeySQL = {
+      ...key2,
+      metadataVersion: 1,
+      clientId: client.id,
+      createdAt: key2.createdAt.toISOString(),
+    };
+
+    expect(clientSQL).toEqual(expectedClientSQL);
+    expect(clientUsersSQL).toEqual(
+      expect.arrayContaining([expectedClientUserSQL1, expectedClientUserSQL2])
+    );
+    expect(clientPurposesSQL).toEqual(
+      expect.arrayContaining([
+        expectedClientEServicesSQL1,
+        expectedClientEServicesSQL2,
+      ])
+    );
+    expect(clientKeysSQL).toEqual(
+      expect.arrayContaining([expectedClientKeySQL1, expectedClientKeySQL2])
+    );
+  });
+});