fixed #2231. Close outgoing stream if LeaseSet not found

libi2pd/Streaming.cpp

@@ -1817,19 +1817,29 @@ namespace stream
 			auto remoteLeaseSet = m_LocalDestination.GetOwner ()->FindLeaseSet (m_RemoteIdentity->GetIdentHash ());
 			if (!remoteLeaseSet)
 			{
-				LogPrint (eLogWarning, "Streaming: LeaseSet ", m_RemoteIdentity->GetIdentHash ().ToBase64 (), m_RemoteLeaseSet ? " expired" : " not found");
+				LogPrint (eLogWarning, "Streaming: LeaseSet ", m_RemoteIdentity->GetIdentHash ().ToBase32 (), m_RemoteLeaseSet ? " expired" : " not found");
 				if (!m_IsIncoming) // outgoing
 				{	
+					auto requestCallback = [s = shared_from_this ()](std::shared_ptr<i2p::data::LeaseSet> ls)
+					    {
+							if (!ls && s->m_Status == eStreamStatusOpen) // LeaseSet not found
+							{
+								// close the socket without sending FIN or RST
+								s->m_Status = eStreamStatusClosed;
+								s->AsyncClose ();
+							}	
+						};
+					
 					if (m_RemoteLeaseSet && m_RemoteLeaseSet->IsPublishedEncrypted ())
 					{
 						m_LocalDestination.GetOwner ()->RequestDestinationWithEncryptedLeaseSet (
-							std::make_shared<i2p::data::BlindedPublicKey>(m_RemoteIdentity));
+							std::make_shared<i2p::data::BlindedPublicKey>(m_RemoteIdentity), requestCallback);
 						return; // we keep m_RemoteLeaseSet for possible next request
 					}
 					else
 					{
 						m_RemoteLeaseSet = nullptr;
-						m_LocalDestination.GetOwner ()->RequestDestination (m_RemoteIdentity->GetIdentHash ()); // try to request for a next attempt
+						m_LocalDestination.GetOwner ()->RequestDestination (m_RemoteIdentity->GetIdentHash (), requestCallback); // try to request for a next attempt	
 					}
 				}
 				else // incoming