options/parsing/actions.c

Go to the documentation of this file.

 
#include <ascii-chat/options/actions.h>
#include <string.h>
#include <stddef.h>
 
#include <ascii-chat/asciichat_errno.h>
#include <ascii-chat/common.h>
#include <ascii-chat/log/log.h>
#include <ascii-chat/network/update_checker.h>
#include <ascii-chat/options/manpage.h>
#include <ascii-chat/options/presets.h>
#include <ascii-chat/options/config.h>
#include <ascii-chat/options/completions/completions.h>
#include <ascii-chat/options/schema.h>
#include <ascii-chat/platform/terminal.h>
#include <ascii-chat/platform/question.h>
#include <ascii-chat/platform/stat.h>
#include <ascii-chat/version.h>
#include <ascii-chat/video/webcam/webcam.h>
#include <ascii-chat/audio/audio.h>
#include <ascii-chat/util/string.h>
#include <ascii-chat/util/path.h>
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
 
// ============================================================================
// Action Exit Helper
// ============================================================================
 
static _Noreturn void action_exit(int code) {
  fflush(NULL);
  _Exit(code);
}
 
// ============================================================================
// Deferred Action Tracking System
// ============================================================================
 
static struct {
  deferred_action_t action;
  action_args_t args;
  bool has_action;
} g_deferred_action_state = {
    .action = ACTION_NONE,
    .args = {0},
    .has_action = false,
};
 
void actions_defer(deferred_action_t action, const action_args_t *args) {
  // Only remember the first action found
  if (g_deferred_action_state.has_action) {
    return; // Action already deferred, ignore subsequent actions
  }
 
  g_deferred_action_state.action = action;
  g_deferred_action_state.has_action = true;
 
  // Copy arguments if provided
  if (args) {
    memcpy(&g_deferred_action_state.args, args, sizeof(action_args_t));
  } else {
    memset(&g_deferred_action_state.args, 0, sizeof(action_args_t));
  }
}
 
deferred_action_t actions_get_deferred(void) {
  return g_deferred_action_state.action;
}
 
const action_args_t *actions_get_args(void) {
  if (!g_deferred_action_state.has_action) {
    return NULL;
  }
  return &g_deferred_action_state.args;
}
 
// ============================================================================
// Webcam Action
// ============================================================================
 
void action_list_webcams(void) {
  // Defer execution until after options are fully parsed
  actions_defer(ACTION_LIST_WEBCAMS, NULL);
}
 
static void execute_list_webcams(void) {
  webcam_device_info_t *devices = NULL;
  unsigned int device_count = 0;
 
  asciichat_error_t result = webcam_list_devices(&devices, &device_count);
  if (result != ASCIICHAT_OK) {
    log_error("Failed to enumerate webcam devices");
    action_exit(ERROR_WEBCAM);
  }
 
  if (device_count == 0) {
    log_plain_stdout("No webcam devices found.");
  } else {
    log_plain_stdout("Available Webcam Devices:");
    for (unsigned int i = 0; i < device_count; i++) {
      log_plain_stdout("  %u %s", devices[i].index, devices[i].name);
    }
  }
 
  webcam_free_device_list(devices);
  action_exit(0);
}
 
// ============================================================================
// Audio Device Actions
// ============================================================================
 
void action_list_microphones(void) {
  // Defer execution until after options are fully parsed
  actions_defer(ACTION_LIST_MICROPHONES, NULL);
}
 
static void execute_list_microphones(void) {
  audio_device_info_t *devices = NULL;
  unsigned int device_count = 0;
 
  asciichat_error_t result = audio_list_input_devices(&devices, &device_count);
  if (result != ASCIICHAT_OK) {
    log_error("Failed to enumerate audio input devices");
    action_exit(ERROR_AUDIO);
  }
 
  if (device_count == 0) {
    log_plain_stdout("No microphone devices found.");
  } else {
    log_plain_stdout("Available Microphone Devices:");
    for (unsigned int i = 0; i < device_count; i++) {
      if (devices[i].is_default_input) {
        log_plain_stdout("  %d %s (default)", devices[i].index, devices[i].name);
      } else {
        log_plain_stdout("  %d %s", devices[i].index, devices[i].name);
      }
    }
  }
 
  audio_free_device_list(devices);
  action_exit(0);
}
 
void action_list_speakers(void) {
  // Defer execution until after options are fully parsed
  actions_defer(ACTION_LIST_SPEAKERS, NULL);
}
 
