saving order details in redis

pass/app/Order.js

+const config = require("config");
+const dayjs = require("dayjs");
+
+class Order {
+  static get STORAGE_KEY_PREFIX() {
+    return "order_";
+  }
+  static get PURCHASE_STORAGE_TIME_MONTHS() {
+    return 6;
+  }
+  // How many minutes is a user allowed to take for finishing the payment
+  static get PURCHASE_TIME_LIMIT_MINUTES() {
+    return 15;
+  }
+
+  /**
+   * Data stored in Redis Database
+   */
+  #order_id;
+  #amount;
+  #price;
+  #encrypted_sales_receipts;
+  #payment_completed;
+
+  /**
+   * Data populated by context
+   */
+  #create_mode;
+  #redis_client;
+
+  constructor(order_id, amount, price, encrypted_sales_receipts) {
+    this.#order_id = order_id;
+    this.#amount = amount;
+    this.#price = price;
+    this.#encrypted_sales_receipts = encrypted_sales_receipts;
+
+    this.#payment_completed = false;
+    this.#create_mode = true;
+
+    let Redis = require("ioredis");
+    this.#redis_client = new Redis({
+      host: config.get("redis.host"),
+    });
+  }
+
+  static async LOAD_ORDER_FROM_ID(order_id) {
+    let Redis = require("ioredis");
+    let redis_client = new Redis({
+      host: config.get("redis.host"),
+    });
+
+    let redis_key = Order.STORAGE_KEY_PREFIX + order_id;
+    let order_data = await redis_client.hgetall(redis_key);
+    console.log(order_data);
+  }
+
+  async save() {
+    let redis_key = Order.STORAGE_KEY_PREFIX + this.#order_id;
+    let expiration = new dayjs();
+    if (this.#create_mode) {
+      expiration = expiration.add(Order.PURCHASE_TIME_LIMIT_MINUTES, "minute");
+    } else {
+      expiration = expiration.add(Order.PURCHASE_STORAGE_TIME_MONTHS, "month");
+    }
+    expiration = Math.round(expiration.diff() / 1000);
+
+    let key_exists = await this.#redis_client.exists(redis_key);
+    if (this.#create_mode && key_exists) {
+      return Promise.reject("Cannot create a Order that already exists!");
+    }
+
+    let storage_promise = this.#redis_client
+      .hmset(redis_key, {
+        order_id: this.#order_id,
+        amount: this.#amount,
+        price: this.#price,
+        encrypted_sales_receipts: this.#encrypted_sales_receipts,
+        payment_completed: this.#payment_completed,
+      })
+      .then((result) => {
+        this.#create_mode = false;
+      })
+      .then((result) => {
+        this.#redis_client.expire(redis_key, expiration);
+      });
+
+    await storage_promise;
+  }
+}
+
+module.exports = Order;

pass/routes/checkout/checkout.js

 const BlindSignature = require("blind-signatures");
 const Crypto = require("../../app/Crypto.js");
+const Order = require("../../app/Order.js");
 const config = require("config");
 
 const price_for_100 = 1;
@@ -115,7 +116,29 @@ router.use(
     if (!errors.isEmpty()) {
       return res.status(400).json({ errors: errors.array() });
     }
-    next("route");
+
+    // Order data is validated: Create and store the order in the redis database
+    let order = new Order(
+      req.body.order_id,
+      req.body.amount,
+      req.body.price,
+      req.body.encrypted_sales_receipts
+    );
+    order
+      .save()
+      .then(() => {
+        // Order created on our side. Continue the payment with the selected provider
+        next("route");
+      })
+      .catch((reason) => {
+        return res.status(400).json({
+          errors: [
+            {
+              msg: reason,
+            },
+          ],
+        });
+      });
   }
 );
 

pass/routes/checkout/paypal.js

@@ -9,10 +9,8 @@ const base = "https://api-m.sandbox.paypal.com";
 
 /* Client initiates payment */
 router.post("/", async (req, res, next) => {
-  res.status(500);
-  res.json(["Disabling Order creating temporarily"]);
-  return;
-  const order = await createOrder();
+  // All Submitted data is verified at this point
+  const order = await createOrder(req);
   res.json(order);
 });
 
@@ -26,11 +24,30 @@ module.exports = router;
 
 // use the orders api to create an order
 
-async function createOrder() {
+async function createOrder(req) {
   const accessToken = await generateAccessToken();
 
   const url = `${base}/v2/checkout/orders`;
 
+  let order = {
+    intent: "CAPTURE",
+
+    purchase_units: [
+      {
+        description: "MetaGer Pass Einkauf",
+        amount: {
+          currency_code: "EUR",
+          value: req.body.price.toFixed(2),
+        },
+      },
+    ],
+    application_context: {
+      brand_name: "SUMA-EV",
+      shipping_preference: "NO_SHIPPING",
+    },
+  };
+  console.log(order.purchase_units[0].amount);
+
   const response = await fetch(url, {
     method: "post",
 
@@ -39,31 +56,7 @@ async function createOrder() {
       Authorization: `Bearer ${accessToken}`,
     },
 
-    body: JSON.stringify({
-      intent: "CAPTURE",
-
-      purchase_units: [
-        {
-          description: "Test Payment",
-          amount: {
-            currency_code: "EUR",
-
-            value: "4.00",
-          },
-        },
-      ],
-      payment_source: {
-        paypal: {
-          experience_context: {
-            payment_method_preference: "IMMEDIATE_PAYMENT_REQUIRED",
-            payment_method_selected: "PAYPAL",
-            user_action: "PAY_NOW",
-            brand_name: "EXAMPLE INC",
-            shipping_preference: "NO_SHIPPING",
-          },
-        },
-      },
-    }),
+    body: JSON.stringify(order),
   });
 
   const data = await response.json();