IMN-685 IMN-686 IMN-687 IMN-688 - BFF Agreement routes pt.1 (#830)

pagopa · Sep 11, 2024 · 6e68aeb · 6e68aeb
1 parent 47861c8
commit 6e68aeb
Show file tree

Hide file tree

Showing 3 changed files with 173 additions and 1 deletion.
diff --git a/packages/bff/src/model/api/apiConverter.ts b/packages/bff/src/model/api/apiConverter.ts
@@ -153,6 +153,24 @@ export function toTenantWithOnlyAttributes(
   };
 }
 
+export function toCompactEserviceLight(
+  eservice: agreementApi.CompactEService
+): bffApi.CompactEServiceLight {
+  return {
+    id: eservice.id,
+    name: eservice.name,
+  };
+}
+
+export function toCompactOrganization(
+  organization: agreementApi.CompactOrganization
+): bffApi.CompactOrganization {
+  return {
+    id: organization.id,
+    name: organization.name,
+  };
+}
+
 export function toCompactEservice(
   eservice: catalogApi.EService,
   producer: tenantApi.Tenant

diff --git a/packages/bff/src/services/agreementService.ts b/packages/bff/src/services/agreementService.ts
@@ -19,6 +19,10 @@ import {
 } from "../providers/clientProvider.js";
 import { BffAppContext, Headers } from "../utilities/context.js";
 import { agreementDescriptorNotFound } from "../model/domain/errors.js";
+import {
+  toCompactEserviceLight,
+  toCompactOrganization,
+} from "../model/api/apiConverter.js";
 import {
   toCompactEservice,
   toCompactDescriptor,
@@ -103,6 +107,148 @@ export function agreementServiceBuilder(clients: PagoPAInteropBeClients) {
 
       return enrichAgreement(agreement, clients, ctx);
     },
+
+    async getAgreementsEserviceProducers(
+      {
+        offset,
+        limit,
+        requesterId,
+        states,
+        eServiceName,
+      }: {
+        offset: number;
+        limit: number;
+        requesterId: string;
+        states: agreementApi.AgreementState[];
+        eServiceName?: string;
+      },
+      { headers, logger }: WithLogger<BffAppContext>
+    ): Promise<bffApi.CompactEServicesLight> {
+      logger.info(
+        `Retrieving producer eservices from agreement filtered by eservice name ${eServiceName}, offset ${offset}, limit ${limit}`
+      );
+
+      if (eServiceName && eServiceName.length < 3) {
+        return emptyPagination(offset, limit);
+      }
+
+      const eservices = await agreementProcessClient.getAgreementEServices({
+        queries: {
+          offset,
+          limit,
+          eServiceName,
+          producersIds: [requesterId],
+          states,
+        },
+        headers,
+      });
+
+      return {
+        pagination: {
+          limit,
+          offset,
+          totalCount: eservices.totalCount,
+        },
+        results: eservices.results.map((e) => toCompactEserviceLight(e)),
+      };
+    },
+
+    async getAgreementsEserviceConsumers(
+      offset: number,
+      limit: number,
+      requesterId: string,
+      eServiceName: string | undefined,
+      { headers, logger }: WithLogger<BffAppContext>
+    ) {
+      logger.info(
+        `Retrieving consumer eservices from agreement filtered by eservice name ${eServiceName}, offset ${offset}, limit ${limit}`
+      );
+
+      if (eServiceName && eServiceName.length < 3) {
+        return emptyPagination(offset, limit);
+      }
+
+      const eservices = await agreementProcessClient.getAgreementEServices({
+        queries: {
+          offset,
+          limit,
+          eServiceName,
+          consumersIds: [requesterId],
+        },
+        headers,
+      });
+
+      return {
+        pagination: {
+          limit,
+          offset,
+          totalCount: eservices.totalCount,
+        },
+        results: eservices.results.map((e) => toCompactEserviceLight(e)),
+      };
+    },
+
+    async getAgreementProducers(
+      offset: number,
+      limit: number,
+      producerName: string | undefined,
+      { logger, headers }: WithLogger<BffAppContext>
+    ): Promise<bffApi.CompactOrganizations> {
+      logger.info(`Retrieving agreement producers`);
+
+      if (producerName && producerName.length < 3) {
+        return emptyPagination(offset, limit);
+      }
+
+      const producers = await agreementProcessClient.getAgreementProducers({
+        queries: {
+          offset,
+          limit,
+          producerName,
+        },
+        headers,
+      });
+
+      return {
+        pagination: {
+          limit,
+          offset,
+          totalCount: producers.totalCount,
+        },
+        results: producers.results.map((p) => toCompactOrganization(p)),
+      };
+    },
+
+    async getAgreementConsumers(
+      offset: number,
+      limit: number,
+      consumerName: string | undefined,
+      { logger, headers }: WithLogger<BffAppContext>
+    ): Promise<bffApi.CompactOrganizations> {
+      logger.info(`Retrieving agreement consumers`);
+
+      if (consumerName && consumerName.length < 3) {
+        return emptyPagination(offset, limit);
+      }
+
+      const consumers = await agreementProcessClient.getAgreementConsumers({
+        queries: {
+          offset,
+          limit,
+          consumerName,
+        },
+        headers,
+      });
+
+      return {
+        pagination: {
+          limit,
+          offset,
+          totalCount: consumers.totalCount,
+        },
+        results: consumers.results.map((c) => toCompactOrganization(c)),
+      };
+    },
   };
 }
 
@@ -349,3 +495,12 @@ export function getCurrentDescriptor(
   }
   return descriptor;
 }
+
+const emptyPagination = (offset: number, limit: number) => ({
+  pagination: {
+    limit,
+    offset,
+    totalCount: 0,
+  },
+  results: [],
+});
diff --git a/packages/commons/src/index.ts b/packages/commons/src/index.ts
@@ -20,7 +20,6 @@ export * from "./types/index.js";
 export * from "./utils/arrays.js";
 export * from "./utils/getAll.js";
 export * from "./utils/date.js";
-export * from "./utils/getAll.js";
 export * from "./auth/jwk.js";
 export * from "./auth/converters.js";
 export * from "./email-manager/index.js";