connection_factory.c File Reference

Shared connection factory for TCP and WebSocket endpoints. More...

Go to the source code of this file.

Functions
asciichat_error_t	connection_factory_open (const char *name, const char *input, uint16_t default_port, crypto_context_t *crypto_ctx, acip_transport_t **transport_out, connection_endpoint_t *endpoint_out)

Detailed Description

Shared connection factory for TCP and WebSocket endpoints.

Definition in file connection_factory.c.

Function Documentation

connection_factory_open()

asciichat_error_t connection_factory_open	(	const char *	name,
		const char *	input,
		uint16_t	default_port,
		crypto_context_t *	crypto_ctx,
		acip_transport_t **	transport_out,
		connection_endpoint_t *	endpoint_out
	)

Open a transport for a resolved endpoint.

The factory hides the backend-specific setup details:

• TCP endpoints are resolved and connected with timeout handling
• WebSocket endpoints use the WebSocket transport constructor

Parameters

name	Transport/debug name
input	Original endpoint string
default_port	Fallback port for bare hostnames
crypto_ctx	Optional crypto context to attach to the transport
transport_out	Receives the connected transport on success
endpoint_out	Optional normalized endpoint output

Returns

ASCIICHAT_OK on success, error code otherwise

Definition at line 75 of file connection_factory.c.

                                                                               {
  if (!name || !input || !transport_out) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid connection factory parameters");
  }
 
  *transport_out = NULL;
 
  connection_endpoint_t endpoint = {0};
  asciichat_error_t resolve_result = connection_endpoint_resolve(input, default_port, &endpoint);
  if (resolve_result != ASCIICHAT_OK) {
    return resolve_result;
  }
 
  acip_transport_t *transport = NULL;
 
  switch (endpoint.protocol) {
  case CONNECTION_ENDPOINT_WEBSOCKET:
    transport = acip_websocket_client_transport_create(name, endpoint.input, crypto_ctx);
    if (!transport) {
      return SET_ERRNO(ERROR_NETWORK_CONNECT, "Failed to create WebSocket transport");
    }
    break;
 
  case CONNECTION_ENDPOINT_TCP:
    resolve_result = connection_factory_open_tcp(name, &endpoint, crypto_ctx, &transport);
    if (resolve_result != ASCIICHAT_OK) {
      return resolve_result;
    }
    break;
 
  default:
    return SET_ERRNO(ERROR_INVALID_PARAM, "Unsupported endpoint protocol");
  }
 
  if (endpoint_out) {
    *endpoint_out = endpoint;
  }
  *transport_out = transport;
  return ASCIICHAT_OK;
}

References acip_websocket_client_transport_create(), ASCIICHAT_OK, connection_endpoint_resolve(), CONNECTION_ENDPOINT_TCP, CONNECTION_ENDPOINT_WEBSOCKET, ERROR_INVALID_PARAM, ERROR_NETWORK_CONNECT, connection_endpoint_t::input, connection_endpoint_t::protocol, and SET_ERRNO.

Referenced by server_connection_establish().