transports.h

Go to the documentation of this file.

/*
 * transport.h
 *
 * Transport declarations
 *
 * Open Phone Abstraction Library (OPAL)
 * Formally known as the Open H323 project.
 *
 * Copyright (c) 2001 Equivalence Pty. Ltd.
 * Portions Copyright (C) 2006 by Post Increment
 *
 * The contents of this file are subject to the Mozilla Public License
 * Version 1.0 (the "License"); you may not use this file except in
 * compliance with the License. You may obtain a copy of the License at
 * http://www.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS IS"
 * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 * the License for the specific language governing rights and limitations
 * under the License.
 *
 * The Original Code is Open Phone Abstraction Library.
 *
 * The Initial Developer of the Original Code is Equivalence Pty. Ltd.
 *
 * Contributor(s): Post Increment
 *     Portions of this code were written with the assistance of funding from
 *     US Joint Forces Command Joint Concept Development & Experimentation (J9)
 *     http://www.jfcom.mil/about/abt_j9.htm
 */

#ifndef OPAL_OPAL_TRANSPORT_H
#define OPAL_OPAL_TRANSPORT_H

#ifdef P_USE_PRAGMA
#pragma interface
#endif

#include <opal_config.h>

#include <ptlib/sockets.h>
#include <ptclib/psockbun.h>
#include <ptclib/http.h>


class OpalManager;
class OpalEndPoint;
class OpalListener;
class OpalTransport;
class OpalInternalTransport;

typedef PSafePtr<OpalTransport> OpalTransportPtr;



class OpalTransportAddress : public PCaselessString
{
  PCLASSINFO(OpalTransportAddress, PCaselessString);
  public:
    static const PCaselessString & IpPrefix();
    static const PCaselessString & UdpPrefix();
    static const PCaselessString & TcpPrefix();
#if OPAL_PTLIB_SSL
    static const PCaselessString & TlsPrefix();
#if OPAL_PTLIB_HTTP
    static const PCaselessString & WsPrefix();  // RFC6455 WebSocket (yes, still needs SSL)
    static const PCaselessString & WssPrefix(); // RFC6455 WebSocket over TLS
#endif
#endif

    OpalTransportAddress();
    OpalTransportAddress(
      const char * address,      
      WORD port = 0,             
      const char * proto = NULL  
    );
    OpalTransportAddress(
      const PString & address,   
      WORD port = 0,             
      const char * proto = NULL  
    );
    OpalTransportAddress(
      const PIPSocket::Address & ip,  
      WORD port = 0,                  
      const char * proto = NULL       
    );
    OpalTransportAddress(
      const PIPSocket::AddressAndPort & ap,  
      const char * proto = NULL              
    );

    virtual PObject * Clone() const { return new OpalTransportAddress(*this); }

    PBoolean IsEquivalent(
      const OpalTransportAddress & address,   
      bool wildcards = false   
    ) const;

    PBoolean IsCompatible(
      const OpalTransportAddress & address
    ) const;

    PCaselessString GetProtoPrefix() const { return Left(Find('$')+1); }

    // For backward compatibility
    PCaselessString GetProto(bool withDollar = false) const { return Left(Find('$')+(withDollar?1:0)); }

    PBoolean GetIpAddress(PIPSocket::Address & ip) const;

    PBoolean GetIpAndPort(PIPSocket::Address & ip, WORD & port) const;
    PBoolean GetIpAndPort(PIPSocketAddressAndPort & ipPort) const;

    virtual PString GetHostName(
      bool includeService = false
    ) const;

    enum BindOptions {
      NoBinding,
      HostOnly,
      FullTSAP,
      Streamed,
      Datagram,
      RouteInterface,
      NumBindOptions
    };

    OpalListener * CreateListener(
      OpalEndPoint & endpoint,   
      BindOptions option         
    ) const;

    virtual OpalTransport * CreateTransport(
      OpalEndPoint & endpoint,   
      BindOptions option = HostOnly 
    ) const;


  protected:
    void SetInternalTransport(
      WORD port,             
      const char * proto     
    );

