P2P: Feature: Transaction notice

plugins/net_plugin/include/eosio/net_plugin/buffer_factory.hpp

@@ -124,6 +124,15 @@ namespace eosio {
          return send_buffer;
       }
 
+      /// caches result for subsequent calls, only provide same packed_transaction_ptr instance for each invocation.
+      /// Do not use get_send_buffer() with get_notice_send_buffer(), only one valid per trx_buffer_factory instance.
+      const send_buffer_type& get_notice_send_buffer( const packed_transaction_ptr& trx ) {
+         if( !send_buffer ) {
+            send_buffer = buffer_factory::create_send_buffer( transaction_notice_message{trx->id()} );
+         }
+         return send_buffer;
+      }
+
    private:
 
       static send_buffer_type create_send_buffer( const packed_transaction_ptr& trx ) {

plugins/net_plugin/include/eosio/net_plugin/protocol.hpp

@@ -136,6 +136,10 @@ namespace eosio {
       block_id_type id;
    };
 
+   struct transaction_notice_message {
+      transaction_id_type id;
+   };
+
    struct gossip_bp_peers_message {
       struct bp_peer_info_v1 {
          std::string               server_endpoint;      // externally available address to connect to
@@ -175,7 +179,8 @@ namespace eosio {
                                     vote_message,
                                     block_nack_message,
                                     block_notice_message,
-                                    gossip_bp_peers_message>;
+                                    gossip_bp_peers_message,
+                                    transaction_notice_message>;
 
    // see protocol net_message
    enum class msg_type_t {
@@ -191,7 +196,8 @@ namespace eosio {
       vote_message           = fc::get_index<net_message, vote_message>(),
       block_nack_message     = fc::get_index<net_message, block_nack_message>(),
       block_notice_message   = fc::get_index<net_message, block_notice_message>(),
-      gossip_bp_peers_message= fc::get_index<net_message, gossip_bp_peers_message>(),
+      gossip_bp_peers_message    = fc::get_index<net_message, gossip_bp_peers_message>(),
+      transaction_notice_message = fc::get_index<net_message, transaction_notice_message>(),
       unknown
    };
 
@@ -225,6 +231,7 @@ FC_REFLECT( eosio::request_message, (req_trx)(req_blocks) )
 FC_REFLECT( eosio::sync_request_message, (start_block)(end_block) )
 FC_REFLECT( eosio::block_nack_message, (id) )
 FC_REFLECT( eosio::block_notice_message, (previous)(id) )
+FC_REFLECT( eosio::transaction_notice_message, (id) )
 FC_REFLECT( eosio::gossip_bp_peers_message::bp_peer_info_v1, (server_endpoint)(outbound_ip_address)(expiration) )
 FC_REFLECT( eosio::gossip_bp_peers_message::bp_peer, (version)(producer_name)(bp_peer_info) )
 FC_REFLECT_DERIVED(eosio::gossip_bp_peers_message::signed_bp_peer, (eosio::gossip_bp_peers_message::bp_peer), (sig) )