management.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
 
#include "azure/core/amqp/internal/models/amqp_error.hpp"
#include "azure/core/amqp/models/amqp_message.hpp"
#include "session.hpp"
 
#include <azure/core/context.hpp>
 
#include <string>
#include <tuple>
#include <vector>
 
namespace Azure { namespace Core { namespace Amqp { namespace _detail {
  class ManagementClientImpl;
  class ManagementClientFactory;
}}}} // namespace Azure::Core::Amqp::_detail
 
namespace Azure { namespace Core { namespace Amqp { namespace _internal {
  enum class ManagementOperationStatus
  {
    Invalid,
    Ok,
    Error,
    FailedBadStatus,
    InstanceClosed,
    Cancelled,
  };
 
  enum class ManagementOpenStatus
  {
    Invalid,
    Ok,
    Error,
    Cancelled,
  };
 
  struct ManagementClientOptions final
  {
    std::string ExpectedStatusCodeKeyName = "statusCode";
 
    std::string ExpectedStatusDescriptionKeyName = "statusDescription";
 
    std::string ManagementNodeName = "$management";
 
    bool EnableTrace{false};
  };
 
  class ManagementClientEvents {
  protected:
    ~ManagementClientEvents() {}
 
  public:
    virtual void OnError(Models::_internal::AmqpError const& error) = 0;
  };
 
  struct ManagementOperationResult final
  {
    ManagementOperationStatus Status = ManagementOperationStatus::Invalid;
 
    std::shared_ptr<Models::AmqpMessage> Message;
 
    Models::_internal::AmqpError Error;
 
    uint32_t StatusCode = 0;
  };
 
  class ManagementClient final {
  public:
    ManagementClient() = default;
 
    ~ManagementClient() noexcept = default;
 
    ManagementClient(ManagementClient const&) = default;
 
    ManagementClient& operator=(ManagementClient const&) = default;
 
    ManagementClient(ManagementClient&&) = default;
 
    ManagementClient& operator=(ManagementClient&&) = default;
 
    _azure_NODISCARD ManagementOpenStatus Open(Context const& context = {});
 
    void Close(Context const& context = {});
 
    _azure_NODISCARD ManagementOperationResult ExecuteOperation(
        std::string const& operationToPerform,
        std::string const& typeOfOperation,
        std::string const& locales,
        Models::AmqpMessage messageToSend,
        Context const& context = {});
 
  private:
    friend class Azure::Core::Amqp::_detail::ManagementClientFactory;
    ManagementClient(std::shared_ptr<_detail::ManagementClientImpl> impl) : m_impl{impl} {}
    std::shared_ptr<_detail::ManagementClientImpl> m_impl;
  };
 
}}}} // namespace Azure::Core::Amqp::_internal