    OpalInternalTransport * m_transport;
};


class OpalTransportAddressArray : public PArray<OpalTransportAddress>
{
    typedef PArray<OpalTransportAddress> ParentClass;
    PCLASSINFO_WITH_CLONE(OpalTransportAddressArray, ParentClass);

  public:
    OpalTransportAddressArray(PINDEX initialSize = 0)
      : ParentClass(initialSize) { }
    OpalTransportAddressArray(
      const PString & address
    ) { AppendString(address); }
    OpalTransportAddressArray(
      const OpalTransportAddress & address
    ) { AppendAddress(address); }
    OpalTransportAddressArray(
      const PCollection & coll
    ) { AppendStringCollection(coll); }

    bool AppendAddress(
      const OpalTransportAddress & address,
      bool unique = false
    );

    bool AppendString(
      const PString & address
    );

    bool AppendStringCollection(
      const PCollection & coll
    );

    bool SetAddressPair(
      const OpalTransportAddress & addr1,
      const OpalTransportAddress & addr2
    );

    void GetIpAndPort(
      PINDEX index,
      PIPAddressAndPort & ap
    );

  protected:
    bool AddInterfaces(const PIPAddress & network, const PIPAddress & mask, const PString & portStr);
};





class OpalListener : public PObject
{
    PCLASSINFO(OpalListener, PObject);
  public:
    OpalListener(
      OpalEndPoint & endpoint   
    );

    void PrintOn(
      ostream & strm
    ) const;

    enum ThreadMode {
      SpawnNewThreadMode,
      HandOffThreadMode,
      SingleThreadMode
    };

    typedef PNotifierTemplate<const OpalTransportPtr &> AcceptHandler;
    #define PDECLARE_AcceptHandlerNotifier(cls, fn) PDECLARE_NOTIFIER2(OpalListener, cls, fn, const OpalTransportPtr &)

    virtual bool Open(
      const AcceptHandler & acceptHandler,  
      ThreadMode mode = SpawnNewThreadMode 
    );

    virtual bool IsOpen() const = 0;

    virtual void Close() = 0;

#if OPAL_PTLIB_NAT

    virtual bool ChangedNAT() { return true; }
#endif // OPAL_PTLIB_NAT

    virtual OpalTransport * Accept(
      const PTimeInterval & timeout  
    ) = 0;

    virtual OpalTransport * CreateTransport(
      const OpalTransportAddress & localAddress,
      const OpalTransportAddress & remoteAddress
    ) const = 0;

    virtual OpalTransportAddress GetLocalAddress(
      const OpalTransportAddress & remoteAddress = OpalTransportAddress(),
      const OpalTransportAddress & defaultAddress = OpalTransportAddress() // If INADDR_ANY
    ) const = 0;

    void CloseWait();

    void CleanUpOnTermination() { CloseWait(); }

    virtual const PCaselessString & GetProtoPrefix() const = 0;

  protected:
    void ListenForConnections();
    void TransportThreadMain(OpalTransportPtr transport);

    OpalEndPoint & m_endpoint;
    PThread      * m_thread;
    AcceptHandler  m_acceptHandler;
    ThreadMode     m_threadMode;

  private:
    OpalListener(const OpalListener & other) : PObject(other), m_endpoint(other.m_endpoint) { }
    void operator=(const OpalListener &) { }

  friend class OpalHTTPConnector;
};


PLIST(OpalListenerList, OpalListener);


class OpalListenerIP : public OpalListener
{
  PCLASSINFO(OpalListenerIP, OpalListener);
  public:
    OpalListenerIP(
      OpalEndPoint & endpoint,                 
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,                           
      PBoolean exclusive = true               
    );
    OpalListenerIP(
      OpalEndPoint & endpoint,                  
      const OpalTransportAddress & binding,     
      OpalTransportAddress::BindOptions option  
    );

    virtual OpalTransportAddress GetLocalAddress(
      const OpalTransportAddress & remoteAddress = OpalTransportAddress(),
      const OpalTransportAddress & defaultAddress = OpalTransportAddress() // If INADDR_ANY
    ) const;

