Method HandleDatagram3

libi2pd/Datagram.cpp:286–351

	}

	void DatagramDestination::HandleDatagram3 (uint16_t fromPort, uint16_t toPort, const uint8_t * buf, size_t len,
		i2p::garlic::ECIESX25519AEADRatchetSession * from)
	{
		if (len < 34)
		{
			LogPrint (eLogWarning, "Datagram: datagram3 is too short ", len);
			return;
		}
		if (from)
		{
			std::shared_ptr<const i2p::data::LeaseSet> ls;
			i2p::data::IdentHash ident(buf);
			auto session = FindSession (ident);
			if (session) ls = session->GetRemoteLeaseSet ();
			if (!ls) ls = m_Owner->FindLeaseSet (ident);
			if (ls)
			{
				uint8_t staticKey[32];
				ls->Encrypt (nullptr, staticKey);
				if (!memcmp (from->GetRemoteStaticKey (), staticKey, 32))
				{
					if (!session)
					{
						session = ObtainSession (ident);
						session->SetVersion (eDatagramV3);
					}
					session->SetRemoteLeaseSet (ls);
					auto r = FindReceiver(toPort);
					if (r)
					{
						const uint8_t * flags = buf + 32;
						size_t offset = 34;
						bool isOptions = false;
						if (flags[1] & DATAGRAM3_FLAG_OPTIONS)
						{
							isOptions = true;
							m_Options.CleanUp ();
							auto optionsLen = m_Options.FromBuffer (buf + offset, len - offset);
							if (optionsLen)
								offset += optionsLen;
							else
							{
								LogPrint (eLogWarning, "Datagram: datagram3 can't read options");
								return;
							}
						}
						if (offset > len)
						{
							LogPrint (eLogWarning, "Datagram: datagram3 is too short ", len, " expected ", offset);
							return;
						}
						r(*ls->GetIdentity (), fromPort, toPort, buf + offset, len - offset, isOptions ? &m_Options : nullptr);
					}
					else
						LogPrint (eLogWarning, "Datagram: no receiver for port ", toPort);
					session->Ack ();
				}
				else