subscription.h

[詳解]

//
// © NTT DOCOMO BUSINESS, Inc. All Rights Reserved.
//
 
#pragma once
 
#ifdef __cplusplus
extern "C"
{
#endif
 
#include <stddef.h>
#include <stdint.h>
 
#include "member.h"
#include "publication.h"
 

#define SKW_ROOM_SUBSCRIPTION_ID_SIZE (36+1)

typedef enum {
    SKW_ROOM_SUBSCRIPTION_OK                          = 0,   
    SKW_ROOM_SUBSCRIPTION_ERR_NULL_ARGS               = 1,   
    SKW_ROOM_SUBSCRIPTION_ERR_INVALID_ARGS            = 2,   
    SKW_ROOM_SUBSCRIPTION_ERR_CONTEXT_NOT_INITED      = 3,   
    SKW_ROOM_SUBSCRIPTION_ERR_CONTEXT_NOT_SETUP       = 4,   
    SKW_ROOM_SUBSCRIPTION_ERR_REQUEST_FAILED          = 5,   
    SKW_ROOM_SUBSCRIPTION_ERR_MUTEX_UNLOCK_FAILED     = 6,   
    SKW_ROOM_SUBSCRIPTION_ERR_CALLED_IN_HANDLER       = 7,   
    SKW_ROOM_SUBSCRIPTION_ERR_SEND_FAILED             = 8,   
    SKW_ROOM_SUBSCRIPTION_ERR_TIMEOUT                 = 9,   
    SKW_ROOM_SUBSCRIPTION_ERR_CONNECTION_CLOSED       = 10,  
    SKW_ROOM_SUBSCRIPTION_ERR_RESPONSE_TOO_LARGE      = 11,  
    SKW_ROOM_SUBSCRIPTION_ERR_RESPONSE_PARSE_FAILED   = 12,  
    SKW_ROOM_SUBSCRIPTION_ERR_UNKNOWN                 = 99,  
    SKW_ROOM_SUBSCRIPTION_ERR_BAD_REQUEST             = 400, 
    SKW_ROOM_SUBSCRIPTION_ERR_UNAUTHORIZED            = 401, 
    SKW_ROOM_SUBSCRIPTION_ERR_FORBIDDEN               = 403, 
    SKW_ROOM_SUBSCRIPTION_ERR_NOT_FOUND               = 404, 
    SKW_ROOM_SUBSCRIPTION_ERR_ALREADY_EXIST           = 409, 
    SKW_ROOM_SUBSCRIPTION_ERR_TOO_LARGE               = 413, 
    SKW_ROOM_SUBSCRIPTION_ERR_TOO_MANY_REQUESTS       = 429, 
    SKW_ROOM_SUBSCRIPTION_ERR_SERVER_INTERNAL         = 500, 
    SKW_ROOM_SUBSCRIPTION_ERR_SERVER_BUSY             = 503, 
} skw_room_subscription_err_t;

typedef char skw_room_subscription_id_t[SKW_ROOM_SUBSCRIPTION_ID_SIZE];

typedef struct {
    skw_room_subscription_id_t *id;             
    skw_room_publication_id_t  *publication_id; 
    skw_room_member_id_t       *subscriber_id;  
} skw_room_subscription_data_field_t;

typedef void (*skw_room_subscription_on_data_t)(const char* subscription_id, const char* publication_id, const uint8_t* data, size_t length);

typedef void (*skw_room_subscription_on_video_frame_t)(const char* subscription_id, const char* publication_id, const uint8_t* data, size_t length, uint32_t pts);

typedef void (*skw_room_subscription_on_audio_frame_t)(const char* subscription_id, const char* publication_id, const uint8_t* data, size_t length, uint32_t pts);

typedef struct {
    skw_room_subscription_on_data_t on_data;               
    skw_room_subscription_on_video_frame_t on_video_frame; 
    skw_room_subscription_on_audio_frame_t on_audio_frame; 
} skw_room_subscription_handlers_t;

skw_room_subscription_err_t skw_room_subscription_register_handlers(const skw_room_subscription_handlers_t* handlers);

skw_room_subscription_err_t skw_room_subscription_unregister_handlers(void);
 
#ifdef __cplusplus
}
#endif