server_status.c File Reference

Server status screen display with live log feed at FPS rate. More...

Go to the source code of this file.

Functions
void	server_status_log_init (void)
void	server_status_log_destroy (void)
void	server_status_log_clear (void)
void	server_status_log_append (const char *message)
asciichat_error_t	server_status_gather (tcp_server_t *server, const char *session_string, const char *ipv4_address, const char *ipv6_address, uint16_t port, time_t start_time, const char *mode_name, bool session_is_mdns_only, server_status_t *out_status)
void	server_status_display (const server_status_t *status)
bool	server_status_display_interactive (const server_status_t *status)
	Display status screen with keyboard input support Returns true if status screen should continue, false if Escape was pressed to exit.
void	server_status_update (tcp_server_t *server, const char *session_string, const char *ipv4_address, const char *ipv6_address, uint16_t port, time_t start_time, const char *mode_name, bool session_is_mdns_only, uint64_t *last_update_ns)

Detailed Description

Server status screen display with live log feed at FPS rate.

Definition in file server_status.c.

Function Documentation

server_status_display()

void server_status_display

(

const server_status_t *

status

)

Definition at line 237 of file server_status.c.

                                                          {
  if (!status) {
    return;
  }
 
  // Only render the status screen in interactive mode
  // In non-interactive mode, logs flow to stdout/stderr normally
  if (!terminal_is_interactive()) {
    return;
  }
 
  // If --grep pattern was provided, enter interactive grep mode with it pre-populated
  // Only do this once (check if not already entering)
  static bool grep_mode_entered = false;
  if (!grep_mode_entered && grep_get_last_pattern() && grep_get_last_pattern()[0] != '\0') {
    interactive_grep_enter_mode();
    grep_mode_entered = true;
  }
 
  // Use terminal_screen abstraction for rendering
  terminal_screen_config_t config = {
      .fixed_header_lines = 4,
      .render_header = render_server_status_header,
      .user_data = (void *)status,
      .show_logs = true,
  };
 
  terminal_screen_render(&config);
}

References grep_get_last_pattern(), interactive_grep_enter_mode(), terminal_is_interactive(), and terminal_screen_render().

Referenced by server_status_update().

server_status_display_interactive()

bool server_status_display_interactive

(

const server_status_t *

status

)

Display status screen with keyboard input support Returns true if status screen should continue, false if Escape was pressed to exit.

Definition at line 271 of file server_status.c.

                                                                      {
  if (!status) {
    return true;
  }
 
  // Only render the status screen in interactive mode
  if (!terminal_is_interactive()) {
    return true;
  }
 
  // If --grep pattern was provided, enter interactive grep mode with it pre-populated
  static bool grep_mode_entered = false;
  if (!grep_mode_entered && grep_get_last_pattern() && grep_get_last_pattern()[0] != '\0') {
    interactive_grep_enter_mode();
    grep_mode_entered = true;
  }
 
  // Initialize keyboard for interactive grep
  bool keyboard_enabled = false;
  if (keyboard_init() == ASCIICHAT_OK) {
    keyboard_enabled = true;
  }
 
  // Use terminal_screen abstraction for rendering
  terminal_screen_config_t config = {
      .fixed_header_lines = 4,
      .render_header = render_server_status_header,
      .user_data = (void *)status,
      .show_logs = true,
  };
 
  terminal_screen_render(&config);
 
  // Poll keyboard for Escape to exit or for interactive grep
  bool should_exit_status = false;
  if (keyboard_enabled) {
    keyboard_key_t key = keyboard_read_nonblocking();
    if (key == KEY_ESCAPE) {
      // Escape key: cancel grep if active, otherwise exit status screen
      if (interactive_grep_is_active()) {
        interactive_grep_exit_mode(false); // Cancel grep without applying
      } else {
        should_exit_status = true; // Exit status screen
      }
    } else if (key != KEY_NONE && interactive_grep_should_handle(key)) {
      interactive_grep_handle_key(key);
    }
  }
 
  // Cleanup keyboard
  if (keyboard_enabled) {
    keyboard_destroy();
  }
 
  return !should_exit_status; // Return false if user wants to exit
}

