You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
3.0 KiB
108 lines
3.0 KiB
#include "webfuse/adapter/impl/session.h"
|
|
#include "webfuse/adapter/impl/authenticators.h"
|
|
#include "webfuse/core/message_queue.h"
|
|
#include "webfuse/core/message.h"
|
|
#include "webfuse/adapter/impl/jsonrpc/proxy.h"
|
|
#include "webfuse/adapter/impl/jsonrpc/request.h"
|
|
#include "webfuse/adapter/impl/jsonrpc/response.h"
|
|
|
|
#include <libwebsockets.h>
|
|
#include <stddef.h>
|
|
|
|
static bool wf_impl_session_send(
|
|
json_t * request,
|
|
void * user_data)
|
|
{
|
|
struct wf_impl_session * session = user_data;
|
|
struct wf_message * message = wf_message_create(request);
|
|
|
|
bool result = (session->is_authenticated || wf_impl_jsonrpc_is_response(request)) && (NULL != session->wsi);
|
|
|
|
if (result)
|
|
{
|
|
wf_message_queue_push(&session->queue, message);
|
|
lws_callback_on_writable(session->wsi);
|
|
|
|
result = true;
|
|
}
|
|
else
|
|
{
|
|
wf_message_dispose(message);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
void wf_impl_session_init(
|
|
struct wf_impl_session * session,
|
|
struct lws * wsi,
|
|
struct wf_impl_authenticators * authenticators,
|
|
struct wf_impl_timeout_manager * timeout_manager,
|
|
struct wf_impl_jsonrpc_server * server)
|
|
{
|
|
session->wsi = wsi;
|
|
session->is_authenticated = false;
|
|
session->authenticators = authenticators;
|
|
session->server = server;
|
|
wf_impl_jsonrpc_proxy_init(&session->rpc, timeout_manager, &wf_impl_session_send, session);
|
|
wf_message_queue_init(&session->queue);
|
|
}
|
|
|
|
void wf_impl_session_cleanup(
|
|
struct wf_impl_session * session)
|
|
{
|
|
wf_impl_jsonrpc_proxy_cleanup(&session->rpc);
|
|
wf_message_queue_cleanup(&session->queue);
|
|
session->is_authenticated = false;
|
|
session->wsi = NULL;
|
|
session->authenticators = NULL;
|
|
session->server = NULL;
|
|
}
|
|
|
|
bool wf_impl_session_authenticate(
|
|
struct wf_impl_session * session,
|
|
struct wf_credentials * creds)
|
|
{
|
|
session->is_authenticated = wf_impl_authenticators_authenticate(session->authenticators, creds);
|
|
|
|
return session->is_authenticated;
|
|
}
|
|
|
|
void wf_impl_session_onwritable(
|
|
struct wf_impl_session * session)
|
|
{
|
|
if (!wf_message_queue_empty(&session->queue))
|
|
{
|
|
struct wf_message * message = wf_message_queue_pop(&session->queue);
|
|
lws_write(session->wsi, (unsigned char*) message->data, message->length, LWS_WRITE_TEXT);
|
|
wf_message_dispose(message);
|
|
|
|
if (!wf_message_queue_empty(&session->queue))
|
|
{
|
|
lws_callback_on_writable(session->wsi);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
void wf_impl_session_receive(
|
|
struct wf_impl_session * session,
|
|
char const * data,
|
|
size_t length)
|
|
{
|
|
json_t * message = json_loadb(data, length, 0, NULL);
|
|
if (NULL != message)
|
|
{
|
|
if (wf_impl_jsonrpc_is_response(message))
|
|
{
|
|
wf_impl_jsonrpc_proxy_onresult(&session->rpc, message);
|
|
}
|
|
else if (wf_impl_jsonrpc_is_request(message))
|
|
{
|
|
wf_impl_jsonrpc_server_process(session->server, message, &wf_impl_session_send, session);
|
|
}
|
|
|
|
json_decref(message);
|
|
}
|
|
|
|
} |