    WORD GetListenerPort() const { return m_binding.GetPort(); }


  protected:
    bool CanCreateTransport(
      const OpalTransportAddress & localAddress,
      const OpalTransportAddress & remoteAddress
    ) const;

    PIPSocketAddressAndPort m_binding;
    bool                    m_exclusiveListener;
};


class OpalListenerTCP : public OpalListenerIP
{
  PCLASSINFO(OpalListenerTCP, OpalListenerIP);
  public:
    OpalListenerTCP(
      OpalEndPoint & endpoint,                 
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,                           
      PBoolean exclusive = true               
    );
    OpalListenerTCP(
      OpalEndPoint & endpoint,                  
      const OpalTransportAddress & binding,     
      OpalTransportAddress::BindOptions option  
    );

    ~OpalListenerTCP();

    virtual bool Open(
      const AcceptHandler & acceptHandler,  
      ThreadMode mode = SpawnNewThreadMode 
    );

    virtual bool IsOpen() const;

    virtual void Close();

    virtual OpalTransport * Accept(
      const PTimeInterval & timeout  
    );

    virtual OpalTransport * CreateTransport(
      const OpalTransportAddress & localAddress,
      const OpalTransportAddress & remoteAddress
    ) const;


  protected:
    virtual const PCaselessString & GetProtoPrefix() const;
    virtual OpalTransport * OnAccept(PTCPSocket * socket);

    PTCPSocket m_listener;
};


class OpalListenerUDP : public OpalListenerIP
{
  PCLASSINFO(OpalListenerUDP, OpalListenerIP);
  public:
    OpalListenerUDP(
      OpalEndPoint & endpoint,  
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,            
      PBoolean exclusive = true  
    );
    OpalListenerUDP(
      OpalEndPoint & endpoint,                  
      const OpalTransportAddress & binding,     
      OpalTransportAddress::BindOptions option  
    );

    ~OpalListenerUDP();

    virtual bool Open(
      const AcceptHandler & acceptHandler,  
      ThreadMode mode = SpawnNewThreadMode 
    );

    virtual bool IsOpen() const;

    virtual void Close();

#if OPAL_PTLIB_NAT

    virtual bool ChangedNAT();
#endif // OPAL_PTLIB_NAT

    virtual OpalTransport * Accept(
      const PTimeInterval & timeout  
    );

    virtual OpalTransport * CreateTransport(
      const OpalTransportAddress & localAddress,
      const OpalTransportAddress & remoteAddress
    ) const;

    virtual OpalTransportAddress GetLocalAddress(
      const OpalTransportAddress & remoteAddress = OpalTransportAddress(),
      const OpalTransportAddress & defaultAddress = OpalTransportAddress() // If INADDR_ANY
    ) const;

    void SetBufferSize(
      PINDEX size
    ) { m_bufferSize = size; }


  protected:
    virtual const PCaselessString & GetProtoPrefix() const;

    PMonitoredSocketsPtr m_listenerBundle;
    PINDEX               m_bufferSize;
};



class OpalTransport : public PSafeObject
{
    PCLASSINFO(OpalTransport, PSafeObject);
  protected:
    OpalTransport(OpalEndPoint & endpoint, PChannel * channel);

  public:
    ~OpalTransport();

    void PrintOn(
      ostream & strm
    ) const;

    virtual PBoolean Write(
      const void * buf, 
      PINDEX len        
    );

    virtual PBoolean IsReliable() const = 0;

    virtual bool IsAuthenticated(
      const PString & /*domain*/
    ) const { return true; }

    virtual PString GetInterface() const = 0;

    virtual bool SetInterface(
      const PString & iface  
    );

    virtual OpalTransportAddress GetLocalAddress() const = 0;

    virtual OpalTransportAddress GetRemoteAddress() const = 0;

    virtual PBoolean SetRemoteAddress(
      const OpalTransportAddress & address
    ) = 0;

    virtual PBoolean Connect() = 0;

    PBoolean ConnectTo(
      const OpalTransportAddress & address
    ) { return SetRemoteAddress(address) && Connect(); }

