Merge pull request #1341 from ainblockchain/bugfix/platfowner/bugfix

Update echo-bot code

Author: platfowner

tools/chatbot/sendCreateAppAndConfigTx.js

@@ -27,12 +27,12 @@ function buildChatbotConfigTxBody(timestamp) {
       op_list: [
         {
           type: "SET_OWNER",
-          ref: `/apps/${config.appName}/common/messages`,
+          ref: `/apps/${config.appName}/messages`,
           value: {
             ".owner": {
               owners: {
                 "*": {
-                  branch_owner: true,
+                  branch_owner: false,
                   write_function: true,
                   write_owner: true,
                   write_rule: true
@@ -43,7 +43,7 @@ function buildChatbotConfigTxBody(timestamp) {
         },
         {
           type: "SET_RULE",
-          ref: `/apps/${config.appName}/common/messages/$key`,
+          ref: `/apps/${config.appName}/messages/$addr/$key`,
           value: {
             ".rule": {
               "write": true
@@ -52,13 +52,13 @@ function buildChatbotConfigTxBody(timestamp) {
         },
         {
           type: "SET_FUNCTION",
-          ref: `/apps/${config.appName}/common/messages/$key/user`,
+          ref: `/apps/${config.appName}/messages/$addr/$key/user`,
           value: {
             ".function": {
-              "liayoo-ainjs": {
+              "echo-bot": {
                 function_type: "REST",
                 function_url: "http://localhost:3000/trigger",
-                function_id: "liayoo-ainjs"
+                function_id: "echo-bot"
               }
             }
           }

tools/chatbot/sendMessageTx.js

@@ -4,11 +4,11 @@ const path = require('path');
 const { signAndSendTx, confirmTransaction } = require('../util');
 let config = {};
 
-function buildMessageTxBody(timestamp, message) {
+function buildMessageTxBody(address, timestamp, message) {
   return {
     operation: {
       type: 'SET_VALUE',
-      ref: `/apps/${config.appName}/common/messages/${timestamp}/user`,
+      ref: `/apps/${config.appName}/messages/${address}/${timestamp}/user`,
       value: message,
     },
     gas_price: 500,
@@ -17,11 +17,11 @@ function buildMessageTxBody(timestamp, message) {
   };
 }
 
-async function sendTransaction(message) {
+async function sendTransaction(config, message) {
   console.log('\n*** sendTransaction():');
   const timestamp = Date.now();
 
-  const txBody = buildMessageTxBody(timestamp, message);
+  const txBody = buildMessageTxBody(config.userAddr, timestamp, message);
   console.log(`txBody: ${JSON.stringify(txBody, null, 2)}`);
 
   const txInfo = await signAndSendTx(config.endpointUrl, txBody, config.serviceOwnerPrivateKey, config.chainId);
@@ -42,7 +42,7 @@ async function processArguments() {
     message = process.argv[3];
   }
   config = require(path.resolve(__dirname, process.argv[2]));
-  await sendTransaction(message);
+  await sendTransaction(config, message);
 }
 
 function usage() {

tools/simple-chatbot-server/index.js

@@ -42,8 +42,8 @@ app.post('/trigger', async (req, res) => {
   const ref = _.get(tx, 'tx_body.operation.ref');
   const parsedRef = CommonUtil.parsePath(ref);
   const userVal = _.get(tx, 'tx_body.operation.value');
-  if (parsedRef.length !== 6 || parsedRef[0] !== 'apps' || parsedRef[1] !== APP_NAME ||
-      parsedRef[3] !== 'messages' || parsedRef[5] !== 'user') {
+    if (parsedRef.length !== 6 || parsedRef[0] !== 'apps' ||
+      parsedRef[2] !== 'messages' || parsedRef[5] !== 'user') {
     console.log(`Not supported path pattern: ${ref}`);
     return;
   }

tools/simple-chatbot-server/start_echo_bot.sh

@@ -0,0 +1,2 @@
+nohup node ./index.js >console_logs.txt 2>error_logs.txt &
+