static void execute_list_speakers(void) {
  audio_device_info_t *devices = NULL;
  unsigned int device_count = 0;
 
  asciichat_error_t result = audio_list_output_devices(&devices, &device_count);
  if (result != ASCIICHAT_OK) {
    log_error("Failed to enumerate audio output devices");
    action_exit(ERROR_AUDIO);
  }
 
  if (device_count == 0) {
    log_plain_stdout("No speaker devices found.");
  } else {
    log_plain_stdout("Available Speaker Devices:");
    for (unsigned int i = 0; i < device_count; i++) {
      if (devices[i].is_default_output) {
        log_plain_stdout("  %d %s (default)", devices[i].index, devices[i].name);
      } else {
        log_plain_stdout("  %d %s", devices[i].index, devices[i].name);
      }
    }
  }
 
  audio_free_device_list(devices);
  action_exit(0);
}
 
// ============================================================================
// Terminal Capabilities Action
// ============================================================================
 
void action_show_capabilities_immediate(void) {
  terminal_capabilities_t caps = detect_terminal_capabilities();
 
  // Determine if we should use colored output
  bool use_colors = terminal_should_color_output(STDOUT_FILENO);
 
  // Override color level if colors should not be shown
  if (!use_colors) {
    caps.color_level = TERM_COLOR_NONE;
    caps.color_count = 0;
    caps.capabilities &= ~((uint32_t)(TERM_CAP_COLOR_TRUE | TERM_CAP_COLOR_256 | TERM_CAP_COLOR_16));
  }
 
  // Use detected terminal size (immediate execution doesn't have parsed options yet)
  terminal_size_t size;
  terminal_get_size(&size);
  unsigned short width = size.cols;
  unsigned short height = size.rows;
 
  log_color_t label_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
  log_color_t string_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
  log_color_t good_color = use_colors ? LOG_COLOR_INFO : LOG_COLOR_GREY;
  log_color_t bad_color = use_colors ? LOG_COLOR_ERROR : LOG_COLOR_GREY;
  log_color_t number_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
 
  printf("%s\n", colored_string(LOG_COLOR_WARN, "Terminal Capabilities:"));
 
  char size_buf[64];
  snprintf(size_buf, sizeof(size_buf), "%ux%u", width, height);
  printf("  %s: %s\n", colored_string(label_color, "Terminal Size"), colored_string(number_color, size_buf));
 
  const char *color_level_name = terminal_color_level_name(caps.color_level);
  log_color_t color_level_color = (caps.color_level == TERM_COLOR_NONE) ? bad_color : string_color;
  printf("  %s: %s\n", colored_string(label_color, "Color Level"),
         colored_string(color_level_color, (char *)color_level_name));
 
  char colors_buf[64];
  snprintf(colors_buf, sizeof(colors_buf), "%u", caps.color_count);
  printf("  %s: %s\n", colored_string(label_color, "Max Colors"), colored_string(number_color, colors_buf));
 
  log_color_t utf8_color = caps.utf8_support ? good_color : bad_color;
  printf("  %s: %s\n", colored_string(label_color, "UTF-8 Support"),
         colored_string(utf8_color, (char *)(caps.utf8_support ? "Yes" : "No")));
 
  const char *render_mode_str = "unknown";
  if (caps.render_mode == RENDER_MODE_FOREGROUND) {
    render_mode_str = "foreground";
  } else if (caps.render_mode == RENDER_MODE_BACKGROUND) {
    render_mode_str = "background";
  } else if (caps.render_mode == RENDER_MODE_HALF_BLOCK) {
    render_mode_str = "half-block";
  }
  printf("  %s: %s\n", colored_string(label_color, "Render Mode"),
         colored_string(string_color, (char *)render_mode_str));
  printf("  %s: %s\n", colored_string(label_color, "TERM"), colored_string(string_color, (char *)caps.term_type));
  printf("  %s: %s\n", colored_string(label_color, "COLORTERM"),
         colored_string(string_color, (char *)(strlen(caps.colorterm) ? caps.colorterm : "(not set)")));
 
  log_color_t reliable_color = caps.detection_reliable ? good_color : bad_color;
  printf("  %s: %s\n", colored_string(label_color, "Detection Reliable"),
         colored_string(reliable_color, (char *)(caps.detection_reliable ? "Yes" : "No")));
 
  char bitmask_buf[64];
  snprintf(bitmask_buf, sizeof(bitmask_buf), "0x%08x", caps.capabilities);
  printf("  %s: %s\n", colored_string(label_color, "Capabilities Bitmask"), colored_string(number_color, bitmask_buf));
 
  fflush(stdout);
  action_exit(0);
}
 
