✨ Add evm migration API

Author: williamchong

src/routes/wallet/index.ts

@@ -2,7 +2,7 @@ import { Router } from 'express';
 import { checkCosmosSignPayload, checkEvmSignPayload } from '../../util/api/users';
 import { ValidationError } from '../../util/ValidationError';
 import { jwtSign } from '../../util/jwt';
-import { findLikeWalletByEvmWallet } from '../../util/api/wallet';
+import { findLikeWalletByEvmWallet, migrateLikeWalletToEvmWallet } from '../../util/api/wallet';
 
 const router = Router();
 
@@ -51,4 +51,47 @@ router.post('/authorize', async (req, res, next) => {
   }
 });
 
+router.post('/evm/migrate', async (req, res, next) => {
+  try {
+    const {
+      wallet, from, signature, publicKey, message, signMethod,
+    } = req.body;
+    const inputWallet = wallet || from;
+    if (!inputWallet || !signature || !publicKey || !message) throw new ValidationError('INVALID_PAYLOAD');
+    if (!publicKey) throw new ValidationError('INVALID_PAYLOAD');
+    const signed = checkCosmosSignPayload({
+      signature, publicKey, message, inputWallet, signMethod, action: 'migrate',
+    });
+    if (!signed) {
+      throw new ValidationError('INVALID_SIGN');
+    }
+    const { evmWallet } = signed;
+    if (!evmWallet) {
+      throw new ValidationError('INVALID_PAYLOAD');
+    }
+    const {
+      isMigratedBookUser,
+      isMigratedLikerId,
+      isMigratedLikerLand,
+      migratedLikerId,
+      migratedLikerLandUser,
+      migrateBookUserError,
+      migrateLikerIdError,
+      migrateLikerLandError,
+    } = await migrateLikeWalletToEvmWallet(evmWallet, inputWallet);
+    res.json({
+      isMigratedBookUser,
+      isMigratedLikerId,
+      isMigratedLikerLand,
+      migratedLikerId,
+      migratedLikerLandUser,
+      migrateBookUserError,
+      migrateLikerIdError,
+      migrateLikerLandError,
+    });
+  } catch (err) {
+    next(err);
+  }
+});
+
 export default router;

src/util/api/wallet/index.ts

@@ -1,4 +1,7 @@
-import { likeNFTBookUserCollection } from '../../firebase';
+import {
+  db, FieldValue, likeNFTBookUserCollection, userCollection,
+} from '../../firebase';
+import { migrateLikerLandEvmWallet } from '../../liker-land';
 
 export async function findLikeWalletByEvmWallet(evmWallet: string) {
   const userQuery = await likeNFTBookUserCollection.where('evmWallet', '==', evmWallet).get();
@@ -8,4 +11,80 @@ export async function findLikeWalletByEvmWallet(evmWallet: string) {
   return userQuery.docs[0].data()?.likeWallet;
 }
 
+async function migrateBookUser(likeWallet: string, evmWallet: string) {
+  try {
+    const userExists = await db.runTransaction(async (t) => {
+      const [evmQuery, userDoc] = await Promise.all([
+        t.get(likeNFTBookUserCollection.where('evmWallet', '==', evmWallet).limit(1)),
+        t.get(likeNFTBookUserCollection.doc(likeWallet).get()),
+      ]);
+      if (evmQuery.docs.length > 0) {
+        throw new Error('EVM_WALLET_ALREADY_EXIST');
+      }
+      if (!userDoc.exists) {
+        t.create(likeNFTBookUserCollection.doc(likeWallet), {
+          evmWallet,
+          likeWallet,
+          timestamp: FieldValue.serverTimestamp(),
+        });
+      } else {
+        t.update({ evmWallet, likeWallet });
+      }
+      return userDoc.exists;
+    });
+    return { error: null };
+  } catch (error) {
+    // eslint-disable-next-line no-console
+    console.error(error);
+    return { error: (error as Error).message };
+  }
+}
+
+async function migrateLikerId(likeWallet:string, evmWallet: string) {
+  try {
+    const likerId = await db.runTransaction(async (t) => {
+      const [evmQuery, userQuery] = await Promise.all([
+        t.get(userCollection.where('evmWallet', '==', evmWallet).limit(1)),
+        t.get(userCollection.where('likeWallet', '==', likeWallet).limit(1)),
+      ]);
+      if (evmQuery.docs.length > 0) {
+        throw new Error('EVM_WALLET_ALREADY_EXIST');
+      }
+      if (userQuery.docs.length === 0) {
+        throw new Error('LIKE_WALLET_NOT_FOUND');
+      }
+      const userDoc = userQuery.docs[0];
+      t.update(userDoc.ref, { evmWallet });
+      return userDoc.id;
+    });
+    return { likerId, error: null };
+  } catch (error) {
+    // eslint-disable-next-line no-console
+    console.error(error);
+    return { error: (error as Error).message };
+  }
+}
+
+export async function migrateLikeWalletToEvmWallet(likeWallet: string, evmWallet: string) {
+  const [
+    { error: migrateBookUserError },
+    { error: migrateLikerIdError, likerId },
+    { error: migrateLikerLandError, user: likerLandUser },
+  ] = await Promise.all([
+    migrateBookUser(likeWallet, evmWallet),
+    migrateLikerId(likeWallet, evmWallet),
+    migrateLikerLandEvmWallet(likeWallet, evmWallet),
+  ]);
+  return {
+    isMigratedBookUser: !migrateBookUserError,
+    isMigratedLikerId: !migrateLikerIdError,
+    isMigratedLikerLand: !migrateLikerLandError,
+    migratedLikerId: likerId,
+    migratedLikerLandUser: likerLandUser,
+    migrateBookUserError,
+    migrateLikerIdError,
+    migrateLikerLandError,
+  };
+}
+
 export default findLikeWalletByEvmWallet;

src/util/liker-land.ts

@@ -1,4 +1,4 @@
-import axios from 'axios';
+import axios, { AxiosError } from 'axios';
 import { LIKER_LAND_HOSTNAME } from '../constant';
 import {
   LIKER_LAND_GET_WALLET_SECRET,
@@ -431,3 +431,20 @@ export async function fetchLikerLandWalletUserInfo(wallet) {
     return null;
   }
 }
+
+export async function migrateLikerLandEvmWallet(likeWallet: string, evmWallet: string) {
+  try {
+    const { data } = await axios.post(`https://${LIKER_LAND_HOSTNAME}/api/v2/users/wallet/evm/migrate`, {
+      evmWallet,
+    }, {
+      headers: { 'x-likerland-api-key': LIKER_LAND_GET_WALLET_SECRET },
+      params: { wallet: likeWallet },
+    });
+    return { user: data, error: null };
+  } catch (error) {
+    if (axios.isAxiosError(error)) {
+      return { error: new Error((error as AxiosError).response?.data as string) };
+    }
+    return { user: null, error: null };
+  }
+}