    virtual PBoolean Close();

    void CloseWait();

    void CleanUpOnTermination() { CloseWait(); }

    virtual PBoolean IsCompatibleTransport(
      const OpalTransportAddress & address
    ) const = 0;

    enum PromisciousModes {
      AcceptFromRemoteOnly,
      AcceptFromAnyAutoSet,
      AcceptFromAny,
      NumPromisciousModes
    };

    virtual void SetPromiscuous(
      PromisciousModes promiscuous
    );

    virtual OpalTransportAddress GetLastReceivedAddress() const;

    virtual PString GetLastReceivedInterface() const;

    virtual PBoolean ReadPDU(
      PBYTEArray & packet   
    ) = 0;

    virtual PBoolean WritePDU(
      const PBYTEArray & pdu     
    ) = 0;

    typedef PNotifierTemplate<bool &> WriteConnectCallback;
    #define PDECLARE_WriteConnectCallback(cls, fn) PDECLARE_NOTIFIER2(OpalTransport, cls, fn, bool &)

    virtual bool WriteConnect(
      const WriteConnectCallback & function  
    );

    void SetKeepAlive(
      const PTimeInterval & timeout,    
      const PBYTEArray & data           
    );

    bool HasKeepAlive() const { return !m_keepAliveData.IsEmpty() && m_keepAliveTimer.IsRunning(); }

    virtual void AttachThread(
      PThread * thread
    );

    virtual PBoolean IsRunning() const;

    OpalEndPoint & GetEndPoint() const { return m_endpoint; }

    virtual const PCaselessString & GetProtoPrefix() const = 0;

    bool IsOpen() const;
    bool IsGood() const;
    PChannel::Errors GetErrorCode(PChannel::ErrorGroup group = PChannel::NumErrorGroups) const;
    PString GetErrorText(PChannel::ErrorGroup group = PChannel::NumErrorGroups) const;
    int GetErrorNumber(PChannel::ErrorGroup group = PChannel::NumErrorGroups) const;
    void SetReadTimeout(const PTimeInterval & t);

    PChannel * GetChannel() const { return m_channel; }

    bool IsIdle() const { return m_referenceCount == 0 && m_idleTimer.HasExpired(); }
    void ResetIdle();

    void Reference()   { ++m_referenceCount; }
    void Dereference() { --m_referenceCount; }

  protected:
    PDECLARE_NOTIFIER(PTimer, OpalTransport, KeepAlive);

    OpalEndPoint   & m_endpoint;
    PChannel       * m_channel;
    PThread        * m_thread;      
    PCriticalSection m_threadMutex;
    PTimer           m_keepAliveTimer;
    PBYTEArray       m_keepAliveData;
    PSimpleTimer     m_idleTimer;
    atomic<unsigned> m_referenceCount;

  private:
    OpalTransport(const OpalTransport & other) : PSafeObject(other), m_endpoint(other.m_endpoint), m_referenceCount(0) { }
    void operator=(const OpalTransport &) { }
};


class OpalTransportIP : public OpalTransport
{
    PCLASSINFO(OpalTransportIP, OpalTransport);
  protected:
    OpalTransportIP(
      OpalEndPoint & endpoint,    
      PChannel * channel,         
      PIPSocket::Address binding, 
      WORD port                   
    );

  public:
    virtual PString GetInterface() const;

    virtual OpalTransportAddress GetLocalAddress() const;

    virtual OpalTransportAddress GetRemoteAddress() const;

    virtual PBoolean SetRemoteAddress(
      const OpalTransportAddress & address
    );


  protected:
    virtual const PCaselessString & GetProtoPrefix() const = 0;

    PIPAddress              m_binding;
    PIPSocketAddressAndPort m_localAP;  // Address of the local (NAT adjusted)
    PIPSocketAddressAndPort m_remoteAP; // Address of the remote host
};


class OpalTransportTCP : public OpalTransportIP
{
    PCLASSINFO(OpalTransportTCP, OpalTransportIP);
  public:
    OpalTransportTCP(
      OpalEndPoint & endpoint,    
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,              
      bool dummy = false          
    );
    OpalTransportTCP(
      OpalEndPoint & endpoint,    
      PChannel * socket           
    );

