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_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 (*on_crypto_parameters)(packet_type_t type, const void *payload, size_t payload_len, void *ctx);

  void (*on_crypto_key_exchange_init)(packet_type_t type, const void *payload, size_t payload_len, void *ctx);

  void (*on_crypto_auth_challenge)(packet_type_t type, const void *payload, size_t payload_len, void *ctx);

  void (*on_crypto_server_auth_resp)(packet_type_t type, const void *payload, size_t payload_len, void *ctx);

  void (*on_crypto_auth_failed)(packet_type_t type, const void *payload, size_t payload_len, void *ctx);

  void (*on_crypto_handshake_complete)(packet_type_t type, const void *payload, size_t payload_len, 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_image_frame_h264)(uint32_t width, uint32_t height, uint8_t flags, const void *data, size_t data_len,
                              void *client_ctx, void *app_ctx);
  void (*on_image_frame_h265)(uint32_t width, uint32_t height, uint8_t flags, const void *h265_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_key_exchange_resp)(packet_type_t type, const void *payload, size_t payload_len, void *client_ctx,
                                      void *app_ctx);

  void (*on_crypto_auth_response)(packet_type_t type, const void *payload, size_t payload_len, void *client_ctx,
                                  void *app_ctx);

  void (*on_crypto_no_encryption)(packet_type_t type, 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);