moved all stuff to github

1 files changed, 315 insertions, 0 deletions

diff --git a/src/p2p/p2p_protocol_defs.h b/src/p2p/p2p_protocol_defs.h
new file mode 100644
index 000000000..7ae6d08f3
--- /dev/null
+++ b/src/p2p/p2p_protocol_defs.h
@@ -0,0 +1,315 @@
+// Copyright (c) 2012-2013 The Cryptonote developers
+// Distributed under the MIT/X11 software license, see the accompanying
+// file COPYING or http://www.opensource.org/licenses/mit-license.php.
+
+#pragma once
+
+#include <boost/uuid/uuid.hpp>
+#include "serialization/keyvalue_serialization.h"
+#include "misc_language.h"
+#include "cryptonote_config.h"
+#include "crypto/crypto.h"
+
+namespace nodetool
+{
+  typedef boost::uuids::uuid uuid;
+  typedef uint64_t peerid_type;
+
+#pragma pack (push, 1)
+  
+  struct net_address
+  {
+    boost::uint32_t ip;
+    boost::uint32_t port;
+  };
+
+  struct peerlist_entry
+  {
+    net_address adr;
+    peerid_type id;
+    time_t last_seen;
+  };
+
+  struct connection_entry
+  {
+    net_address adr;
+    peerid_type id;
+    bool is_income;
+  };
+
+#pragma pack(pop)
+
+  inline
+  bool operator < (const net_address& a, const net_address& b)
+  {
+    return  epee::misc_utils::is_less_as_pod(a, b);
+  }
+
+  inline
+    bool operator == (const net_address& a, const net_address& b)
+  {
+    return  memcmp(&a, &b, sizeof(a)) == 0;
+  }
+  inline 
+  std::string print_peerlist_to_string(const std::list<peerlist_entry>& pl)
+  {
+    time_t now_time = 0;
+    time(&now_time);
+    std::stringstream ss;
+    ss << std::setfill ('0') << std::setw (8) << std::hex << std::noshowbase;
+    BOOST_FOREACH(const peerlist_entry& pe, pl)
+    {
+      ss << pe.id << "\t" << epee::string_tools::get_ip_string_from_int32(pe.adr.ip) << ":" << boost::lexical_cast<std::string>(pe.adr.port) << " \tlast_seen: " << epee::misc_utils::get_time_interval_string(now_time - pe.last_seen) << std::endl;
+    }
+    return ss.str();
+  }
+
+
+  struct network_config
+  {
+    BEGIN_KV_SERIALIZE_MAP()
+      KV_SERIALIZE(connections_count)
+      KV_SERIALIZE(handshake_interval)
+      KV_SERIALIZE(packet_max_size)
+      KV_SERIALIZE(config_id)
+    END_KV_SERIALIZE_MAP()
+
+    boost::uint32_t connections_count;
+    boost::uint32_t connection_timeout;
+    boost::uint32_t ping_connection_timeout;
+    boost::uint32_t handshake_interval;
+    boost::uint32_t packet_max_size;
+    boost::uint32_t config_id;
+    boost::uint32_t send_peerlist_sz;
+  };
+
+  struct basic_node_data
+  {
+    uuid network_id;                   
+    time_t local_time;
+    uint32_t my_port;
+    peerid_type peer_id;
+
+    BEGIN_KV_SERIALIZE_MAP()
+      KV_SERIALIZE_VAL_POD_AS_BLOB(network_id)
+      KV_SERIALIZE(peer_id)
+      KV_SERIALIZE(local_time)
+      KV_SERIALIZE(my_port)
+    END_KV_SERIALIZE_MAP()
+  };
+  
+
+#define P2P_COMMANDS_POOL_BASE 1000
+
+  /************************************************************************/
+  /*                                                                      */
+  /************************************************************************/
+  template<class t_playload_type>
+	struct COMMAND_HANDSHAKE_T
+	{
+		const static int ID = P2P_COMMANDS_POOL_BASE + 1;
+
+    struct request
+    {
+      basic_node_data node_data;
+      t_playload_type payload_data;
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(node_data)
+        KV_SERIALIZE(payload_data)
+      END_KV_SERIALIZE_MAP()
+    };
+
+    struct response
+    {
+      basic_node_data node_data;
+      t_playload_type payload_data;
+      std::list<peerlist_entry> local_peerlist; 
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(node_data)
+        KV_SERIALIZE(payload_data)
+        KV_SERIALIZE_CONTAINER_POD_AS_BLOB(local_peerlist)
+      END_KV_SERIALIZE_MAP()
+    };
+	};
+
+
+  /************************************************************************/
+  /*                                                                      */
+  /************************************************************************/
+  template<class t_playload_type>
+  struct COMMAND_TIMED_SYNC_T
+  {
+    const static int ID = P2P_COMMANDS_POOL_BASE + 2;
+
+    struct request
+    {
+      t_playload_type payload_data;
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(payload_data)
+      END_KV_SERIALIZE_MAP()
+    };
+
+    struct response
+    {
+      time_t local_time;
+      t_playload_type payload_data;
+      std::list<peerlist_entry> local_peerlist; 
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(local_time)
+        KV_SERIALIZE(payload_data)
+        KV_SERIALIZE_CONTAINER_POD_AS_BLOB(local_peerlist)
+      END_KV_SERIALIZE_MAP()
+    };
+  };
+
+  /************************************************************************/
+  /*                                                                      */
+  /************************************************************************/
+
+  struct COMMAND_PING
+  {
+    /*
+      Used to make "callback" connection, to be sure that opponent node 
+      have accessible connection point. Only other nodes can add peer to peerlist,
+      and ONLY in case when peer has accepted connection and answered to ping.
+    */
+    const static int ID = P2P_COMMANDS_POOL_BASE + 3;
+
+#define PING_OK_RESPONSE_STATUS_TEXT "OK"
+
+    struct request
+    {
+      /*actually we don't need to send any real data*/
+
+      BEGIN_KV_SERIALIZE_MAP()
+      END_KV_SERIALIZE_MAP()
+    };
+
+    struct response
+    {
+      std::string status;
+      peerid_type peer_id;
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(status)
+        KV_SERIALIZE(peer_id)
+      END_KV_SERIALIZE_MAP()    
+    };
+  };
+
+  
+#ifdef ALLOW_DEBUG_COMMANDS
+  //These commands are considered as insecure, and made in debug purposes for a limited lifetime. 
+  //Anyone who feel unsafe with this commands can disable the ALLOW_GET_STAT_COMMAND macro.
+
+  struct proof_of_trust
+  {
+    peerid_type peer_id;
+    uint64_t    time;
+    crypto::signature sign;
+
+    BEGIN_KV_SERIALIZE_MAP()
+      KV_SERIALIZE(peer_id)
+      KV_SERIALIZE(time)        
+      KV_SERIALIZE_VAL_POD_AS_BLOB(sign)  
+    END_KV_SERIALIZE_MAP()    
+  };
+
+
+  template<class payload_stat_info>
+  struct COMMAND_REQUEST_STAT_INFO_T
+  {
+    const static int ID = P2P_COMMANDS_POOL_BASE + 4;
+
+    struct request
+    {
+      proof_of_trust tr;
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(tr)
+      END_KV_SERIALIZE_MAP()    
+    };
+    
+    struct response
+    {
+      std::string version;
+      std::string os_version;
+      uint64_t connections_count;
+      uint64_t incoming_connections_count;
+      payload_stat_info payload_info;
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(version)
+        KV_SERIALIZE(os_version)
+        KV_SERIALIZE(connections_count)
+        KV_SERIALIZE(incoming_connections_count)
+        KV_SERIALIZE(payload_info)
+      END_KV_SERIALIZE_MAP()    
+    };
+  };
+
+
+  /************************************************************************/
+  /*                                                                      */
+  /************************************************************************/
+  struct COMMAND_REQUEST_NETWORK_STATE
+  {
+    const static int ID = P2P_COMMANDS_POOL_BASE + 5;
+
+    struct request
+    {
+      proof_of_trust tr;
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(tr)
+      END_KV_SERIALIZE_MAP()    
+    };
+
+    struct response
+    {
+      std::list<peerlist_entry> local_peerlist_white; 
+      std::list<peerlist_entry> local_peerlist_gray; 
+      std::list<connection_entry> connections_list; 
+      peerid_type my_id;
+      uint64_t    local_time;
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE_CONTAINER_POD_AS_BLOB(local_peerlist_white)
+        KV_SERIALIZE_CONTAINER_POD_AS_BLOB(local_peerlist_gray)
+        KV_SERIALIZE_CONTAINER_POD_AS_BLOB(connections_list)
+        KV_SERIALIZE(my_id)
+        KV_SERIALIZE(local_time)
+      END_KV_SERIALIZE_MAP()    
+    };
+  };
+
+  /************************************************************************/
+  /*                                                                      */
+  /************************************************************************/
+  struct COMMAND_REQUEST_PEER_ID
+  {
+    const static int ID = P2P_COMMANDS_POOL_BASE + 6;
+
+    struct request
+    {
+      BEGIN_KV_SERIALIZE_MAP()
+      END_KV_SERIALIZE_MAP()    
+    };
+
+    struct response
+    {
+      peerid_type my_id;
+
+      BEGIN_KV_SERIALIZE_MAP()
+        KV_SERIALIZE(my_id)
+      END_KV_SERIALIZE_MAP()    
+    };
+  };
+
+#endif
+
+
+}
+
+
+