rpc: Expose BIP324 session id via getpeerinfo

Author: dhruv

src/net.cpp

@@ -689,6 +689,7 @@ void CNode::CopyStats(CNodeStats& stats)
 
     X(m_conn_type);
     X(m_transport_type);
+    X(m_v2_session_id);
 }
 #undef X
 
@@ -712,6 +713,7 @@ void CNode::InitV2P2P(const Span<const std::byte> their_ellswift, const Span<con
     }
     // Both peers must keep around a copy of the garbage terminator for the BIP324 shapable handshake
     v2_keys_derived = true;
+    m_v2_session_id = HexStr(v2_keys.session_id);
 }
 
 void CNode::EnsureInitV2Key(bool initiating)

src/net.h

@@ -234,6 +234,7 @@ class CNodeStats
     uint32_t m_mapped_as;
     ConnectionType m_conn_type;
     TransportProtocolType m_transport_type;
+    std::string m_v2_session_id;
 };
 
 
@@ -656,7 +657,7 @@ class CNode
           bool inbound_onion,
           CNodeOptions&& node_opts = {},
           bool prefer_p2p_v2 = false,
-         TransportProtocolType transport_type_in = TransportProtocolType::V1);
+          TransportProtocolType transport_type_in = TransportProtocolType::V1);
     CNode(const CNode&) = delete;
     CNode& operator=(const CNode&) = delete;
 
@@ -759,6 +760,7 @@ class CNode
 
     // Peer prefers a BIP324(v2) p2p transport
     bool m_prefer_p2p_v2;
+    std::string m_v2_session_id;
 };
 
 /**

src/rpc/net.cpp

@@ -169,6 +169,7 @@ static RPCHelpMan getpeerinfo()
                                                               "Please note this output is unlikely to be stable in upcoming releases as we iterate to\n"
                                                               "best capture connection behaviors."},
                     {RPCResult::Type::STR, "transport_protocol_type", "Type of transport protocol: \n" + Join(TRANSPORT_TYPE_DOC, ",\n") + ".\n"},
+                    {RPCResult::Type::STR, "v2_session_id", /* optional */ true, "BIP324 session id for an encrypted v2 connection.\n"},
                 }},
             }},
         },
@@ -270,6 +271,9 @@ static RPCHelpMan getpeerinfo()
         obj.pushKV("bytesrecv_per_msg", recvPerMsgType);
         obj.pushKV("connection_type", ConnectionTypeAsString(stats.m_conn_type));
         obj.pushKV("transport_protocol_type", TransportTypeAsString(stats.m_transport_type));
+        if (stats.m_transport_type == TransportProtocolType::V2) {
+            obj.pushKV("v2_session_id", stats.m_v2_session_id);
+        }
 
         ret.push_back(obj);
     }

test/functional/p2p_v2.py

@@ -31,7 +31,12 @@ def run_test(self):
         # sync_all() verifies that the block tips match
         self.sync_all(self.nodes[0:2])
         assert_equal(self.nodes[1].getblockcount(), 5)
-        assert_equal(self.nodes[1].getpeerinfo()[0]["transport_protocol_type"], "v2")
+        peerinfo_0 = self.nodes[0].getpeerinfo()
+        peerinfo_1 = self.nodes[1].getpeerinfo()
+        assert_equal(peerinfo_0[0]["transport_protocol_type"], "v2")
+        assert_equal(peerinfo_1[0]["transport_protocol_type"], "v2")
+        assert_equal(len(peerinfo_0[0]["v2_session_id"]), 64)
+        assert_equal(peerinfo_0[0]["v2_session_id"], peerinfo_1[0]["v2_session_id"])
 
         # V1 nodes can sync with each other
         assert_equal(self.nodes[2].getblockcount(), 0)
@@ -43,7 +48,9 @@ def run_test(self):
         self.sync_all(self.nodes[2:4])
         assert_equal(self.nodes[3].getblockcount(), 8)
         assert self.nodes[0].getbestblockhash() != self.nodes[2].getbestblockhash()
-        assert_equal(self.nodes[2].getpeerinfo()[0]["transport_protocol_type"], "v1")
+        peerinfo_2 = self.nodes[2].getpeerinfo()
+        assert_equal(peerinfo_2[0]["transport_protocol_type"], "v1")
+        assert "v2_session_id" not in peerinfo_2[0]
 
         # V1 nodes can sync with V2 nodes
         self.disconnect_nodes(0, 1)