fetch.h

Go to the documentation of this file.

 
#pragma once
#include "pyc.h"
#include <openssl/types.h>
#include <stdbool.h>
#include <stdio.h>
 
struct url {
    char *host;
 
    struct str hostname;
 
    char *pathname;
 
    struct str port;
 
    struct str protocol;
};
void url_free(struct url *url);
 
struct dispatch {
    int sockfd;
    SSL *ssl;
    SSL_CTX *ctx;
    struct url url;
    struct addrinfo *addrinfo;
};
void dispatch_free(struct dispatch *dispatch);
struct dispatch *fetch_socket(const char *url, const char *init[4]);
int use_fetch(int fds[4], struct dispatch *dispatch);
 
struct fetch_state {
    /* FDs */
    int netfd;        // TCP socket (nonblocking)
    int outfd;        // socketpair writer FD (nonblocking)
    int ep;           // epoll instance FD
 
    char *hostname;
    SSL_CTX *ssl_ctx;
    SSL     *ssl;
 
    /* --- HTTP HEADER PARSING --- */
    bool headers_done;
    char header_buf[8192];  // store header bytes
    size_t header_len;
 
    bool chunked_mode;
    size_t content_length;
 
    /* --- CHUNKED DECODING STATE --- */
    bool reading_chunk_size;    // true = reading hex size line
    char chunk_line[128];       // buffer for chunk-size line
    size_t chunk_line_len;      // how many chars collected
    size_t current_chunk_size;  // remaining bytes in current chunk
    int expecting_crlf;         // 2 -> expecting "\r\n"
 
    FILE *stream;
 
    /* --- NONBLOCKING SEND STATE FOR outfd --- */
    char *pending_buf;         // partial write buffer (JSON object)
    size_t pending_len;         // bytes left to send
    size_t pending_off;         // current offset in pending_send
 
    /* --- TERMINATION STATE --- */
    bool http_done;             // reached end of chunked stream or TCP closed
    bool closed_outfd;          // have we closed outfd yet?
};
 
void *fetcher(void *arg);