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        15

#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,                  \
                .data_ready = 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;

typedef struct janus_plugin_rtp janus_plugin_rtp;
typedef struct janus_plugin_rtp_extensions janus_plugin_rtp_extensions;
typedef struct janus_plugin_rtcp janus_plugin_rtcp;
typedef struct janus_plugin_data janus_plugin_data;

/* 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, janus_plugin_rtp *packet);
        void (* const incoming_rtcp)(janus_plugin_session *handle, janus_plugin_rtcp *packet);
        void (* const incoming_data)(janus_plugin_session *handle, janus_plugin_data *packet);
        void (* const data_ready)(janus_plugin_session *handle);
        void (* const slow_link)(janus_plugin_session *handle, gboolean uplink, gboolean video);
        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, janus_plugin_rtp *packet);
        void (* const relay_rtcp)(janus_plugin_session *handle, janus_plugin_rtcp *packet);
        void (* const relay_data)(janus_plugin_session *handle, janus_plugin_data *packet);

        void (* const send_pli)(janus_plugin_session *handle);
        void (* const send_remb)(janus_plugin_session *handle, guint32 bitrate);

        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);



struct janus_plugin_rtp_extensions {
        int8_t audio_level;
        gboolean audio_level_vad;
        int16_t video_rotation;
        gboolean video_back_camera;
        gboolean video_flipped;
};
void janus_plugin_rtp_extensions_reset(janus_plugin_rtp_extensions *extensions);

struct janus_plugin_rtp {
        gboolean video;
        char *buffer;
        uint16_t length;
        janus_plugin_rtp_extensions extensions;
};
void janus_plugin_rtp_reset(janus_plugin_rtp *packet);

struct janus_plugin_rtcp {
        gboolean video;
        char *buffer;
        uint16_t length;
};
void janus_plugin_rtcp_reset(janus_plugin_rtcp *packet);

struct janus_plugin_data {
        char *label;
        char *protocol;
        gboolean binary;
        char *buffer;
        uint16_t length;
};
void janus_plugin_data_reset(janus_plugin_data *packet);


#endif