h2_client.h

Go to the documentation of this file.

 
#ifndef KEEL_H2_CLIENT_H
#define KEEL_H2_CLIENT_H
 
#include <stddef.h>
#include <stdint.h>
#include <keel/allocator.h>
#include <keel/event_ctx.h>
#include <keel/h2.h>
#include <keel/tls.h>
 
/* ── Defaults ────────────────────────────────────────────────────── */
 
#define KL_H2_CLIENT_DEFAULT_TIMEOUT_MS  30000
#define KL_H2_CLIENT_RECV_BUF_SIZE       16384
 
/* ── Types ───────────────────────────────────────────────────────── */
 
typedef struct KlH2ClientConn    KlH2ClientConn;
typedef struct KlH2ClientStream  KlH2ClientStream;
typedef struct KlH2ClientSession KlH2ClientSession;
 
typedef struct {
    const char *name;   
    const char *value;  
} KlH2ClientHeader;
 
typedef struct {
    int              status;      
    KlH2ClientHeader *headers;   
    int              num_headers; 
    int              headers_cap; 
    char             *body;       
    size_t           body_len;    
    size_t           body_cap;    
} KlH2ClientResponse;
 
/* ── Session callbacks (session -> KEEL) ─────────────────────────── */
 
typedef struct {
    int  (*on_send)(KlH2ClientSession *s, const void *data, size_t len);
    void (*on_response)(KlH2ClientSession *s, int32_t stream_id,
                        int status, const KlH2ClientHeader *hdrs, int n);
    void (*on_data)(KlH2ClientSession *s, int32_t stream_id,
                    const char *data, size_t len);
    void (*on_stream_close)(KlH2ClientSession *s, int32_t stream_id, int err);
} KlH2ClientCallbacks;
 
/* ── Session vtable (user provides, wraps nghttp2 etc.) ──────────── */
 
struct KlH2ClientSession {
    int (*recv)(KlH2ClientSession *self, const char *data, size_t len);
    int32_t (*submit_request)(KlH2ClientSession *self,
                              const char *method, const char *path,
                              const char *authority,
                              const KlH2ClientHeader *hdrs, int n,
                              const char *body, size_t body_len);
    int (*flush)(KlH2ClientSession *self);
    void (*destroy)(KlH2ClientSession *self);
    KlH2ClientCallbacks keel_cbs;
    void *keel_ctx;
};
 
typedef KlH2ClientSession *(*KlH2ClientSessionFactory)(KlAllocator *alloc);
 
/* ── Config ──────────────────────────────────────────────────────── */
 
typedef struct {
    int                       timeout_ms;              
    int                       max_concurrent_streams;  
    KlTlsConfig              *tls;
    KlH2ClientSessionFactory  session;                 
} KlH2ClientConfig;
 
/* ── Callbacks ───────────────────────────────────────────────────── */
 
typedef void (*KlH2ClientResponseFn)(KlH2ClientConn *c, int32_t stream_id,
                                      const KlH2ClientResponse *resp,
                                      void *user_data);
typedef void (*KlH2ClientErrorFn)(KlH2ClientConn *c, const char *msg,
                                   void *user_data);
 
/* ── Public API ──────────────────────────────────────────────────── */
 
KlH2ClientConn *kl_h2_client_connect(KlEventCtx *ev, KlAllocator *alloc,
                                      const KlH2ClientConfig *cfg,
                                      const char *url,
                                      KlH2ClientErrorFn on_error,
                                      void *user_data);
 
int32_t kl_h2_client_request(KlH2ClientConn *c, const char *method,
                              const char *path,
                              const KlH2ClientHeader *hdrs, int n,
                              const char *body, size_t body_len,
                              KlH2ClientResponseFn on_resp, void *ud);
 
void kl_h2_client_close(KlH2ClientConn *c);
void kl_h2_client_free(KlH2ClientConn *c);
void kl_h2_client_response_free(KlH2ClientResponse *resp, KlAllocator *alloc);
 
#endif