wip: i2p connect

Author: vasild

src/net.cpp

@@ -43,7 +43,9 @@ static_assert(MINIUPNPC_API_VERSION >= 10, "miniUPnPc API version >= 10 assumed"
 #include <chrono>
 #include <cstdint>
 #include <exception>
+#include <ios>
 #include <memory>
+#include <system_error>
 #include <unordered_map>
 
 #include <math.h>
@@ -433,6 +435,9 @@ CNode* CConnman::ConnectNode(CAddress addrConnect, const char *pszDest, bool fCo
     bool connected = false;
     SOCKET hSocket = INVALID_SOCKET;
     proxyType proxy;
+    CAddress addr_bind;
+    assert(!addr_bind.IsValid());
+
     if (addrConnect.IsValid()) {
         bool proxyConnectionFailed = false;
 
@@ -442,6 +447,18 @@ CNode* CConnman::ConnectNode(CAddress addrConnect, const char *pszDest, bool fCo
                 return nullptr;
             }
             connected = ConnectThroughProxy(proxy, addrConnect.ToStringIP(), addrConnect.GetPort(), hSocket, nConnectTimeout, proxyConnectionFailed);
+        } else if (addrConnect.GetNetwork() == NET_I2P) {
+            try {
+                const i2p::Connection& conn = m_i2p_sam_session->Connect(addrConnect);
+                connected = true;
+                hSocket = conn.socket;
+                addr_bind = CAddress{conn.me, NODE_NONE};
+            } catch (const std::ios_base::failure& e) {
+                LogPrint(BCLog::I2P, "I2P: %s\n", e.what());
+                if (e.code() == std::errc::network_unreachable) {
+                    proxyConnectionFailed = true;
+                }
+            }
         } else {
             // no proxy needed (none set for target network)
             hSocket = CreateSocket(addrConnect);
@@ -474,7 +491,9 @@ CNode* CConnman::ConnectNode(CAddress addrConnect, const char *pszDest, bool fCo
     // Add node
     NodeId id = GetNewNodeId();
     uint64_t nonce = GetDeterministicRandomizer(RANDOMIZER_ID_LOCALHOSTNONCE).Write(id).Finalize();
-    CAddress addr_bind = GetBindAddress(hSocket);
+    if (!addr_bind.IsValid()) {
+        addr_bind = GetBindAddress(hSocket);
+    }
     CNode* pnode = new CNode(id, nLocalServices, GetBestHeight(), hSocket, addrConnect, CalculateKeyedNetGroup(addrConnect), nonce, addr_bind, pszDest ? pszDest : "", conn_type);
     pnode->AddRef();