websocket_deflate.hpp

浏览该文件的文档.

#ifndef NEFORCE_NETWORK_HTTP_WEBSOCKET_DEFLATE_HPP__
#define NEFORCE_NETWORK_HTTP_WEBSOCKET_DEFLATE_HPP__

 
#include "NeForce/core/string/string.hpp"
#ifdef NEFORCE_SUPPORT_ZLIB
#    include "NeForce/compress/zlib_compress.hpp"
#endif
NEFORCE_BEGIN_NAMESPACE__
NEFORCE_BEGIN_HTTP__


struct NEFORCE_API websocket_deflate_config {
    int client_max_window_bits = 15;

    int server_max_window_bits = 15;

    bool client_no_context_takeover = false;

    bool server_no_context_takeover = false;

    bool active = false;

    static websocket_deflate_config negotiate(string_view request_extensions);

    NEFORCE_NODISCARD string to_response_header() const;
};
 
#ifdef NEFORCE_SUPPORT_ZLIB

class NEFORCE_API websocket_deflate {
private:
    bool compress_mode_;
    int window_bits_;
    bool no_context_takeover_;
    bool initialized_ = false;
    bool stream_finished_ = false;
 
    unique_ptr<zlib_compressor::stream_compressor> compressor_;
    unique_ptr<zlib_compressor::stream_decompressor> decompressor_;
 
    void ensure_initialized();
 
public:
    websocket_deflate(bool compress, int window_bits, bool no_context_takeover);
 
    ~websocket_deflate() = default;
 
    websocket_deflate(const websocket_deflate&) = delete;
    websocket_deflate& operator=(const websocket_deflate&) = delete;
    websocket_deflate(websocket_deflate&&) noexcept;
    websocket_deflate& operator=(websocket_deflate&&) noexcept;

    string process(string_view data, bool is_final);

    void reset_context();
};
 
#else // !NEFORCE_SUPPORT_ZLIB

class websocket_deflate {
public:
    websocket_deflate(bool, int, bool) {}
    ~websocket_deflate() = default;
    websocket_deflate(const websocket_deflate&) = delete;
    websocket_deflate& operator=(const websocket_deflate&) = delete;
    websocket_deflate(websocket_deflate&&) noexcept {}
    websocket_deflate& operator=(websocket_deflate&&) noexcept { return *this; }

    string process(string_view data, bool) { return {data}; }

    void reset_context() {}
};
 
#endif // NEFORCE_SUPPORT_ZLIB
 // HTTP
 
NEFORCE_END_HTTP__
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_NETWORK_HTTP_WEBSOCKET_DEFLATE_HPP__