transport.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
#include <azure/core/context.hpp>
 
#include <exception>
#include <functional>
#include <memory>
#include <stdexcept>
#include <string>
 
namespace Azure { namespace Core { namespace Amqp { namespace Network { namespace _detail {
  struct TransportImpl;
}}}}} // namespace Azure::Core::Amqp::Network::_detail
 
namespace Azure { namespace Core { namespace Amqp { namespace Network { namespace _internal {
 
  enum class TransportOpenStatus
  {
    Invalid,
    Ok,
    Error,
    Cancelled,
  };
 
  enum class TransportSendStatus
  {
    Invalid,
 
    Unknown,
 
    Ok,
 
    Error,
 
    Cancelled,
  };
 
  class Transport;
 
  class TransportEvents {
  protected:
    ~TransportEvents() {}
 
  public:
    virtual void OnBytesReceived(
        Transport const& transport,
        const unsigned char* buffer,
        size_t size)
        = 0;
 
    virtual void OnIOError() = 0;
  };
 
  class Transport final {
 
  public:
    using TransportSendCompleteFn = std::function<void(TransportSendStatus)>;
 
    ~Transport();
 
    TransportOpenStatus Open(Context const& context = {});
 
    void Close(Context const& context = {});
 
    bool Send(uint8_t* buffer, size_t size, TransportSendCompleteFn callback) const;
 
    void Poll() const;
 
    void SetEventHandler(TransportEvents* events);
 
    Transport(std::shared_ptr<_detail::TransportImpl> impl) : m_impl{impl} {}
    std::shared_ptr<_detail::TransportImpl> GetImpl() const { return m_impl; }
 
  private:
    std::shared_ptr<_detail::TransportImpl> m_impl;
  };
}}}}} // namespace Azure::Core::Amqp::Network::_internal