    ~OpalTransportTCP();

    virtual PBoolean IsReliable() const;

    virtual PBoolean IsCompatibleTransport(
      const OpalTransportAddress & address
    ) const;

    virtual PBoolean Connect();

    virtual PBoolean ReadPDU(
      PBYTEArray & pdu  
    );

    virtual PBoolean WritePDU(
      const PBYTEArray & pdu     
    );

    void SetPDULengthFormat(int fmt,int off)
    {
      m_pduLengthFormat = fmt;
      m_pduLengthOffset = off;
    }

  protected:
    virtual const PCaselessString & GetProtoPrefix() const;

    bool OnConnectedSocket(PTCPSocket * socket);

    int  m_pduLengthFormat;
    int  m_pduLengthOffset;
};


class OpalTransportUDP : public OpalTransportIP
{
  PCLASSINFO(OpalTransportUDP, OpalTransportIP);
  public:
    OpalTransportUDP(
      OpalEndPoint & endpoint,    
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,              
      bool reuseAddr = false,     
      bool preOpen = false        
    );

    OpalTransportUDP(
      OpalEndPoint & endpoint,              
      const PMonitoredSocketsPtr & sockets, 
      const PString & iface,                
      const OpalTransportAddress & remoteAddress 
    );

    ~OpalTransportUDP();

    virtual PBoolean Read(
      void * buffer,
      PINDEX length
    );

    virtual PBoolean IsReliable() const;

    virtual PBoolean IsCompatibleTransport(
      const OpalTransportAddress & address
    ) const;

    virtual PBoolean Connect();

    virtual PString GetInterface() const;

    virtual bool SetInterface(
      const PString & iface  
    );

    virtual OpalTransportAddress GetLocalAddress() const;

    virtual PBoolean SetRemoteAddress(
      const OpalTransportAddress & address
    );

    virtual void SetPromiscuous(
      PromisciousModes promiscuous
    );

    virtual OpalTransportAddress GetLastReceivedAddress() const;

    virtual PString GetLastReceivedInterface() const;

    virtual PBoolean ReadPDU(
      PBYTEArray & packet   
    );

    virtual PBoolean WritePDU(
      const PBYTEArray & pdu     
    );

    virtual bool WriteConnect(
      const WriteConnectCallback & function  
    );

    void SetBufferSize(
      PINDEX size
    ) { m_bufferSize = size; }

  protected:
    virtual const PCaselessString & GetProtoPrefix() const;

    OpalManager & m_manager;
    PINDEX        m_bufferSize;
    PBYTEArray    m_preReadPacket;
    bool          m_preReadOK;

  friend class OpalListenerUDP;
};



class OpalInternalTransport : public PObject
{
    PCLASSINFO(OpalInternalTransport, PObject);
  public:
    virtual bool Parse(
      OpalTransportAddress & address,
      WORD port
    ) const = 0;

    virtual PString GetHostName(
      const OpalTransportAddress & address,
      bool includeService
    ) const;

    virtual PBoolean GetIpAndPort(
      const OpalTransportAddress & address,
      PIPSocket::Address & ip,
      WORD & port
    ) const;

    virtual OpalListener * CreateListener(
      const OpalTransportAddress & address,
      OpalEndPoint & endpoint,
      OpalTransportAddress::BindOptions options
    ) const  = 0;

    virtual OpalTransport * CreateTransport(
      const OpalTransportAddress & address,
      OpalEndPoint & endpoint,
      OpalTransportAddress::BindOptions options
    ) const = 0;
};



class OpalInternalIPTransport : public OpalInternalTransport
{
    PCLASSINFO(OpalInternalIPTransport, OpalInternalTransport);
  public:
    virtual bool Parse(
      OpalTransportAddress & address,
      WORD port
    ) const;
    virtual PString GetHostName(
      const OpalTransportAddress & address,
      bool includeService
    ) const;
    virtual PBoolean GetIpAndPort(
      const OpalTransportAddress & address,
      PIPSocket::Address & ip,
      WORD & port
    ) const;

