MOL-357/PICT-241: add endpoint for post-deploy and undeploy

Author: tdang1-shopmacher

processor/src/controllers/processor.controller.ts

@@ -8,6 +8,12 @@ import CustomError from '../errors/custom.error';
 import SkipError from '../errors/skip.error';
 import { apiError } from '../api/error.api';
 import { formatErrorResponse } from '../errors/mollie.error';
+import { createPaymentExtension, deletePaymentExtension } from '../commercetools/extensions.commercetools';
+import {
+  createCustomPaymentInterfaceInteractionType,
+  createCustomPaymentTransactionCancelReasonType,
+  createCustomPaymentType,
+} from '../commercetools/customFields.commercetools';
 
 /**
  * Exposed service endpoint.
@@ -33,24 +39,64 @@ export const post = async (request: Request, response: Response) => {
       data = await paymentController(action, resource);
       logger.debug('SCTM - Processor - Finish processing payment requests');
     } else {
+      logger.debug(`SCTM - Processor - Internal Server Error - Resource not recognized. Allowed values are 'payment'.`);
       throw new CustomError(500, `Internal Server Error - Resource not recognized. Allowed values are 'payment'.`);
     }
 
     return apiSuccess(200, response, data?.actions);
   } catch (error) {
     if (error instanceof SkipError) {
-      logger.debug('Skip action', error.message);
+      logger.debug('SCTM - Processor - Skip action', error.message);
 
       return apiSuccess(200, response, []);
     }
     if (error instanceof CustomError) {
-      logger.debug('Error occurred when processing request', error);
+      logger.debug('SCTM - Processor - Error occurred when processing request', error);
 
       return apiError(response, error.errors);
     }
 
-    logger.debug('Unexpected error occurred when processing request', error);
+    logger.debug('SCTM - Processor - Unexpected error occurred when processing request', error);
 
     return apiError(response, formatErrorResponse(error).errors);
   }
 };
+
+/**
+ * Exposed service endpoint.
+ * - Creates the Mollie payment extension, CustomPaymentType, CustomPaymentInterfaceInteractionType and CustomPaymentTransactionCancelReasonType.
+ *
+ * @param {Request} request The express request
+ * @param {Response} response The express response
+ * @returns
+ */
+export const installation = async (request: Request, response: Response) => {
+  const { extensionUrl } = request.body;
+
+  if (!extensionUrl) {
+    logger.debug('SCTM - installation - Missing body parameters {extensionUrl}.');
+    return apiError(response, formatErrorResponse(new CustomError(400, 'Missing body parameters.')).errors);
+  }
+
+  try {
+    await createPaymentExtension(extensionUrl);
+    await createCustomPaymentType();
+    await createCustomPaymentInterfaceInteractionType();
+    await createCustomPaymentTransactionCancelReasonType();
+    logger.debug('SCTM - installation - Finish processing installation requests');
+    return apiSuccess(200, response, []);
+  } catch (error) {
+    logger.debug('SCTM - installation - Unexpected error occurred when processing request', error);
+    return apiError(response, formatErrorResponse(error).errors);
+  }
+};
+
+export const uninstallation = async (request: Request, response: Response) => {
+  try {
+    deletePaymentExtension();
+    return apiSuccess(200, response, []);
+  } catch (error) {
+    logger.debug('SCTM - uninstallation - Unexpected error occurred when processing request', error);
+    return apiError(response, formatErrorResponse(error).errors);
+  }
+};

processor/src/routes/processor.route.ts

@@ -1,5 +1,5 @@
 import { Router } from 'express';
-import { post } from '../controllers/processor.controller';
+import { post, installation, uninstallation } from '../controllers/processor.controller';
 
 const serviceRouter = Router();
 
@@ -9,4 +9,8 @@ serviceRouter.get('/health-check', async (req, res) => {
 
 serviceRouter.post('/', post);
 
+serviceRouter.post('/install', installation);
+
+serviceRouter.post('/uninstall', uninstallation);
+
 export default serviceRouter;