client.c File Reference

WebSocket client implementation. More...

Go to the source code of this file.

Functions
websocket_client_t *	websocket_client_create (void)
	Create and initialize WebSocket client.
void	websocket_client_destroy (websocket_client_t **client_ptr)
	Destroy WebSocket client and free resources.
bool	websocket_client_is_active (const websocket_client_t *client)
	Check if connection is currently active.
bool	websocket_client_is_lost (const websocket_client_t *client)
	Check if connection was lost.
void	websocket_client_signal_lost (websocket_client_t *client)
	Signal that connection was lost.
void	websocket_client_close (websocket_client_t *client)
	Close connection gracefully.
void	websocket_client_shutdown (websocket_client_t *client)
	Shutdown connection forcefully.
acip_transport_t *	websocket_client_connect (websocket_client_t *client, const char *url, struct crypto_context_t *crypto_ctx)
	Establish WebSocket connection to server.
acip_transport_t *	websocket_client_get_transport (const websocket_client_t *client)
	Get active transport instance.

Detailed Description

WebSocket client implementation.

Thin implementation that delegates to acip_websocket_client_transport_create() for actual connection setup. Mirrors tcp_client.c structure for consistency.

Author

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

Date

February 2026

Definition in file lib/network/websocket/client.c.

Function Documentation

websocket_client_close()

void websocket_client_close

(

websocket_client_t *

client

)

Close connection gracefully.

Definition at line 100 of file lib/network/websocket/client.c.

                                                        {
  if (!client) {
    return;
  }
 
  log_debug("Closing WebSocket client");
 
  if (client->transport) {
    acip_transport_close(client->transport);
  }
 
  atomic_store(&client->connection_active, false);
}

websocket_client_connect()

acip_transport_t * websocket_client_connect	(	websocket_client_t *	client,
		const char *	url,
		struct crypto_context_t *	crypto_ctx
	)

Establish WebSocket connection to server.

Delegates to acip_websocket_client_transport_create() which handles:

• URL parsing and validation
• WebSocket handshake
• Transport setup and lifecycle

Definition at line 141 of file lib/network/websocket/client.c.

                                                                                {
  if (!client || !url) {
    log_error("Invalid arguments to websocket_client_connect");
    return NULL;
  }
 
  log_info("Connecting WebSocket client to %s", url);
 
  // Store URL for reference
  strncpy(client->url, url, sizeof(client->url) - 1);
  client->url[sizeof(client->url) - 1] = '\0';
 
  // Create transport using ACIP layer
  acip_transport_t *transport = acip_websocket_client_transport_create(url, crypto_ctx);
  if (!transport) {
    log_error("Failed to create WebSocket transport");
    atomic_store(&client->connection_lost, true);
    return NULL;
  }
 
  // Store transport and mark as active
  client->transport = transport;
  atomic_store(&client->connection_active, true);
  atomic_store(&client->connection_lost, false);
 
  log_info("WebSocket client connected to %s", url);
 
  return transport;
}

References acip_websocket_client_transport_create().

Referenced by connection_attempt_tcp(), and connection_attempt_websocket().

websocket_client_create()

websocket_client_t * websocket_client_create

(

void

)

Create and initialize WebSocket client.

Definition at line 24 of file lib/network/websocket/client.c.

                                                  {
  websocket_client_t *client = SAFE_MALLOC(sizeof(websocket_client_t), websocket_client_t *);
  if (!client) {
    log_error("Failed to allocate websocket_client_t");
    return NULL;
  }
 
  // Zero-initialize all fields
  memset(client, 0, sizeof(*client));
 
  // Initialize connection state
  atomic_store(&client->connection_active, false);
  atomic_store(&client->connection_lost, false);
  client->transport = NULL;
 
  log_debug("WebSocket client created");
 
  return client;
}

Referenced by connection_attempt_tcp(), connection_attempt_websocket(), and session_client_like_run().

websocket_client_destroy()

void websocket_client_destroy

(

websocket_client_t **

client_ptr

)

Destroy WebSocket client and free resources.

Definition at line 47 of file lib/network/websocket/client.c.

                                                               {
  if (!client_ptr || !*client_ptr) {
    return; // No-op if NULL
  }
 
  websocket_client_t *client = *client_ptr;
 
  log_debug("Destroying WebSocket client");
 
  // Close and destroy transport if it exists
  if (client->transport) {
    acip_transport_destroy(client->transport);
    client->transport = NULL;
  }
 
  SAFE_FREE(*client_ptr);
}

References acip_transport_destroy().

Referenced by connection_attempt_tcp(), connection_attempt_websocket(), connection_context_cleanup(), and session_client_like_run().

websocket_client_get_transport()

acip_transport_t * websocket_client_get_transport

(

const websocket_client_t *

client

)

Get active transport instance.

Definition at line 175 of file lib/network/websocket/client.c.

                                                                                   {
  if (!client) {
    return NULL;
  }
  return client->transport;
}

websocket_client_is_active()

bool websocket_client_is_active

(

const websocket_client_t *

client

)

Check if connection is currently active.

Definition at line 68 of file lib/network/websocket/client.c.

                                                                  {
  if (!client) {
    return false;
  }
  return atomic_load(&client->connection_active);
}

websocket_client_is_lost()

bool websocket_client_is_lost

(

const websocket_client_t *

client

)

Check if connection was lost.

Definition at line 78 of file lib/network/websocket/client.c.

                                                                {
  if (!client) {
    return false;
  }
  return atomic_load(&client->connection_lost);
}

websocket_client_shutdown()

void websocket_client_shutdown

(

websocket_client_t *

client

)

Shutdown connection forcefully.

Definition at line 117 of file lib/network/websocket/client.c.

                                                           {
  if (!client) {
    return;
  }
 
  log_debug("Shutting down WebSocket client");
 
  // Force close the transport
  if (client->transport) {
    acip_transport_close(client->transport);
  }
 
  atomic_store(&client->connection_active, false);
  atomic_store(&client->connection_lost, true);
}

websocket_client_signal_lost()

void websocket_client_signal_lost

(

websocket_client_t *

client

)

Signal that connection was lost.

Definition at line 88 of file lib/network/websocket/client.c.

                                                              {
  if (!client) {
    return;
  }
  atomic_store(&client->connection_lost, true);
  atomic_store(&client->connection_active, false);
  log_debug("WebSocket connection marked as lost");
}