send.c File Reference

ACIP protocol packet sending functions (transport-agnostic) More...

Go to the source code of this file.

Functions
asciichat_error_t	packet_send_via_transport (acip_transport_t *transport, packet_type_t type, const void *payload, size_t payload_len)
	Send packet via transport with proper header (exported for generic wrappers)
asciichat_error_t	acip_send_audio_batch (acip_transport_t *transport, const float *samples, uint32_t num_samples, uint32_t batch_count)
	Send audio batch packet.
asciichat_error_t	acip_send_audio_opus (acip_transport_t *transport, const void *opus_data, size_t opus_len)
	Send Opus-encoded audio packet.
asciichat_error_t	acip_send_audio_opus_batch (acip_transport_t *transport, const void *opus_data, size_t opus_len, const uint16_t *frame_sizes, uint32_t frame_count, uint32_t sample_rate, uint32_t frame_duration)
	Send batched Opus-encoded audio frames.
asciichat_error_t	acip_send_ping (acip_transport_t *transport)
	Send ping packet.
asciichat_error_t	acip_send_pong (acip_transport_t *transport)
	Send pong packet.
asciichat_error_t	acip_send_error (acip_transport_t *transport, uint32_t error_code, const char *message)
	Send error message packet.
asciichat_error_t	acip_send_remote_log (acip_transport_t *transport, uint8_t log_level, uint8_t direction, const char *message)
	Send remote log packet.
asciichat_error_t	acip_send_session_created (acip_transport_t *transport, const acip_session_created_t *response)
	Send SESSION_CREATED response packet.
asciichat_error_t	acip_send_session_info (acip_transport_t *transport, const acip_session_info_t *info)
	Send SESSION_INFO response packet.
asciichat_error_t	acip_send_session_joined (acip_transport_t *transport, const acip_session_joined_t *response)
	Send SESSION_JOINED response packet.

Detailed Description

ACIP protocol packet sending functions (transport-agnostic)

Implementation of send functions that work with any transport. Refactored from lib/network/av.c to use transport abstraction.

Author

Zachary Fogg me@zf.nosp@m.o.gg

Date

January 2026

Definition in file send.c.

Function Documentation

acip_send_audio_batch()

asciichat_error_t acip_send_audio_batch	(	acip_transport_t *	transport,
		const float *	samples,
		uint32_t	num_samples,
		uint32_t	batch_count
	)

Send audio batch packet.

Parameters

transport	Transport instance
samples	Audio samples (float array)
num_samples	Number of samples
batch_count	Number of batches aggregated

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 90 of file send.c.

                                                              {
  if (!transport || !samples || num_samples == 0) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid parameters");
  }
 
  // Build batch header
  audio_batch_packet_t header;
  header.batch_count = batch_count;
  header.total_samples = (uint32_t)num_samples;
  header.sample_rate = (uint32_t)AUDIO_SAMPLE_RATE;
  header.channels = 1;
 
  // Calculate total size (header + float samples)
  size_t samples_size = num_samples * sizeof(float);
  size_t total_size = sizeof(header) + samples_size;
 
  uint8_t *buffer = buffer_pool_alloc(NULL, total_size);
  if (!buffer) {
    return SET_ERRNO(ERROR_MEMORY, "Failed to allocate buffer");
  }
 
  // Copy header and samples
  memcpy(buffer, &header, sizeof(header));
  memcpy(buffer + sizeof(header), samples, samples_size);
 
  asciichat_error_t result = packet_send_via_transport(transport, PACKET_TYPE_AUDIO_BATCH, buffer, total_size);
 
  buffer_pool_free(NULL, buffer, total_size);
  return result;
}

References AUDIO_SAMPLE_RATE, audio_batch_packet_t::batch_count, buffer_pool_alloc(), buffer_pool_free(), audio_batch_packet_t::channels, ERROR_INVALID_PARAM, ERROR_MEMORY, packet_send_via_transport(), PACKET_TYPE_AUDIO_BATCH, audio_batch_packet_t::sample_rate, SET_ERRNO, and audio_batch_packet_t::total_samples.

acip_send_audio_opus()

asciichat_error_t acip_send_audio_opus	(	acip_transport_t *	transport,
		const void *	opus_data,
		size_t	opus_len
	)

