websocket.h

Go to the documentation of this file.

 
#ifndef __CWIST_WEBSOCKET_H__
#define __CWIST_WEBSOCKET_H__
 
#include <cwist/net/http/http.h>
#include <stdint.h>
#include <stdbool.h>
 
typedef enum {
    CWIST_WS_FRAME_CONTINUATION = 0x0,
    CWIST_WS_FRAME_TEXT = 0x1,
    CWIST_WS_FRAME_BINARY = 0x2,
    CWIST_WS_FRAME_CLOSE = 0x8,
    CWIST_WS_FRAME_PING = 0x9,
    CWIST_WS_FRAME_PONG = 0xA
} cwist_ws_opcode_t;
 
typedef struct cwist_websocket {
    int fd;
    bool is_closed;
    /* Fragmented-message reassembly state (RFC 6455 section 5.4).
     * frag_buf accumulates payload bytes across FIN=0 frames; frag_opcode
     * preserves the first fragment's opcode so the assembled frame reports
     * the correct type (text vs binary). */
    uint8_t *frag_buf;
    size_t frag_len;
    size_t frag_cap;
    cwist_ws_opcode_t frag_opcode;
} cwist_websocket;
 
typedef struct cwist_ws_frame {
    bool fin;
    cwist_ws_opcode_t opcode;
    uint8_t *payload;
    size_t payload_len;
} cwist_ws_frame;
 
bool cwist_websocket_upgrade_response(cwist_http_request *req, cwist_http_response *res);
 
cwist_websocket *cwist_websocket_upgrade(cwist_http_request *req, int client_fd);
 
cwist_ws_frame *cwist_websocket_receive(cwist_websocket *ws);
 
int cwist_websocket_send(cwist_websocket *ws, cwist_ws_opcode_t opcode, const uint8_t *data,
                         size_t len);
 
int cwist_websocket_send_sequenced(cwist_websocket *ws, const uint8_t *data, size_t len,
                                   uint16_t chunk_payload_size);
 
uint8_t *cwist_websocket_receive_sequenced(cwist_websocket *ws, size_t *out_len);
 
void cwist_websocket_frame_destroy(cwist_ws_frame *frame);
 
void cwist_websocket_close(cwist_websocket *ws);
 
void cwist_websocket_destroy(cwist_websocket *ws);
 
#endif