void action_show_capabilities(void) {
  // Defer execution until after options are fully parsed and dimensions updated
  // This ensures --width and --height flags are properly reflected in the output
  actions_defer(ACTION_SHOW_CAPABILITIES, NULL);
}
 
// ============================================================================
// Update Check Action
// ============================================================================
 
void action_check_update_immediate(void) {
  printf("Checking for updates...\n");
  update_check_result_t result;
  asciichat_error_t err = update_check_perform(&result);
  if (err != ASCIICHAT_OK) {
    printf("\nFailed to check for updates.\n\n");
    action_exit(1);
  }
  if (result.update_available) {
    char notification[1024];
    update_check_format_notification(&result, notification, sizeof(notification));
    printf("\n%s\n\n", notification);
  } else {
    printf("\nYou are already on the latest version: %s (%.8s)\n\n", result.current_version, result.current_sha);
  }
  action_exit(0);
}
 
void action_check_update(void) {
  // Defer execution until after options are fully parsed
  actions_defer(ACTION_CHECK_UPDATE, NULL);
}
 
static void execute_show_capabilities(void) {
  terminal_capabilities_t caps = detect_terminal_capabilities();
 
  // Determine if we should use colored output
  bool use_colors = terminal_should_color_output(STDOUT_FILENO);
 
  // Override color level if colors should not be shown
  if (!use_colors) {
    // User requested no colors or output is piped or CLAUDECODE is set
    caps.color_level = TERM_COLOR_NONE;
    caps.color_count = 0;
    caps.capabilities &= ~((uint32_t)(TERM_CAP_COLOR_TRUE | TERM_CAP_COLOR_256 | TERM_CAP_COLOR_16));
  }
 
  // Get width and height from parsed options (respects --width and --height flags)
  const options_t *opts = options_get();
  unsigned short width = opts ? opts->width : 110;
  unsigned short height = opts ? opts->height : 70;
 
  // Color scheme:
  // - Labels: grey
  // - Regular string values: blue (DEBUG - cyan/blue)
  // - Affirmative values (Yes, true): green (INFO)
  // - Bad/negative values (No, false, error): red (ERROR)
  // - Numbers and hex: magenta (FATAL)
  log_color_t label_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
  log_color_t string_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
  log_color_t good_color = use_colors ? LOG_COLOR_INFO : LOG_COLOR_GREY;
  log_color_t bad_color = use_colors ? LOG_COLOR_ERROR : LOG_COLOR_GREY;
  log_color_t number_color = use_colors ? LOG_COLOR_DEBUG : LOG_COLOR_GREY;
 
  printf("%s\n", colored_string(LOG_COLOR_WARN, "Terminal Capabilities:"));
 
  char size_buf[64];
  snprintf(size_buf, sizeof(size_buf), "%ux%u", width, height);
  printf("  %s: %s\n", colored_string(label_color, "Terminal Size"), colored_string(number_color, size_buf));
 
  // Color Level: green if good, red if none/bad
  const char *color_level_name = terminal_color_level_name(caps.color_level);
  log_color_t color_level_color = (caps.color_level == TERM_COLOR_NONE) ? bad_color : string_color;
  printf("  %s: %s\n", colored_string(label_color, "Color Level"),
         colored_string(color_level_color, (char *)color_level_name));
 
  char colors_buf[64];
  snprintf(colors_buf, sizeof(colors_buf), "%u", caps.color_count);
  printf("  %s: %s\n", colored_string(label_color, "Max Colors"), colored_string(number_color, colors_buf));
 
  // UTF-8: green if Yes, red if No
  log_color_t utf8_color = caps.utf8_support ? good_color : bad_color;
  printf("  %s: %s\n", colored_string(label_color, "UTF-8 Support"),
         colored_string(utf8_color, (char *)(caps.utf8_support ? "Yes" : "No")));
 
  const char *render_mode_str = "unknown";
  if (caps.render_mode == RENDER_MODE_FOREGROUND) {
    render_mode_str = "foreground";
  } else if (caps.render_mode == RENDER_MODE_BACKGROUND) {
    render_mode_str = "background";
  } else if (caps.render_mode == RENDER_MODE_HALF_BLOCK) {
    render_mode_str = "half-block";
  }
  printf("  %s: %s\n", colored_string(label_color, "Render Mode"),
         colored_string(string_color, (char *)render_mode_str));
  printf("  %s: %s\n", colored_string(label_color, "TERM"), colored_string(string_color, (char *)caps.term_type));
  printf("  %s: %s\n", colored_string(label_color, "COLORTERM"),
         colored_string(string_color, (char *)(strlen(caps.colorterm) ? caps.colorterm : "(not set)")));
 
  // Detection Reliable: green if Yes, red if No
  log_color_t reliable_color = caps.detection_reliable ? good_color : bad_color;
  printf("  %s: %s\n", colored_string(label_color, "Detection Reliable"),
         colored_string(reliable_color, (char *)(caps.detection_reliable ? "Yes" : "No")));
 
  char bitmask_buf[64];
  snprintf(bitmask_buf, sizeof(bitmask_buf), "0x%08x", caps.capabilities);
  printf("  %s: %s\n", colored_string(label_color, "Capabilities Bitmask"), colored_string(number_color, bitmask_buf));
 
  fflush(stdout);
 
  action_exit(0);
}
 