Send Opus-encoded audio packet.

Parameters

transport	Transport instance
opus_data	Opus-encoded audio data
opus_len	Length of encoded data

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 122 of file send.c.

                                                                                                            {
  if (!transport || !opus_data || opus_len == 0) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid parameters");
  }
 
  return packet_send_via_transport(transport, PACKET_TYPE_AUDIO_OPUS, opus_data, opus_len);
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_AUDIO_OPUS, and SET_ERRNO.

Referenced by client_send_thread_func().

acip_send_audio_opus_batch()

asciichat_error_t acip_send_audio_opus_batch	(	acip_transport_t *	transport,
		const void *	opus_data,
		size_t	opus_len,
		const uint16_t *	frame_sizes,
		uint32_t	frame_count,
		uint32_t	sample_rate,
		uint32_t	frame_duration
	)

Send batched Opus-encoded audio frames.

Parameters

transport	Transport instance
opus_data	Opus-encoded data (multiple frames concatenated)
opus_len	Total length of encoded data
frame_sizes	Array of individual frame sizes
frame_count	Number of frames in batch
sample_rate	Sample rate in Hz
frame_duration	Duration per frame in milliseconds

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 130 of file send.c.

                                                                      {
  if (!transport || !opus_data || !frame_sizes || frame_count == 0) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid parameters");
  }
 
  // Build batch header (16 bytes)
  uint8_t header[16];
  *(uint32_t *)(header + 0) = HOST_TO_NET_U32(sample_rate);
  *(uint32_t *)(header + 4) = HOST_TO_NET_U32(frame_duration);
  *(uint32_t *)(header + 8) = HOST_TO_NET_U32(frame_count);
  *(uint32_t *)(header + 12) = 0; // reserved
 
  // Calculate sizes array size
  size_t sizes_len = frame_count * sizeof(uint16_t);
  size_t total_size = sizeof(header) + sizes_len + opus_len;
 
  uint8_t *buffer = buffer_pool_alloc(NULL, total_size);
  if (!buffer) {
    return SET_ERRNO(ERROR_MEMORY, "Failed to allocate buffer");
  }
 
  // Build packet: header + sizes + opus_data
  memcpy(buffer, header, sizeof(header));
 
  // Convert frame sizes to network byte order before copying
  // IMPORTANT: Server expects network byte order and will apply NET_TO_HOST_U16()
  uint16_t *sizes_buf = (uint16_t *)(buffer + sizeof(header));
  for (uint32_t i = 0; i < frame_count; i++) {
    sizes_buf[i] = HOST_TO_NET_U16(frame_sizes[i]);
  }
 
  memcpy(buffer + sizeof(header) + sizes_len, opus_data, opus_len);
 
  asciichat_error_t result = packet_send_via_transport(transport, PACKET_TYPE_AUDIO_OPUS_BATCH, buffer, total_size);
 
  buffer_pool_free(NULL, buffer, total_size);
  return result;
}

References buffer_pool_alloc(), buffer_pool_free(), ERROR_INVALID_PARAM, ERROR_MEMORY, HOST_TO_NET_U16, HOST_TO_NET_U32, packet_send_via_transport(), PACKET_TYPE_AUDIO_OPUS_BATCH, and SET_ERRNO.

Referenced by threaded_send_audio_opus_batch().

acip_send_error()

asciichat_error_t acip_send_error	(	acip_transport_t *	transport,
		uint32_t	error_code,
		const char *	message
	)

Send error message packet.

Parameters

