AsyncEncryptedUdpSocket.h

Go to the documentation of this file.

 
#ifndef ASYNC_ENCRYPTED_UDP_SOCKET_INCLUDED
#define ASYNC_ENCRYPTED_UDP_SOCKET_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <openssl/evp.h>
#include <vector>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncUdpSocket.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
class EncryptedUdpSocket : public UdpSocket
{
  public:
    using Cipher = EVP_CIPHER;
 
    static const Cipher* fetchCipher(const std::string& name);
 
    static void freeCipher(Cipher* cipher);
 
    static const std::string cipherName(const Cipher* cipher);
 
    static bool randomBytes(std::vector<uint8_t>& bytes);
 
    EncryptedUdpSocket(uint16_t local_port=0,
        const IpAddress &bind_ip=IpAddress());
 
    //EncryptedUdpSocket(const EncryptedUdpSocket&) = delete;
 
    //EncryptedUdpSocket& operator=(const EncryptedUdpSocket&) = delete;
 
    ~EncryptedUdpSocket(void) override;
 
    bool initOk(void) const override
    {
      return UdpSocket::initOk() && (m_cipher_ctx != nullptr);
    }
 
    bool setCipher(const std::string& type);
 
    bool setCipher(const Cipher* cipher);
 
    bool setCipherIV(std::vector<uint8_t> iv);
 
    const std::vector<uint8_t> cipherIV(void) const;
 
    bool setCipherKey(std::vector<uint8_t> key);
 
    bool setCipherKey(void);
 
    const std::vector<uint8_t> cipherKey(void) const;
 
    void setTagLength(int taglen) { m_taglen = taglen; }
 
    int tagLength(void) const { return m_taglen; }
 
    void setCipherAADLength(int aadlen) { m_aadlen = aadlen; }
 
    size_t cipherAADLength(void) const { return m_aadlen; }
 
    bool write(const IpAddress& remote_ip, int remote_port,
               const void *buf, int count) override;
 
    bool write(const IpAddress& remote_ip, int remote_port,
               const void *aad, int aadlen, const void *buf, int cnt);
 
    sigc::signal<bool, const IpAddress&, uint16_t,
                 void*, int> cipherDataReceived;
 
    sigc::signal<void, const IpAddress&, uint16_t,
                 void*, void*, int> dataReceived;
 
  protected:
    void onDataReceived(const IpAddress& ip, uint16_t port, void* buf,
        int count) override;
 
  private:
    EVP_CIPHER_CTX*       m_cipher_ctx  = nullptr;
    std::vector<uint8_t>  m_cipher_iv;
    std::vector<uint8_t>  m_cipher_key;
    size_t                m_taglen      = 0;
    size_t                m_aadlen      = 0;
 
};  /* class EncryptedUdpSocket */
 
 
} /* namespace Async */
 
#endif /* ASYNC_ENCRYPTED_UDP_SOCKET_INCLUDED */
 
/*
 * This file has not been truncated
 */