establish.c File Reference

Go to the source code of this file.

Macros
#define	SESSION_ESTABLISH_TARGET_BUFFER_SIZE   320

Functions
asciichat_error_t	session_connection_establish (const char *name, const char *address, uint16_t port, const network_connect_config_t *config, network_connection_t **owner, char *password, size_t capacity, network_connection_prepare_fn prepare, void(*detach)(void *), void *context)

Macro Definition Documentation

SESSION_ESTABLISH_TARGET_BUFFER_SIZE

#define SESSION_ESTABLISH_TARGET_BUFFER_SIZE   320

Definition at line 3 of file src/common/session/establish.c.

Referenced by session_connection_establish().

Function Documentation

session_connection_establish()

asciichat_error_t session_connection_establish	(	const char *	name,
		const char *	address,
		uint16_t	port,
		const network_connect_config_t *	config,
		network_connection_t **	owner,
		char *	password,
		size_t	capacity,
		network_connection_prepare_fn	prepare,
		void(*	detach )(void *),
		void *	context )

Definition at line 14 of file src/common/session/establish.c.

                                                                                      {
  if (!owner || *owner || !password || capacity < PASSWORD_BUFFER_SIZE || !prepare)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid session establishment parameters");
  const char *selected_address = address;
  char fallback_address[URL_BUFFER_SIZE];
  int fallback_port = GET_OPTION(quic_fallback_port);
  bool fallback_available = address && strncasecmp(address, "quic://", 7) == 0 && fallback_port > 0;
  if (fallback_available) {
    if (!GET_OPTION(server_key)[0] || GET_OPTION(no_encrypt) || GET_OPTION(no_auth))
      return SET_ERRNO(ERROR_USAGE, "QUIC TCP fallback requires --server-key and ACIP encryption and authentication");
    connection_endpoint_t endpoint;
    asciichat_error_t result = connection_endpoint_resolve(address, port, &endpoint);
    if (result != ASCIICHAT_OK)
      return result;
    if (strchr(endpoint.host, ':'))
      SAFE_SNPRINTF(fallback_address, sizeof(fallback_address), "tcp://[%s]:%d", endpoint.host, fallback_port);
    else
      SAFE_SNPRINTF(fallback_address, sizeof(fallback_address), "tcp://%s:%d", endpoint.host, fallback_port);
  }
  for (;;) {
    network_establish_config_t settings = {.name = name,
                                           .address = selected_address,
                                           .default_port = port,
                                           .connect = config,
                                           .password = password[0] ? password : NULL,
                                           .protocol = NETWORK_PROTOCOL_MEDIA,
                                           // Authentication is resolved by the shared security initializer in
                                           // the prepare callback. Do not force it for unauthenticated defaults;
                                           // discovery participants use this same establishment path.
                                           .authenticate = false,
                                           .prepare = prepare,
                                           .context = context};
    network_establish_result_t attempt;
    asciichat_errno_scope_t attempt_errors = errno_scope_begin();
    asciichat_error_t result = network_connection_establish(&settings, owner, &attempt);
    if (result == ASCIICHAT_OK) {
      errno_scope_end(attempt_errors, ASCIICHAT_ERRNO_HANDLED);
      return ASCIICHAT_OK;
    }
    if (fallback_available && result == ERROR_NETWORK_TIMEOUT && !*owner) {
      errno_scope_end(attempt_errors, ASCIICHAT_ERRNO_DISMISSED);
      selected_address = fallback_address;
      fallback_available = false;
      log_info("QUIC timed out; trying authenticated TCP fallback on port %d", fallback_port);
      continue;
    }
    if (!attempt.password_failure) {
      // A failed negotiation cannot produce the first frame that normally
      // ends the splash. Release it before presenting the connection error.
      splash_intro_done();
      splash_wait_for_animation();
      return result;
    }
    // Recover only the rejected negotiation; caller and cleanup errors remain pending.
    errno_scope_end(attempt_errors, ASCIICHAT_ERRNO_DISMISSED);
    if (detach)
      detach(context);
    network_connection_destroy(owner);
    char target[SESSION_ESTABLISH_TARGET_BUFFER_SIZE];
    snprintf(target, sizeof(target), "%s:%u", attempt.endpoint.host, attempt.endpoint.port);
    result = ui_input_password(target, password, capacity, attempt.password_failure & AUTH_FAIL_PASSWORD_INCORRECT);
    if (result != ASCIICHAT_OK)
      return result;
  }
}

References ASCIICHAT_ERRNO_DISMISSED, ASCIICHAT_ERRNO_HANDLED, ASCIICHAT_OK, AUTH_FAIL_PASSWORD_INCORRECT, connection_endpoint_resolve(), network_establish_result_t::endpoint, errno_scope_begin(), errno_scope_end(), ERROR_INVALID_PARAM, ERROR_NETWORK_TIMEOUT, ERROR_USAGE, GET_OPTION, connection_endpoint_t::host, log_info, network_connection_destroy(), network_connection_establish(), NETWORK_PROTOCOL_MEDIA, PASSWORD_BUFFER_SIZE, network_establish_result_t::password_failure, connection_endpoint_t::port, SAFE_SNPRINTF, SESSION_ESTABLISH_TARGET_BUFFER_SIZE, SET_ERRNO, splash_intro_done(), splash_wait_for_animation(), ui_input_password(), and URL_BUFFER_SIZE.

Referenced by client_connection_start(), and session_participant_connect().