transport	Transport instance
error_code	Error code from asciichat_error_t
message	Error message (will be truncated to MAX_ERROR_MESSAGE_LENGTH)

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 205 of file send.c.

                                                                                                         {
  if (!transport) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
 
  // Calculate message length (max MAX_ERROR_MESSAGE_LENGTH)
  size_t msg_len = 0;
  if (message) {
    msg_len = strlen(message);
    if (msg_len > MAX_ERROR_MESSAGE_LENGTH) {
      msg_len = MAX_ERROR_MESSAGE_LENGTH;
    }
  }
 
  error_packet_t header;
  header.error_code = HOST_TO_NET_U32(error_code);
  header.message_length = HOST_TO_NET_U32((uint32_t)msg_len);
 
  // Allocate buffer for header + message
  size_t total_size = sizeof(header) + msg_len;
  uint8_t *buffer = buffer_pool_alloc(NULL, total_size);
  if (!buffer) {
    return SET_ERRNO(ERROR_MEMORY, "Failed to allocate buffer");
  }
 
  // Build packet
  memcpy(buffer, &header, sizeof(header));
  if (msg_len > 0) {
    memcpy(buffer + sizeof(header), message, msg_len);
  }
 
  asciichat_error_t result = packet_send_via_transport(transport, PACKET_TYPE_ERROR_MESSAGE, buffer, total_size);
 
  buffer_pool_free(NULL, buffer, total_size);
  return result;
}

References buffer_pool_alloc(), buffer_pool_free(), error_code, error_packet_t::error_code, ERROR_INVALID_PARAM, ERROR_MEMORY, HOST_TO_NET_U32, MAX_ERROR_MESSAGE_LENGTH, error_packet_t::message_length, packet_send_via_transport(), PACKET_TYPE_ERROR_MESSAGE, and SET_ERRNO.

acip_send_ping()

asciichat_error_t acip_send_ping

(

acip_transport_t *

transport

)

Send ping packet.

Parameters

transport

Transport instance

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 175 of file send.c.

                                                              {
  if (!transport) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
 
  // Ping has no payload
  return packet_send_via_transport(transport, PACKET_TYPE_PING, NULL, 0);
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_PING, and SET_ERRNO.

acip_send_pong()

asciichat_error_t acip_send_pong

(

acip_transport_t *

transport

)

Send pong packet.

Parameters

transport

Transport instance

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 184 of file send.c.

                                                              {
  if (!transport) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
 
  // Pong has no payload
  return packet_send_via_transport(transport, PACKET_TYPE_PONG, NULL, 0);
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_PONG, and SET_ERRNO.

Referenced by process_decrypted_packet().

acip_send_remote_log()

asciichat_error_t acip_send_remote_log	(	acip_transport_t *	transport,
		uint8_t	log_level,
		uint8_t	direction,
		const char *	message
	)

Send remote log packet.

Parameters

transport	Transport instance
log_level	Log level (0=DEBUG, 1=INFO, 2=WARN, 3=ERROR)
direction	Direction hint (0=client->server, 1=server->client)
message	Log message

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 242 of file send.c.

                                                            {
  if (!transport || !message) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport or message");
  }
 
  size_t msg_len = strlen(message);
 
  remote_log_packet_t header;
  header.log_level = log_level;
  header.direction = direction;
  header.flags = 0;
  header.message_length = HOST_TO_NET_U32((uint32_t)msg_len);
 
  size_t total_size = sizeof(header) + msg_len;
 
  uint8_t *buffer = buffer_pool_alloc(NULL, total_size);
  if (!buffer) {
    return SET_ERRNO(ERROR_MEMORY, "Failed to allocate buffer");
  }
 
  // Build packet
  memcpy(buffer, &header, sizeof(header));
  memcpy(buffer + sizeof(header), message, msg_len);
 
  asciichat_error_t result = packet_send_via_transport(transport, PACKET_TYPE_REMOTE_LOG, buffer, total_size);
 
  buffer_pool_free(NULL, buffer, total_size);
  return result;
}

References buffer_pool_alloc(), buffer_pool_free(), remote_log_packet_t::direction, ERROR_INVALID_PARAM, ERROR_MEMORY, remote_log_packet_t::flags, HOST_TO_NET_U32, remote_log_packet_t::log_level, remote_log_packet_t::message_length, packet_send_via_transport(), PACKET_TYPE_REMOTE_LOG, and SET_ERRNO.

acip_send_session_created()

asciichat_error_t acip_send_session_created	(	acip_transport_t *	transport,
		const acip_session_created_t *	response
	)

Send SESSION_CREATED response packet.

Parameters

transport	Transport instance
response	Session created response structure

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 277 of file send.c.

                                                                                                                 {
  if (!transport || !response) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport or response");
  }
 
  return packet_send_via_transport(transport, PACKET_TYPE_ACIP_SESSION_CREATED, response, sizeof(*response));
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_ACIP_SESSION_CREATED, and SET_ERRNO.

acip_send_session_info()

asciichat_error_t acip_send_session_info	(	acip_transport_t *	transport,
		const acip_session_info_t *	info
	)

Send SESSION_INFO response packet.

Parameters

transport	Transport instance
info	Session info structure

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 285 of file send.c.

                                                                                                       {
  if (!transport || !info) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport or info");
  }
 
  return packet_send_via_transport(transport, PACKET_TYPE_ACIP_SESSION_INFO, info, sizeof(*info));
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_ACIP_SESSION_INFO, and SET_ERRNO.

acip_send_session_joined()

asciichat_error_t acip_send_session_joined	(	acip_transport_t *	transport,
		const acip_session_joined_t *	response
	)

Send SESSION_JOINED response packet.

Parameters

transport	Transport instance
response	Session joined response structure

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 293 of file send.c.

                                                                                                               {
  if (!transport || !response) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport or response");
  }
 
  return packet_send_via_transport(transport, PACKET_TYPE_ACIP_SESSION_JOINED, response, sizeof(*response));
}