// ============================================================================
// Version Action
// ============================================================================
 
void action_show_version(void) {
  bool use_colors = terminal_should_color_output(STDOUT_FILENO);
  if (use_colors) {
    printf("%s %s (%s, %s)\n", colored_string(LOG_COLOR_WARN, "ascii-chat"),
           colored_string(LOG_COLOR_INFO, (char *)ASCII_CHAT_VERSION_FULL),
           colored_string(LOG_COLOR_DEBUG, (char *)ASCII_CHAT_BUILD_TYPE),
           colored_string(LOG_COLOR_GREY, (char *)ASCII_CHAT_BUILD_DATE));
  } else {
    printf("ascii-chat %s (%s, %s)\n", ASCII_CHAT_VERSION_FULL, ASCII_CHAT_BUILD_TYPE, ASCII_CHAT_BUILD_DATE);
  }
 
  action_exit(0);
}
 
// ============================================================================
// Help Actions
// ============================================================================
 
void action_help_server(void) {
  usage(stdout, MODE_SERVER);
  action_exit(0);
}
 
void action_help_client(void) {
  usage(stdout, MODE_CLIENT);
  action_exit(0);
}
 
void action_help_mirror(void) {
  usage(stdout, MODE_MIRROR);
  action_exit(0);
}
 
void action_help_acds(void) {
  usage(stdout, MODE_DISCOVERY_SERVICE);
  action_exit(0);
}
 
void action_help_discovery(void) {
  usage(stdout, MODE_DISCOVERY);
  action_exit(0);
}
 
// ============================================================================
// Man Page Generation Action
// ============================================================================
 
void action_create_manpage(const char *output_path) {
  // Get binary-level config
  const options_config_t *config = options_preset_unified(NULL, NULL);
 
  if (!config) {
    log_error("Failed to get binary options config");
    action_exit(ERROR_FILE_OPERATION);
  }
 
  // Determine output path: use provided path, or NULL for stdout
  const char *path_to_use = NULL;
  if (output_path && strlen(output_path) > 0 && strcmp(output_path, "-") != 0) {
    // User provided explicit path - use it
    path_to_use = output_path;
  } else {
    // No path or "-" means stdout
    path_to_use = NULL;
  }
 
  // Generate merged man page from embedded or filesystem resources
  // Resources are loaded automatically based on build type:
  // - Production (Release): From embedded binary data
  // - Development (Debug): From filesystem files
  asciichat_error_t err =
      options_config_generate_manpage_merged(config, "ascii-chat", NULL, path_to_use, "Video chat in your terminal");
 
  if (err != ASCIICHAT_OK) {
    asciichat_error_context_t err_ctx;
    if (HAS_ERRNO(&err_ctx)) {
      log_error("%s", err_ctx.context_message);
    } else {
      log_error("Failed to generate man page");
    }
    action_exit(ERROR_FILE_OPERATION);
  }
 
  if (path_to_use) {
    log_info("Man page written to: %s", path_to_use);
  } else {
    log_info("Man page written to stdout");
  }
 
  action_exit(0);
}
 
// ============================================================================
// Config Creation Action
// ============================================================================
 
