tesseract_ecs

defmodule Tesseract.ECS.Scene do
  alias Tesseract.ECS.{Entity, System}
  alias Tesseract.ECS.Entity.Supervisor, as: EntitySupervisor
  alias Tesseract.Ext.EnumExt

  defstruct label: nil,
            game_id: nil,
            systems: [],
            entities: %{},
            systems_by_action: %{}

  use GenServer
  use Tesseract.Ext.MapLike, for: Tesseract.ECS.Scene
  use Tesseract.Ext.MapAccess

  def via_tuple(label) do
    {:via, :gproc, {:n, :l, {:scene, label}}}
  end

  # =======================
  # == Client interface. ==
  # =======================

  def make(label, params \\ [])

  def make(label, %__MODULE__{} = params) do
    %{params | label: label}
  end

  def make(label, params) do
    params
    |> Enum.into(%__MODULE__{})
    |> Map.put(:label, label)
  end

  def start_link(params \\ []) do
    if params[:label] === nil do
      raise "label needs to be set."
    end

    params = params[:label] |> make(params)

    GenServer.start_link(__MODULE__, params, name: via_tuple(params[:label]))
  end

  # TODO: remove.
  def get_state(label) do
    GenServer.call(via_tuple(label), :get_state)
  end

  def get_entities(label) do
    GenServer.call(via_tuple(label), :get_entities)
  end

  def dispatch(label, receiver, {_, _, _} = action) do
    GenServer.cast(via_tuple(label), {:dispatch, receiver, action})
  end

  # def dispatch(label, {_, _, _} = action) do
  #   # TODO: broadcast.
  # end

  def add_entity(label, %Entity{} = entity_cfg) do
    GenServer.cast(via_tuple(label), {:add_entity, entity_cfg})
  end

  # =============
  # == Server. ==
  # =============
  def init(%__MODULE__{} = state) do
    state =
      state
      |> index_system_actions()
      |> init_entities

    {:ok, state}
  end

  def handle_call(:get_state, _from, %__MODULE__{} = state) do
    {:reply, state, state}
  end

  def handle_call(:get_systems, _from, %__MODULE__{systems: systems} = state) do
    {:reply, systems, state}
  end

  def handle_call(:get_entities, _from, %__MODULE__{entities: entities} = state) do
    {:reply, entities, state}
  end

  def handle_cast({:dispatch, receiver, action}, %__MODULE__{} = state) do
    unicast(receiver, action, state)

    {:noreply, state}
  end

  def handle_cast({:add_entity, %Entity{} = cfg}, %__MODULE__{} = state) do
    {:noreply, cfg |> init_entity(state)}
  end

  defp unicast(receiver, {action_name, _, _} = action, %__MODULE__{} = state) do
    receiver_entity = state.entities |> Map.fetch!(receiver)

    state.systems_by_action
    |> Map.get(action_name, [])
    |> Enum.map(&Enum.find(state.systems, nil, fn sys -> sys.label == &1 end))
    |> Enum.filter(fn sys -> Entity.has_components?(receiver_entity, sys.components) end)
    |> Enum.each(&(:ok = Entity.process(receiver, action, &1)))
  end

  defp init_entities(%__MODULE__{entities: entities} = state) do
    clean_state = %{state | entities: %{}}

    entities |> Enum.reduce(clean_state, &init_entity/2)
  end

  defp init_entity(%Entity{} = entity_cfg, %__MODULE__{} = state) do
    entity_cfg = entity_cfg |> Map.put(:game_id, state.game_id)
    state = %{state | entities: state.entities |> Map.put(entity_cfg.label, entity_cfg)}

    {:ok, _} = EntitySupervisor.start_child(state.label, entity_cfg)
    unicast(entity_cfg.label, {:spawn, nil, nil}, state)

    state
  end

  defp index_system_actions(%__MODULE__{systems: systems} = state) do
    sys_actions = fn %System{} = sys -> sys.actions end
    sys_label = fn %System{} = sys -> sys.label end

    multi_grouped = EnumExt.multigroup_by(systems, sys_actions, sys_label)
    %{state | systems_by_action: multi_grouped}
  end
end