evs.h

Go to the documentation of this file.

#pragma once
#include "quickio.h"

#define EVS_NO_CALLBACK (0l)

typedef guint64 evs_cb_t;

typedef enum evs_status (*evs_handler_fn)(
        struct client *client,
        const gchar *ev_extra,
        const evs_cb_t client_cb,
        gchar *json);

typedef void (*evs_off_fn)(
        struct client *client,
        const gchar *ev_extra);

typedef enum evs_status (*evs_cb_fn)(
        struct client *client,
        const void *data,
        const evs_cb_t client_cb,
        gchar *json);

enum evs_status {
        EVS_STATUS_OK,

        EVS_STATUS_ERR,

        EVS_STATUS_HANDLED,
};

enum evs_code {
        CODE_OK = 200,

        CODE_ACCEPTED = 202,

        CODE_BAD = 400,

        CODE_UNAUTH = 401,

        CODE_NOT_FOUND = 404,

        CODE_ENHANCE_CALM = 420,

        CODE_UNKNOWN = 500,
};

struct evs_on_info {
        gchar *ev_extra;

        struct subscription *sub;

        struct client *client;

        evs_cb_t client_cb;
};

typedef enum evs_status (*evs_on_fn)(const struct evs_on_info *info);

struct event {
        gchar *ev_path;

        evs_handler_fn handler_fn;

        evs_on_fn on_fn;

        evs_off_fn off_fn;

        gboolean handle_children;

        GHashTable *subs;

        GRWLock subs_lock;
};

void event_init(
        struct event *ev,
        const gchar *ev_path,
        const evs_handler_fn handler_fn,
        const evs_on_fn on_fn,
        const evs_off_fn off_fn,
        const gboolean handle_children);

void event_clear(struct event *ev);

struct event* evs_add_handler(
        const gchar *ev_prefix,
        const gchar *ev_path,
        const evs_handler_fn handler_fn,
        const evs_on_fn on_fn,
        const evs_off_fn off_fn,
        const gboolean handle_children);

enum evs_status evs_no_on(const struct evs_on_info *info);

guint evs_clean_path(gchar *ev_path);

GString* evs_make_path(
        const gchar *ev_prefix,
        const gchar *ev_path,
        const gchar *ev_extra);

void evs_route(
        struct client *client,
        gchar *ev_path,
        const evs_cb_t client_cb,
        gchar *json);

void evs_on(
        struct client *client,
        struct event *ev,
        gchar *ev_extra,
        const evs_cb_t client_cb);

void evs_send(
        struct client *client,
        struct event *ev,
        const gchar *ev_extra,
        const gchar *json);

void evs_send_info(const struct evs_on_info *info, const gchar *json);

void evs_send_sub(
        struct client *client,
        struct subscription *sub,
        const gchar *json);

void evs_send_full(
        struct client *client,
        struct event *ev,
        const gchar *ev_extra,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_send_info_full(
        const struct evs_on_info *info,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_send_sub_full(
        struct client *client,
        struct subscription *sub,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_send_bruteforce(
        struct client *client,
        const gchar *ev_prefix,
        const gchar *ev_path,
        const gchar *ev_extra,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_on_cb(
        const gboolean success,
        const struct evs_on_info *info);

struct evs_on_info* evs_on_info_copy(
        const struct evs_on_info *info,
        const gboolean with_ev_extra);

void evs_on_info_free(struct evs_on_info *info);

void evs_off(
        struct client *client,
        struct event *ev,
        const gchar *ev_extra);

void evs_client_offd(struct client *client, struct subscription *sub);

void evs_cb(
        struct client *client,
        const evs_cb_t client_cb,
        const gchar *json);

void evs_cb_with_cb(
        struct client *client,
        const evs_cb_t client_cb,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_err_cb(
        struct client *client,
        const evs_cb_t client_cb,
        const enum evs_code code,
        const gchar *err_msg,
        const gchar *json);

void evs_cb_full(
        struct client *client,
        const evs_cb_t client_cb,
        const enum evs_code code,
        const gchar *err_msg,
        const gchar *json,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

void evs_broadcast(
        struct event *ev,
        const gchar *ev_extra,
        const gchar *json);

void evs_client_close(struct client *client);

void evs_broadcast_path(
        const gchar *ev_path,
        const gchar *json);

void evs_broadcast_tick();

void evs_pre_init();

void evs_init();