protocols.h

Go to the documentation of this file.

#pragma once
#include "quickio.h"

#define PROTOCOLS_HEARTBEAT "/qio/heartbeat:0=null"

enum protocol_handles {
        PROT_YES,

        PROT_MAYBE,

        PROT_NO,
};

enum protocol_status {
        PROT_OK,

        PROT_AGAIN,

        PROT_FATAL,
};

struct protocol_heartbeat {
        gint64 timeout;

        gint64 poll;

        gint64 heartbeat;

        gint64 challenge;

        gint64 dead;
};

struct protocol_frames {
        GString *def;

        GString *raw;
};

struct protocol {
        guint id;

        struct protocol **global;

        void (*init)();

        enum protocol_handles (*handles)(struct client *client);

        enum protocol_status (*handshake)(struct client *client);

        enum protocol_status (*route)(struct client *client, gsize *used);

        void (*heartbeat)(struct client *client, const struct protocol_heartbeat *hb);

        struct protocol_frames (*frame)(
                const gchar *ev_path,
                const gchar *ev_extra,
                const evs_cb_t server_cb,
                const gchar *json);

        void (*send)(struct client *client, const struct protocol_frames *frames);

        void (*close)(struct client *client, guint reason);
};

struct client* protocols_new_surrogate(struct protocol *prot);

void protocols_route(struct client *client);

void protocols_send(
        struct client *client,
        const gchar *ev_path,
        const gchar *ev_extra,
        const evs_cb_t server_cb,
        const gchar *json);

void protocols_closed(struct client *client, guint reason);

struct protocol_frames* protocols_bcast(const gchar *ev_path, const gchar *json);

void protocols_bcast_write(
        struct client *client,
        const struct protocol_frames *frames);

void protocols_bcast_free(struct protocol_frames *frames);

void protocols_heartbeat(
        struct client *client,
        const struct protocol_heartbeat *hb);

struct protocol_heartbeat protocols_heartbeat_get_intervals();

void protocols_switch(struct client *client, struct protocol *prot);

void protocols_init();