raxol

defmodule Raxol.Core.Accessibility.AccessibilityServer do
  @moduledoc """
  Unified GenServer implementation for accessibility features in Raxol.

  This server consolidates all accessibility state management, eliminating
  Process dictionary usage across Accessibility, Announcements, and Metadata modules.

  ## Features
  - Screen reader announcements with queuing and priority
  - High contrast mode management
  - Reduced motion support
  - Large text support
  - Keyboard focus indicators
  - Accessibility metadata tracking
  - User preference integration
  - Theme integration for accessibility
  - Announcement history tracking

  ## State Structure
  The server maintains state with the following structure:
  ```elixir
  %{
    enabled: boolean(),
    preferences: %{
      screen_reader: boolean(),
      high_contrast: boolean(),
      reduced_motion: boolean(),
      large_text: boolean(),
      keyboard_focus: boolean(),
      silence_announcements: boolean()
    },
    announcements: %{
      queue: [announcement],
      history: [announcement],
      max_history: 100
    },
    metadata: %{component_id => metadata},
    theme_settings: map(),
    user_preferences_pid: pid() | nil,
    announcement_callback: function() | nil
  }
  ```
  """

  use GenServer
  require Logger
  alias Raxol.Core.Events.EventManager, as: EventManager

  @default_preferences %{
    screen_reader: true,
    high_contrast: false,
    reduced_motion: false,
    large_text: false,
    keyboard_focus: true,
    silence_announcements: false
  }

  @default_state %{
    enabled: false,
    preferences: @default_preferences,
    announcements: %{
      queue: [],
      history: [],
      max_history: 100
    },
    metadata: %{},
    theme_settings: %{},
    user_preferences_pid: nil,
    announcement_callback: nil
  }

  # Client API

  @doc """
  Starts the Accessibility server.
  """
  def start_link(opts \\ []) do
    name = Keyword.get(opts, :name, __MODULE__)
    initial_state = Keyword.get(opts, :initial_state, @default_state)
    GenServer.start_link(__MODULE__, initial_state, name: name)
  end

  @doc """
  Enables accessibility features with the given options.
  """
  def enable(server \\ __MODULE__, options \\ [], user_preferences_pid \\ nil) do
    GenServer.call(server, {:enable, options, user_preferences_pid})
  end

  @doc """
  Disables accessibility features.
  """
  def disable(server \\ __MODULE__) do
    GenServer.call(server, :disable)
  end

  @doc """
  Checks if accessibility is enabled.
  """
  def enabled?(server \\ __MODULE__) do
    GenServer.call(server, :is_enabled)
  end

  @doc """
  Makes an announcement for screen readers.

  ## Options
  - `:priority` - Priority level (:high, :medium, :low) default: :medium
  - `:interrupt` - Whether to interrupt current announcement default: false
  - `:language` - Language for the announcement
  """
  def announce(server \\ __MODULE__, message, opts \\ []) do
    GenServer.cast(server, {:announce, message, opts})
  end

  @doc """
  Announces with synchronous confirmation.
  """
  def announce_sync(server \\ __MODULE__, message, opts \\ []) do
    GenServer.call(server, {:announce_sync, message, opts})
  end

  @doc """
  Sets high contrast mode.
  """
  def set_high_contrast(server \\ __MODULE__, enabled)
      when is_boolean(enabled) do
    GenServer.call(server, {:set_preference, :high_contrast, enabled})
  end

  @doc """
  Gets high contrast mode status.
  """
  def high_contrast?(server \\ __MODULE__) do
    GenServer.call(server, {:get_preference, :high_contrast})
  end

  @doc """
  Sets reduced motion mode.
  """
  def set_reduced_motion(server \\ __MODULE__, enabled)
      when is_boolean(enabled) do
    GenServer.call(server, {:set_preference, :reduced_motion, enabled})
  end

  @doc """
  Gets reduced motion mode status.
  """
  def reduced_motion?(server \\ __MODULE__) do
    GenServer.call(server, {:get_preference, :reduced_motion})
  end

  @doc """
  Sets large text mode.
  """
  def set_large_text(server \\ __MODULE__, enabled) when is_boolean(enabled) do
    GenServer.call(server, {:set_preference, :large_text, enabled})
  end

  def set_large_text_with_prefs(
        server \\ __MODULE__,
        enabled,
        user_preferences_pid
      )
      when is_boolean(enabled) do
    GenServer.call(
      server,
      {:set_preference_with_prefs, :large_text, enabled, user_preferences_pid}
    )
  end

  @doc """
  Gets large text mode status.
  """
  def large_text?(server \\ __MODULE__) do
    GenServer.call(server, {:get_preference, :large_text})
  end

  @doc """
  Sets screen reader support.
  """
  def set_screen_reader(server \\ __MODULE__, enabled)
      when is_boolean(enabled) do
    GenServer.call(server, {:set_preference, :screen_reader, enabled})
  end

  @doc """
  Gets screen reader support status.
  """
  def screen_reader?(server \\ __MODULE__) do
    GenServer.call(server, {:get_preference, :screen_reader})
  end

  @doc """
  Sets keyboard focus indicators.
  """
  def set_keyboard_focus(server \\ __MODULE__, enabled)
      when is_boolean(enabled) do
    GenServer.call(server, {:set_preference, :keyboard_focus, enabled})
  end

  @doc """
  Sets accessibility metadata for a component.
  """
  def set_metadata(server \\ __MODULE__, component_id, metadata) do
    GenServer.call(server, {:set_metadata, component_id, metadata})
  end

  @doc """
  Registers element metadata for a component.
  """
  def register_element_metadata(element_id, metadata) do
    register_element_metadata(__MODULE__, element_id, metadata)
  end

  def register_element_metadata(server, element_id, metadata) do
    GenServer.call(server, {:register_metadata, element_id, metadata})
  end

  @doc """
  Gets element metadata for a component.
  """
  def get_element_metadata(element_id) do
    get_element_metadata(__MODULE__, element_id)
  end

  def get_element_metadata(server, element_id) do
    GenServer.call(server, {:get_metadata, element_id})
  end

  @doc """
  Gets accessibility metadata for a component.
  """
  def get_metadata(server \\ __MODULE__, component_id) do
    GenServer.call(server, {:get_metadata, component_id})
  end

  @doc """
  Removes metadata for a component.
  """
  def remove_metadata(server \\ __MODULE__, component_id) do
    GenServer.call(server, {:remove_metadata, component_id})
  end

  @doc """
  Gets all current preferences.
  """
  def get_preferences(server \\ __MODULE__) do
    GenServer.call(server, :get_preferences)
  end

  @doc """
  Adds an announcement to the queue.
  """
  def add_announcement(announcement, user_preferences_pid_or_name \\ nil) do
    add_announcement(__MODULE__, announcement, user_preferences_pid_or_name)
  end

  def add_announcement(server, announcement, _user_preferences_pid_or_name) do
    GenServer.cast(server, {:announce, announcement, []})
  end

  @doc """
  Gets the next announcement from the queue.
  """
  def get_next_announcement(user_preferences_pid_or_name \\ nil) do
    get_next_announcement(__MODULE__, user_preferences_pid_or_name)
  end

  def get_next_announcement(server, _user_preferences_pid_or_name) do
    GenServer.call(server, :get_next_announcement)
  end

  @doc """
  Clears all announcements from the queue.
  """
  def clear_all_announcements do
    clear_all_announcements(__MODULE__)
  end

  def clear_all_announcements(server) do
    GenServer.call(server, :clear_all_announcements)
  end

  @doc """
  Clears announcements for a specific user.
  """
  def clear_announcements(user_preferences_pid_or_name) do
    clear_announcements(__MODULE__, user_preferences_pid_or_name)
  end

  def clear_announcements(server, _user_preferences_pid_or_name) do
    GenServer.call(server, :clear_all_announcements)
  end

  @doc """
  Gets announcement history.
  """
  def get_announcement_history(server \\ __MODULE__, limit \\ nil) do
    GenServer.call(server, {:get_announcement_history, limit})
  end

  @doc """
  Clears announcement history.
  """
  def clear_announcement_history(server \\ __MODULE__) do
    GenServer.call(server, :clear_announcement_history)
  end

  @doc """
  Sets the announcement callback function.
  """
  def set_announcement_callback(server \\ __MODULE__, callback)
      when is_function(callback, 1) do
    GenServer.call(server, {:set_announcement_callback, callback})
  end

  @doc """
  Gets the current state (for debugging/testing).
  """
  def get_state(server \\ __MODULE__) do
    GenServer.call(server, :get_state)
  end

  @doc """
  Checks if announcements should be made.
  """
  def should_announce?(user_preferences_pid_or_name \\ nil) do
    # If user preferences provided, check if announcements are enabled
    case user_preferences_pid_or_name do
      # Default to allowing announcements
      nil ->
        true

      pid when is_pid(pid) ->
        # Try to check user preferences, default to true if unavailable
        try do
          GenServer.call(pid, :get_silence_announcements, 1000)
          |> case do
            {:ok, silence} -> not silence
            _ -> true
          end
        catch
          :exit, _ -> true
        end

      name when is_atom(name) ->
        case Process.whereis(name) do
          nil -> true
          pid -> should_announce?(pid)
        end

      _ ->
        true
    end
  end

  @doc """
  Handles focus change events.
  """
  def handle_focus_change(server \\ __MODULE__, old_focus, new_focus) do
    GenServer.cast(server, {:handle_focus_change, old_focus, new_focus})
  end

  @doc """
  Gets an option value.
  """
  def get_option(key, default \\ nil) do
    get_option(__MODULE__, key, default)
  end

  def get_option(server, key, default) do
    case GenServer.call(server, {:get_preference, key}) do
      nil -> default
      value -> value
    end
  end

  @doc """
  Sets an option value.
  """
  def set_option(key, value) do
    set_option(__MODULE__, key, value)
  end

  def set_option(server, key, value) do
    GenServer.call(server, {:set_preference, key, value})
  end

  @doc """
  Gets a component hint.
  """
  def get_component_hint(component_id, hint_level \\ :normal) do
    get_component_hint(__MODULE__, component_id, hint_level)
  end

  def get_component_hint(server, component_id, _hint_level) do
    case GenServer.call(server, {:get_metadata, component_id}) do
      nil -> nil
      metadata -> Map.get(metadata, :hint)
    end
  end

  @doc """
  Registers component style.
  """
  def register_component_style(component_type, style) do
    register_component_style(__MODULE__, component_type, style)
  end

  def register_component_style(server, component_type, style) do
    GenServer.call(server, {:register_component_style, component_type, style})
  end

  @doc """
  Gets component style.
  """
  def get_component_style(component_type) do
    get_component_style(__MODULE__, component_type)
  end

  def get_component_style(server, component_type) do
    GenServer.call(server, {:get_component_style, component_type})
  end

  @doc """
  Unregisters component style.
  """
  def unregister_component_style(component_type) do
    unregister_component_style(__MODULE__, component_type)
  end

  def unregister_component_style(server, component_type) do
    GenServer.call(server, {:unregister_component_style, component_type})
  end

  @doc """
  Unregisters element metadata.
  """
  def unregister_element_metadata(element_id) do
    unregister_element_metadata(__MODULE__, element_id)
  end

  def unregister_element_metadata(server, element_id) do
    GenServer.call(server, {:remove_metadata, element_id})
  end

  @doc """
  Gets focus history.
  """
  def get_focus_history do
    get_focus_history(__MODULE__)
  end

  def get_focus_history(server) do
    GenServer.call(server, :get_focus_history)
  end

  # GenServer Callbacks

  @impl GenServer
  def init(initial_state) do
    {:ok, initial_state}
  end

  @impl GenServer
  def handle_call({:enable, options, user_preferences_pid}, _from, state) do
    preferences = merge_preferences(state.preferences, options)

    new_state = %{
      state
      | enabled: true,
        preferences: preferences,
        user_preferences_pid: user_preferences_pid
    }

    # Sync preferences with UserPreferences if pid is provided
    case user_preferences_pid do
      nil -> :ok
      pid -> sync_preferences_to_user_preferences(preferences, pid)
    end

    # Register event handlers
    register_event_handlers()

    # Dispatch accessibility enabled event
    EventManager.dispatch({:accessibility_enabled, preferences})

    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(:disable, _from, state) do
    new_state = %{state | enabled: false}

    # Unregister event handlers
    unregister_event_handlers()

    # Dispatch accessibility disabled event
    EventManager.dispatch(:accessibility_disabled)

    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(:is_enabled, _from, state) do
    {:reply, state.enabled, state}
  end

  @impl GenServer
  def handle_call({:set_preference, key, value}, _from, state) do
    new_preferences = Map.put(state.preferences, key, value)
    new_state = %{state | preferences: new_preferences}

    # Sync to UserPreferences if available
    case state.user_preferences_pid do
      nil ->
        :ok

      pid ->
        pref_key = [:accessibility, key]
        Raxol.Core.UserPreferences.set(pref_key, value, pid)
    end

    # Dispatch preference change event
    EventManager.dispatch({:accessibility_preference_changed, key, value})

    # Special handling for high contrast to notify ColorSystem
    if key == :high_contrast do
      # Notify ColorSystem.Server directly
      if Process.whereis(Raxol.Style.Colors.System.Server) do
        Raxol.Style.Colors.System.handle_high_contrast(
          {:accessibility_high_contrast, value}
        )
      end
    end

    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(
        {:set_preference_with_prefs, key, value, user_preferences_pid},
        _from,
        state
      ) do
    new_preferences = Map.put(state.preferences, key, value)
    new_state = %{state | preferences: new_preferences}

    # Sync to UserPreferences using provided pid
    case user_preferences_pid do
      nil ->
        :ok

      pid ->
        pref_key = [:accessibility, key]
        Raxol.Core.UserPreferences.set(pref_key, value, pid)
    end

    # Dispatch preference change event
    EventManager.dispatch({:accessibility_preference_changed, key, value})

    # Special handling for high contrast to notify ColorSystem
    if key == :high_contrast do
      # Notify ColorSystem.Server directly
      if Process.whereis(Raxol.Style.Colors.System.Server) do
        Raxol.Style.Colors.System.handle_high_contrast(
          {:accessibility_high_contrast, value}
        )
      end
    end

    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:get_preference, key}, _from, state) do
    value =
      case key do
        :enabled -> state.enabled
        _ -> Map.get(state.preferences, key, false)
      end

    {:reply, value, state}
  end

  @impl GenServer
  def handle_call(:get_preferences, _from, state) do
    {:reply, state.preferences, state}
  end

  @impl GenServer
  def handle_call({:announce_sync, message, opts}, _from, state) do
    new_state = process_announcement(state, message, opts)
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:set_metadata, component_id, metadata}, _from, state) do
    new_metadata = Map.put(state.metadata, component_id, metadata)
    new_state = %{state | metadata: new_metadata}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:get_metadata, component_id}, _from, state) do
    metadata = Map.get(state.metadata, component_id)
    {:reply, metadata, state}
  end

  @impl GenServer
  def handle_call({:remove_metadata, component_id}, _from, state) do
    new_metadata = Map.delete(state.metadata, component_id)
    new_state = %{state | metadata: new_metadata}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:get_announcement_history, limit}, _from, state) do
    history = get_limited_history(state.announcements.history, limit)

    {:reply, history, state}
  end

  @impl GenServer
  def handle_call(:clear_announcement_history, _from, state) do
    new_announcements = %{state.announcements | history: []}
    new_state = %{state | announcements: new_announcements}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:set_announcement_callback, callback}, _from, state) do
    new_state = %{state | announcement_callback: callback}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(:get_state, _from, state) do
    {:reply, state, state}
  end

  @impl GenServer
  def handle_call(:get_next_announcement, _from, state) do
    Raxol.Core.Runtime.Log.debug(
      "get_next_announcement: queue length=#{length(state.announcements.queue)}"
    )

    case state.announcements.queue do
      [] ->
        Raxol.Core.Runtime.Log.debug(
          "get_next_announcement: queue is empty, returning nil"
        )

        {:reply, nil, state}

      [announcement | rest] ->
        Raxol.Core.Runtime.Log.debug(
          "get_next_announcement: found announcement=#{announcement.message}"
        )

        new_announcements = %{state.announcements | queue: rest}
        new_state = %{state | announcements: new_announcements}
        {:reply, announcement.message, new_state}
    end
  end

  @impl GenServer
  def handle_call(:clear_all_announcements, _from, state) do
    new_announcements = %{state.announcements | queue: []}
    new_state = %{state | announcements: new_announcements}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:register_metadata, element_id, metadata}, _from, state) do
    new_metadata = Map.put(state.metadata, element_id, metadata)
    new_state = %{state | metadata: new_metadata}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(
        {:register_component_style, component_type, style},
        _from,
        state
      ) do
    # Store component styles in metadata with a special key
    style_key = {:component_style, component_type}
    new_metadata = Map.put(state.metadata, style_key, style)
    new_state = %{state | metadata: new_metadata}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call({:get_component_style, component_type}, _from, state) do
    style_key = {:component_style, component_type}
    style = Map.get(state.metadata, style_key, %{})
    {:reply, style, state}
  end

  @impl GenServer
  def handle_call({:unregister_component_style, component_type}, _from, state) do
    style_key = {:component_style, component_type}
    new_metadata = Map.delete(state.metadata, style_key)
    new_state = %{state | metadata: new_metadata}
    {:reply, :ok, new_state}
  end

  @impl GenServer
  def handle_call(:get_focus_history, _from, state) do
    # Return focus history from metadata or empty list
    focus_history = Map.get(state.metadata, :focus_history, [])
    {:reply, focus_history, state}
  end

  @impl GenServer
  def handle_cast({:announce, message, opts}, state) do
    new_state = process_announcement(state, message, opts)
    {:noreply, new_state}
  end

  @impl GenServer
  def handle_cast({:handle_focus_change, _old_focus, new_focus}, state) do
    handle_focus_change_with_state(state, new_focus)
  end

  # Private Helper Functions

  @spec get_limited_history(any(), any()) :: any() | nil
  defp get_limited_history(history, nil), do: history
  @spec get_limited_history(any(), any()) :: any() | nil
  defp get_limited_history(history, limit), do: Enum.take(history, limit)

  @spec handle_focus_change_with_state(map(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_focus_change_with_state(state, new_focus) do
    should_announce = state.enabled && state.preferences.screen_reader

    Raxol.Core.Runtime.Log.debug(
      "handle_focus_change_with_state: new_focus=#{inspect(new_focus)}, enabled=#{state.enabled}, screen_reader=#{state.preferences.screen_reader}, should_announce=#{should_announce}"
    )

    handle_focus_announcement(should_announce, state, new_focus)
  end

  @spec handle_focus_announcement(any(), map(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_focus_announcement(false, state, _new_focus),
    do: {:noreply, state}

  @spec handle_focus_announcement(any(), map(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_focus_announcement(true, state, new_focus) do
    # Get metadata for the new focus
    metadata = Map.get(state.metadata, new_focus, %{})

    Raxol.Core.Runtime.Log.debug(
      "handle_focus_announcement: new_focus=#{new_focus}, metadata=#{inspect(metadata)}"
    )

    # Create announcement based on metadata
    announcement_text = create_focus_announcement(new_focus, metadata)

    Raxol.Core.Runtime.Log.debug(
      "handle_focus_announcement: announcement_text=#{announcement_text}"
    )

    # Create announcement object directly
    announcement = %{
      message: announcement_text,
      priority: :high,
      timestamp: DateTime.utc_now(),
      opts: [priority: :high]
    }

    # Add directly to queue and history
    new_history = [announcement | state.announcements.history]
    limited_history = Enum.take(new_history, state.announcements.max_history)
    # Queue should be FIFO: append to end, take from front
    new_queue = state.announcements.queue ++ [announcement]

    # Dispatch event for other systems
    _ =
      EventManager.dispatch(:screen_reader_announcement, %{
        text: announcement_text
      })

    new_announcements = %{
      state.announcements
      | history: limited_history,
        queue: new_queue
    }

    new_state = %{state | announcements: new_announcements}
    {:noreply, new_state}
  end

  @spec should_process_announcement?(map()) :: boolean()
  defp should_process_announcement?(state) do
    result =
      state.enabled && state.preferences.screen_reader &&
        !state.preferences.silence_announcements

    Raxol.Core.Runtime.Log.debug(
      "should_process_announcement? enabled=#{state.enabled}, screen_reader=#{state.preferences.screen_reader}, silence_announcements=#{state.preferences.silence_announcements}, result=#{result}"
    )

    result
  end

  @spec handle_announcement_delivery(any(), any(), any(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_announcement_delivery(true, queue, announcement, callback) do
    # Immediate announcement when interrupt is true
    Raxol.Core.Runtime.Log.debug(
      "handle_announcement_delivery: interrupt=true, delivering immediately"
    )

    deliver_announcement(announcement, callback)
    # Still add to queue for testing/retrieval purposes (FIFO)
    new_queue = queue ++ [announcement]

    Raxol.Core.Runtime.Log.debug(
      "handle_announcement_delivery: added to queue, new length=#{length(new_queue)}"
    )

    new_queue
  end

  @spec handle_announcement_delivery(any(), any(), any(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_announcement_delivery(false, queue, announcement, callback) do
    Raxol.Core.Runtime.Log.debug(
      "handle_announcement_delivery: interrupt=false, checking queue"
    )

    handle_queue_delivery(Enum.empty?(queue), queue, announcement, callback)
  end

  @spec handle_queue_delivery(any(), any(), any(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_queue_delivery(true, queue, announcement, callback) do
    # Immediate announcement when queue is empty
    deliver_announcement(announcement, callback)
    # Add to queue for retrieval purposes (FIFO)
    queue ++ [announcement]
  end

  @spec handle_queue_delivery(any(), any(), any(), any()) ::
          {:ok, any()}
          | {:error, any()}
          | {:reply, any(), any()}
          | {:noreply, any()}
  defp handle_queue_delivery(false, queue, announcement, callback) do
    # Queue announcement based on priority
    new_queue = insert_by_priority(queue, announcement)
    process_queue(new_queue, callback)
    new_queue
  end

  @spec call_callback_if_present(any(), String.t()) :: any()
  defp call_callback_if_present(nil, _message), do: :ok
  @spec call_callback_if_present(any(), String.t()) :: any()
  defp call_callback_if_present(callback, message), do: callback.(message)

  @spec merge_preferences(any(), any()) :: any()
  defp merge_preferences(current, options) do
    options_map = Enum.into(options, %{})
    Map.merge(current, options_map)
  end

  defp register_event_handlers do
    EventManager.register_handler(
      :focus_change,
      __MODULE__,
      :handle_focus_change_event
    )

    EventManager.register_handler(
      :preference_changed,
      __MODULE__,
      :handle_preference_changed_event
    )

    EventManager.register_handler(
      :theme_changed,
      __MODULE__,
      :handle_theme_changed_event
    )
  end

  defp unregister_event_handlers do
    EventManager.unregister_handler(
      :focus_change,
      __MODULE__,
      :handle_focus_change_event
    )

    EventManager.unregister_handler(
      :preference_changed,
      __MODULE__,
      :handle_preference_changed_event
    )

    EventManager.unregister_handler(
      :theme_changed,
      __MODULE__,
      :handle_theme_changed_event
    )
  end

  @spec process_announcement(map(), String.t(), keyword()) :: any()
  defp process_announcement(state, message, opts) do
    Raxol.Core.Runtime.Log.debug(
      "process_announcement called with message: #{message}"
    )

    should_process = should_process_announcement?(state)

    Raxol.Core.Runtime.Log.debug(
      "should_process_announcement?: #{should_process}"
    )

    case should_process do
      true ->
        priority = Keyword.get(opts, :priority, :medium)
        interrupt = Keyword.get(opts, :interrupt, false)

        announcement = %{
          message: message,
          priority: priority,
          timestamp: DateTime.utc_now(),
          opts: opts
        }

        Raxol.Core.Runtime.Log.debug(
          "Created announcement object: #{inspect(announcement)}"
        )

        # Add to history
        new_history = [announcement | state.announcements.history]

        limited_history =
          Enum.take(new_history, state.announcements.max_history)

        # Process announcement and update queue
        new_queue =
          handle_announcement_delivery(
            interrupt,
            state.announcements.queue,
            announcement,
            state.announcement_callback
          )

        Raxol.Core.Runtime.Log.debug(
          "New queue after delivery: #{inspect(new_queue)}"
        )

        new_announcements = %{
          state.announcements
          | history: limited_history,
            queue: new_queue
        }

        new_state = %{state | announcements: new_announcements}

        Raxol.Core.Runtime.Log.debug(
          "Returning new state with queue length: #{length(new_state.announcements.queue)}"
        )

        new_state

      false ->
        Raxol.Core.Runtime.Log.debug(
          "Not processing announcement - conditions not met"
        )

        state
    end
  end

  @spec deliver_announcement(any(), any()) :: any()
  defp deliver_announcement(announcement, callback) do
    Raxol.Core.Runtime.Log.debug(
      "deliver_announcement: #{announcement.message}"
    )

    # Call the callback if provided
    call_callback_if_present(callback, announcement.message)

    # Dispatch event for other systems
    EventManager.dispatch({:screen_reader_announcement, announcement.message})

    Raxol.Core.Runtime.Log.debug(
      "deliver_announcement: dispatched screen reader event"
    )
  end

  @spec insert_by_priority(any(), any()) :: any()
  defp insert_by_priority(queue, announcement) do
    Enum.sort_by([announcement | queue], fn a ->
      case a.priority do
        :high -> 1
        :medium -> 2
        :low -> 3
      end
    end)
  end

  @spec process_queue(any(), any()) :: any()
  defp process_queue([], _callback), do: :ok

  @spec process_queue(any(), any()) :: any()
  defp process_queue([announcement | _rest], callback) do
    deliver_announcement(announcement, callback)
  end

  @spec create_focus_announcement(String.t() | integer(), any()) :: any()
  defp create_focus_announcement(component_id, metadata) do
    label = Map.get(metadata, :label, component_id)
    explicit_role = Map.get(metadata, :role)
    description = Map.get(metadata, :description, "")

    # Start with just the label
    parts = [label]

    # Only add role if it was explicitly set (not default)
    parts =
      case explicit_role do
        nil -> parts
        role -> parts ++ [role]
      end

    # Add description if present
    parts =
      case description != "" do
        true -> parts ++ [description]
        false -> parts
      end

    Enum.join(parts, ", ")
  end

  # Event handler callbacks (called by EventManager)
  def handle_focus_change_event({:focus_change, old_focus, new_focus}) do
    handle_focus_change(__MODULE__, old_focus, new_focus)
  end

  def handle_focus_change_event(event_type, event_data) when event_type == :focus_change do
    case event_data do
      %{nil: new_focus} ->
        # Handle the case where EventManager converts {nil, new_focus} to %{nil: new_focus}
        handle_focus_change(__MODULE__, nil, new_focus)
      {old_focus, new_focus} ->
        # Handle direct tuple format
        handle_focus_change(__MODULE__, old_focus, new_focus)
      new_focus when is_binary(new_focus) ->
        # Handle simple string format
        handle_focus_change(__MODULE__, nil, new_focus)
      map when is_map(map) ->
        # Handle maps like %{"search_button" => "text_input"} - take the values
        case Map.values(map) do
          [new_focus] -> handle_focus_change(__MODULE__, nil, new_focus)
          [old_focus, new_focus] -> handle_focus_change(__MODULE__, old_focus, new_focus)
          _ -> handle_focus_change(__MODULE__, nil, inspect(map))
        end
      _ ->
        handle_focus_change(__MODULE__, nil, event_data)
    end
  end

  def handle_focus_change_event(old_focus, new_focus) do
    handle_focus_change(__MODULE__, old_focus, new_focus)
  end

  def handle_preference_changed_event({:preference_changed, _key, _value}) do
    # Handle preference changes from other systems
    :ok
  end

  def handle_theme_changed_event({:theme_changed, _theme}) do
    # Handle theme changes that might affect accessibility
    :ok
  end

  @impl GenServer
  def handle_info({:preferences_applied, _name}, state) do
    # Ignore preferences_applied messages from UserPreferences
    {:noreply, state}
  end

  def handle_info(msg, state) do
    Raxol.Core.Runtime.Log.error(
      "#{__MODULE__} received unexpected message in handle_info/2: #{inspect(msg)}"
    )

    {:noreply, state}
  end

  # Helper function to sync accessibility preferences to UserPreferences
  @spec sync_preferences_to_user_preferences(
          reference(),
          String.t() | integer()
        ) :: any()
  defp sync_preferences_to_user_preferences(preferences, user_preferences_pid) do
    # Define the accessibility preference keys that should be synced
    preference_keys = [
      :high_contrast,
      :reduced_motion,
      :large_text,
      :screen_reader,
      :keyboard_focus,
      :silence_announcements
    ]

    # Sync each preference to UserPreferences
    Enum.each(preference_keys, fn key ->
      value = Map.get(preferences, key, false)
      pref_key = [:accessibility, key]
      Raxol.Core.UserPreferences.set(pref_key, value, user_preferences_pid)
    end)
  end
end