References grep_get_last_pattern(), interactive_grep_enter_mode(), interactive_grep_exit_mode(), interactive_grep_handle_key(), interactive_grep_is_active(), interactive_grep_should_handle(), terminal_is_interactive(), and terminal_screen_render().

server_status_gather()

asciichat_error_t server_status_gather	(	tcp_server_t *	server,
		const char *	session_string,
		const char *	ipv4_address,
		const char *	ipv6_address,
		uint16_t	port,
		time_t	start_time,
		const char *	mode_name,
		bool	session_is_mdns_only,
		server_status_t *	out_status
	)

Definition at line 49 of file server_status.c.

                                                                                                                      {
  if (!server || !out_status || !mode_name) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid parameters for server_status_gather");
  }
 
  memset(out_status, 0, sizeof(*out_status));
 
  // Copy session string
  if (session_string) {
    SAFE_STRNCPY(out_status->session_string, session_string, sizeof(out_status->session_string));
  }
 
  // Format IPv4 address
  out_status->ipv4_bound = (ipv4_address && ipv4_address[0] != '\0');
  if (out_status->ipv4_bound) {
    snprintf(out_status->ipv4_address, sizeof(out_status->ipv4_address), "%s:%u", ipv4_address, port);
  }
 
  // Format IPv6 address
  out_status->ipv6_bound = (ipv6_address && ipv6_address[0] != '\0');
  if (out_status->ipv6_bound) {
    snprintf(out_status->ipv6_address, sizeof(out_status->ipv6_address), "[%s]:%u", ipv6_address, port);
  }
 
  out_status->port = port;
  out_status->start_time = start_time;
  out_status->mode_name = mode_name;
  out_status->session_is_mdns_only = session_is_mdns_only;
  out_status->connected_count = tcp_server_get_client_count(server);
 
  return ASCIICHAT_OK;
}

References tcp_server_get_client_count().

Referenced by server_status_update().

server_status_log_append()

void server_status_log_append

(

const char *

message

)

Definition at line 40 of file server_status.c.

                                                   {
  // Delegate to shared session log buffer
  session_log_buffer_append(message);
}

References session_log_buffer_append().

server_status_log_clear()

void server_status_log_clear

(

void

)

Definition at line 35 of file server_status.c.

                                   {
  // Delegate to shared session log buffer
  session_log_buffer_clear();
}

References session_log_buffer_clear().

Referenced by server_main().

server_status_log_destroy()

void server_status_log_destroy

(

void

)

Definition at line 30 of file server_status.c.

                                     {
  // Delegate to shared session log buffer
  session_log_buffer_destroy();
}

References session_log_buffer_destroy().

Referenced by server_main().

server_status_log_init()

void server_status_log_init

(

void

)

Definition at line 25 of file server_status.c.

                                  {
  // Delegate to shared session log buffer
  (void)session_log_buffer_init();
}

References session_log_buffer_init().

Referenced by server_main().

server_status_update()

void server_status_update	(	tcp_server_t *	server,
		const char *	session_string,
		const char *	ipv4_address,
		const char *	ipv6_address,
		uint16_t	port,
		time_t	start_time,
		const char *	mode_name,
		bool	session_is_mdns_only,
		uint64_t *	last_update_ns
	)

Definition at line 328 of file server_status.c.

                                                                               {
  if (!server || !last_update_ns) {
    return;
  }
 
  // Update at FPS rate (60 Hz = 16.67ms by default)
  uint32_t fps = GET_OPTION(fps);
  if (fps == 0) {
    fps = 60; // Default
  }
 
  // Calculate frame interval in microseconds
  uint64_t frame_interval_us = US_PER_SEC_INT / fps;
 
  // Get current time in microseconds using platform abstraction
  uint64_t now_us = platform_get_monotonic_time_us();
 
  // Check if enough time has passed
  if ((now_us - *last_update_ns) < frame_interval_us) {
    return; // Too soon, skip frame
  }
 
  server_status_t status;
  if (server_status_gather(server, session_string, ipv4_address, ipv6_address, port, start_time, mode_name,
                           session_is_mdns_only, &status) == ASCIICHAT_OK) {
    server_status_display(&status);
    *last_update_ns = now_us;
  }
}

References platform_get_monotonic_time_us(), server_status_display(), and server_status_gather().