Mercurial > hg > webserver / file revision

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2026 Olaf Wintermann. All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *   1. Redistributions of source code must retain the above copyright
 *      notice, this list of conditions and the following disclaimer.
 *
 *   2. Redistributions in binary form must reproduce the above copyright
 *      notice, this list of conditions and the following disclaimer in the
 *      documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#ifndef PROXY_HTTPCLIENT_H
#define PROXY_HTTPCLIENT_H

#include "../public/nsapi.h"
#include "../daemon/httpparser.h"

#include <sys/socket.h>
#include <cx/string.h>
#include <cx/mempool.h>

#ifdef __cplusplus
extern "C" {
#endif

typedef struct HttpClient HttpClient;
struct HttpClient {
    EventHandler *ev;
    CxMempool *mp;
    char *uri;
    
    struct sockaddr *addr;
    size_t addrlen;
    
    int socketfd;
    
    HeaderArray *request_headers;
    HeaderArray *response_headers;
    
    /*
     * Request body callback function
     * 
     * size_t request_body_read(HttpClient *client, void *buf, size_t size, void *userdata)
     */
    // TODO: fix, doesn't work this way
    //size_t (*request_body_read)(HttpClient *, void *, size_t, void *);
    //void *request_body_read_userdata;
    
    /*
     * Response start callback function
     * 
     * int response_start(HttpClient *client, int status, char *message, void *userdata)
     */
    int (*response_start)(HttpClient *, int, char *, void *);
    void *response_start_userdata;
    
    /*
     * Response body write function
     * 
     * int response_body_write(HttpClient *client, void *buf, size_t size, void *userdata)
     */
    int (*response_body_write)(HttpClient *, void *, size_t, void *);
    void *response_body_write_userdata;
    
    /*
     * Response finished callback
     * 
     * void response_finished(HttpClient *client, int error, void *userdata)
     */
    void (*response_finished)(HttpClient *, int, void *);
    void *response_finished_userdata;
    
    
    // internals
    
    char *req_buffer;
    size_t req_buffer_len;
    
    Event readev;
    Event writeev;
};

HttpClient* http_client_new(EventHandler *ev);

int http_client_set_addr(HttpClient *client, const struct sockaddr *addr, socklen_t addrlen);

/*
 * Adds a request header
 * 
 * This function does not create a copy of name/value. The string pointers must
 * be valid for the lifetime of the HttpClient.
 */
int http_client_add_request_header(HttpClient *client, cxmutstr name, cxmutstr value);

/*
 * Adds a request header
 * 
 * This functions creates a copy of name/value and the original pointers can be
 * discarded after the function returns.
 */
int http_client_add_request_header_copy(HttpClient *client, cxstring name, cxstring value);

int http_client_start(HttpClient *client);

#ifdef __cplusplus
}
#endif

#endif /* PROXY_HTTPCLIENT_H */