比特股创始人：Lisk智能合约并不智能，远不及以太坊

我最近为“Steem”实施了一个类似的消息应用（又名插件），Steem甚至还称不上是一个智能合约平台！但我的信息插件比 Lisk的应用要略为强大和复杂。所以，我将在下面展示一个简化的版本。如果你读不懂这些代码，不要担心，你读下解释就行。

第1步 – 定义消息

  struct private_message {

      string from;

      string to;

      string message;

  };

  FC_REFLECT( private_message, (from)(to)(message) )

第二步 —— 定义一个数据库和index函数

这一步比起使用标准的Boost多index函数包含库（Boost Multi Index Containers）而言，谈不上更复杂。这些包含库的性能，要好于任何带有类似index函数的SQL数据库。在这种情况下，我们建立一个强大的index函数，它可以很容易地按照它们接收或发出的顺序来请求信息。这使得每一位用户都能使用“收件箱”和“发件箱”功能。

struct message_object {

    time_point received;

    string         from;

    string         to;

    string         message;

};

FC_REFLECT_DERIVED ( message_object, (db::object), (received)(from)(to)(message) )

struct by_to_date;

struct by_from_date;

struct by_id;  

typedef multi_index_container<

   message_object,

   indexed_by<

      ordered_unique< tag< by_id >, member< object, object_id_type, &object::id > >,

      ordered_unique< tag< by_to_date >, 

            composite_key< message_object,

               member< message_object, string, &message_object::to >,

               member< message_object, time_point, &message_object::receive_time >,

               member<object, object_id_type, &object::id >

            >,

            composite_key_compare< less<string>, 

                                   greater< time_point >, 

                                   less< object_id_type > >

      >,

      ordered_unique< tag< by_from_date >, 

            composite_key< message_object,

               member< message_object, string, &message_object::from >,

               member< message_object, time_point, &message_object::receive_time >,

               member<object, object_id_type, &object::id >

            >,

            composite_key_compare< less<string>, 

                                   greater< time_point >, 

                                   less< object_id_type > >

      >

   >

> message_multi_index_type;

typedef generic_index< message_object, message_multi_index_type> private_message_index;

第三步 － 定义一个API

定义一个API，其目的是允许第三方能够检查你的应用状态。在这个例子当中，我们需要两个API调用，一个是负责收件箱，另一个负责发件箱。

class private_message_api : public std::enable_shared_from_this<private_message_api> {

   public:

      typedef vector<message_object> messages;

      private_message_api(const app::api_context& ctx):_app(&ctx.app){}

      

      messages get_inbox( string to, time_point newest, uint16_t limit )const;

      messages get_outbox( string from, time_point newest, uint16_t limit )const;

   private:

      app::application* _app = nullptr;

};

第四步 － 实现消息处理程序

该方法的目的，是当每一个私有信息（private_message）操作被包含在区块链时，就对状态进行更新处理。该消息处理程序，负责验证消息是被发送者签名过的，如果是这样的，就将该信息添加到数据库当中。

void private_message_plugin::on_operation( const operation_object& op_obj ) {

  if( op_obj.op.which() == operation::tag<custom_json_operation>::value ) {

    const custom_json_operation& cop = op_obj.op.get<custom_json_operation>();

    if( cop.id == “private_message” )  {

      auto message = json::from_string(cop.json).as<private_message_operation>();

      FC_ASSERT( cop.requires_auth(message.from),”sender didn’t sign message” );

      

      db.create<message_object>( [&]( message_object& pmo ) {

               pmo.from               = pm.from;

               pmo.to                 = pm.to;

               pmo.message            = pm.message;

               pmo.receive_time       = db.head_block_time();

            });

    }

  }

}

第五步 － 实现API

通过JSON RPC，这个API是可访问steemd 进程的。除了使用了替代指示by_from_date，而不是by_to_date，这个get_outbox API几乎是相同的。

messages private_message_api::get_inbox( string to, 

                                         time_point newest, 

                                         uint16_t limit )const 

{

   const auto& pmi = db.get_index_type<private_message_index>();

   const auto& idx = pmi.indices().get<by_to_date>();

   messages result;   

   auto itr = idx.lower_bound( make_tuple( to, newest ) );

   while( itr != idx.end() && limit && itr->to == to ) {

      result.push_back(*itr);

      ++itr;   –limit;

   }

   return result;

}