Mirrors/i2pd
2
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-03-20 08:16:38 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

use ToBase64 for incoming stream accept

Browse source
This commit is contained in:
orignal 2025-03-17 19:00:48 -04:00
parent 9cc625b19e
commit 8e6b9370d0
1 changed files with 13 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
libi2pd_client/SAM.cpp
View file

@ -1112,18 +1112,19 @@ namespace client
} }
} }
if (!m_IsSilent) if (!m_IsSilent)
{ {
// get remote peer address if (m_SocketType != eSAMSocketTypeTerminated)
auto ident_ptr = stream->GetRemoteIdentity(); {
const size_t ident_len = ident_ptr->GetFullLen(); // get remote peer address
uint8_t* ident = new uint8_t[ident_len]; auto ident = std::make_shared<std::string>(stream->GetRemoteIdentity()->ToBase64 ()); // we need to keep it until sent
ident->push_back ('\n');
// send remote peer address as base64 // send remote peer address back to client like received from stream
const size_t l = ident_ptr->ToBuffer (ident, ident_len); boost::asio::async_write (m_Socket, boost::asio::buffer (ident->data (), ident->size ()), boost::asio::transfer_all(),
const size_t l1 = i2p::data::ByteStreamToBase64 (ident, l, (char *)m_StreamBuffer, SAM_SOCKET_BUFFER_SIZE); [ident, s = shared_from_this ()](const boost::system::error_code& ecode, size_t bytes_transferred)
delete[] ident; {
m_StreamBuffer[l1] = '\n'; s->HandleWriteI2PData (ecode, bytes_transferred);
HandleI2PReceive (boost::system::error_code (), l1 +1); // we send identity like it has been received from stream });
}
} }
else else
I2PReceive (); I2PReceive ();