handlers.h

Go to the documentation of this file.

 
#pragma once
 
#include "network/acip/transport.h"
#include "network/acip/messages.h"
#include "asciichat_errno.h"
#include <stddef.h>
 
// =============================================================================
// Client-Side Handler Callbacks
// =============================================================================
 
typedef struct {
  void (*on_ascii_frame)(const ascii_frame_packet_t *header, const void *frame_data, size_t data_len, void *ctx);
 
  void (*on_audio)(const void *audio_data, size_t audio_len, void *ctx);
 
  void (*on_audio_batch)(const audio_batch_packet_t *header, const float *samples, size_t num_samples, void *ctx);
 
  void (*on_audio_opus)(const void *opus_data, size_t opus_len, void *ctx);
 
  void (*on_audio_opus_batch)(const void *batch_data, size_t batch_len, void *ctx);
 
  void (*on_server_state)(const server_state_packet_t *state, void *ctx);
 
  void (*on_error)(const error_packet_t *header, const char *message, void *ctx);
 
  void (*on_remote_log)(const remote_log_packet_t *header, const char *message, void *ctx);
 
  void (*on_ping)(void *ctx);
 
  void (*on_pong)(void *ctx);
 
  void (*on_clear_console)(void *ctx);
 
  void (*on_crypto_rekey_request)(const void *payload, size_t payload_len, void *ctx);
 
  void (*on_crypto_rekey_response)(const void *payload, size_t payload_len, void *ctx);
 
  void (*on_webrtc_sdp)(const acip_webrtc_sdp_t *sdp, size_t total_len, void *ctx);
 
  void (*on_webrtc_ice)(const acip_webrtc_ice_t *ice, size_t total_len, void *ctx);
 
  void (*on_session_joined)(const acip_session_joined_t *joined, void *ctx);
 
  void *app_ctx;
} acip_client_callbacks_t;
 
asciichat_error_t acip_handle_client_packet(acip_transport_t *transport, packet_type_t type, const void *payload,
                                            size_t payload_len, const acip_client_callbacks_t *callbacks);
 
// =============================================================================
// Server-Side Handler Callbacks
// =============================================================================
 
typedef struct {
  void (*on_protocol_version)(const protocol_version_packet_t *version, void *client_ctx, void *app_ctx);
 
  void (*on_image_frame)(const image_frame_packet_t *header, const void *pixel_data, size_t data_len, void *client_ctx,
                         void *app_ctx);
 
  void (*on_audio)(const void *audio_data, size_t audio_len, void *client_ctx, void *app_ctx);
 
  void (*on_audio_batch)(const audio_batch_packet_t *header, const float *samples, size_t num_samples, void *client_ctx,
                         void *app_ctx);
 
  void (*on_audio_opus)(const void *opus_data, size_t opus_len, void *client_ctx, void *app_ctx);
 
  void (*on_audio_opus_batch)(const void *batch_data, size_t batch_len, void *client_ctx, void *app_ctx);
 
  void (*on_client_join)(const void *join_data, size_t data_len, void *client_ctx, void *app_ctx);
 
  void (*on_client_leave)(void *client_ctx, void *app_ctx);
 
  void (*on_stream_start)(uint32_t stream_types, void *client_ctx, void *app_ctx);
 
  void (*on_stream_stop)(uint32_t stream_types, void *client_ctx, void *app_ctx);
 
  void (*on_capabilities)(const void *cap_data, size_t data_len, void *client_ctx, void *app_ctx);
 
  void (*on_ping)(void *client_ctx, void *app_ctx);
 
  void (*on_pong)(void *client_ctx, void *app_ctx);
 
  void (*on_error)(const error_packet_t *header, const char *message, void *client_ctx, void *app_ctx);
 
  void (*on_remote_log)(const remote_log_packet_t *header, const char *message, void *client_ctx, void *app_ctx);
 
  void (*on_crypto_rekey_request)(const void *payload, size_t payload_len, void *client_ctx, void *app_ctx);
 
  void (*on_crypto_rekey_response)(const void *payload, size_t payload_len, void *client_ctx, void *app_ctx);
 
  void (*on_crypto_rekey_complete)(const void *payload, size_t payload_len, void *client_ctx, void *app_ctx);
 
  void *app_ctx;
} acip_server_callbacks_t;
 
asciichat_error_t acip_handle_server_packet(acip_transport_t *transport, packet_type_t type, const void *payload,
                                            size_t payload_len, void *client_ctx,
                                            const acip_server_callbacks_t *callbacks);