grpc.hpp

浏览该文件的文档.

#ifndef NEFORCE_NETWORK_HTTP_GRPC_HPP__
#define NEFORCE_NETWORK_HTTP_GRPC_HPP__

 
#include "NeForce/core/functional/function.hpp"
#include "NeForce/core/utility/byte_size.hpp"
#include "NeForce/network/http/http_server_message.hpp"
NEFORCE_BEGIN_NAMESPACE__
NEFORCE_BEGIN_HTTP__

 
NEFORCE_INLINE17 constexpr string_view GRPC_CONTENT_TYPE = "application/grpc";
NEFORCE_INLINE17 constexpr string_view GRPC_CONTENT_TYPE_PROTO = "application/grpc+proto";

enum class grpc_status : uint8_t {
    OK = 0,
    CANCELLED = 1,
    UNKNOWN = 2,
    INVALID_ARGUMENT = 3,
    DEADLINE_EXCEEDED = 4,
    NOT_FOUND = 5,
    ALREADY_EXISTS = 6,
    PERMISSION_DENIED = 7,
    RESOURCE_EXHAUSTED = 8,
    FAILED_PRECONDITION = 9,
    ABORTED = 10,
    OUT_OF_RANGE = 11,
    UNIMPLEMENTED = 12,
    INTERNAL = 13,
    UNAVAILABLE = 14,
    DATA_LOSS = 15,
    UNAUTHENTICATED = 16,
};

struct grpc_message {
    bool compressed{false};
    byte_vector payload;
 
    grpc_message() = default;
    grpc_message(byte_vector data, bool comp = false) :
    compressed(comp),
    payload(move(data)) {}
};

class NEFORCE_API grpc_framer {
public:
    byte_size max_receive_size{4_MB};
 
    grpc_framer() = default;

    static byte_vector encode(const grpc_message& msg);

    static byte_vector encode_messages(const vector<grpc_message>& messages);

    int decode(const byte_t* data, size_t len, vector<grpc_message>& out);
};

class NEFORCE_API grpc_handler {
public:
    using unary_handler = function<grpc_message(const grpc_message&)>;
    using stream_handler = function<void(const grpc_message&, function<void(grpc_message)>)>;
 
    grpc_handler() = default;
    virtual ~grpc_handler() = default;

    void process_unary(http_request& request, http_response& response, unary_handler handler);

    static void send_error(http_response& response, grpc_status status, const string& message);

    static http_status grpc_to_http_status(grpc_status status) noexcept;
 
private:
    grpc_framer framer_;
};
 
// TODO: Client streaming support — implement request-streaming handler with backpressure and flow control
// TODO: Server streaming support — implement response-streaming handler with chunked gRPC frames
// TODO: Bidirectional streaming support — full duplex bidi streaming with concurrent read/write channels
// TODO: Protobuf integration — code generation from .proto files, typed request/response wrappers (beyond raw byte_vector)
// TODO: gRPC-Web support — gRPC-Web protocol translation for browser-based gRPC clients (text and binary modes)
// TODO: gRPC interceptor chain — unary/stream interceptor stack for logging, auth, metrics, tracing
 // gRPC
 
NEFORCE_END_HTTP__
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_NETWORK_HTTP_GRPC_HPP__