Task 10 (Backend For Frontend)

bffService/.ebextensions/options.config

@@ -0,0 +1,5 @@
+option_settings:
+  aws:elasticbeanstalk:application:environment:
+    NODE_ENV: 'production'
+    products: 'https://6f58bqhfvi.execute-api.eu-west-1.amazonaws.com/dev'
+    cart: 'http://bam6ycha-cart-service-api.eu-west-1.elasticbeanstalk.com/api/profile'

bffService/.gitignore

@@ -0,0 +1,14 @@
+# package directories
+node_modules
+jspm_packages
+
+# env variables
+.env
+
+# build
+dist
+
+# Elastic Beanstalk Files
+.elasticbeanstalk/*
+!.elasticbeanstalk/*.cfg.yml
+!.elasticbeanstalk/*.global.yml

bffService/ProcFile

@@ -0,0 +1 @@
+web: node ./dist/app.js

bffService/app/app.ts

@@ -0,0 +1,62 @@
+import express, { Express, Request, Response } from 'express';
+import dotenv from 'dotenv';
+import axios, { AxiosResponse, AxiosError } from 'axios';
+
+dotenv.config();
+
+const app: Express = express();
+const port = process.env.PORT || 3001;
+
+app.use(express.json());
+
+app.all('/*', (req: Request, res: Response) => {
+  console.log('Original URL', req.originalUrl);
+  console.log('Method', req.method);
+  console.log('body', req.body);
+
+  const { '0': recipient } = req.params;
+
+  console.log('recipient', recipient);
+  const recipientUrl = process.env[recipient];
+  console.log('recipientUrl', recipientUrl);
+
+  const { authorization } = req.headers;
+
+  if (recipientUrl) {
+    const axiosConfig = {
+      method: req.method,
+      url: `${recipientUrl}${req.originalUrl}`,
+      headers: {
+        authorization,
+      },
+      ...(Object.keys(req.body || {}).length > 0 && { data: req.body }),
+    };
+
+    axios(axiosConfig)
+      .then((response: AxiosResponse) => {
+        console.log('Response from recipient', response.data);
+        res.json(response.data);
+      })
+      .catch((error: AxiosError) => {
+        console.log('response error', JSON.stringify(error));
+
+        if (error.response) {
+          const { status, data } = error.response;
+
+          res.status(status).json(data);
+        } else {
+          res.status(500).json({
+            error: error.message,
+          });
+        }
+      });
+  } else {
+    res.status(502).json({
+      error: 'Cannot process request',
+    });
+  }
+});
+
+app.listen(port, () => {
+  console.log(`⚡️[server]: Server is running at https://localhost:${port}`);
+});