IMN-690 IMN-691 IMN-692 - Agreement routes pt.2 (#831)

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

Hide file tree

Showing 3 changed files with 100 additions and 9 deletions.
diff --git a/packages/bff/src/routers/agreementRouter.ts b/packages/bff/src/routers/agreementRouter.ts
@@ -10,6 +10,7 @@ import { makeApiProblem } from "../model/domain/errors.js";
 import { PagoPAInteropBeClients } from "../providers/clientProvider.js";
 import { fromBffAppContext } from "../utilities/context.js";
 import {
+  activateAgreementErrorMapper,
   emptyErrorMapper,
   getAgreementByIdErrorMapper,
   getAgreementsErrorMapper,
@@ -114,15 +115,63 @@ const agreementRouter = (
       }
     })
 
-    .delete("/agreements/:agreementId", async (_req, res) =>
-      res.status(501).send()
-    )
-    .post("/agreements/:agreementId/activate", async (_req, res) =>
-      res.status(501).send()
-    )
-    .post("/agreements/:agreementId/clone", async (_req, res) =>
-      res.status(501).send()
-    )
+    .delete("/agreements/:agreementId", async (req, res) => {
+      const ctx = fromBffAppContext(req.ctx, req.headers);
+
+      try {
+        await agreementService.deleteAgreement(req.params.agreementId, ctx);
+        return res.status(204).end();
+      } catch (error) {
+        const errorRes = makeApiProblem(
+          error,
+          emptyErrorMapper,
+          ctx.logger,
+          `Error deleting agreement ${req.params.agreementId}`
+        );
+        return res.status(errorRes.status).json(errorRes).end();
+      }
+    })
+
+    .post("/agreements/:agreementId/activate", async (req, res) => {
+      const ctx = fromBffAppContext(req.ctx, req.headers);
+
+      try {
+        const result = await agreementService.activateAgreement(
+          req.params.agreementId,
+          ctx
+        );
+        return res.status(200).json(result).end();
+      } catch (error) {
+        const errorRes = makeApiProblem(
+          error,
+          activateAgreementErrorMapper,
+          ctx.logger,
+          `Error activating agreement ${req.params.agreementId}`
+        );
+        return res.status(errorRes.status).json(errorRes).end();
+      }
+    })
+
+    .post("/agreements/:agreementId/clone", async (req, res) => {
+      const ctx = fromBffAppContext(req.ctx, req.headers);
+
+      try {
+        const result = await agreementService.cloneAgreement(
+          req.params.agreementId,
+          ctx
+        );
+        return res.status(200).json(result).end();
+      } catch (error) {
+        const errorRes = makeApiProblem(
+          error,
+          emptyErrorMapper,
+          ctx.logger,
+          `Error cloning agreement ${req.params.agreementId}`
+        );
+        return res.status(errorRes.status).json(errorRes).end();
+      }
+    })
+
     .post("/agreements/:agreementId/consumer-documents", async (_req, res) =>
       res.status(501).send()
     )

diff --git a/packages/bff/src/services/agreementService.ts b/packages/bff/src/services/agreementService.ts
@@ -108,6 +108,41 @@ export function agreementServiceBuilder(clients: PagoPAInteropBeClients) {
       return enrichAgreement(agreement, clients, ctx);
     },
 
+    async deleteAgreement(
+      agreementId: string,
+      { headers }: WithLogger<BffAppContext>
+    ): Promise<void> {
+      return await agreementProcessClient.deleteAgreement(undefined, {
+        params: { agreementId },
+        headers,
+      });
+    },
+
+    async activateAgreement(
+      agreementId: string,
+      ctx: WithLogger<BffAppContext>
+    ): Promise<bffApi.Agreement> {
+      const agreement = await agreementProcessClient.activateAgreement(
+        undefined,
+        {
+          params: { agreementId },
+          headers: ctx.headers,
+        }
+      );
+      return enrichAgreement(agreement, clients, ctx);
+    },
+
+    async cloneAgreement(
+      agreementId: string,
+      { headers }: WithLogger<BffAppContext>
+    ): Promise<bffApi.CreatedResource> {
+      const agreement = await agreementProcessClient.cloneAgreement(undefined, {
+        params: { agreementId },
+        headers,
+      });
+      return { id: agreement.id };
+    },
+
     async getAgreementsEserviceProducers(
       {
         offset,

diff --git a/packages/bff/src/utilities/errorMappers.ts b/packages/bff/src/utilities/errorMappers.ts
@@ -99,6 +99,13 @@ export const getAgreementByIdErrorMapper = (
     )
     .otherwise(() => HTTP_STATUS_INTERNAL_SERVER_ERROR);
 
+export const activateAgreementErrorMapper = (
+  error: ApiError<ErrorCodes>
+): number =>
+  match(error.code)
+    .with("agreementDescriptorNotFound", () => HTTP_STATUS_NOT_FOUND)
+    .otherwise(() => HTTP_STATUS_INTERNAL_SERVER_ERROR);
+
 export const getClientUsersErrorMapper = (
   error: ApiError<ErrorCodes>
 ): number =>