🚧 Add WIP migrate book id endpoint

Author: williamchong

src/routes/wallet/index.ts

@@ -3,7 +3,10 @@ import { checkCosmosSignPayload, checkEvmSignPayload } from '../../util/api/user
 import { ValidationError } from '../../util/ValidationError';
 import { jwtSign } from '../../util/jwt';
 import {
-  findLikeWalletByEvmWallet, migrateLikeUserToEvmUser, migrateLikeWalletToEvmWallet,
+  findLikeWalletByEvmWallet,
+  migrateBookClassId,
+  migrateLikeUserToEvmUser,
+  migrateLikeWalletToEvmWallet,
 } from '../../util/api/wallet';
 
 const router = Router();
@@ -53,6 +56,28 @@ router.post('/authorize', async (req, res, next) => {
   }
 });
 
+router.post('/evm/migrate/book', async (req, res, next) => {
+  try {
+    const {
+      like_class_id: likeClassId,
+      evm_class_id: evmClassId,
+    } = req.body;
+    if (!likeClassId || !evmClassId) throw new ValidationError('INVALID_PAYLOAD');
+    const {
+      error,
+      migratedClassIds,
+      migratedCollectionIds,
+    } = await migrateBookClassId(likeClassId, evmClassId);
+    res.json({
+      migratedClassIds,
+      migratedCollectionIds,
+      error,
+    });
+  } catch (err) {
+    next(err);
+  }
+});
+
 router.post('/evm/migrate/user', async (req, res, next) => {
   try {
     const {

src/util/ValidationHelper.ts

@@ -682,6 +682,7 @@ export function filterNFTBookListingInfo(bookInfo, isOwner = false) {
   const {
     id: inputId,
     classId,
+    evmClassId,
     prices: inputPrices = [],
     shippingRates,
     pendingNFTCount,
@@ -711,6 +712,7 @@ export function filterNFTBookListingInfo(bookInfo, isOwner = false) {
   const payload: any = {
     id,
     classId: id,
+    evmClassId,
     prices,
     shippingRates,
     isSoldOut: stock <= 0,

src/util/api/wallet/index.ts

@@ -1,5 +1,10 @@
 import {
-  db, FieldValue, likeNFTBookCollection, likeNFTBookUserCollection, userCollection,
+  db,
+  FieldValue,
+  likeNFTBookCollection,
+  likeNFTBookUserCollection,
+  likeNFTCollectionCollection,
+  userCollection,
 } from '../../firebase';
 import { migrateLikerLandEvmWallet } from '../../liker-land';
 
@@ -97,6 +102,53 @@ async function migrateLikerId(likeWallet:string, evmWallet: string) {
   }
 }
 
+export async function migrateBookClassId(likeClassId:string, evmClassId: string) {
+  try {
+    // TODO: verify evmClassId contains information about likeClassId
+    const res = await db.runTransaction(async (t) => {
+      const migratedClassIds: string[] = [];
+      const migratedCollectionIds: string[] = [];
+      const [bookListingDoc, collectionQuery] = await Promise.all([
+        t.get(likeNFTBookCollection.doc(likeClassId).get()),
+        t.get(likeNFTCollectionCollection.where('classIds', 'array-contains', likeClassId).limit(100)),
+      ]);
+      if (bookListingDoc.exists) {
+        const { evmClassId: existingEvmClassId } = bookListingDoc.data();
+        if (!existingEvmClassId) {
+          t.update(bookListingDoc.ref, { evmClassId });
+          migratedClassIds.push(likeClassId);
+        }
+      }
+      collectionQuery.docs.forEach((doc) => {
+        const { classIds } = doc.data();
+        const index = classIds.indexOf(likeClassId);
+        if (index >= 0) {
+          classIds[index] = evmClassId;
+          t.update(doc.ref, { classIds });
+          migratedCollectionIds.push(doc.id);
+        }
+      });
+      return {
+        migratedClassIds,
+        migratedCollectionIds,
+      };
+    });
+    const {
+      migratedClassIds,
+      migratedCollectionIds,
+    } = res;
+    return {
+      error: null,
+      migratedClassIds,
+      migratedCollectionIds,
+    };
+  } catch (error) {
+    // eslint-disable-next-line no-console
+    console.error(error);
+    return { error: (error as Error).message };
+  }
+}
+
 export async function migrateLikeUserToEvmUser(likeWallet: string, evmWallet: string) {
   const [
     { error: migrateLikerIdError, likerId },