bun_uws_sys 0.1.0

A Rust-native programmable browser runtime built on Servo and SpiderMonkey
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149

#pragma once

#ifndef LIBUWS_CAPI_HEADER
#define LIBUWS_CAPI_HEADER

#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>

#ifndef STRING_POINTER
#define STRING_POINTER
typedef struct StringPointer {
    uint32_t off;
    uint32_t len;
} StringPointer;
#endif

#ifdef __cplusplus
extern "C" {
#endif

enum uws_compress_options_t : int32_t {
    /* These are not actual compression options */
    _COMPRESSOR_MASK = 0x00FF,
    _DECOMPRESSOR_MASK = 0x0F00,
    /* Disabled, shared, shared are "special" values */
    DISABLED = 0,
    SHARED_COMPRESSOR = 1,
    SHARED_DECOMPRESSOR = 1 << 8,
    /* Highest 4 bits describe decompressor */
    DEDICATED_DECOMPRESSOR_32KB = 15 << 8,
    DEDICATED_DECOMPRESSOR_16KB = 14 << 8,
    DEDICATED_DECOMPRESSOR_8KB = 13 << 8,
    DEDICATED_DECOMPRESSOR_4KB = 12 << 8,
    DEDICATED_DECOMPRESSOR_2KB = 11 << 8,
    DEDICATED_DECOMPRESSOR_1KB = 10 << 8,
    DEDICATED_DECOMPRESSOR_512B = 9 << 8,
    /* Same as 32kb */
    DEDICATED_DECOMPRESSOR = 15 << 8,

    /* Lowest 8 bit describe compressor */
    DEDICATED_COMPRESSOR_3KB = 9 << 4 | 1,
    DEDICATED_COMPRESSOR_4KB = 9 << 4 | 2,
    DEDICATED_COMPRESSOR_8KB = 10 << 4 | 3,
    DEDICATED_COMPRESSOR_16KB = 11 << 4 | 4,
    DEDICATED_COMPRESSOR_32KB = 12 << 4 | 5,
    DEDICATED_COMPRESSOR_64KB = 13 << 4 | 6,
    DEDICATED_COMPRESSOR_128KB = 14 << 4 | 7,
    DEDICATED_COMPRESSOR_256KB = 15 << 4 | 8,
    /* Same as 256kb */
    DEDICATED_COMPRESSOR = 15 << 4 | 8
};

enum uws_opcode_t : int32_t {
    CONTINUATION = 0,
    TEXT = 1,
    BINARY = 2,
    CLOSE = 8,
    PING = 9,
    PONG = 10
};

enum uws_sendstatus_t : uint32_t { BACKPRESSURE,
    SUCCESS,
    DROPPED };

typedef struct {

    int port;
    const char* host;
    int options;
} uws_app_listen_config_t;

struct uws_app_s;
struct uws_req_s;
struct uws_res_s;
struct uws_websocket_s;
struct uws_header_iterator_s;
typedef struct uws_app_s uws_app_t;
typedef struct uws_req_s uws_req_t;
typedef struct uws_res_s uws_res_t;
typedef struct uws_socket_context_s uws_socket_context_t;
typedef struct uws_websocket_s uws_websocket_t;

typedef void (*uws_websocket_handler)(uws_websocket_t* ws);
typedef void (*uws_websocket_message_handler)(uws_websocket_t* ws,
    const char* message,
    size_t length,
    uws_opcode_t opcode);
typedef void (*uws_websocket_ping_pong_handler)(uws_websocket_t* ws,
    const char* message,
    size_t length);
typedef void (*uws_websocket_close_handler)(uws_websocket_t* ws, int code,
    const char* message, size_t length);
typedef void (*uws_websocket_upgrade_handler)(void*, uws_res_t* response,
    uws_req_t* request,
    uws_socket_context_t* context,
    size_t id);

typedef struct {
    uws_compress_options_t compression;
    /* Maximum message size we can receive */
    unsigned int maxPayloadLength;
    /* 2 minutes timeout is good */
    unsigned short idleTimeout;
    /* 64kb backpressure is probably good */
    unsigned int maxBackpressure;
    bool closeOnBackpressureLimit;
    /* This one depends on kernel timeouts and is a bad default */
    bool resetIdleTimeoutOnSend;
    /* A good default, esp. for newcomers */
    bool sendPingsAutomatically;
    /* Maximum socket lifetime in seconds before forced closure (defaults to
     * disabled) */
    unsigned short maxLifetime;

    uws_websocket_upgrade_handler upgrade;
    uws_websocket_handler open;
    uws_websocket_message_handler message;
    uws_websocket_handler drain;
    uws_websocket_ping_pong_handler ping;
    uws_websocket_ping_pong_handler pong;
    uws_websocket_close_handler close;
} uws_socket_behavior_t;

typedef void (*uws_listen_handler)(struct us_listen_socket_t* listen_socket,
    void* user_data);
typedef void (*uws_listen_domain_handler)(
    struct us_listen_socket_t* listen_socket, const char* domain, int options,
    void* user_data);

typedef void (*uws_method_handler)(uws_res_t* response, uws_req_t* request,
    void* user_data);
typedef void (*uws_filter_handler)(uws_res_t* response, int, void* user_data);
typedef void (*uws_missing_server_handler)(const char* hostname,
    void* user_data);
typedef void (*uws_get_headers_server_handler)(const char* header_name,
    size_t header_name_size,
    const char* header_value,
    size_t header_value_size,
    void* user_data);

struct us_loop_t* uws_get_loop();

#ifdef __cplusplus
}
#endif

#endif