forked from cory/tildefriends
808 lines
31 KiB
C
808 lines
31 KiB
C
|
#include "socket.h"
|
||
|
#include "task.h"
|
||
|
#include "tls.h"
|
||
|
#include "tlscontextwrapper.h"
|
||
|
|
||
|
#include <assert.h>
|
||
|
#include <string.h>
|
||
|
#include <uv.h>
|
||
|
|
||
|
#include "quickjs-libc.h"
|
||
|
|
||
|
typedef int promiseid_t;
|
||
|
|
||
|
static JSClassID _classId;
|
||
|
static int _count;
|
||
|
static int _open_count;
|
||
|
static tf_tls_context_t* _defaultTlsContext;
|
||
|
|
||
|
typedef enum _socket_direction_t {
|
||
|
kUndetermined,
|
||
|
kAccept,
|
||
|
kConnect,
|
||
|
} socket_direction_t;
|
||
|
|
||
|
typedef struct _socket_t {
|
||
|
tf_task_t* _task;
|
||
|
uv_tcp_t _socket;
|
||
|
tf_tls_session_t* _tls;
|
||
|
promiseid_t _startTlsPromise;
|
||
|
promiseid_t _closePromise;
|
||
|
bool _connected;
|
||
|
bool _noDelay;
|
||
|
char _peerName[256];
|
||
|
socket_direction_t _direction;
|
||
|
JSValue _object;
|
||
|
JSValue _onConnect;
|
||
|
JSValue _onRead;
|
||
|
JSValue _onError;
|
||
|
} socket_t;
|
||
|
|
||
|
static JSValue _socket_create(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static void _socket_finalizer(JSRuntime *runtime, JSValue value);
|
||
|
|
||
|
static JSValue _socket_startTls(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_stopTls(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_bind(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_connect(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_listen(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_accept(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_close(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_shutdown(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_read(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_onError(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_write(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_isConnected(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_getPeerName(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_getPeerCertificate(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_getNoDelay(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
static JSValue _socket_setNoDelay(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv);
|
||
|
|
||
|
static void _socket_onClose(uv_handle_t* handle);
|
||
|
static void _socket_onShutdown(uv_shutdown_t* request, int status);
|
||
|
static void _socket_onResolvedForBind(uv_getaddrinfo_t* resolver, int status, struct addrinfo* result);
|
||
|
static void _socket_onResolvedForConnect(uv_getaddrinfo_t* resolver, int status, struct addrinfo* result);
|
||
|
static void _socket_onConnect(uv_connect_t* request, int status);
|
||
|
static void _socket_onNewConnection(uv_stream_t* server, int status);
|
||
|
static void _socket_allocateBuffer(uv_handle_t* handle, size_t suggestedSize, uv_buf_t* buffer);
|
||
|
static void _socket_onRead(uv_stream_t* stream, ssize_t readSize, const uv_buf_t* buffer);
|
||
|
static void _socket_onWrite(uv_write_t* request, int status);
|
||
|
static void _socket_onTlsShutdown(uv_write_t* request, int status);
|
||
|
|
||
|
static void _socket_notifyDataRead(socket_t* socket, const char* data, size_t length);
|
||
|
static int _socket_writeBytes(socket_t* socket, promiseid_t promise, int (*callback)(socket_t* socket, promiseid_t promise, const char*, size_t), JSValue value, int* outLength);
|
||
|
static int _socket_writeInternal(socket_t* socket, promiseid_t promise, const char* data, size_t length);
|
||
|
static void _socket_processTlsShutdown(socket_t* socket, promiseid_t promise);
|
||
|
static void _socket_shutdownInternal(socket_t* socket, promiseid_t promise);
|
||
|
static bool _socket_processSomeOutgoingTls(socket_t* socket, promiseid_t promise, uv_write_cb callback);
|
||
|
static void _socket_processOutgoingTls(socket_t* socket);
|
||
|
static void _socket_reportTlsErrors(socket_t* socket);
|
||
|
static void _socket_reportError(socket_t* socket, const char* error);
|
||
|
|
||
|
/*
|
||
|
class Socket {
|
||
|
private:
|
||
|
|
||
|
};
|
||
|
*/
|
||
|
|
||
|
JSValue tf_socket_init(JSContext* context) {
|
||
|
JS_NewClassID(&_classId);
|
||
|
JSClassDef def = {
|
||
|
.class_name = "Socket",
|
||
|
.finalizer = &_socket_finalizer,
|
||
|
};
|
||
|
if (JS_NewClass(JS_GetRuntime(context), _classId, &def) != 0) {
|
||
|
fprintf(stderr, "Failed to register Socket.\n");
|
||
|
}
|
||
|
return JS_NewCFunction2(context, _socket_create, "Socket", 0, JS_CFUNC_constructor, 0);
|
||
|
}
|
||
|
|
||
|
int tf_socket_get_count() {
|
||
|
return _count;
|
||
|
}
|
||
|
|
||
|
int tf_socket_get_open_count() {
|
||
|
return _open_count;
|
||
|
}
|
||
|
|
||
|
typedef struct _socket_resolve_data_t {
|
||
|
uv_getaddrinfo_t resolver;
|
||
|
socket_t* socket;
|
||
|
promiseid_t promise;
|
||
|
} socket_resolve_data_t;
|
||
|
|
||
|
socket_t* _socket_create_internal(JSContext* context) {
|
||
|
socket_t* socket = malloc(sizeof(socket_t));
|
||
|
memset(socket, 0, sizeof(*socket));
|
||
|
|
||
|
socket->_onRead = JS_UNDEFINED;
|
||
|
socket->_onError = JS_UNDEFINED;
|
||
|
socket->_onConnect = JS_UNDEFINED;
|
||
|
socket->_closePromise = -1;
|
||
|
socket->_startTlsPromise = -1;
|
||
|
|
||
|
++_count;
|
||
|
JSValue object = JS_NewObjectClass(context, _classId);
|
||
|
socket->_task = tf_task_get(context);
|
||
|
socket->_object = object;
|
||
|
JS_SetOpaque(object, socket);
|
||
|
|
||
|
JS_SetPropertyStr(context, object, "bind", JS_NewCFunction(context, _socket_bind, "bind", 2));
|
||
|
JS_SetPropertyStr(context, object, "connect", JS_NewCFunction(context, _socket_connect, "connect", 2));
|
||
|
JS_SetPropertyStr(context, object, "listen", JS_NewCFunction(context, _socket_listen, "listen", 2));
|
||
|
JS_SetPropertyStr(context, object, "accept", JS_NewCFunction(context, _socket_accept, "accept", 0));
|
||
|
JS_SetPropertyStr(context, object, "startTls", JS_NewCFunction(context, _socket_startTls, "startTls", 0));
|
||
|
JS_SetPropertyStr(context, object, "stopTls", JS_NewCFunction(context, _socket_stopTls, "stopTls", 0));
|
||
|
JS_SetPropertyStr(context, object, "shutdown", JS_NewCFunction(context, _socket_shutdown, "shutdown", 0));
|
||
|
JS_SetPropertyStr(context, object, "close", JS_NewCFunction(context, _socket_close, "close", 0));
|
||
|
JS_SetPropertyStr(context, object, "read", JS_NewCFunction(context, _socket_read, "read", 0));
|
||
|
JS_SetPropertyStr(context, object, "onError", JS_NewCFunction(context, _socket_onError, "onError", 1));
|
||
|
JS_SetPropertyStr(context, object, "write", JS_NewCFunction(context, _socket_write, "write", 1));
|
||
|
|
||
|
JSAtom atom = JS_NewAtom(context, "isConnected");
|
||
|
JS_DefinePropertyGetSet(context, object, atom, JS_NewCFunction(context, _socket_isConnected, "isConnected", 0), JS_NULL, 0);
|
||
|
JS_FreeAtom(context, atom);
|
||
|
|
||
|
atom = JS_NewAtom(context, "peerName");
|
||
|
JS_DefinePropertyGetSet(context, object, atom, JS_NewCFunction(context, _socket_getPeerName, "peerName", 0), JS_NULL, 0);
|
||
|
JS_FreeAtom(context, atom);
|
||
|
|
||
|
atom = JS_NewAtom(context, "peerCertificate");
|
||
|
JS_DefinePropertyGetSet(context, object, atom, JS_NewCFunction(context, _socket_getPeerCertificate, "peerCertificate", 0), JS_NULL, 0);
|
||
|
JS_FreeAtom(context, atom);
|
||
|
|
||
|
atom = JS_NewAtom(context, "noDelay");
|
||
|
JSValue get_no_delay = JS_NewCFunction(context, _socket_getNoDelay, "getNoDelay", 0);
|
||
|
JSValue set_no_delay = JS_NewCFunction(context, _socket_setNoDelay, "setNoDelay", 1);
|
||
|
JS_DefinePropertyGetSet(context, object, atom, get_no_delay, set_no_delay, 0);
|
||
|
JS_FreeAtom(context, atom);
|
||
|
|
||
|
++_open_count;
|
||
|
uv_tcp_init(tf_task_get_loop(socket->_task), &socket->_socket);
|
||
|
socket->_socket.data = socket;
|
||
|
|
||
|
return socket;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_create(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
return _socket_create_internal(context)->_object;
|
||
|
}
|
||
|
|
||
|
void _socket_finalizer(JSRuntime *runtime, JSValue value) {
|
||
|
socket_t* socket = JS_GetOpaque(value, _classId);
|
||
|
--_count;
|
||
|
free(socket);
|
||
|
}
|
||
|
|
||
|
void _socket_close_internal(socket_t* socket) {
|
||
|
if (!uv_is_closing((uv_handle_t*)&socket->_socket)) {
|
||
|
JS_FreeValue(tf_task_get_context(socket->_task), socket->_onRead);
|
||
|
socket->_onRead = JS_UNDEFINED;
|
||
|
JS_FreeValue(tf_task_get_context(socket->_task), socket->_onError);
|
||
|
socket->_onError = JS_UNDEFINED;
|
||
|
if (socket->_tls) {
|
||
|
tf_tls_session_destroy(socket->_tls);
|
||
|
socket->_tls = NULL;
|
||
|
}
|
||
|
uv_close((uv_handle_t*)&socket->_socket, _socket_onClose);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_reportError(socket_t* socket, const char* error) {
|
||
|
if (JS_IsFunction(tf_task_get_context(socket->_task),socket-> _onError)) {
|
||
|
JSValue exception = JS_ThrowInternalError(tf_task_get_context(socket->_task), "%s", error);
|
||
|
JSValue result = JS_Call(tf_task_get_context(socket->_task), socket->_onError, socket->_object, 1, &exception);
|
||
|
if (JS_IsException(result)) {
|
||
|
printf("Socket error.\n");
|
||
|
js_std_dump_error(tf_task_get_context(socket->_task));
|
||
|
}
|
||
|
tf_task_run_jobs(socket->_task);
|
||
|
JS_FreeValue(tf_task_get_context(socket->_task), exception);
|
||
|
} else {
|
||
|
fprintf(stderr, "Socket::reportError: %s\n", error);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_reportTlsErrors(socket_t* socket) {
|
||
|
char buffer[4096];
|
||
|
while (socket->_tls && tf_tls_session_get_error(socket->_tls, buffer, sizeof(buffer))) {
|
||
|
_socket_reportError(socket, buffer);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
JSValue _socket_startTls(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
if (!socket->_tls) {
|
||
|
tf_tls_context_t* context = 0;
|
||
|
|
||
|
if (argc > 0 && JS_IsObject(argv[0])) {
|
||
|
context = tf_tls_context_wrapper_get(argv[0]);
|
||
|
} else {
|
||
|
if (!_defaultTlsContext) {
|
||
|
_defaultTlsContext = tf_tls_context_create();
|
||
|
}
|
||
|
context = _defaultTlsContext;
|
||
|
}
|
||
|
|
||
|
if (context) {
|
||
|
socket->_tls = tf_tls_context_create_session(context);
|
||
|
}
|
||
|
|
||
|
if (socket->_tls) {
|
||
|
tf_tls_session_set_hostname(socket->_tls, socket->_peerName);
|
||
|
if (socket->_direction == kAccept) {
|
||
|
tf_tls_session_start_accept(socket->_tls);
|
||
|
} else if (socket->_direction == kConnect) {
|
||
|
tf_tls_session_start_connect(socket->_tls);
|
||
|
}
|
||
|
socket->_startTlsPromise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue result = tf_task_get_promise(socket->_task, socket->_startTlsPromise);
|
||
|
_socket_processOutgoingTls(socket);
|
||
|
return result;
|
||
|
} else {
|
||
|
return JS_ThrowInternalError(tf_task_get_context(socket->_task), "Failed to get TLS context");
|
||
|
}
|
||
|
} else {
|
||
|
return JS_ThrowInternalError(tf_task_get_context(socket->_task), "startTls with TLS already started");
|
||
|
}
|
||
|
}
|
||
|
|
||
|
JSValue _socket_stopTls(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
if (socket->_tls) {
|
||
|
_socket_processOutgoingTls(socket);
|
||
|
tf_tls_session_destroy(socket->_tls);
|
||
|
socket->_tls = NULL;
|
||
|
} else {
|
||
|
JS_ThrowInternalError(tf_task_get_context(socket->_task), "stopTls with TLS already stopped");
|
||
|
}
|
||
|
return JS_NULL;
|
||
|
}
|
||
|
|
||
|
bool _socket_processSomeOutgoingTls(socket_t* socket, promiseid_t promise, uv_write_cb callback) {
|
||
|
char buffer[65536];
|
||
|
int result = tf_tls_session_read_encrypted(socket->_tls, buffer, sizeof(buffer));
|
||
|
if (result > 0) {
|
||
|
char* request_buffer = malloc(sizeof(uv_write_t) + result);
|
||
|
uv_write_t* request = (uv_write_t*)request_buffer;
|
||
|
memset(request, 0, sizeof(*request));
|
||
|
request->data = (void*)(intptr_t)(promise);
|
||
|
char* rawBuffer = request_buffer + sizeof(uv_write_t);
|
||
|
memcpy(rawBuffer, buffer, result);
|
||
|
|
||
|
uv_buf_t writeBuffer =
|
||
|
{
|
||
|
.base = rawBuffer,
|
||
|
.len = result,
|
||
|
};
|
||
|
|
||
|
int writeResult = uv_write(request, (uv_stream_t*)&socket->_socket, &writeBuffer, 1, callback);
|
||
|
if (writeResult != 0) {
|
||
|
free(request_buffer);
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_write: %s", uv_strerror(writeResult));
|
||
|
_socket_reportError(socket, error);
|
||
|
}
|
||
|
} else {
|
||
|
_socket_reportTlsErrors(socket);
|
||
|
}
|
||
|
return result > 0;
|
||
|
}
|
||
|
|
||
|
void _socket_processOutgoingTls(socket_t* socket) {
|
||
|
while (_socket_processSomeOutgoingTls(socket, -1, _socket_onWrite)) {}
|
||
|
}
|
||
|
|
||
|
JSValue _socket_bind(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
const char* node = JS_ToCString(tf_task_get_context(socket->_task), argv[0]);
|
||
|
const char* port = JS_ToCString(tf_task_get_context(socket->_task), argv[1]);
|
||
|
|
||
|
socket_resolve_data_t* data = malloc(sizeof(socket_resolve_data_t));
|
||
|
memset(data, 0, sizeof(*data));
|
||
|
struct addrinfo hints = {
|
||
|
.ai_family = PF_INET,
|
||
|
.ai_socktype = SOCK_STREAM,
|
||
|
.ai_protocol = IPPROTO_TCP,
|
||
|
.ai_flags = 0,
|
||
|
};
|
||
|
data->resolver.data = data;
|
||
|
data->socket = socket;
|
||
|
data->promise = tf_task_allocate_promise(socket->_task);
|
||
|
|
||
|
int result = uv_getaddrinfo(tf_task_get_loop(socket->_task), &data->resolver, _socket_onResolvedForBind, node, port, &hints);
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_getaddrinfo: %s", uv_strerror(result));
|
||
|
tf_task_reject_promise(socket->_task, data->promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), error));
|
||
|
free(data);
|
||
|
}
|
||
|
return tf_task_get_promise(socket->_task, data->promise);
|
||
|
}
|
||
|
|
||
|
void _socket_onResolvedForBind(uv_getaddrinfo_t* resolver, int status, struct addrinfo* result) {
|
||
|
socket_resolve_data_t* data = (socket_resolve_data_t*)resolver->data;
|
||
|
if (status != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_getaddrinfo: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(data->socket->_task, data->promise, JS_ThrowInternalError(tf_task_get_context(data->socket->_task), error));
|
||
|
} else {
|
||
|
int bindResult = uv_tcp_bind(&data->socket->_socket, result->ai_addr, 0);
|
||
|
if (bindResult != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_tcp_bind: %s", uv_strerror(bindResult));
|
||
|
tf_task_reject_promise(data->socket->_task, data->promise, JS_ThrowInternalError(tf_task_get_context(data->socket->_task), error));
|
||
|
} else {
|
||
|
tf_task_resolve_promise(data->socket->_task, data->promise, JS_UNDEFINED);
|
||
|
}
|
||
|
}
|
||
|
free(data);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_connect(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
socket->_direction = kConnect;
|
||
|
const char* node = JS_ToCString(context, argv[0]);
|
||
|
const char* port = JS_ToCString(context, argv[1]);
|
||
|
|
||
|
strncpy(socket->_peerName, node, sizeof(socket->_peerName) - 1);
|
||
|
|
||
|
promiseid_t promise = tf_task_allocate_promise(socket->_task);
|
||
|
|
||
|
socket_resolve_data_t* data = malloc(sizeof(socket_resolve_data_t));
|
||
|
memset(data, 0, sizeof(*data));
|
||
|
struct addrinfo hints = {
|
||
|
.ai_family = PF_INET,
|
||
|
.ai_socktype = SOCK_STREAM,
|
||
|
.ai_protocol = IPPROTO_TCP,
|
||
|
};
|
||
|
data->resolver.data = data;
|
||
|
data->socket = socket;
|
||
|
data->promise = promise;
|
||
|
|
||
|
int result = uv_getaddrinfo(tf_task_get_loop(socket->_task), &data->resolver, _socket_onResolvedForConnect, node, port, &hints);
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_getaddrinfo: %s", uv_strerror(result));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(context, "%s", error));
|
||
|
free(data);
|
||
|
}
|
||
|
|
||
|
JS_FreeCString(context, node);
|
||
|
JS_FreeCString(context, port);
|
||
|
return tf_task_get_promise(socket->_task, promise);
|
||
|
}
|
||
|
|
||
|
void _socket_onResolvedForConnect(uv_getaddrinfo_t* resolver, int status, struct addrinfo* result) {
|
||
|
socket_resolve_data_t* data = resolver->data;
|
||
|
if (status != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_getaddrinfo: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(data->socket->_task, data->promise, JS_ThrowInternalError(tf_task_get_context(data->socket->_task), "%s", error));
|
||
|
} else {
|
||
|
uv_connect_t* request = malloc(sizeof(uv_connect_t));
|
||
|
memset(request, 0, sizeof(*request));
|
||
|
request->data = (void*)(intptr_t)data->promise;
|
||
|
int connectResult = uv_tcp_connect(request, &data->socket->_socket, result->ai_addr, _socket_onConnect);
|
||
|
if (connectResult != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_tcp_connect: %s", uv_strerror(connectResult));
|
||
|
tf_task_reject_promise(data->socket->_task, data->promise, JS_ThrowInternalError(tf_task_get_context(data->socket->_task), "%s", error));
|
||
|
}
|
||
|
}
|
||
|
uv_freeaddrinfo(result);
|
||
|
free(data);
|
||
|
}
|
||
|
|
||
|
void _socket_onConnect(uv_connect_t* request, int status) {
|
||
|
promiseid_t promise = (intptr_t)request->data;
|
||
|
if (promise != -1) {
|
||
|
socket_t* socket = request->handle->data;
|
||
|
if (status == 0) {
|
||
|
socket->_connected = true;
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_NewInt32(tf_task_get_context(socket->_task), status));
|
||
|
} else {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_tcp_connect: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), "%s", error));
|
||
|
}
|
||
|
}
|
||
|
free(request);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_listen(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
int backlog = 1;
|
||
|
JS_ToInt32(context, &backlog, argv[0]);
|
||
|
if (JS_IsUndefined(socket->_onConnect)) {
|
||
|
socket->_onConnect = JS_DupValue(context, argv[1]);
|
||
|
int result = uv_listen((uv_stream_t*)&socket->_socket, backlog, _socket_onNewConnection);
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_listen: %s", uv_strerror(result));
|
||
|
return JS_ThrowInternalError(context, error);
|
||
|
}
|
||
|
return JS_NewInt32(context, result);
|
||
|
} else {
|
||
|
return JS_ThrowInternalError(context, "listen: Already listening.");
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_onNewConnection(uv_stream_t* server, int status) {
|
||
|
socket_t* socket = server->data;
|
||
|
if (!JS_IsUndefined(socket->_onConnect)) {
|
||
|
JSValue result = JS_Call(tf_task_get_context(socket->_task), socket->_onConnect, socket->_object, 0, NULL);
|
||
|
if (JS_IsException(result)) {
|
||
|
printf("Socket error on connection.\n");
|
||
|
js_std_dump_error(tf_task_get_context(socket->_task));
|
||
|
}
|
||
|
tf_task_run_jobs(socket->_task);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
JSValue _socket_accept(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
|
||
|
socket_t* client = _socket_create_internal(context);
|
||
|
client->_direction = kAccept;
|
||
|
promiseid_t promise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue result = tf_task_get_promise(socket->_task, promise);
|
||
|
int status = uv_accept((uv_stream_t*)&socket->_socket, (uv_stream_t*)&client->_socket);
|
||
|
if (status == 0) {
|
||
|
client->_connected = true;
|
||
|
tf_task_resolve_promise(socket->_task, promise, client->_object);
|
||
|
} else {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_accept: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(context, error));
|
||
|
}
|
||
|
return result;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_close(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
if (socket->_closePromise == -1) {
|
||
|
socket->_closePromise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue result = tf_task_get_promise(socket->_task, socket->_closePromise);
|
||
|
_socket_close_internal(socket);
|
||
|
return result;
|
||
|
}
|
||
|
return JS_UNDEFINED;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_shutdown(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
promiseid_t promise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue result = tf_task_get_promise(socket->_task, promise);
|
||
|
if (socket->_tls) {
|
||
|
_socket_processTlsShutdown(socket, promise);
|
||
|
} else {
|
||
|
_socket_shutdownInternal(socket, promise);
|
||
|
}
|
||
|
return result;
|
||
|
}
|
||
|
|
||
|
void _socket_shutdownInternal(socket_t* socket, promiseid_t promise) {
|
||
|
uv_shutdown_t* request = malloc(sizeof(uv_shutdown_t));
|
||
|
memset(request, 0, sizeof(*request));
|
||
|
request->data = (void*)(intptr_t)promise;
|
||
|
int result = uv_shutdown(request, (uv_stream_t*)&socket->_socket, _socket_onShutdown);
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_shutdown: %s", uv_strerror(result));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), "%s", error));
|
||
|
free(request);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_processTlsShutdown(socket_t* socket, promiseid_t promise) {
|
||
|
tf_tls_session_shutdown(socket->_tls);
|
||
|
if (!_socket_processSomeOutgoingTls(socket, promise, _socket_onTlsShutdown)) {
|
||
|
_socket_shutdownInternal(socket, promise);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_onTlsShutdown(uv_write_t* request, int status) {
|
||
|
socket_t* socket = request->handle->data;
|
||
|
promiseid_t promise = (intptr_t)request->data;
|
||
|
_socket_processTlsShutdown(socket, promise);
|
||
|
free(request);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_onError(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
if (!JS_IsUndefined(socket->_onError)) {
|
||
|
JS_FreeValue(context, socket->_onError);
|
||
|
socket->_onError = JS_UNDEFINED;
|
||
|
}
|
||
|
socket->_onError = JS_DupValue(context, argv[0]);
|
||
|
return JS_NULL;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_read(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
socket->_onRead = JS_DupValue(context, argv[0]);
|
||
|
int result = uv_read_start((uv_stream_t*)&socket->_socket, _socket_allocateBuffer, _socket_onRead);
|
||
|
promiseid_t promise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue read_result = tf_task_get_promise(socket->_task, promise);
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_read_start: %s", uv_strerror(result));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(context, error));
|
||
|
} else {
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_UNDEFINED);
|
||
|
}
|
||
|
return read_result;
|
||
|
}
|
||
|
|
||
|
void _socket_allocateBuffer(uv_handle_t* handle, size_t suggestedSize, uv_buf_t* buf) {
|
||
|
*buf = uv_buf_init(malloc(suggestedSize), suggestedSize);
|
||
|
}
|
||
|
|
||
|
void _socket_onRead(uv_stream_t* stream, ssize_t readSize, const uv_buf_t* buffer) {
|
||
|
socket_t* socket = stream->data;
|
||
|
if (readSize <= 0) {
|
||
|
socket->_connected = false;
|
||
|
if (!JS_IsUndefined(socket->_onRead)) {
|
||
|
JSValue args[] = { JS_UNDEFINED };
|
||
|
JSValue result = JS_Call(tf_task_get_context(socket->_task), socket->_onRead, socket->_object, 1, args);
|
||
|
if (JS_IsException(result)) {
|
||
|
printf("Socket error on read.\n");
|
||
|
js_std_dump_error(tf_task_get_context(socket->_task));
|
||
|
}
|
||
|
tf_task_run_jobs(socket->_task);
|
||
|
}
|
||
|
_socket_close_internal(socket);
|
||
|
} else {
|
||
|
if (socket->_tls) {
|
||
|
_socket_reportTlsErrors(socket);
|
||
|
tf_tls_session_write_encrypted(socket->_tls, buffer->base, readSize);
|
||
|
if (socket->_startTlsPromise != -1) {
|
||
|
tf_tls_handshake_t result = tf_tls_session_handshake(socket->_tls);
|
||
|
if (result == k_tls_handshake_done) {
|
||
|
promiseid_t promise = socket->_startTlsPromise;
|
||
|
socket->_startTlsPromise = -1;
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_UNDEFINED);
|
||
|
} else if (result == k_tls_handshake_failed) {
|
||
|
promiseid_t promise = socket->_startTlsPromise;
|
||
|
socket->_startTlsPromise = -1;
|
||
|
char buffer[8192];
|
||
|
if (tf_tls_session_get_error(socket->_tls, buffer, sizeof(buffer))) {
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), buffer));
|
||
|
} else {
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_UNDEFINED);
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
while (true) {
|
||
|
char plain[8192];
|
||
|
int result = tf_tls_session_read_plain(socket->_tls, plain, sizeof(plain));
|
||
|
if (result > 0) {
|
||
|
_socket_notifyDataRead(socket, plain, result);
|
||
|
} else if (result == k_tls_read_failed) {
|
||
|
_socket_reportTlsErrors(socket);
|
||
|
_socket_close_internal(socket);
|
||
|
break;
|
||
|
} else if (result == k_tls_read_zero) {
|
||
|
if (!JS_IsUndefined(socket->_onRead)) {
|
||
|
JSValue args[] = { JS_UNDEFINED };
|
||
|
JSValue result = JS_Call(tf_task_get_context(socket->_task), socket->_onRead, socket->_object, 1, args);
|
||
|
if (JS_IsException(result)) {
|
||
|
printf("Socket error on read plain.\n");
|
||
|
js_std_dump_error(tf_task_get_context(socket->_task));
|
||
|
}
|
||
|
tf_task_run_jobs(socket->_task);
|
||
|
}
|
||
|
break;
|
||
|
} else {
|
||
|
break;
|
||
|
}
|
||
|
}
|
||
|
if (socket->_tls) {
|
||
|
_socket_processOutgoingTls(socket);
|
||
|
}
|
||
|
} else {
|
||
|
_socket_notifyDataRead(socket, buffer->base, readSize);
|
||
|
}
|
||
|
}
|
||
|
free(buffer->base);
|
||
|
}
|
||
|
|
||
|
static JSValue _newUint8Array(JSContext* context, const void* data, size_t length) {
|
||
|
JSValue arrayBuffer = JS_NewArrayBufferCopy(context, (const uint8_t*)data, length);
|
||
|
JSValue global = JS_GetGlobalObject(context);
|
||
|
JSValue constructor = JS_GetPropertyStr(context, global, "Uint8Array");
|
||
|
JSValue typedArray = JS_CallConstructor(context, constructor, 1, &arrayBuffer);
|
||
|
JS_FreeValue(context, constructor);
|
||
|
JS_FreeValue(context, global);
|
||
|
JS_FreeValue(context, arrayBuffer);
|
||
|
return typedArray;
|
||
|
}
|
||
|
|
||
|
void _socket_notifyDataRead(socket_t* socket, const char* data, size_t length) {
|
||
|
if (!JS_IsUndefined(socket->_onRead)) {
|
||
|
if (data && length > 0) {
|
||
|
JSValue typedArray = _newUint8Array(tf_task_get_context(socket->_task), data, length);
|
||
|
JSValue args[] = { typedArray };
|
||
|
JSValue result = JS_Call(tf_task_get_context(socket->_task), socket->_onRead, socket->_object, 1, args);
|
||
|
if (JS_IsException(result)) {
|
||
|
printf("Socket error on data read.\n");
|
||
|
js_std_dump_error(tf_task_get_context(socket->_task));
|
||
|
}
|
||
|
tf_task_run_jobs(socket->_task);
|
||
|
JS_FreeValue(tf_task_get_context(socket->_task), typedArray);
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
int _socket_writeBytes(socket_t* socket, promiseid_t promise, int (*callback)(socket_t* socket, promiseid_t promise, const char*, size_t), JSValue value, int* outLength) {
|
||
|
int result = -1;
|
||
|
size_t length;
|
||
|
uint8_t* array = NULL;
|
||
|
JSContext* context = tf_task_get_context(socket->_task);
|
||
|
if (JS_IsString(value)) {
|
||
|
const char* stringValue = JS_ToCStringLen(context, &length, value);
|
||
|
result = callback(socket, promise, stringValue, length);
|
||
|
JS_FreeCString(context, stringValue);
|
||
|
} else if ((array = tf_try_get_array_buffer(context, &length, value)) != 0) {
|
||
|
result = callback(socket, promise, (const char*)array, length);
|
||
|
} else {
|
||
|
size_t offset;
|
||
|
size_t element_size;
|
||
|
JSValue buffer = tf_try_get_typed_array_buffer(context, value, &offset, &length, &element_size);
|
||
|
size_t size;
|
||
|
if ((array = tf_try_get_array_buffer(context, &size, buffer)) != 0) {
|
||
|
result = callback(socket, promise, (const char*)array, length);
|
||
|
}
|
||
|
JS_FreeValue(context, buffer);
|
||
|
}
|
||
|
|
||
|
if (outLength) {
|
||
|
*outLength = (int)length;
|
||
|
}
|
||
|
|
||
|
return result;
|
||
|
}
|
||
|
|
||
|
int _socket_writeInternal(socket_t* socket, promiseid_t promise, const char* data, size_t length) {
|
||
|
char* rawBuffer = malloc(sizeof(uv_write_t) + length);
|
||
|
uv_write_t* request = (uv_write_t*)rawBuffer;
|
||
|
memcpy(rawBuffer + sizeof(uv_write_t), data, length);
|
||
|
|
||
|
uv_buf_t buffer = {
|
||
|
.base = rawBuffer + sizeof(uv_write_t),
|
||
|
.len = length,
|
||
|
};
|
||
|
|
||
|
request->data = (void*)(intptr_t)promise;
|
||
|
return uv_write(request, (uv_stream_t*)&socket->_socket, &buffer, 1, _socket_onWrite);
|
||
|
}
|
||
|
|
||
|
static int _socket_write_tls(socket_t* socket, promiseid_t promise, const char* data, size_t size) {
|
||
|
return tf_tls_session_write_plain(socket->_tls, data, size);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_write(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
promiseid_t promise = tf_task_allocate_promise(socket->_task);
|
||
|
JSValue write_result = tf_task_get_promise(socket->_task, promise);
|
||
|
if (!JS_IsUndefined(argv[0])) {
|
||
|
if (socket->_tls) {
|
||
|
_socket_reportTlsErrors(socket);
|
||
|
int length = 0;
|
||
|
int result = _socket_writeBytes(socket, -1, _socket_write_tls, argv[0], &length);
|
||
|
char buffer[8192];
|
||
|
if (result <= 0 && tf_tls_session_get_error(socket->_tls, buffer, sizeof(buffer))) {
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(context, buffer));
|
||
|
} else if (result < length) {
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_NewInt32(context, result));
|
||
|
} else {
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_NewInt32(context, result));
|
||
|
}
|
||
|
_socket_processOutgoingTls(socket);
|
||
|
} else {
|
||
|
int length;
|
||
|
int result = _socket_writeBytes(socket, promise, _socket_writeInternal, argv[0], &length);
|
||
|
|
||
|
if (result != 0) {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_write: %s", uv_strerror(result));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(context, error));
|
||
|
}
|
||
|
}
|
||
|
} else {
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_NewInt32(context, -2));
|
||
|
}
|
||
|
return write_result;
|
||
|
}
|
||
|
|
||
|
void _socket_onWrite(uv_write_t* request, int status) {
|
||
|
socket_t* socket = request->handle->data;
|
||
|
promiseid_t promise = (intptr_t)request->data;
|
||
|
if (promise != -1) {
|
||
|
if (status == 0) {
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_NewInt32(tf_task_get_context(socket->_task), status));
|
||
|
} else {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_write: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), error));
|
||
|
}
|
||
|
}
|
||
|
free(request);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_isConnected(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
return socket->_connected ? JS_TRUE : JS_FALSE;
|
||
|
}
|
||
|
|
||
|
void _socket_onClose(uv_handle_t* handle) {
|
||
|
--_open_count;
|
||
|
socket_t* socket = handle->data;
|
||
|
if (socket->_closePromise != -1) {
|
||
|
promiseid_t promise = socket->_closePromise;
|
||
|
socket->_closePromise = -1;
|
||
|
socket->_connected = false;
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_UNDEFINED);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void _socket_onShutdown(uv_shutdown_t* request, int status) {
|
||
|
socket_t* socket = request->handle->data;
|
||
|
promiseid_t promise = (intptr_t)request->data;
|
||
|
if (status == 0) {
|
||
|
tf_task_resolve_promise(socket->_task, promise, JS_UNDEFINED);
|
||
|
} else {
|
||
|
char error[256];
|
||
|
snprintf(error, sizeof(error), "uv_shutdown: %s", uv_strerror(status));
|
||
|
tf_task_reject_promise(socket->_task, promise, JS_ThrowInternalError(tf_task_get_context(socket->_task), "%s", error));
|
||
|
}
|
||
|
free(request);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_getPeerName(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
struct sockaddr_in6 addr;
|
||
|
int nameLength = sizeof(addr);
|
||
|
if (uv_tcp_getpeername(&socket->_socket, (struct sockaddr*)&addr, &nameLength) == 0) {
|
||
|
char name[1024];
|
||
|
if ((size_t)nameLength > sizeof(struct sockaddr_in)) {
|
||
|
if (uv_ip6_name(&addr, name, sizeof(name)) == 0) {
|
||
|
return JS_NewString(context, name);
|
||
|
}
|
||
|
} else {
|
||
|
if (uv_ip4_name((struct sockaddr_in*)&addr, name, sizeof(name)) == 0) {
|
||
|
return JS_NewString(context, name);
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
return JS_UNDEFINED;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_getPeerCertificate(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
if (socket->_tls) {
|
||
|
char buffer[128 * 1024];
|
||
|
int result = tf_tls_session_get_peer_certificate(socket->_tls, buffer, sizeof(buffer));
|
||
|
if (result > 0) {
|
||
|
return _newUint8Array(tf_task_get_context(socket->_task), buffer, sizeof(buffer));
|
||
|
}
|
||
|
}
|
||
|
return JS_UNDEFINED;
|
||
|
}
|
||
|
|
||
|
JSValue _socket_getNoDelay(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
return JS_NewBool(context, socket->_noDelay);
|
||
|
}
|
||
|
|
||
|
JSValue _socket_setNoDelay(JSContext* context, JSValueConst this_val, int argc, JSValueConst* argv) {
|
||
|
socket_t* socket = JS_GetOpaque(this_val, _classId);
|
||
|
int result = JS_ToBool(context, argv[0]);
|
||
|
socket->_noDelay = result > 0;
|
||
|
uv_tcp_nodelay(&socket->_socket, result > 0 ? 1 : 0);
|
||
|
return JS_UNDEFINED;
|
||
|
}
|