plugin.h

Go to the documentation of this file.

#ifndef JANUS_PLUGIN_H
#define JANUS_PLUGIN_H

#include <stdlib.h>
#include <stdint.h>
#include <stdio.h>
#include <string.h>
#include <ctype.h>
#include <unistd.h>
#include <inttypes.h>

#include <glib.h>

#include "refcount.h"


#define JANUS_PLUGIN_API_VERSION        13

#define JANUS_PLUGIN_INIT(...) {                \
                .init = NULL,                                   \
                .destroy = NULL,                                \
                .get_api_compatibility = NULL,  \
                .get_version = NULL,                    \
                .get_version_string = NULL,             \
                .get_description = NULL,                \
                .get_name = NULL,                               \
                .get_author = NULL,                             \
                .get_package = NULL,                    \
                .create_session = NULL,                 \
                .handle_message = NULL,                 \
                .handle_admin_message = NULL,   \
                .setup_media = NULL,                    \
                .incoming_rtp = NULL,                   \
                .incoming_rtcp = NULL,                  \
                .incoming_data = NULL,                  \
                .slow_link = NULL,                              \
                .hangup_media = NULL,                   \
                .destroy_session = NULL,                \
                .query_session = NULL,                  \
                ## __VA_ARGS__ }


typedef struct janus_callbacks janus_callbacks;
typedef struct janus_plugin janus_plugin;
typedef struct janus_plugin_session janus_plugin_session;
typedef struct janus_plugin_result janus_plugin_result;

/* Use forward declaration to avoid including jansson.h */
typedef struct json_t json_t;

struct janus_plugin_session {
        void *gateway_handle;
        void *plugin_handle;
        volatile gint stopped;
        janus_refcount ref;
};

struct janus_plugin {
        int (* const init)(janus_callbacks *callback, const char *config_path);
        void (* const destroy)(void);

        int (* const get_api_compatibility)(void);
        int (* const get_version)(void);
        const char *(* const get_version_string)(void);
        const char *(* const get_description)(void);
        const char *(* const get_name)(void);
        const char *(* const get_author)(void);
        const char *(* const get_package)(void);

        void (* const create_session)(janus_plugin_session *handle, int *error);
        struct janus_plugin_result * (* const handle_message)(janus_plugin_session *handle, char *transaction, json_t *message, json_t *jsep);
        struct json_t * (* const handle_admin_message)(json_t *message);
        void (* const setup_media)(janus_plugin_session *handle);
        void (* const incoming_rtp)(janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len);
        void (* const incoming_rtcp)(janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len);
        void (* const incoming_data)(janus_plugin_session *handle, char *label, char *buf, int len);
        void (* const slow_link)(janus_plugin_session *handle, int mindex, gboolean video, gboolean uplink);
        void (* const hangup_media)(janus_plugin_session *handle);
        void (* const destroy_session)(janus_plugin_session *handle, int *error);
        json_t *(* const query_session)(janus_plugin_session *handle);

};

struct janus_callbacks {
        int (* const push_event)(janus_plugin_session *handle, janus_plugin *plugin, const char *transaction, json_t *message, json_t *jsep);

        void (* const relay_rtp)(janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len);
        void (* const relay_rtcp)(janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len);
        void (* const relay_data)(janus_plugin_session *handle, char *label, char *buf, int len);

        void (* const close_pc)(janus_plugin_session *handle);
        void (* const end_session)(janus_plugin_session *handle);

        gboolean (* const events_is_enabled)(void);
        void (* const notify_event)(janus_plugin *plugin, janus_plugin_session *handle, json_t *event);

        gboolean (* const auth_is_signature_valid)(janus_plugin *plugin, const char *token);
        gboolean (* const auth_signature_contains)(janus_plugin *plugin, const char *token, const char *descriptor);
};

typedef janus_plugin* create_p(void);



typedef enum janus_plugin_result_type {
        JANUS_PLUGIN_ERROR = -1,
        JANUS_PLUGIN_OK,
        JANUS_PLUGIN_OK_WAIT,
} janus_plugin_result_type;

struct janus_plugin_result {
        janus_plugin_result_type type;
        const char *text;
        json_t *content;
};

janus_plugin_result *janus_plugin_result_new(janus_plugin_result_type type, const char *text, json_t *content);

void janus_plugin_result_destroy(janus_plugin_result *result);


#endif