void action_create_config(const char *output_path) {
  // Build the schema first so config_create_default can generate options from it
  const options_config_t *unified_config = options_preset_unified(NULL, NULL);
  if (unified_config) {
    asciichat_error_t schema_build_result = config_schema_build_from_configs(&unified_config, 1);
    if (schema_build_result != ASCIICHAT_OK) {
      // Schema build failed, but continue anyway
      (void)schema_build_result;
    }
    // options_config_destroy(unified_config);
  }
 
  const char *config_path = NULL;
 
  // Determine output path: use provided path, or NULL for stdout
  if (output_path && strlen(output_path) > 0 && strcmp(output_path, "-") != 0) {
    // User provided explicit path - use it as-is
    config_path = output_path;
  } else {
    // No path or "-" means stdout
    config_path = NULL;
  }
 
  // Create config with default options
  asciichat_error_t result = config_create_default(config_path);
  if (result != ASCIICHAT_OK) {
    asciichat_error_context_t err_ctx;
    if (HAS_ERRNO(&err_ctx)) {
      log_error("Error creating config: %s", err_ctx.context_message);
    } else {
      log_error("Failed to create config file");
    }
    action_exit(ERROR_CONFIG);
  }
 
  if (config_path) {
    log_info("Created default config file at: %s", config_path);
  } else {
    log_info("Config written to stdout");
  }
  action_exit(0);
}
 
// ============================================================================
// Shell Completions Action
// ============================================================================
 
void action_completions(const char *shell_name, const char *output_path) {
  if (!shell_name || strlen(shell_name) == 0) {
    log_error("--completions requires shell name (bash, fish, zsh, powershell)");
    action_exit(ERROR_USAGE);
  }
 
  completion_format_t format = completions_parse_shell_name(shell_name);
  if (format == COMPLETION_FORMAT_UNKNOWN) {
    log_error("Unknown shell '%s' (supported: bash, fish, zsh, powershell)", shell_name);
    action_exit(ERROR_USAGE);
  }
 
  FILE *output = stdout;
  bool should_close = false;
 
  // Determine output: use provided path if given and not "-", otherwise stdout
  if (output_path && strlen(output_path) > 0 && strcmp(output_path, "-") != 0) {
    // Check if file already exists and prompt for confirmation
    struct stat st;
    if (stat(output_path, &st) == 0) {
      // File exists - ask user if they want to overwrite
      log_plain("Completions file already exists: %s", output_path);
 
      bool overwrite = platform_prompt_yes_no("Overwrite", false); // Default to No
      if (!overwrite) {
        log_plain("Completions generation cancelled.");
        action_exit(0);
      }
 
      log_plain("Overwriting existing completions file...");
    }
 
    output = platform_fopen("file_stream", output_path, "w");
    if (!output) {
      log_error("Failed to open %s for writing", output_path);
      action_exit(ERROR_FILE_OPERATION);
    }
    should_close = true;
  }
 
  asciichat_error_t result = completions_generate_for_shell(format, output);
 
  if (should_close) {
    fclose(output);
  }
 
  if (result != ASCIICHAT_OK) {
    log_error("Failed to generate %s completions", completions_get_shell_name(format));
    action_exit(ERROR_USAGE);
  }
 
  // Silently exit - completions are written (either to file or stdout)
  action_exit(0);
}
 
static void execute_check_update(void) {
  printf("Checking for updates...\n");
 
  update_check_result_t result;
  asciichat_error_t err = update_check_perform(&result);
 
  if (err != ASCIICHAT_OK) {
    asciichat_error_context_t ctx;
    if (HAS_ERRNO(&ctx)) {
      fprintf(stderr, "Update check failed: %s\n", ctx.context_message);
    }
    action_exit(1);
  }
 
  // Display results
  if (result.update_available) {
    char notification[1024];
    update_check_format_notification(&result, notification, sizeof(notification));
    printf("\n%s\n\n", notification);
  } else {
    printf("\nYou are already on the latest version: %s (%.8s)\n\n", result.current_version, result.current_sha);
  }
 
  action_exit(0);
}
 
// ============================================================================
// Deferred Action Execution
// ============================================================================
 
void actions_execute_deferred(void) {
  deferred_action_t action = actions_get_deferred();
 
  switch (action) {
  case ACTION_NONE:
    // No action to execute
    break;
 
  case ACTION_LIST_WEBCAMS:
    execute_list_webcams();
    break;
 
  case ACTION_LIST_MICROPHONES:
    execute_list_microphones();
    break;
 
  case ACTION_LIST_SPEAKERS:
    execute_list_speakers();
    break;
 
  case ACTION_SHOW_CAPABILITIES:
    execute_show_capabilities();
    break;
 
  case ACTION_CHECK_UPDATE:
    execute_check_update();
    break;
 
  default:
    log_warn("Unknown deferred action: %d", action);
    break;
  }
}