feat: add create like api POST /users/:address/items/:item_id/likes

Author: KJlmfe

app/controller/user.js

@@ -39,6 +39,25 @@ class UserController extends Controller {
     ctx.body = { address };
   }
 
+  async createLike() {
+    const ctx = this.ctx;
+
+    const to_address = ctx.params.address;
+    const item_id = ctx.params.item_id;
+    const { from_user_id, value, message, referrer } = ctx.request.body;
+
+    // TODO: 检查权限 只有本人 或者 管理员 才有权限
+    // ctx.throw();
+
+    ctx.body = await ctx.service.user.createLike({
+      from_user_id,
+      to_address,
+      item_id,
+      value,
+      message,
+      referrer,
+    });
+  }
 }
 
 module.exports = UserController;

app/router.js

@@ -37,6 +37,8 @@ module.exports = app => {
   router.get('/users/:address', controller.user.getUser);
   router.patch('/users/:address', controller.user.updateUser);
   router.post('/users/:id/wallet', controller.user.createWallet);
+  // 创建打赏
+  router.post('/users/:address/items/:item_id/likes', controller.user.createLike);
 
   router.get('/likes', controller.like.list);
   router.post('/likes', isUser, controller.like.create);

app/service/user.js

@@ -127,6 +127,29 @@ class UserService extends Service {
     };
   }
 
+  // 创建一个打赏
+  async createLike({ from_user_id, to_address, item_id, value, message, referrer }) {
+    const ctx = this.ctx;
+
+    const from_user = await ctx.model.User.find({ where: { id: from_user_id } });
+    if (!from_user) {
+      ctx.throw(400, `用户(id: ${from_user_id})不存在`, { code: 'USER_NOT_FOUND', errors: { from_user_id } });
+    }
+    if (!from_user.address || !from_user.private_key) {
+      ctx.throw(400, `用户(id: ${from_user_id})没有钱包`, { code: 'USER_HAS_NO_WALLET', errors: { from_user_id } });
+    }
+
+    const tx_hash = await ctx.web3.callContract({
+      value,
+      method: 'like',
+      from: from_user.address,
+      to: ctx.app.config.blockchain.contract_address,
+      privateKey: from_user.private_key,
+      args: [ from_user.address, to_address, item_id, message, referrer ],
+    });
+
+    return { tx_hash, tx_link: ctx.app.config.blockchain.etherscan_host + '/tx/' + tx_hash };
+  }
 }
 
 module.exports = UserService;

config/config.default.js

@@ -60,5 +60,10 @@ module.exports = appInfo => {
   // https://ropsten.etherscan.io/address/0x7e0ca9A3c1Bb74C7FD860453e5292b391866aa41
   config.contract = '0x7e0ca9A3c1Bb74C7FD860453e5292b391866aa41';
 
+  config.blockchain = {
+    contract_address: '0xed608ed37a7635a175be1a183bfc87f3b4a69be3',
+    etherscan_host: 'https://ropsten.etherscan.io',
+  };
+
   return config;
 };