IWebSocketSender.hpp

Go to the documentation of this file.

#pragma once
#ifndef _KURLYK_IWEBSOCKET_SENDER_HPP_INCLUDED
#define _KURLYK_IWEBSOCKET_SENDER_HPP_INCLUDED

 
namespace kurlyk {

    class IWebSocketSender {
    public:

        IWebSocketSender() = default;

        virtual ~IWebSocketSender() = default;

        virtual std::string get_http_version() = 0;

        virtual Headers get_headers() = 0;

        virtual std::string get_remote_endpoint() = 0;

        virtual bool send_message(
                const std::string &message,
                long rate_limit_id = 0,
                std::function<void(const std::error_code&)> callback = nullptr) = 0;

        virtual SubmitResult submit_message(
                const std::string &message,
                long rate_limit_id = 0,
                std::function<void(const std::error_code&)> callback = nullptr) {
            const bool accepted = send_message(message, rate_limit_id, std::move(callback));
            return SubmitResult{accepted, std::error_code()};
        }

        virtual bool send_close(
                int status = 1000,
                const std::string &reason = std::string(),
                std::function<void(const std::error_code&)> callback = nullptr) = 0;

        virtual SubmitResult submit_close(
                int status = 1000,
                const std::string &reason = std::string(),
                std::function<void(const std::error_code&)> callback = nullptr) {
            const bool accepted = send_close(status, reason, std::move(callback));
            return SubmitResult{accepted, std::error_code()};
        }

        virtual bool is_connected() const = 0;
 
    };

    using WebSocketSenderPtr = std::shared_ptr<IWebSocketSender>;
 
} // namespace kurlyk
 
#endif // _KURLYK_IWEBSOCKET_SENDER_HPP_INCLUDED