MessageStatusMessage

I2CP.cpp

@@ -55,7 +55,7 @@ namespace client
 		SetLeaseSet (ls);
 	}
 	
-	void I2CPDestination::SendMsgTo (const uint8_t * payload, size_t len, const i2p::data::IdentHash& ident)
+	void I2CPDestination::SendMsgTo (const uint8_t * payload, size_t len, const i2p::data::IdentHash& ident, uint32_t nonce)
 	{
 		auto msg = NewI2NPMessage ();
 		uint8_t * buf = msg->GetPayload ();
@@ -70,14 +70,20 @@ namespace client
 		{
 			auto s = GetSharedFromThis ();
 			RequestDestination (ident,
-				[s, msg](std::shared_ptr<i2p::data::LeaseSet> ls)
+				[s, msg, nonce](std::shared_ptr<i2p::data::LeaseSet> ls)
 				{
-					if (ls) s->SendMsg (msg, ls);
+					if (ls)
+					{ 
+						bool sent = s->SendMsg (msg, ls);
+						s->m_Owner.SendMessageStatusMessage (nonce, sent ? eI2CPMessageStatusGuaranteedSuccess : eI2CPMessageStatusGuaranteedFailure);
+					}
+					else
+						s->m_Owner.SendMessageStatusMessage (nonce, eI2CPMessageStatusNoLeaseSet);
 				});
 		}
 	}
 
-	void I2CPDestination::SendMsg (std::shared_ptr<I2NPMessage> msg, std::shared_ptr<const i2p::data::LeaseSet> remote)
+	bool I2CPDestination::SendMsg (std::shared_ptr<I2NPMessage> msg, std::shared_ptr<const i2p::data::LeaseSet> remote)
 	{
 		auto outboundTunnel = GetTunnelPool ()->GetNextOutboundTunnel ();
 		auto leases = remote->GetNonExpiredLeases ();
@@ -93,6 +99,7 @@ namespace client
 					garlic
 				});
 			outboundTunnel->SendTunnelDataMsg (msgs);
+			return true;
 		}
 		else
 		{
@@ -100,6 +107,7 @@ namespace client
 				LogPrint (eLogWarning, "I2CP: Failed to send message. All leases expired");
 			else
 				LogPrint (eLogWarning, "I2CP: Failed to send message. No outbound tunnels");
+			return false;
 		}	
 	}
 
@@ -298,6 +306,17 @@ namespace client
 		SendI2CPMessage (I2CP_SESSION_STATUS_MESSAGE, buf, 3); 
 	}
 
+	void I2CPSession::SendMessageStatusMessage (uint32_t nonce, I2CPMessageStatus status)
+	{
+		uint8_t buf[15];
+		htobe16buf (buf, m_SessionID);
+		htobe32buf (buf + 2, m_MessageID++);
+		buf[6] = (uint8_t)status;
+		memset (buf + 7, 0, 4); // size
+		htobe32buf (buf + 11, nonce);	
+		SendI2CPMessage (I2CP_MESSAGE_STATUS_MESSAGE, buf, 15); 	
+	}
+
 	void I2CPSession::CreateLeaseSetMessageHandler (const uint8_t * buf, size_t len)
 	{
 		uint16_t sessionID = bufbe16toh (buf);
@@ -325,7 +344,11 @@ namespace client
 			{
 				i2p::data::IdentityEx identity;
 				offset += identity.FromBuffer (buf + offset, len - offset);
-				m_Destination->SendMsgTo (buf + offset, len - offset, identity.GetIdentHash ());
+				uint32_t payloadLen = bufbe32toh (buf + offset);
+				offset += 4;
+				uint32_t nonce = bufbe32toh (buf + offset + payloadLen);
+				SendMessageStatusMessage (nonce, eI2CPMessageStatusAccepted); // accepted
+				m_Destination->SendMsgTo (buf + offset, payloadLen, identity.GetIdentHash (), nonce);
 			} 
 		}	
 		else
