client.h

Go to the documentation of this file.

 
#ifndef KEEL_CLIENT_H
#define KEEL_CLIENT_H
 
#include <keel/allocator.h>
#include <keel/decompress.h>
#include <keel/error.h>
#include <keel/event_ctx.h>
#include <keel/parser.h>
#include <keel/resolver.h>
#include <keel/tls.h>
#include <keel/url.h>
 
/* ── Constants ────────────────────────────────────────────────────── */
 
#define KL_CLIENT_HOSTNAME_MAX       256
#define KL_CLIENT_REQ_BUF_SIZE       4096
#define KL_CLIENT_MAX_REQ_HEADERS    64
#define KL_CLIENT_DEFAULT_TIMEOUT_MS 30000
#define KL_CLIENT_DEFAULT_MAX_RESP   (4 * 1024 * 1024)
#define KL_CLIENT_RECV_BUF_SIZE      8192
#define KL_CLIENT_CHUNK_BUF_SIZE     4096
#define KL_CLIENT_CHUNK_HDR_SIZE     16    
#define KL_CLIENT_FINAL_CHUNK_LEN    5     
/* ── Proxy ────────────────────────────────────────────────────────── */
 
typedef struct {
    const char *host;       
    uint16_t    port;       
    const char *auth;       
} KlProxyConfig;
 
/* ── Types ────────────────────────────────────────────────────────── */
 
typedef struct {
    const char *name;   
    const char *value;  
} KlClientHeader;
 
typedef struct KlClientResponse {
    int              status;
    char            *body;
    size_t           body_len;
    KlClientHeader  *headers;
    int              num_headers;
    KlAllocator      alloc;     
    KlError          error;     
} KlClientResponse;
 
typedef struct {
    int              timeout_ms;        
    size_t           max_response_size;  
    KlTlsConfig     *tls;              
    KlResolver      *resolver;          
    KlDecompressConfig *decompress;     
    KlProxyConfig   *proxy;             
} KlClientConfig;
 
/* ── Streaming types ──────────────────────────────────────────────── */
 
typedef int (*KlClientBodyFn)(const char *data, size_t len, void *user_data);
 
typedef int (*KlClientHeadersFn)(int status, const KlClientHeader *headers,
                                  int num_headers, void *user_data);
 
typedef ssize_t (*KlClientReadFn)(char *buf, size_t buf_len, void *user_data);
 
typedef struct {
    KlClientBodyFn     on_body;        
    KlClientHeadersFn  on_headers;    
    void             (*on_complete)(void *user_data);  
    KlClientReadFn     body_read;     
    void              *user_data;     
} KlClientStreamCfg;
 
/* ── Sync API ─────────────────────────────────────────────────────── */
 
int kl_client_request(KlAllocator *alloc, const KlClientConfig *cfg,
                      const char *method, const char *url,
                      const KlClientHeader *headers, int num_headers,
                      const char *body, size_t body_len,
                      KlClientResponse *resp);
 
int kl_client_request_s(KlAllocator *alloc, const KlClientConfig *cfg,
                         const char *method, const char *url,
                         const KlClientHeader *headers, int num_headers,
                         const char *body, size_t body_len,
                         const KlClientStreamCfg *stream,
                         KlClientResponse *resp);
 
void kl_client_response_free(KlClientResponse *resp);
 
/* ── Async API (requires KlEventCtx, NOT KlServer) ───────────────── */
 
typedef struct KlClient KlClient;
 
typedef void (*KlClientDoneFn)(KlClient *client, void *user_data);
 
KlClient *kl_client_start(KlEventCtx *ev_ctx, KlAllocator *alloc,
                           const KlClientConfig *cfg,
                           const char *method, const char *url,
                           const KlClientHeader *headers, int num_headers,
                           const char *body, size_t body_len,
                           KlClientDoneFn on_done, void *user_data);
 
KlClient *kl_client_start_s(KlEventCtx *ev_ctx, KlAllocator *alloc,
                              const KlClientConfig *cfg,
                              const char *method, const char *url,
                              const KlClientHeader *headers, int num_headers,
                              const char *body, size_t body_len,
                              const KlClientStreamCfg *stream,
                              KlClientDoneFn on_done, void *user_data);
 
const KlClientResponse *kl_client_response(const KlClient *client);
 
int kl_client_error(const KlClient *client);
 
KlError kl_client_last_error(const KlClient *client);
 
void kl_client_cancel(KlClient *client);
 
void kl_client_free(KlClient *client);
 
/* ── Streaming parser factory ─────────────────────────────────────── */
 
KlResponseParser *kl_response_parser_llhttp_s(size_t max_response_size,
                                                KlAllocator *alloc,
                                                KlClientBodyFn on_body,
                                                KlClientHeadersFn on_headers,
                                                void (*on_complete)(void *),
                                                void *stream_user_data);
 
#endif /* KEEL_CLIENT_H */