i2pd/I2PTunnel.h

165 lines
5.1 KiB
C
Raw Normal View History

2014-08-13 05:14:19 +04:00
#ifndef I2PTUNNEL_H__
#define I2PTUNNEL_H__
#include <inttypes.h>
#include <string>
2014-08-13 23:25:52 +04:00
#include <set>
2014-11-23 19:33:58 +03:00
#include <memory>
#include <sstream>
2014-08-13 05:14:19 +04:00
#include <boost/asio.hpp>
#include "Identity.h"
#include "Destination.h"
2014-08-13 05:14:19 +04:00
#include "Streaming.h"
#include "I2PService.h"
2014-08-13 05:14:19 +04:00
namespace i2p
{
namespace client
2014-08-13 05:14:19 +04:00
{
2014-08-13 23:25:52 +04:00
const size_t I2P_TUNNEL_CONNECTION_BUFFER_SIZE = 8192;
const int I2P_TUNNEL_CONNECTION_MAX_IDLE = 3600; // in seconds
2014-10-15 20:07:06 +04:00
const int I2P_TUNNEL_DESTINATION_REQUEST_TIMEOUT = 10; // in seconds
2016-01-11 21:48:18 +03:00
// for HTTP tunnels
const char X_I2P_DEST_HASH[] = "X-I2P-DestHash"; // hash in base64
2016-01-19 17:36:56 +03:00
const char X_I2P_DEST_B64[] = "X-I2P-DestB64"; // full address in base64
const char X_I2P_DEST_B32[] = "X-I2P-DestB32"; // .b32.i2p address
class I2PTunnelConnection: public I2PServiceHandler, public std::enable_shared_from_this<I2PTunnelConnection>
2014-08-13 05:14:19 +04:00
{
public:
I2PTunnelConnection (I2PService * owner, std::shared_ptr<boost::asio::ip::tcp::socket> socket,
2015-03-13 20:29:27 +03:00
std::shared_ptr<const i2p::data::LeaseSet> leaseSet, int port = 0); // to I2P
I2PTunnelConnection (I2PService * owner, std::shared_ptr<boost::asio::ip::tcp::socket> socket,
2015-06-02 20:03:22 +03:00
std::shared_ptr<i2p::stream::Stream> stream); // to I2P using simplified API
I2PTunnelConnection (I2PService * owner, std::shared_ptr<i2p::stream::Stream> stream, std::shared_ptr<boost::asio::ip::tcp::socket> socket,
const boost::asio::ip::tcp::endpoint& target, bool quiet = true); // from I2P
2014-08-13 05:14:19 +04:00
~I2PTunnelConnection ();
void I2PConnect (const uint8_t * msg = nullptr, size_t len = 0);
2014-11-24 06:23:17 +03:00
void Connect ();
2015-06-02 20:03:22 +03:00
protected:
2014-08-13 05:14:19 +04:00
2014-08-13 23:25:52 +04:00
void Terminate ();
void Receive ();
void HandleReceived (const boost::system::error_code& ecode, std::size_t bytes_transferred);
2015-06-02 20:03:22 +03:00
virtual void Write (const uint8_t * buf, size_t len); // can be overloaded
2014-08-13 23:25:52 +04:00
void HandleWrite (const boost::system::error_code& ecode);
void StreamReceive ();
void HandleStreamReceive (const boost::system::error_code& ecode, std::size_t bytes_transferred);
2014-08-20 23:03:10 +04:00
void HandleConnect (const boost::system::error_code& ecode);
2014-08-13 23:25:52 +04:00
private:
uint8_t m_Buffer[I2P_TUNNEL_CONNECTION_BUFFER_SIZE], m_StreamBuffer[I2P_TUNNEL_CONNECTION_BUFFER_SIZE];
std::shared_ptr<boost::asio::ip::tcp::socket> m_Socket;
2014-11-23 19:33:58 +03:00
std::shared_ptr<i2p::stream::Stream> m_Stream;
2014-11-24 06:23:17 +03:00
boost::asio::ip::tcp::endpoint m_RemoteEndpoint;
bool m_IsQuiet; // don't send destination
};
2015-06-02 20:03:22 +03:00
class I2PTunnelConnectionHTTP: public I2PTunnelConnection
{
public:
I2PTunnelConnectionHTTP (I2PService * owner, std::shared_ptr<i2p::stream::Stream> stream,
std::shared_ptr<boost::asio::ip::tcp::socket> socket,
const boost::asio::ip::tcp::endpoint& target, const std::string& host);
protected:
void Write (const uint8_t * buf, size_t len);
private:
2015-06-03 19:30:15 +03:00
std::string m_Host;
std::stringstream m_InHeader, m_OutHeader;
bool m_HeaderSent;
2016-01-11 21:48:18 +03:00
std::shared_ptr<const i2p::data::IdentityEx> m_From;
2015-06-02 20:03:22 +03:00
};
2015-01-08 05:49:35 +03:00
class I2PClientTunnel: public TCPIPAcceptor
2014-08-13 05:14:19 +04:00
{
2015-01-08 05:49:35 +03:00
protected:
// Implements TCPIPAcceptor
std::shared_ptr<I2PServiceHandler> CreateHandler(std::shared_ptr<boost::asio::ip::tcp::socket> socket);
2015-01-08 05:49:35 +03:00
2014-08-13 05:14:19 +04:00
public:
2016-01-14 04:21:53 +03:00
I2PClientTunnel (const std::string& name, const std::string& destination,
const std::string& address, int port, std::shared_ptr<ClientDestination> localDestination, int destinationPort = 0);
2015-01-08 05:49:35 +03:00
~I2PClientTunnel () {}
2014-08-13 23:25:52 +04:00
void Start ();
void Stop ();
2016-01-14 04:21:53 +03:00
const char* GetName() { return m_Name.c_str (); }
2014-08-13 05:14:19 +04:00
private:
const i2p::data::IdentHash * GetIdentHash ();
2014-08-13 05:14:19 +04:00
2016-01-14 04:21:53 +03:00
private:
std::string m_Name, m_Destination;
2014-08-13 23:25:52 +04:00
const i2p::data::IdentHash * m_DestinationIdentHash;
2015-03-13 20:29:27 +03:00
int m_DestinationPort;
2014-08-13 05:14:19 +04:00
};
2014-08-20 23:03:10 +04:00
class I2PServerTunnel: public I2PService
2014-08-20 23:03:10 +04:00
{
public:
2016-01-14 04:21:53 +03:00
I2PServerTunnel (const std::string& name, const std::string& address, int port,
std::shared_ptr<ClientDestination> localDestination, int inport = 0);
2014-08-20 23:03:10 +04:00
void Start ();
void Stop ();
2015-03-16 21:52:42 +03:00
void SetAccessList (const std::set<i2p::data::IdentHash>& accessList);
2015-06-02 20:03:22 +03:00
const std::string& GetAddress() const { return m_Address; }
int GetPort () const { return m_Port; };
uint16_t GetLocalPort () const { return m_PortDestination->GetLocalPort (); };
2015-06-02 20:03:22 +03:00
const boost::asio::ip::tcp::endpoint& GetEndpoint () const { return m_Endpoint; }
2016-01-14 04:21:53 +03:00
const char* GetName() { return m_Name.c_str (); }
2014-08-20 23:03:10 +04:00
private:
void HandleResolve (const boost::system::error_code& ecode, boost::asio::ip::tcp::resolver::iterator it,
std::shared_ptr<boost::asio::ip::tcp::resolver> resolver);
2014-08-20 23:03:10 +04:00
void Accept ();
2014-11-23 19:33:58 +03:00
void HandleAccept (std::shared_ptr<i2p::stream::Stream> stream);
2015-06-02 20:03:22 +03:00
virtual void CreateI2PConnection (std::shared_ptr<i2p::stream::Stream> stream);
2014-08-20 23:03:10 +04:00
private:
2016-01-14 04:21:53 +03:00
std::string m_Name, m_Address;
2015-06-02 20:03:22 +03:00
int m_Port;
boost::asio::ip::tcp::endpoint m_Endpoint;
2015-03-16 21:52:42 +03:00
std::shared_ptr<i2p::stream::StreamingDestination> m_PortDestination;
std::set<i2p::data::IdentHash> m_AccessList;
bool m_IsAccessList;
2014-08-20 23:03:10 +04:00
};
2015-05-20 23:00:09 +03:00
class I2PServerTunnelHTTP: public I2PServerTunnel
{
public:
2016-01-14 04:21:53 +03:00
I2PServerTunnelHTTP (const std::string& name, const std::string& address, int port,
2015-05-20 23:00:09 +03:00
std::shared_ptr<ClientDestination> localDestination, int inport = 0);
2015-06-02 20:03:22 +03:00
private:
void CreateI2PConnection (std::shared_ptr<i2p::stream::Stream> stream);
2015-05-20 23:00:09 +03:00
};
}
2014-08-13 05:14:19 +04:00
}
#endif