HttpRequestResponse.h

Go to the documentation of this file.

#pragma once
 
#include <aws/crt/Exports.h>
#include <aws/crt/Types.h>
#include <aws/crt/io/Stream.h>
 
struct aws_http_header;
struct aws_http_message;
 
namespace Aws
{
    namespace Crt
    {
        namespace Mqtt
        {
            class MqttConnection;
            class MqttConnectionCore;
        } // namespace Mqtt
        namespace Mqtt5
        {
            class Mqtt5ClientCore;
        }
        namespace Http
        {
            using HttpHeader = aws_http_header;

            class AWS_CRT_CPP_API HttpMessage
            {
              public:
                virtual ~HttpMessage();
 
                HttpMessage(const HttpMessage &) = delete;
                HttpMessage(HttpMessage &&) = delete;
                HttpMessage &operator=(const HttpMessage &) = delete;
                HttpMessage &operator=(HttpMessage &&) = delete;

                std::shared_ptr<Aws::Crt::Io::InputStream> GetBody() const noexcept;

                bool SetBody(const std::shared_ptr<Aws::Crt::Io::IStream> &body) noexcept;

                bool SetBody(const std::shared_ptr<Aws::Crt::Io::InputStream> &body) noexcept;

                size_t GetHeaderCount() const noexcept;

                Optional<HttpHeader> GetHeader(size_t index) const noexcept;

                bool AddHeader(const HttpHeader &header) noexcept;

                bool EraseHeader(size_t index) noexcept;

                operator bool() const noexcept { return m_message != nullptr; }

                struct aws_http_message *GetUnderlyingMessage() const noexcept { return m_message; }
 
              protected:
                HttpMessage(Allocator *allocator, struct aws_http_message *message) noexcept;
 
                Allocator *m_allocator;
                struct aws_http_message *m_message;
                std::shared_ptr<Aws::Crt::Io::InputStream> m_bodyStream;
            };

            class AWS_CRT_CPP_API HttpRequest : public HttpMessage
            {
                friend class Mqtt::MqttConnectionCore;
                friend class Mqtt5::Mqtt5ClientCore;
 
              public:
                HttpRequest(Allocator *allocator = ApiAllocator());

                Optional<ByteCursor> GetMethod() const noexcept;

                bool SetMethod(ByteCursor method) noexcept;

                Optional<ByteCursor> GetPath() const noexcept;

                bool SetPath(ByteCursor path) noexcept;
 
              protected:
                HttpRequest(Allocator *allocator, struct aws_http_message *message);
            };

            class AWS_CRT_CPP_API HttpResponse : public HttpMessage
            {
              public:
                HttpResponse(Allocator *allocator = ApiAllocator());

                Optional<int> GetResponseCode() const noexcept;

                bool SetResponseCode(int response) noexcept;
            };
        } // namespace Http
    } // namespace Crt
} // namespace Aws