    static PBoolean GetAdjustedIpAndPort(const OpalTransportAddress & address,
                                     OpalEndPoint & endpoint,
                                     OpalTransportAddress::BindOptions option,
                                     PIPSocketAddressAndPort & ap,
                                     PBoolean & reuseAddr);
};

template <class ListenerType, class TransportType, unsigned AltTypeOption, class AltTypeClass>
class OpalInternalIPTransportTemplate : public OpalInternalIPTransport
{
  public:
    OpalListener * CreateListener(
      const OpalTransportAddress & address,
      OpalEndPoint & endpoint,
      OpalTransportAddress::BindOptions options
    ) const
    {
      return new ListenerType(endpoint, address, options);
    }

    OpalTransport * CreateTransport(
      const OpalTransportAddress & address,
      OpalEndPoint & endpoint,
      OpalTransportAddress::BindOptions options
    ) const
    {
      PIPSocketAddressAndPort ap;
      PBoolean reuseAddr;
      if (GetAdjustedIpAndPort(address, endpoint, options, ap, reuseAddr)) {
        if (options == AltTypeOption)
          return new AltTypeClass(endpoint, ap.GetAddress(), 0, reuseAddr);
        else
          return new TransportType(endpoint, ap.GetAddress(), 0, reuseAddr);
      }
      return NULL;
    }
};

typedef OpalInternalIPTransportTemplate<OpalListenerTCP, OpalTransportTCP, OpalTransportAddress::Datagram, OpalTransportUDP> OpalInternalTCPTransport;
typedef OpalInternalIPTransportTemplate<OpalListenerUDP, OpalTransportUDP, OpalTransportAddress::Streamed, OpalTransportTCP> OpalInternalUDPTransport;




#if OPAL_PTLIB_SSL

class PSSLContext;
class PSSLChannel;

class OpalListenerTLS : public OpalListenerTCP
{
  PCLASSINFO(OpalListenerTLS, OpalListenerTCP);
  public:
    OpalListenerTLS(
      OpalEndPoint & endpoint,                 
      PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
      WORD port = 0,                           
      PBoolean exclusive = true               
    );
    OpalListenerTLS(
      OpalEndPoint & endpoint,                  
      const OpalTransportAddress & binding,     
      OpalTransportAddress::BindOptions option  
    );

    ~OpalListenerTLS();

    virtual PBoolean Open(const AcceptHandler & acceptHandler, ThreadMode mode = SpawnNewThreadMode);
    virtual const PCaselessString & GetProtoPrefix() const;
    virtual OpalTransport * CreateTransport(
      const OpalTransportAddress & localAddress,
      const OpalTransportAddress & remoteAddress
    ) const;

  protected:
    virtual OpalTransport * OnAccept(PTCPSocket * socket);

    PSSLContext * m_sslContext;
};


class OpalTransportTLS : public OpalTransportTCP
{
  PCLASSINFO(OpalTransportTLS, OpalTransportTCP);
    public:
      OpalTransportTLS(
        OpalEndPoint & endpoint,    
        PChannel * ssl
      );

      OpalTransportTLS(
        OpalEndPoint & endpoint,    
        PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
        WORD port = 0,              
        bool dummy = false          
      );

      ~OpalTransportTLS();

      // Overrides
      virtual PBoolean IsCompatibleTransport(const OpalTransportAddress & address) const;
      virtual PBoolean Connect();
      virtual const PCaselessString & GetProtoPrefix() const;
      virtual bool IsAuthenticated(const PString & domain) const;
};


typedef OpalInternalIPTransportTemplate<OpalListenerTLS, OpalTransportTLS, OpalTransportAddress::Datagram, OpalTransportUDP> OpalInternalTLSTransport;

typedef OpalTransportTLS OpalTransportTCPS; // For backward compatibility
typedef OpalListenerTLS OpalListenerTCPS;



#if OPAL_PTLIB_HTTP

