feat: support transfer address from user to user (#484)

* feat: support transfer address from user to user

* feat: remove service worker

worker/src/user_api/bind_address.ts

@@ -5,6 +5,7 @@ import { HonoCustomType } from '../types';
 import { UserSettings } from "../models";
 import { getJsonSetting } from "../utils"
 import { CONSTANTS } from "../constants";
+import { unbindTelegramByAddress } from '../telegram_api/common';
 
 export default {
     bind: async (c: Context<HonoCustomType>) => {
@@ -89,7 +90,7 @@ export default {
                 return c.text("Failed to unbind", 500)
             }
         } catch (e) {
-            return c.text("Invalid address token", 400)
+            return c.text("Failed to unbind", 500)
         }
         return c.json({ success: true })
     },
@@ -139,4 +140,92 @@ export default {
             jwt: jwt
         })
     },
+    transferAddress: async (c: Context<HonoCustomType>) => {
+        const { user_id } = c.get("userPayload");
+        const { address_id, target_user_email } = await c.req.json();
+        // check if address exists
+        const address = await c.env.DB.prepare(
+            `SELECT name FROM address where id = ?`
+        ).bind(address_id).first<string>("name");
+        if (!address) {
+            return c.text("Address not found", 400)
+        }
+        // check if user exists
+        const db_user_id = await c.env.DB.prepare(
+            `SELECT id FROM users where id = ?`
+        ).bind(user_id).first("id");
+        if (!db_user_id) {
+            return c.text("User not found", 400)
+        }
+        // check if target user exists
+        const target_user_id = await c.env.DB.prepare(
+            `SELECT id FROM users where user_email = ?`
+        ).bind(target_user_email).first("id");
+        if (!target_user_id) {
+            return c.text("Target user not found", 400)
+        }
+        // check target user binded address count
+        const value = await getJsonSetting(c, CONSTANTS.USER_SETTINGS_KEY);
+        const settings = new UserSettings(value);
+        if (settings.maxAddressCount > 0) {
+            const { count } = await c.env.DB.prepare(
+                `SELECT COUNT(*) as count FROM users_address where user_id = ?`
+            ).bind(target_user_id).first<{ count: number }>() || { count: 0 };
+            if (count >= settings.maxAddressCount) {
+                return c.text("Target User Max address count reached", 400)
+            }
+        }
+        // check if binded
+        const db_user_address_id = await c.env.DB.prepare(
+            `SELECT user_id FROM users_address where user_id = ? and address_id = ?`
+        ).bind(user_id, address_id).first("user_id");
+        if (!db_user_address_id) return c.text("Address not binded", 400)
+        // unbind telegram address
+        await unbindTelegramByAddress(c, address);
+        // unbind user address
+        try {
+            const { success } = await c.env.DB.prepare(
+                `DELETE FROM users_address where user_id = ? and address_id = ?`
+            ).bind(user_id, address_id).run();
+            if (!success) {
+                return c.text("Failed to unbind", 500)
+            }
+        } catch (e) {
+            return c.text("Failed to unbind user", 500)
+        }
+        // delete address
+        await c.env.DB.prepare(
+            `DELETE FROM address WHERE id = ? `
+        ).bind(address_id).run();
+        // new address
+        const { success: newAddressSuccess } = await c.env.DB.prepare(
+            `INSERT INTO address(name) VALUES(?)`
+        ).bind(address).run();
+        if (!newAddressSuccess) {
+            throw new Error("Failed to create address")
+        }
+        // find new address id
+        let new_address_id = await c.env.DB.prepare(
+            `SELECT id FROM address WHERE name = ?`
+        ).bind(address).first<number | null | undefined>("id");
+        if (!new_address_id) {
+            throw new Error("Failed to find new address id")
+        }
+        // bind
+        try {
+            const { success } = await c.env.DB.prepare(
+                `INSERT INTO users_address (user_id, address_id) VALUES (?, ?)`
+            ).bind(target_user_id, new_address_id).run();
+            if (!success) {
+                return c.text("Failed to bind", 500)
+            }
+        } catch (e) {
+            const error = e as Error;
+            if (error.message && error.message.includes("UNIQUE")) {
+                return c.text("Address already binded, please unbind first", 400)
+            }
+            return c.text("Failed to bind", 500)
+        }
+        return c.json({ success: true })
+    }
 }

worker/src/user_api/index.ts

@@ -27,6 +27,7 @@ api.get('/user_api/bind_address', bind_address.getBindedAddresses);
 api.post('/user_api/bind_address', bind_address.bind);
 api.get('/user_api/bind_address_jwt/:address_id', bind_address.getBindedAddressJwt);
 api.post('/user_api/unbind_address', bind_address.unbind);
+api.post('/user_api/transfer_address', bind_address.transferAddress);
 
 // passkey api
 api.get('/user_api/passkey', passkey.getPassKeys);