/home/mrjunejune/zenbu: seobeo/s

annotate seobeo/s_websocket.c @ 120:cbbf78b17cfa

[Seobeo][Websocket] Created Web socket client logic.

author	June Park <parkjune1995@gmail.com>
date	Thu, 08 Jan 2026 03:19:59 -0800
parents
children	7b1719fa918c

rev	line source
120 cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	1 #include "seobeo/seobeo.h"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	2 #include <time.h>
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	3
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	4 #define SEOBEO_WS_GUID "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	5 #define MAX_INT_16 65536
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	6 #define MAX_INT_64 18446744073709551615
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	7
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	8 static void Seobeo_WebSocket_Parse_Url(const char url, char p_host, char p_port, char p_path, boolean p_use_tls, Dowa_Arena *p_arena)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	9 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	10 if (!url)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	11 return;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	12
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	13 const char *start = url;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	14 *p_use_tls = FALSE;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	15
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	16 if (strncmp(url, "wss://", 6) == 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	17 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	18 *p_use_tls = TRUE;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	19 start = url + 6;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	20 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	21 else if (strncmp(url, "ws://", 5) == 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	22 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	23 *p_use_tls = FALSE;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	24 start = url + 5;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	25 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	26
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	27 const char *slash = strchr(start, '/');
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	28 const char *colon = strchr(start, ':');
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	29
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	30 if (colon && (!slash \|\| colon < slash))
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	31 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	32 size_t host_len = colon - start;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	33 *p_host = Dowa_Arena_Allocate(p_arena, host_len + 1);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	34 memcpy(*p_host, start, host_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	35 (*p_host)[host_len] = '\0';
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	36
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	37 const char *port_start = colon + 1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	38 size_t port_len = slash ? (slash - port_start) : strlen(port_start);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	39 *p_port = Dowa_Arena_Allocate(p_arena, port_len + 1);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	40 memcpy(*p_port, port_start, port_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	41 (*p_port)[port_len] = '\0';
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	42 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	43 else
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	44 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	45 size_t host_len = slash ? (slash - start) : strlen(start);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	46 *p_host = Dowa_Arena_Allocate(p_arena, host_len + 1);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	47 memcpy(*p_host, start, host_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	48 (*p_host)[host_len] = '\0';
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	49
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	50 *p_port = Dowa_Arena_Allocate(p_arena, 8);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	51 strcpy(p_port, p_use_tls ? "443" : "80");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	52 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	53
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	54 if (slash)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	55 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	56 size_t path_len = strlen(slash);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	57 *p_path = Dowa_Arena_Allocate(p_arena, path_len + 1);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	58 strcpy(*p_path, slash);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	59 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	60 else
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	61 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	62 *p_path = Dowa_Arena_Allocate(p_arena, 2);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	63 strcpy(*p_path, "/");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	64 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	65 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	66
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	67 static void Seobeo_WebSocket_Generate_Key(char *key_out, size_t key_size)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	68 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	69 static const char base64_chars[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	70
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	71 srand((unsigned int)time(NULL) ^ (unsigned int)getpid());
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	72
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	73 uint8 random_bytes[16];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	74 for (int i = 0; i < 16; i++)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	75 random_bytes[i] = (uint8)(rand() % 256);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	76
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	77 int out_idx = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	78 for (int i = 0; i < 16; i += 3)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	79 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	80 uint32 triple = (random_bytes[i] << 16) \|
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	81 (i + 1 < 16 ? random_bytes[i + 1] << 8 : 0) \|
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	82 (i + 2 < 16 ? random_bytes[i + 2] : 0);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	83
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	84 key_out[out_idx++] = base64_chars[(triple >> 18) & 0x3F];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	85 key_out[out_idx++] = base64_chars[(triple >> 12) & 0x3F];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	86 key_out[out_idx++] = base64_chars[(triple >> 6) & 0x3F];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	87 key_out[out_idx++] = base64_chars[triple & 0x3F];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	88 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	89
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	90 key_out[out_idx] = '\0';
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	91 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	92
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	93 Seobeo_WebSocket Seobeo_WebSocket_Connect(const char url)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	94 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	95 Seobeo_WebSocket *p_ws = malloc(sizeof(Seobeo_WebSocket));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	96 if (!p_ws)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	97 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	98
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	99 memset(p_ws, 0, sizeof(Seobeo_WebSocket));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	100
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	101 p_ws->p_arena = Dowa_Arena_Create(1024 * 1024);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	102 if (!p_ws->p_arena)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	103 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	104 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	105 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	106 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	107
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	108 size_t url_len = strlen(url);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	109 p_ws->url = Dowa_Arena_Allocate(p_ws->p_arena, url_len + 1);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	110 strcpy(p_ws->url, url);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	111
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	112 Seobeo_WebSocket_Parse_Url(url, &p_ws->host, &p_ws->port, &p_ws->path, &p_ws->use_tls, p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	113
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	114 p_ws->p_handle = Seobeo_Stream_Handle_Client_Create(p_ws->host, p_ws->port, p_ws->use_tls);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	115 if (!p_ws->p_handle \|\| p_ws->p_handle->socket < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	116 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	117 Seobeo_Log(SEOBEO_ERROR, "Failed to create socket connection\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	118 if (p_ws->p_handle)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	119 Seobeo_Handle_Destroy(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	120 Dowa_Arena_Free(p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	121 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	122 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	123 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	124
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	125 char ws_key[32];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	126 Seobeo_WebSocket_Generate_Key(ws_key, sizeof(ws_key));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	127
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	128 char handshake[2048];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	129 int handshake_len = snprintf(handshake, sizeof(handshake),
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	130 "GET %s HTTP/1.1\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	131 "Host: %s\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	132 "Upgrade: websocket\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	133 "Connection: Upgrade\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	134 "Sec-WebSocket-Key: %s\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	135 "Sec-WebSocket-Version: 13\r\n"
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	136 "\r\n",
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	137 p_ws->path, p_ws->host, ws_key);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	138
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	139 Seobeo_Handle_Queue(p_ws->p_handle, (uint8*)handshake, (uint32)handshake_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	140 if (Seobeo_Handle_Flush(p_ws->p_handle) < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	141 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	142 Seobeo_Log(SEOBEO_ERROR, "Failed to send WebSocket handshake\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	143 Seobeo_Handle_Destroy(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	144 Dowa_Arena_Free(p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	145 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	146 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	147 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	148
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	149 while (1)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	150 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	151 int r = Seobeo_Handle_Read(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	152 if (r < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	153 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	154 Seobeo_Log(SEOBEO_ERROR, "Failed to read handshake response\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	155 Seobeo_Handle_Destroy(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	156 Dowa_Arena_Free(p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	157 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	158 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	159 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	160
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	161 if (p_ws->p_handle->read_buffer_len >= 4 &&
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	162 strstr((char*)p_ws->p_handle->read_buffer, "\r\n\r\n") != NULL)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	163 break;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	164
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	165 if (r == 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	166 continue;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	167 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	168
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	169 char response = (char)p_ws->p_handle->read_buffer;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	170 if (strstr(response, "HTTP/1.1 101") == NULL)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	171 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	172 Seobeo_Log(SEOBEO_ERROR, "WebSocket handshake failed: %s\n", response);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	173 Seobeo_Handle_Destroy(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	174 Dowa_Arena_Free(p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	175 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	176 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	177 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	178
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	179 char *end_of_headers = strstr(response, "\r\n\r\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	180 if (end_of_headers)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	181 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	182 size_t header_len = end_of_headers - response + 4;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	183 Seobeo_Handle_Consume(p_ws->p_handle, (uint32)header_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	184 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	185
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	186 p_ws->state = SEOBEO_WS_STATE_OPEN;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	187 p_ws->fragment_capacity = 4096;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	188 p_ws->fragment_buffer = malloc(p_ws->fragment_capacity);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	189
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	190 Seobeo_Log(SEOBEO_INFO, "WebSocket connected to %s\n", url);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	191
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	192 return p_ws;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	193 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	194
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	195 static void Seobeo_WebSocket_Mask_Data(uint8 data, size_t length, const uint8 mask)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	196 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	197 for (size_t i = 0; i < length; i++)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	198 data[i] ^= mask[i % 4];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	199 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	200
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	201 static int32 Seobeo_WebSocket_Send_Frame(Seobeo_WebSocket *p_ws, Seobeo_WebSocket_Opcode opcode,
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	202 const uint8 *payload, size_t payload_length, boolean fin)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	203 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	204 if (!p_ws \|\| p_ws->state != SEOBEO_WS_STATE_OPEN)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	205 return -1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	206
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	207 uint8 frame[14];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	208 size_t frame_len = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	209
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	210 // Big endian
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	211 frame[0] = (fin ? 0x80 : 0x00) \| (opcode & 0x0F);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	212 frame_len++;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	213
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	214 uint8 mask_key[4];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	215 for (int i = 0; i < 4; i++)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	216 mask_key[i] = (uint8)(rand() % 256);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	217
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	218 // within 1 byte
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	219 if (payload_length < 126)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	220 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	221 frame[1] = 0x80 \| (uint8)payload_length;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	222 frame_len++;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	223 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	224 // from now frame 1 is thrown away just keeping it 1
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	225 // within 4 bytes
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	226 else if (payload_length < MAX_INT_16)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	227 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	228 frame[1] = 0x80 \| 126;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	229 frame[2] = (uint8)((payload_length >> 8) & 0xFF);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	230 frame[3] = (uint8)(payload_length & 0xFF);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	231 frame_len += 3;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	232 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	233 // within 8 bytes
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	234 else
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	235 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	236 frame[1] = 0x80 \| 127;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	237 for (int i = 0; i < 8; i++)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	238 frame[2 + i] = (uint8)((payload_length >> (56 - i * 8)) & 0xFF);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	239 frame_len += 9;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	240 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	241
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	242 memcpy(frame + frame_len, mask_key, 4);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	243 frame_len += 4;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	244
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	245 Seobeo_Handle_Queue(p_ws->p_handle, frame, (uint32)frame_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	246
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	247 if (payload_length > 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	248 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	249 uint8 *masked_payload = malloc(payload_length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	250 memcpy(masked_payload, payload, payload_length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	251 Seobeo_WebSocket_Mask_Data(masked_payload, payload_length, mask_key);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	252 Seobeo_Handle_Queue(p_ws->p_handle, masked_payload, (uint32)payload_length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	253 free(masked_payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	254 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	255
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	256 return Seobeo_Handle_Flush(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	257 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	258
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	259 static int32 Seobeo_WebSocket_Send_Fragmented(Seobeo_WebSocket p_ws, Seobeo_WebSocket_Opcode opcode, const uint8 payload, size_t total_length)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	260 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	261 if (!payload \|\| total_length == 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	262 return -1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	263
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	264 const size_t max_fragment_size = 1024 * 1024;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	265
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	266 if (total_length <= max_fragment_size)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	267 return Seobeo_WebSocket_Send_Frame(p_ws, opcode, payload, total_length, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	268
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	269 size_t sent = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	270 int32 result;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	271
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	272 result = Seobeo_WebSocket_Send_Frame(p_ws, opcode, payload, max_fragment_size, FALSE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	273 if (result < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	274 return result;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	275
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	276 sent += max_fragment_size;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	277
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	278 while (sent + max_fragment_size < total_length)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	279 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	280 result = Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_CONTINUATION, payload + sent, max_fragment_size, FALSE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	281 if (result < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	282 return result;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	283 sent += max_fragment_size;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	284 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	285
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	286 size_t remaining = total_length - sent;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	287 return Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_CONTINUATION, payload + sent, remaining, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	288 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	289
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	290 int32 Seobeo_WebSocket_Send_Text(Seobeo_WebSocket p_ws, const char text)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	291 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	292 if (!text)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	293 return -1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	294
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	295 return Seobeo_WebSocket_Send_Fragmented(p_ws, SEOBEO_WS_OPCODE_TEXT, (const uint8*)text, strlen(text));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	296 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	297
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	298 int32 Seobeo_WebSocket_Send_Binary(Seobeo_WebSocket p_ws, const uint8 data, size_t length)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	299 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	300 if (!data)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	301 return -1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	302
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	303 return Seobeo_WebSocket_Send_Fragmented(p_ws, SEOBEO_WS_OPCODE_BINARY, data, length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	304 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	305
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	306 int32 Seobeo_WebSocket_Send_Ping(Seobeo_WebSocket p_ws, const char payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	307 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	308 size_t len = payload ? strlen(payload) : 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	309 return Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_PING, (const uint8*)payload, len, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	310 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	311
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	312 int32 Seobeo_WebSocket_Send_Pong(Seobeo_WebSocket p_ws, const char payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	313 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	314 size_t len = payload ? strlen(payload) : 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	315 return Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_PONG, (const uint8*)payload, len, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	316 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	317
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	318 Seobeo_WebSocket_Message Seobeo_WebSocket_Receive(Seobeo_WebSocket p_ws)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	319 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	320 if (!p_ws \|\| p_ws->state == SEOBEO_WS_STATE_CLOSED)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	321 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	322
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	323 int r = Seobeo_Handle_Read(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	324 if (r < 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	325 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	326 Seobeo_Log(SEOBEO_ERROR, "WebSocket read error\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	327 p_ws->state = SEOBEO_WS_STATE_CLOSED;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	328 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	329 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	330
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	331 if (r == -2)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	332 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	333 Seobeo_Log(SEOBEO_INFO, "WebSocket connection closed\n");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	334 p_ws->state = SEOBEO_WS_STATE_CLOSED;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	335 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	336 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	337
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	338 if (p_ws->p_handle->read_buffer_len < 2)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	339 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	340
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	341 uint8 *buf = p_ws->p_handle->read_buffer;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	342
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	343 uint8 byte1 = buf[0];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	344 uint8 byte2 = buf[1];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	345
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	346 boolean fin = (byte1 & 0x80) != 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	347 Seobeo_WebSocket_Opcode opcode = (Seobeo_WebSocket_Opcode)(byte1 & 0x0F);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	348 boolean masked = (byte2 & 0x80) != 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	349 uint64 payload_len = byte2 & 0x7F;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	350
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	351 size_t header_len = 2;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	352
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	353 if (payload_len == 126)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	354 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	355 if (p_ws->p_handle->read_buffer_len < 4)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	356 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	357 payload_len = (buf[2] << 8) \| buf[3];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	358 header_len += 2;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	359 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	360 else if (payload_len == 127)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	361 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	362 if (p_ws->p_handle->read_buffer_len < 10)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	363 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	364 payload_len = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	365 for (int i = 0; i < 8; i++)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	366 payload_len = (payload_len << 8) \| buf[2 + i];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	367 header_len += 8;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	368 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	369
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	370 uint8 mask_key[4] = {0};
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	371 if (masked)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	372 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	373 if (p_ws->p_handle->read_buffer_len < header_len + 4)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	374 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	375 memcpy(mask_key, buf + header_len, 4);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	376 header_len += 4;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	377 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	378
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	379 if (p_ws->p_handle->read_buffer_len < header_len + payload_len)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	380 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	381
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	382 uint8 *payload = NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	383 if (payload_len > 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	384 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	385 payload = malloc(payload_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	386 memcpy(payload, buf + header_len, payload_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	387
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	388 if (masked)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	389 Seobeo_WebSocket_Mask_Data(payload, payload_len, mask_key);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	390 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	391
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	392 Seobeo_Handle_Consume(p_ws->p_handle, (uint32)(header_len + payload_len));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	393
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	394 if (opcode == SEOBEO_WS_OPCODE_PING)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	395 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	396 Seobeo_WebSocket_Send_Pong(p_ws, (char*)payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	397 if (payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	398 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	399 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	400 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	401
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	402 if (opcode == SEOBEO_WS_OPCODE_PONG)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	403 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	404 if (payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	405 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	406 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	407 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	408
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	409 if (opcode == SEOBEO_WS_OPCODE_CLOSE)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	410 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	411 uint16 close_code = 1000;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	412 if (payload_len >= 2)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	413 close_code = (payload[0] << 8) \| payload[1];
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	414
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	415 Seobeo_Log(SEOBEO_INFO, "WebSocket close received with code %d\n", close_code);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	416 p_ws->state = SEOBEO_WS_STATE_CLOSING;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	417
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	418 Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_CLOSE, payload, payload_len, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	419 p_ws->state = SEOBEO_WS_STATE_CLOSED;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	420
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	421 if (payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	422 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	423 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	424 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	425
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	426 if (opcode == SEOBEO_WS_OPCODE_CONTINUATION)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	427 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	428 if (p_ws->fragment_length + payload_len > p_ws->fragment_capacity)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	429 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	430 p_ws->fragment_capacity = (p_ws->fragment_length + payload_len) * 2;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	431 p_ws->fragment_buffer = realloc(p_ws->fragment_buffer, p_ws->fragment_capacity);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	432 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	433
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	434 if (payload_len > 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	435 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	436 memcpy(p_ws->fragment_buffer + p_ws->fragment_length, payload, payload_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	437 p_ws->fragment_length += payload_len;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	438 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	439
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	440 if (payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	441 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	442
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	443 if (!fin)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	444 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	445
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	446 Seobeo_WebSocket_Message *p_msg = malloc(sizeof(Seobeo_WebSocket_Message));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	447 p_msg->opcode = p_ws->fragment_opcode;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	448 p_msg->data = malloc(p_ws->fragment_length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	449 memcpy(p_msg->data, p_ws->fragment_buffer, p_ws->fragment_length);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	450 p_msg->length = p_ws->fragment_length;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	451 p_msg->is_final = TRUE;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	452
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	453 p_ws->fragment_length = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	454
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	455 return p_msg;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	456 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	457
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	458 if (!fin)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	459 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	460 p_ws->fragment_opcode = opcode;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	461 p_ws->fragment_length = 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	462
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	463 if (payload_len > 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	464 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	465 if (payload_len > p_ws->fragment_capacity)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	466 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	467 p_ws->fragment_capacity = payload_len * 2;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	468 p_ws->fragment_buffer = realloc(p_ws->fragment_buffer, p_ws->fragment_capacity);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	469 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	470
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	471 memcpy(p_ws->fragment_buffer, payload, payload_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	472 p_ws->fragment_length = payload_len;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	473 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	474
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	475 if (payload)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	476 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	477
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	478 return NULL;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	479 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	480
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	481 Seobeo_WebSocket_Message *p_msg = malloc(sizeof(Seobeo_WebSocket_Message));
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	482 p_msg->opcode = opcode;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	483 p_msg->data = payload;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	484 p_msg->length = payload_len;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	485 p_msg->is_final = fin;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	486
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	487 return p_msg;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	488 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	489
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	490 void Seobeo_WebSocket_Message_Destroy(Seobeo_WebSocket_Message *p_msg)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	491 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	492 if (!p_msg)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	493 return;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	494
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	495 if (p_msg->data)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	496 free(p_msg->data);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	497
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	498 free(p_msg);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	499 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	500
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	501 int32 Seobeo_WebSocket_Close(Seobeo_WebSocket p_ws, uint16 code, const char reason)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	502 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	503 if (!p_ws \|\| p_ws->state == SEOBEO_WS_STATE_CLOSED)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	504 return -1;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	505
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	506 p_ws->state = SEOBEO_WS_STATE_CLOSING;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	507
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	508 size_t reason_len = reason ? strlen(reason) : 0;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	509 size_t payload_len = 2 + reason_len;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	510 uint8 *payload = malloc(payload_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	511
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	512 payload[0] = (uint8)((code >> 8) & 0xFF);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	513 payload[1] = (uint8)(code & 0xFF);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	514
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	515 if (reason_len > 0)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	516 memcpy(payload + 2, reason, reason_len);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	517
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	518 int32 result = Seobeo_WebSocket_Send_Frame(p_ws, SEOBEO_WS_OPCODE_CLOSE, payload, payload_len, TRUE);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	519
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	520 free(payload);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	521
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	522 p_ws->state = SEOBEO_WS_STATE_CLOSED;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	523
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	524 return result;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	525 }
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	526
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	527 void Seobeo_WebSocket_Destroy(Seobeo_WebSocket *p_ws)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	528 {
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	529 if (!p_ws)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	530 return;
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	531
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	532 if (p_ws->state == SEOBEO_WS_STATE_OPEN)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	533 Seobeo_WebSocket_Close(p_ws, 1000, "Normal closure");
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	534
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	535 if (p_ws->p_handle)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	536 Seobeo_Handle_Destroy(p_ws->p_handle);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	537
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	538 if (p_ws->fragment_buffer)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	539 free(p_ws->fragment_buffer);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	540
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	541 if (p_ws->p_arena)
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	542 Dowa_Arena_Free(p_ws->p_arena);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	543
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	544 free(p_ws);
cbbf78b17cfa [Seobeo][Websocket] Created Web socket client logic. June Park <parkjune1995@gmail.com> parents: diff changeset	545 }

Mercurial

annotate seobeo/s_websocket.c @ 120:cbbf78b17cfa