class OpalListenerWS : public OpalListenerTCP
{
  PCLASSINFO(OpalListenerWS, OpalListenerTCP);
public:
  OpalListenerWS(
    OpalEndPoint & endpoint,                 
    PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
    WORD port = 0,                           
    bool exclusive = true                    
    );
  OpalListenerWS(
    OpalEndPoint & endpoint,                  
    const OpalTransportAddress & binding,     
    OpalTransportAddress::BindOptions option  
    );

  virtual OpalTransport * CreateTransport(
    const OpalTransportAddress & localAddress,
    const OpalTransportAddress & remoteAddress
    ) const;

protected:
  virtual const PCaselessString & GetProtoPrefix() const;
  virtual OpalTransport * OnAccept(PTCPSocket * socket);
};


class OpalListenerWSS : public OpalListenerTLS
{
  PCLASSINFO(OpalListenerWSS, OpalListenerTLS);
public:
  OpalListenerWSS(
    OpalEndPoint & endpoint,                 
    PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
    WORD port = 0,                           
    PBoolean exclusive = true               
    );
  OpalListenerWSS(
    OpalEndPoint & endpoint,                  
    const OpalTransportAddress & binding,     
    OpalTransportAddress::BindOptions option  
    );

  virtual const PCaselessString & GetProtoPrefix() const;

protected:
  virtual OpalTransport * OnAccept(PTCPSocket * socket);
};


class OpalTransportWS : public OpalTransportTCP
{
  PCLASSINFO(OpalTransportWS, OpalTransportTCP);
public:
  OpalTransportWS(
    OpalEndPoint & endpoint,    
    PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
    WORD port = 0,              
    bool dummy = false          
    );
  OpalTransportWS(
    OpalEndPoint & endpoint,    
    PChannel * socket           
    );

  virtual PBoolean Connect();

  virtual PBoolean ReadPDU(
    PBYTEArray & pdu  
    );

  virtual PBoolean WritePDU(
    const PBYTEArray & pdu     
    );

  virtual PBoolean IsCompatibleTransport(const OpalTransportAddress & address) const;
  virtual const PCaselessString & GetProtoPrefix() const;
};


class OpalTransportWSS : public OpalTransportTLS
{
  PCLASSINFO(OpalTransportWSS, OpalTransportTLS);
public:
  OpalTransportWSS(
    OpalEndPoint & endpoint,    
    PIPSocket::Address binding = PIPSocket::GetDefaultIpAny(), 
    WORD port = 0,              
    bool dummy = false          
    );
  OpalTransportWSS(
    OpalEndPoint & endpoint,    
    PChannel * socket           
    );

  virtual PBoolean Connect();

  virtual PBoolean ReadPDU(
    PBYTEArray & pdu  
    );

  virtual PBoolean WritePDU(
    const PBYTEArray & pdu     
    );

  virtual PBoolean IsCompatibleTransport(const OpalTransportAddress & address) const;
  virtual const PCaselessString & GetProtoPrefix() const;
};


typedef OpalInternalIPTransportTemplate<OpalListenerWS, OpalTransportWS, OpalTransportAddress::Datagram, OpalTransportUDP> OpalInternalWSTransport;
typedef OpalInternalIPTransportTemplate<OpalListenerWSS, OpalTransportWSS, OpalTransportAddress::Datagram, OpalTransportUDP> OpalInternalWSSTransport;


class OpalHTTPConnector : public PHTTPResource
{
    PCLASSINFO(OpalHTTPConnector, PHTTPResource)
  public:
    OpalHTTPConnector(
      OpalManager & manager,         
      const PURL & url               
    );
    OpalHTTPConnector(
      OpalManager & manager,         
      const PURL & url,              
      const PHTTPAuthority & auth    
    );

    virtual bool OnWebSocket(PHTTPServer & server, PHTTPConnectionInfo & connectInfo);

  protected:
    OpalManager & m_manager;
};


#endif // OPAL_PTLIB_HTTP
#endif // OPAL_PTLIB_SSL


#endif  // OPAL_OPAL_TRANSPORT_H


// End of File ///////////////////////////////////////////////////////////////