✨ Store cart to user db

src/server/api/routes/users/v2/auth.js

@@ -32,6 +32,7 @@ router.get('/self', authenticateV2Login, async (req, res, next) => {
       eventLastSeenTs,
       lastLoginMethod: loginMethod,
       locale = DEFAULT_LOCALE,
+      cart,
     } = userDoc.data();
     if (email) {
       try {
@@ -53,6 +54,7 @@ router.get('/self', authenticateV2Login, async (req, res, next) => {
       eventLastSeenTs: eventLastSeenTs ? eventLastSeenTs.toMillis() : 1000,
       locale,
       crispToken: email ? getCrispUserHash(email) : undefined,
+      cart,
     });
   } catch (err) {
     if (req.session) req.session = null;
@@ -71,6 +73,7 @@ router.post('/login', async (req, res, next) => {
     loginMethod = '',
     gaClientId,
     userIdHash,
+    cart,
   } = req.body;
   try {
     if (!inputWallet || !signature || !publicKey || !message) {
@@ -158,6 +161,7 @@ router.post('/login', async (req, res, next) => {
       displayName,
       isNew,
       crispToken: email ? getCrispUserHash(email) : undefined,
+      cart,
     };
     res.json(payload);
     return;

src/server/api/routes/users/v2/cart.js

@@ -0,0 +1,64 @@
+const { Router } = require('express');
+
+const { authenticateV2Login } = require('../../../middleware/auth');
+const {
+  FieldValue,
+  walletUserCollection,
+} = require('../../../../modules/firebase');
+
+const router = Router();
+
+router.get('/cart', authenticateV2Login, async (req, res) => {
+  const { user } = req.session;
+  const cartDoc = await walletUserCollection.doc(user).get();
+  const { cart } = cartDoc.data();
+  res.json({ cart: cart || [] });
+});
+
+router.post('/cart', authenticateV2Login, async (req, res) => {
+  const { user } = req.session;
+  const { cart: inputCart } = req.body;
+  const cart = inputCart
+    .reduce((acc, item) => {
+      acc[item.productId] = item;
+      return acc;
+    }, {})
+    .map(item => {
+      const {
+        productId,
+        collectionId,
+        classId,
+        coupon,
+        customPriceInDecimal,
+        from,
+        timestamp,
+        quantity,
+        priceIndex,
+      } = item;
+      return {
+        productId,
+        collectionId,
+        classId,
+        coupon,
+        customPriceInDecimal,
+        from,
+        timestamp,
+        quantity,
+        priceIndex,
+      };
+    });
+  await walletUserCollection.doc(user).update({
+    cart: cart?.length ? cart : FieldValue.delete(),
+    cartUpdateTimestamp: FieldValue.serverTimestamp(),
+  });
+  res.sendStatus(200);
+});
+
+router.delete('/cart', authenticateV2Login, async (req, res) => {
+  const { user } = req.session;
+  await walletUserCollection.doc(user).update({
+    cart: FieldValue.delete(),
+    cartUpdateTimestamp: FieldValue.serverTimestamp(),
+  });
+  res.sendStatus(200);
+});

src/server/api/routes/users/v2/index.js

@@ -1,6 +1,7 @@
 const { Router } = require('express');
 
 const auth = require('./auth');
+const cart = require('./cart');
 const email = require('./email');
 const event = require('./event');
 const follow = require('./follow');
@@ -12,6 +13,7 @@ const wallet = require('./wallet');
 const router = Router();
 
 router.use(auth);
+router.use(cart);
 router.use(email);
 router.use(event);
 router.use(follow);

src/store/modules/cart.js

@@ -5,6 +5,7 @@ import {
   saveShoppingCartToStorage,
 } from '~/util/shopping-cart';
 import { BATCH_COLLECT_MAX } from '~/constant';
+import { postShoppingCart, deleteShoppingCart } from '~/util/api';
 import * as TYPES from '../mutation-types';
 
 const state = () => ({
@@ -169,14 +170,29 @@ const actions = {
     commit(TYPES.SHOPPING_CART_REPLACE_ALL_BOOK_PRODUCT, {});
     dispatch('saveBookProductShoppingCart');
   },
-  saveBookProductShoppingCart({ state }) {
+  async saveBookProductShoppingCart({ state, getters }) {
     saveShoppingCartToStorage(state.shoppingCartBookProductByIdMap, 'book');
+    if (getters.loginAddress) {
+      const cart = Object.values(state.shoppingCartBookProductByIdMap);
+      try {
+        if (cart.length) {
+          await this.$api.$post(postShoppingCart(), { cart });
+        } else {
+          await this.$api.$post(postShoppingCart(), { cart });
+        }
+      } catch (e) {
+        // eslint-disable-next-line no-console
+        console.error(e);
+      }
+    }
   },
-  loadBookProductShoppingCart({ commit }) {
-    commit(
-      TYPES.SHOPPING_CART_REPLACE_ALL_BOOK_PRODUCT,
-      loadShoppingCartFromStorage('book')
-    );
+  loadBookProductShoppingCart({ commit, getters }) {
+    if (!getters.shoppingCartBookItems.length) {
+      commit(
+        TYPES.SHOPPING_CART_REPLACE_ALL_BOOK_PRODUCT,
+        loadShoppingCartFromStorage('book')
+      );
+    }
   },
 };
 

src/store/modules/wallet.js

@@ -840,13 +840,16 @@ const actions = {
     if (!checkIsLikeCoinAppInAppBrowser(this.$router.app.$route)) {
       await dispatch('setLocale', userInfo.locale);
     }
-    const { displayName, email, crispToken } = userInfo;
+    const { displayName, email, crispToken, cart } = userInfo;
     updateLoggerUserInfo(this, {
       email,
       displayName,
       wallet: state.address,
       crispToken,
     });
+    if (cart?.length) {
+      dispatch('addBookProductsToShoppingCart', cart);
+    }
     return userInfo;
   },
   async walletFetchSessionUserData(

src/util/api/index.js

@@ -454,6 +454,10 @@ export const getUserV2Self = () => '/api/v2/users/self';
 export const postUserV2Login = () => '/api/v2/users/login';
 export const postUserV2Logout = () => '/api/v2/users/logout';
 
+export const getShoppingCart = () => '/api/v2/cart';
+export const postShoppingCart = () => '/api/v2/cart';
+export const deleteShoppingCart = () => '/api/v2/cart';
+
 export const postUserV2WalletEmail = ({
   email,
   followee,