connection_endpoint.c File Reference

Shared endpoint normalization for TCP and WebSocket connections. More...

Go to the source code of this file.

Functions
const char *	connection_endpoint_protocol_name (connection_endpoint_protocol_t protocol)
asciichat_error_t	connection_endpoint_resolve (const char *input, uint16_t default_port, connection_endpoint_t *endpoint_out)
	For connection endpoint, this is the live record that ties protocol, port, has_explicit_port together. The owning code creates it, updates it while work is active, and releases its handles and pointed-to storage before freeing the record. Resolve an input string into a normalized TCP or WebSocket endpoint.

Detailed Description

Shared endpoint normalization for TCP and WebSocket connections.

Definition in file connection_endpoint.c.

Function Documentation

connection_endpoint_protocol_name()

const char * connection_endpoint_protocol_name

(

connection_endpoint_protocol_t

protocol

)

Definition at line 12 of file connection_endpoint.c.

                                                                                       {
  switch (protocol) {
  case CONNECTION_ENDPOINT_TCP:
    return "TCP";
  case CONNECTION_ENDPOINT_WEBSOCKET:
    return "WebSocket";
  case CONNECTION_ENDPOINT_QUIC:
    return "QUIC";
  default:
    return "Unknown";
  }
}

References CONNECTION_ENDPOINT_QUIC, CONNECTION_ENDPOINT_TCP, and CONNECTION_ENDPOINT_WEBSOCKET.

connection_endpoint_resolve()

asciichat_error_t connection_endpoint_resolve	(	const char *	input,
		uint16_t	default_port,
		connection_endpoint_t *	endpoint_out )

For connection endpoint, this is the live record that ties protocol, port, has_explicit_port together. The owning code creates it, updates it while work is active, and releases its handles and pointed-to storage before freeing the record. Resolve an input string into a normalized TCP or WebSocket endpoint.

Supported inputs:

• ws://host[:port]
• wss://host[:port]
• tcp://host[:port]
• quic://host[:port]
• bare hostnames or host:port pairs

Bare hostnames are treated as TCP endpoints and use default_port when the input does not specify a port.

Definition at line 45 of file connection_endpoint.c.

                                                                                   {
  if (!input || !*input || !endpoint_out) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "input or endpoint_out is NULL");
  }
 
  url_parts_t parts = {0};
  asciichat_error_t result;
 
  if (strncasecmp(input, "quic://", sizeof("quic://") - 1) == 0) {
    char rewritten[URL_BUFFER_SIZE];
    if (strlen(input) - 1 >= sizeof(rewritten))
      return SET_ERRNO(ERROR_INVALID_PARAM, "QUIC endpoint is too long");
    SAFE_SNPRINTF(rewritten, sizeof(rewritten), "tcp://%s", input + 7);
    result = url_parse(rewritten, &parts);
    if (result != ASCIICHAT_OK)
      return result;
    if (parts.userinfo || (parts.path && *parts.path)) {
      url_parts_destroy(&parts);
      return SET_ERRNO(ERROR_INVALID_PARAM, "QUIC endpoint must not include user information or a path");
    }
    result = connection_endpoint_from_parts(endpoint_out, &parts, CONNECTION_ENDPOINT_QUIC, default_port, input);
    if (result == ASCIICHAT_OK && parts.ipv6)
      SAFE_STRNCPY(endpoint_out->host, parts.ipv6, sizeof(endpoint_out->host));
    url_parts_destroy(&parts);
    return result;
  }
 
  if (url_is_websocket(input)) {
    result = url_parse(input, &parts);
    if (result != ASCIICHAT_OK) {
      return result;
    }
    result = connection_endpoint_from_parts(endpoint_out, &parts, CONNECTION_ENDPOINT_WEBSOCKET, default_port, input);
    url_parts_destroy(&parts);
    return result;
  }
 
  if (url_is_tcp(input)) {
    result = url_parse(input, &parts);
    if (result != ASCIICHAT_OK) {
      return result;
    }
    result = connection_endpoint_from_parts(endpoint_out, &parts, CONNECTION_ENDPOINT_TCP, default_port, input);
    url_parts_destroy(&parts);
    return result;
  }
 
  /* Unsupported explicit scheme. Bare hostnames are allowed and have no "://". */
  if (strstr(input, "://") != NULL) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Unsupported connection scheme: %s", input);
  }
 
  result = url_parse(input, &parts);
  if (result != ASCIICHAT_OK) {
    return result;
  }
 
  result = connection_endpoint_from_parts(endpoint_out, &parts, CONNECTION_ENDPOINT_TCP, default_port, input);
  url_parts_destroy(&parts);
  return result;
}

References ASCIICHAT_OK, CONNECTION_ENDPOINT_QUIC, CONNECTION_ENDPOINT_TCP, CONNECTION_ENDPOINT_WEBSOCKET, ERROR_INVALID_PARAM, connection_endpoint_t::host, url_parts_t::ipv6, url_parts_t::path, SAFE_SNPRINTF, SAFE_STRNCPY, SET_ERRNO, URL_BUFFER_SIZE, url_is_tcp(), url_is_websocket(), url_parse(), url_parts_destroy(), and url_parts_t::userinfo.

Referenced by network_connection_open(), and session_connection_establish().