livekit_rpc.h

 
#pragma once
 
#include <stdbool.h>
 
#ifdef __cplusplus
extern "C" {
#endif

#define LIVEKIT_RPC_MAX_PAYLOAD_BYTES 15360 // 15 KB

typedef enum {
    LIVEKIT_RPC_RESULT_OK = 0,

    LIVEKIT_RPC_RESULT_APPLICATION = 1500,

    LIVEKIT_RPC_RESULT_CONNECTION_TIMEOUT = 1501,

    LIVEKIT_RPC_RESULT_RESPONSE_TIMEOUT = 1502,

    LIVEKIT_RPC_RESULT_RECIPIENT_DISCONNECTED = 1503,

    LIVEKIT_RPC_RESULT_RESPONSE_PAYLOAD_TOO_LARGE = 1504,

    LIVEKIT_RPC_RESULT_SEND_FAILED = 1505,

    LIVEKIT_RPC_RESULT_UNSUPPORTED_METHOD = 1400,

    LIVEKIT_RPC_RESULT_RECIPIENT_NOT_FOUND = 1401,

    LIVEKIT_RPC_RESULT_REQUEST_PAYLOAD_TOO_LARGE = 1402,

    LIVEKIT_RPC_RESULT_UNSUPPORTED_SERVER = 1403,

    LIVEKIT_RPC_RESULT_UNSUPPORTED_VERSION = 1404
} livekit_rpc_result_code_t;

typedef struct {
    char* id;

    livekit_rpc_result_code_t code;

    char* error_message;

    char* payload;
} livekit_rpc_result_t;

typedef struct {
    char* id;

    char* method;

    char* caller_identity;

    char* payload;

    bool (*send_result)(const livekit_rpc_result_t* res, void* ctx);

    void *ctx;
} livekit_rpc_invocation_t;

typedef void (*livekit_rpc_handler_t)(const livekit_rpc_invocation_t* invocation, void* ctx);

#define livekit_rpc_return_ok(_payload) \
    invocation->send_result(&(livekit_rpc_result_t){ \
        .id = invocation->id, \
        .code = LIVEKIT_RPC_RESULT_OK, \
        .payload = (_payload), \
        .error_message = NULL \
    }, invocation->ctx)

#define livekit_rpc_return_error(_error_message) \
    invocation->send_result(&(livekit_rpc_result_t){ \
        .id = invocation->id, \
        .code = LIVEKIT_RPC_RESULT_APPLICATION, \
        .payload = NULL, \
        .error_message = (_error_message) \
    }, invocation->ctx);
 
#ifdef __cplusplus
}
#endif