client.h

Go to the documentation of this file.

#pragma once
#include "quickio.h"

enum client_sub_state {
        CLIENT_SUB_PENDING,

        CLIENT_SUB_TOMBSTONED,

        CLIENT_SUB_CREATED,

        CLIENT_SUB_ACTIVE,

        CLIENT_SUB_NULL,
};

struct client_sub {
        gint32 idx;

        gboolean pending;

        gboolean tombstone;
};

struct client_cb {
        guint16 id;

        evs_cb_fn cb_fn;

        void *cb_data;

        qev_free_fn free_fn;

        gint64 created;
};

struct client {
        struct qev_client qev_client;

        struct {
                gboolean handshaked:1;

                struct protocol *prot;

                union {

                } flags;
        } protocol;

        gint64 last_send;

        gint64 last_recv;

        qev_timeout_t *timeout;

        GHashTable *subs;

        GHashTable *data;

        struct {
                __uint128_t sid;

                guint tbl;

                guint64 body_len;

                struct {
                        gboolean is_post:1;

                        gboolean iframe_requested:1;

                        gboolean keep_alive:1;

                        gboolean in_request:1;

                        gboolean incoming:1;
                } flags;

                struct client *client;
        } http;

        struct client_cb *cbs[4];

        guint16 cbs_id;
};

evs_cb_t client_cb_new(
        struct client *client,
        const evs_cb_fn cb_fn,
        void *cb_data,
        const qev_free_fn free_fn);

enum evs_status client_cb_fire(
        struct client *client,
        const evs_cb_t server_cb,
        const evs_cb_t client_cb,
        gchar *json);

void client_cb_prune(struct client *client, const gint64 before);

gint64 client_cb_prune_get_before();

gboolean client_sub_active(struct client *client, struct subscription *sub);

enum client_sub_state client_sub_add(
        struct client *client,
        struct subscription *sub);

enum client_sub_state client_sub_accept(
        struct client *client,
        struct subscription *sub);

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

gboolean client_sub_remove(struct client *client, struct subscription *sub);

void client_update_subs_config(
        const guint64 total,
        const guint64 pressure,
        const guint64 min);

void client_set(struct client *client, const GQuark key, GVariant *val);

GVariant* client_get(struct client *client, const GQuark key);

gboolean client_has(struct client *client, const GQuark key);

void client_del(struct client *client, const GQuark key);

void client_closed(struct client *client);

void client_free_all(struct client *client);

void client_init();