transport.h

Go to the documentation of this file.

 
#pragma once
 
#include "../../common.h"
#include "../../asciichat_errno.h"
#include "../../crypto/crypto.h"
#include "../../platform/socket.h"
#include <stddef.h>
#include <stdint.h>
#include <stdbool.h>
 
typedef enum {
  ACIP_TRANSPORT_TCP = 1,       
  ACIP_TRANSPORT_WEBSOCKET = 2, 
  ACIP_TRANSPORT_WEBRTC = 3,    
  ACIP_TRANSPORT_HTTP = 4,      
  ACIP_TRANSPORT_QUIC = 5       
} acip_transport_type_t;
 
typedef struct acip_transport acip_transport_t;
 
typedef struct {
  asciichat_error_t (*send)(acip_transport_t *transport, const void *data, size_t len);
 
  asciichat_error_t (*recv)(acip_transport_t *transport, void **buffer, size_t *out_len, void **out_allocated_buffer);
 
  asciichat_error_t (*close)(acip_transport_t *transport);
 
  acip_transport_type_t (*get_type)(acip_transport_t *transport);
 
  socket_t (*get_socket)(acip_transport_t *transport);
 
  bool (*is_connected)(acip_transport_t *transport);
 
  bool (*has_pending_data)(acip_transport_t *transport);
 
  void (*destroy_impl)(acip_transport_t *transport);
} acip_transport_methods_t;
 
struct acip_transport {
  const acip_transport_methods_t *methods; 
  crypto_context_t *crypto_ctx;            
  uint64_t receive_timeout_ns;              
  void *impl_data;                         
  void *user_data;                         
};
 
// =============================================================================
// Transport Lifecycle
// =============================================================================
 
void acip_transport_destroy(acip_transport_t *transport);
 
// =============================================================================
// Transport Operations (convenience wrappers)
// =============================================================================
 
static inline asciichat_error_t acip_transport_send(acip_transport_t *transport, const void *data, size_t len) {
  if (!transport || !transport->methods || !transport->methods->send) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
  return transport->methods->send(transport, data, len);
}
 
static inline asciichat_error_t acip_transport_recv(acip_transport_t *transport, void **buffer, size_t *out_len,
                                                    void **out_allocated_buffer) {
  if (!transport || !transport->methods || !transport->methods->recv) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
  return transport->methods->recv(transport, buffer, out_len, out_allocated_buffer);
}
 
static inline asciichat_error_t acip_transport_close(acip_transport_t *transport) {
  if (!transport || !transport->methods || !transport->methods->close) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid transport");
  }
  return transport->methods->close(transport);
}
 
static inline acip_transport_type_t acip_transport_get_type(acip_transport_t *transport) {
  if (!transport || !transport->methods || !transport->methods->get_type) {
    return 0;
  }
  return transport->methods->get_type(transport);
}
 
static inline socket_t acip_transport_get_socket(acip_transport_t *transport) {
  if (!transport || !transport->methods || !transport->methods->get_socket) {
    return INVALID_SOCKET_VALUE;
  }
  return transport->methods->get_socket(transport);
}
 
static inline bool acip_transport_is_connected(acip_transport_t *transport) {
  if (!transport || !transport->methods || !transport->methods->is_connected) {
    return false;
  }
  return transport->methods->is_connected(transport);
}
 
static inline bool acip_transport_has_pending_data(acip_transport_t *transport) {
  if (!transport || !transport->methods || !transport->methods->has_pending_data) {
    return false;
  }
  return transport->methods->has_pending_data(transport);
}
 
// =============================================================================
// Transport Implementations (defined in separate files)
// =============================================================================
 
acip_transport_t *acip_tcp_transport_create(const char *name, socket_t sockfd, crypto_context_t *crypto_ctx);
 
acip_transport_t *acip_websocket_client_transport_create(const char *name, const char *url, crypto_context_t *crypto_ctx);
 
struct lws;
acip_transport_t *acip_websocket_server_transport_create(const char *name, struct lws *wsi, crypto_context_t *crypto_ctx);
 
struct webrtc_peer_connection;
struct webrtc_data_channel;
acip_transport_t *acip_webrtc_transport_create(struct webrtc_peer_connection *peer_conn,
                                               struct webrtc_data_channel *data_channel, crypto_context_t *crypto_ctx);