livekit.h

 
#pragma once
 
#include "media_lib_os.h"
#include "esp_capture.h"
#include "av_render.h"
 
#include "livekit_rpc.h"
 
#ifdef __cplusplus
extern "C" {
#endif

typedef enum {
    LIVEKIT_ERR_NONE          =  0,  
    LIVEKIT_ERR_INVALID_ARG   = -1,  
    LIVEKIT_ERR_NO_MEM        = -2,  
    LIVEKIT_ERR_ENGINE        = -3,  
    LIVEKIT_ERR_OTHER         = -4,  
    LIVEKIT_ERR_INVALID_STATE = -5,  
    LIVEKIT_ERR_SYSTEM_INIT   = -6   
} livekit_err_t;

typedef enum {
    LIVEKIT_CONNECTION_STATE_DISCONNECTED = 0, 
    LIVEKIT_CONNECTION_STATE_CONNECTING   = 1, 
    LIVEKIT_CONNECTION_STATE_CONNECTED    = 2, 
    LIVEKIT_CONNECTION_STATE_RECONNECTING = 3, 
    LIVEKIT_CONNECTION_STATE_FAILED       = 4  
} livekit_connection_state_t;

typedef enum {
    LIVEKIT_VIDEO_CODEC_NONE = 0, 
    LIVEKIT_VIDEO_CODEC_H264 = 1  
} livekit_video_codec_t;

typedef enum {
    LIVEKIT_AUDIO_CODEC_NONE  = 0, 
    LIVEKIT_AUDIO_CODEC_G711A = 1, 
    LIVEKIT_AUDIO_CODEC_G711U = 2, 
    LIVEKIT_AUDIO_CODEC_OPUS  = 3  
} livekit_audio_codec_t;

typedef enum {
    LIVEKIT_MEDIA_TYPE_NONE = 0,         
    LIVEKIT_MEDIA_TYPE_AUDIO = (1 << 0), 
    LIVEKIT_MEDIA_TYPE_VIDEO = (1 << 1), 
    LIVEKIT_MEDIA_TYPE_BOTH  = LIVEKIT_MEDIA_TYPE_AUDIO | LIVEKIT_MEDIA_TYPE_VIDEO, 
} livekit_media_kind_t;

typedef struct {
    livekit_video_codec_t codec;  
    int width;                    
    int height;                   
    int fps;                      
} livekit_video_encode_options_t;

typedef struct {
    livekit_audio_codec_t codec;  
    uint32_t sample_rate;         
    uint8_t channel_count;        
} livekit_audio_encode_options_t;

typedef struct {
    livekit_media_kind_t kind;

    livekit_video_encode_options_t video_encode;

    livekit_audio_encode_options_t audio_encode;

    esp_capture_handle_t capturer;
} livekit_pub_options_t;

typedef struct {
    livekit_media_kind_t kind;

    av_render_handle_t renderer;
} livekit_sub_options_t;

typedef struct {
    uint8_t *bytes;  
    size_t size;     
} livekit_data_payload_t;

typedef struct {
    livekit_data_payload_t payload;

    char* topic;

    char* sender_identity;
} livekit_data_received_t;

typedef struct {
    char* sid;
    char* name;
    char* metadata;
    uint32_t participant_count;
    bool active_recording;
} livekit_room_info_t;

typedef enum {
    LIVEKIT_PARTICIPANT_KIND_STANDARD = 0,
    LIVEKIT_PARTICIPANT_KIND_INGRESS = 1,
    LIVEKIT_PARTICIPANT_KIND_EGRESS = 2,
    LIVEKIT_PARTICIPANT_KIND_SIP = 3,
    LIVEKIT_PARTICIPANT_KIND_AGENT = 4
} livekit_participant_kind_t;

typedef enum {
    LIVEKIT_PARTICIPANT_STATE_JOINING = 0,
    LIVEKIT_PARTICIPANT_STATE_JOINED = 1,
    LIVEKIT_PARTICIPANT_STATE_ACTIVE = 2,
    LIVEKIT_PARTICIPANT_STATE_DISCONNECTED = 3
} livekit_participant_state_t;

typedef struct {
    char* sid;
    char* identity;
    char* name;
    char* metadata;
    livekit_participant_kind_t kind;
    livekit_participant_state_t state;
} livekit_participant_info_t;

typedef struct {
    livekit_pub_options_t publish;

    livekit_sub_options_t subscribe;

    void (*on_state_changed)(livekit_connection_state_t state, void* ctx);

    void (*on_rpc_result)(const livekit_rpc_result_t* result, void* ctx);

    void (*on_data_received)(const livekit_data_received_t* data, void* ctx);

    void (*on_room_info)(const livekit_room_info_t* info, void* ctx);

    void (*on_participant_info)(const livekit_participant_info_t* info, void* ctx);

    void* ctx;
} livekit_room_options_t;


livekit_err_t livekit_system_init(void);



typedef void *livekit_room_handle_t;

livekit_err_t livekit_room_create(livekit_room_handle_t *handle, const livekit_room_options_t *options);

livekit_err_t livekit_room_destroy(livekit_room_handle_t handle);



livekit_err_t livekit_room_connect(livekit_room_handle_t handle, const char *server_url, const char *token);

livekit_err_t livekit_room_close(livekit_room_handle_t handle);

livekit_connection_state_t livekit_room_get_state(livekit_room_handle_t handle);

const char* livekit_connection_state_str(livekit_connection_state_t state);




typedef struct {
    livekit_data_payload_t *payload;

    char* topic;

    bool lossy;

    char** destination_identities;

    int destination_identities_count;
} livekit_data_publish_options_t;

livekit_err_t livekit_room_publish_data(livekit_room_handle_t handle, livekit_data_publish_options_t *options);



livekit_err_t livekit_room_rpc_register(livekit_room_handle_t handle, const char* method, livekit_rpc_handler_t handler);

livekit_err_t livekit_room_rpc_unregister(livekit_room_handle_t handle, const char* method);

 
#ifdef __cplusplus
}
#endif