@@ -395,13 +418,14 @@ namespace client
 	void I2CPSession::SendMessagePayloadMessage (const uint8_t * payload, size_t len)
 	{
 		// we don't use SendI2CPMessage to eliminate additional copy
-		auto l = len + 6 + I2CP_HEADER_SIZE;
+		auto l = len + 10 + I2CP_HEADER_SIZE;
 		uint8_t * buf = new uint8_t[l];
-		htobe32buf (buf + I2CP_HEADER_LENGTH_OFFSET, len + 6);
+		htobe32buf (buf + I2CP_HEADER_LENGTH_OFFSET, len + 10);
 		buf[I2CP_HEADER_TYPE_OFFSET] = I2CP_MESSAGE_PAYLOAD_MESSAGE;
 		htobe16buf (buf + I2CP_HEADER_SIZE, m_SessionID);
 		htobe32buf (buf + I2CP_HEADER_SIZE + 2, m_MessageID++);
-		memcpy (buf + I2CP_HEADER_SIZE + 6, payload, len);
+		htobe32buf (buf + I2CP_HEADER_SIZE + 6, len);		
+		memcpy (buf + I2CP_HEADER_SIZE + 10, payload, len);
 		boost::asio::async_write (*m_Socket, boost::asio::buffer (buf, l), boost::asio::transfer_all (),
         	std::bind(&I2CPSession::HandleI2CPMessageSent, shared_from_this (), 
 						std::placeholders::_1, std::placeholders::_2, buf));	

I2CP.h

@@ -37,9 +37,18 @@ namespace client
 	const uint8_t I2CP_CREATE_LEASESET_MESSAGE = 4;	
 	const uint8_t I2CP_SEND_MESSAGE_MESSAGE = 5;
 	const uint8_t I2CP_MESSAGE_PAYLOAD_MESSAGE = 31;
+	const uint8_t I2CP_MESSAGE_STATUS_MESSAGE = 22;	
 	const uint8_t I2CP_HOST_LOOKUP_MESSAGE = 38;
 	const uint8_t I2CP_HOST_REPLY_MESSAGE = 39;		
 
+	enum I2CPMessageStatus
+	{
+		eI2CPMessageStatusAccepted = 1,
+		eI2CPMessageStatusGuaranteedSuccess = 4,
+		eI2CPMessageStatusGuaranteedFailure = 5,
+		eI2CPMessageStatusNoLeaseSet = 21
+	};
+
 	class I2CPSession;
 	class I2CPDestination: public LeaseSetDestination
 	{
@@ -49,7 +58,7 @@ namespace client
 
 			void SetEncryptionPrivateKey (const uint8_t * key);
 			void LeaseSetCreated (const uint8_t * buf, size_t len); // called from I2CPSession
-			void SendMsgTo (const uint8_t * payload, size_t len, const i2p::data::IdentHash& ident); // called from I2CPSession
+			void SendMsgTo (const uint8_t * payload, size_t len, const i2p::data::IdentHash& ident, uint32_t nonce); // called from I2CPSession
 
 		protected:
 
@@ -65,7 +74,7 @@ namespace client
 
 			std::shared_ptr<I2CPDestination> GetSharedFromThis ()
 			{ return std::static_pointer_cast<I2CPDestination>(shared_from_this ()); }  
-			void SendMsg (std::shared_ptr<I2NPMessage> msg, std::shared_ptr<const i2p::data::LeaseSet> remote);
+			bool SendMsg (std::shared_ptr<I2NPMessage> msg, std::shared_ptr<const i2p::data::LeaseSet> remote);
 
 		private:
 
@@ -87,8 +96,10 @@ namespace client
 			void Stop ();
 			uint16_t GetSessionID () const { return m_SessionID; };
 
+			// called from I2CPDestination	
 			void SendI2CPMessage (uint8_t type, const uint8_t * payload, size_t len);
-			void SendMessagePayloadMessage (const uint8_t * payload, size_t len); // called from I2CPDestination			
+			void SendMessagePayloadMessage (const uint8_t * payload, size_t len); 		
+			void SendMessageStatusMessage (uint32_t nonce, I2CPMessageStatus status);
 
 			// message handlers
 			void GetDateMessageHandler (const uint8_t * buf, size_t len);