websocket.hpp

 
//
//저작권 2024 Realm Inc.
//
// Apache 라이선스, 버전 2.0("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스를 준수하는 경우를 제외하고는 이 파일을 사용할 수 없습니다.
// 다음에서 라이선스 사본을 얻을 수 있습니다.
//
// http://www.apache.org/licences/LICENSE-2.0
//
// 관련 법률에서 요구하거나 문서로 동의하지 않는 한, 소프트웨어
// 라이선스에 따라 배포되는 것은 '있는 그대로' 배포됩니다,
// Express 묵시적이든 어떤 종류의 보증이나 조건도 제공하지 않습니다.
// 권한을 관리하는 특정 언어에 대한 내용은 라이선스를 참조하세요.
// 라이선스에 따른 제한 사항.
//
 
#ifndef CPPREALM_NETWORKING_WEBSOCKET_HPP
#define CPPRALM_NETWORKING_WEBSOCKET_HPP
 
#include <cpprealm/internal/bridge/status.hpp>
#include <cpprealm/internal/bridge/realm.hpp>
 
#ifndef REALMCXX_VERSION_MAJOR
#include <cpprealm/version_numbers.hpp>
#endif
 
#include <chrono>
#include <optional>
 
네임스페이스 영역 {
    namespace sync {
        클래스 SyncSocketProvider;
        struct WebSocketInterface;
        struct WebSocketObserver;
 }
 
    네임스페이스 유틸리티 {
        클래스 로거(Logger);
 }
}
 
네임스페이스 영역::네트워킹 {
 
    구조체 websocket_endpoint {
 std::vector<std::string> 프로토콜;
 std::string URL;
 };
 
    열거형 클래스 websocket_err_codes {
 ok = 1000,
 going_ways = 1001,
 protocol_error = 1002,
 unsupported_data = 1003,
 websocket_reserved = 1004,
 no_status_received = 1005,
 비정상적인_클로저 = 1006,
 invalid_payload_data = 1007,
 정책 위반 = 1008,
 message_too_big = 1009,
 invalid_extension = 1010,
 invalid_server_error = 1011,
 TLS_handShake_failed = 1015,
 
 미승인 = 4001,
 forbidden = 4002,
 moved_permanently = 4003,
 client_too_old = 4004,
 client_too_new = 4005,
 protocol_mismatch = 4006,
 
 resolve_failed = 4400,
 connection_failed = 4401,
 read_error = 4402,
 write_error = 4403,
 retry_error = 4404,
 fatal_error = 4405,
 };
 
     status  =:: 영역::internal::bridge::status를 사용 합니다.
    struct websocket_interface;
    struct websocket_observer;
 
    클래스 sync_socket_provider {
    public:
 
        사용 FunctionHandler = std::function< 무효(status)>;
 
        구조체 timer {
            가상 ~timer() = 기본값;
            가상 void cancel() = 0;
 };
 
        사용 sync_timer = std::unique_ptr<sync_socket_provider::timer>;
 
        가상 ~sync_socket_provider() = 기본값;
 
        가상 std::unique_ptr<websocket_interface> connect(std::unique_ptr<websocket_observer> 관찰자,
                                                             websocket_endpoint && endpoint) = 0;
 
        가상 void post(FunctionHandler&& handler) = 0;
 
        가상 sync_timer create_timer(std::chrono::milliseconds 지연, FunctionHandler&& 처리기) = 0;
 };
 
    구조체 websocket_interface {
        가상 ~websocket_interface() = default;
 
        using FunctionHandler = std::function<oid(status)>;
 
        가상 void async_write_binary(std::string_view 데이터, FunctionHandler&& 처리기) = 0;
 };
 
    구조체 websocket_observer {
        가상 ~websocket_observer() = default;
 
        가상 void websocket_connected_handler(const std::string& 프로토콜) = 0;
 
        가상 void websocket_error_handler() = 0;
 
        가상 부울 websocket_binary_message_received(std::string_view 데이터) = 0;
 
        가상 부울 websocket_closed_handler(bool was_clean, websocket_err_codes error_code,
 std::string_view message) = 0;
 };
 
    구조체 default_socket_provider : public sync_socket_provider {
        구조체 구성 {
 std::optional<std::map<std::string, std::string>> custom_http_headers;
 std::optional<::realm::internal::bridge::realm::sync_config::proxy_config> proxy_config;
 
            SSLVerifyCallback = bool(const std::string& server_address,
 internal::bridge:: 영역::sync_config::proxy_config::port_type server_port,
                                           const char* pem_data, size_t pem_size, int preverify_ok, int depth);
            부울 client_validate_ssl = true;
 std::optional<std::string> ssl_ Trust_certificate_path;
 std::function<SSLVerifyCallback> ssl_verify_callback;
 };
        default_socket_provider();
        default_socket_provider(const 구성& c);
        ~default_socket_provider() = 기본값;
 
 std::unique_ptr<websocket_interface> connect(std::unique_ptr<websocket_observer>, websocket_endpoint &&) 재정 의 ;
        void 게시(FunctionHandler&&) 재정 의 ;
        sync_timer create_timer(std::chrono::milliseconds 지연, FunctionHandler&&) 재정 의 ;
 
    보호됨:
        구성 m_configuration;
    private:
        무효 initialize();
 std::unique_ptr<::realm::sync::SyncSocketProvider> m_provider;
 };
}
 
#endif //CPPREALM_NETWORKING_WEBSOCKET_HPP