References ERROR_INVALID_PARAM, packet_send_via_transport(), PACKET_TYPE_ACIP_SESSION_JOINED, and SET_ERRNO.

packet_send_via_transport()

asciichat_error_t packet_send_via_transport	(	acip_transport_t *	transport,
		packet_type_t	type,
		const void *	payload,
		size_t	payload_len
	)

Send packet via transport with proper header (exported for generic wrappers)

Send arbitrary packet via transport (generic packet sender)

Wraps payload in ACIP packet header and sends via transport. Handles CRC32 calculation and network byte order conversion.

Parameters

transport	Transport instance
type	Packet type
payload	Payload data (may be NULL if payload_len is 0)
payload_len	Payload length

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 40 of file send.c.

                                                                {
  if (!transport) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
 
  // Build packet header
  packet_header_t header;
  header.magic = HOST_TO_NET_U32(PACKET_MAGIC);
  header.type = HOST_TO_NET_U16(type);
  header.length = HOST_TO_NET_U32((uint32_t)payload_len);
  header.client_id = 0; // Set by caller if needed
 
  // Calculate CRC32 if we have payload
  if (payload && payload_len > 0) {
    header.crc32 = HOST_TO_NET_U32(asciichat_crc32((const uint8_t *)payload, payload_len));
  } else {
    header.crc32 = 0;
  }
 
  // Calculate total packet size
  size_t total_size = sizeof(header) + payload_len;
 
  // Allocate buffer for complete packet
  uint8_t *packet = buffer_pool_alloc(NULL, total_size);
  if (!packet) {
    return SET_ERRNO(ERROR_MEMORY, "Failed to allocate packet buffer");
  }
 
  // Build complete packet: header + payload
  memcpy(packet, &header, sizeof(header));
  if (payload && payload_len > 0) {
    memcpy(packet + sizeof(header), payload, payload_len);
  }
 
  // Send via transport (transport handles encryption if crypto_ctx present)
  asciichat_error_t result = acip_transport_send(transport, packet, total_size);
 
  buffer_pool_free(NULL, packet, total_size);
  return result;
}

References asciichat_crc32, buffer_pool_alloc(), buffer_pool_free(), packet_header_t::client_id, packet_header_t::crc32, ERROR_INVALID_PARAM, ERROR_MEMORY, HOST_TO_NET_U16, HOST_TO_NET_U32, packet_header_t::length, packet_header_t::magic, PACKET_MAGIC, SET_ERRNO, and packet_header_t::type.

Referenced by acip_send_ascii_frame(), acip_send_audio_batch(), acip_send_audio_opus(), acip_send_audio_opus_batch(), acip_send_capabilities(), acip_send_clear_console(), acip_send_client_join(), acip_send_client_leave(), acip_send_error(), acip_send_image_frame(), acip_send_ping(), acip_send_pong(), acip_send_protocol_version(), acip_send_remote_log(), acip_send_server_state(), acip_send_session_created(), acip_send_session_info(), acip_send_session_joined(), acip_send_stream_start(), acip_send_stream_stop(), client_send_thread_func(), threaded_send_audio_opus(), and threaded_send_packet().