updated_remix

defmodule Remix.Worker do
  require Logger
  use GenServer

  def start_link() do
    GenServer.start_link(__MODULE__, %{}, name: Remix.Worker)
  end

  def init(state) do
    Process.send_after(__MODULE__, :poll_and_reload, 10000)
    {:ok, state}
  end

  def handle_info(:poll_and_reload, state) do
    Logger.info("Started the handle info with state: #{inspect(state)}")
    paths = Application.get_all_env(:updated_remix)[:paths]
    Logger.info("paths: #{inspect(paths)}")

    new_state =
      Map.new(paths, fn path ->
        Logger.info("Started Map.new")
        Logger.info("path: #{inspect(path)}")
        current_mtime = get_current_mtime(path)
        Logger.info("current_mtime: #{inspect(current_mtime)}")

        last_mtime =
          case Map.fetch(state, path) do
            {:ok, val} -> val
            :error -> nil
          end

        Logger.info("last_mtime: #{inspect(last_mtime)}")
        handle_path(path, current_mtime, last_mtime)
      end)

    Process.send_after(__MODULE__, :poll_and_reload, 1000)
    {:noreply, new_state}
  end

  def handle_path(path, current_mtime, current_mtime), do: {path, current_mtime}

  def handle_path(path, current_mtime, _) do
    comp_elixir = fn -> Mix.Tasks.Compile.Elixir.run(["--ignore-module-conflict"]) end
    comp_escript = fn -> Mix.Tasks.Escript.Build.run([]) end

    case Application.get_all_env(:remix)[:silent] do
      true ->
        ExUnit.CaptureIO.capture_io(comp_elixir)

        if Application.get_all_env(:remix)[:escript] == true do
          ExUnit.CaptureIO.capture_io(comp_escript)
        end

      _ ->
        comp_elixir.()

        if Application.get_all_env(:remix)[:escript] == true do
          comp_escript.()
        end
    end

    {path, current_mtime}
  end

  def get_current_mtime(dir) do
    case File.ls(dir) do
      {:ok, files} -> get_current_mtime(files, [], dir)
      _ -> nil
    end
  end

  def get_current_mtime([], mtimes, _cwd) do
    mtimes
    |> Enum.sort()
    |> Enum.reverse()
    |> List.first()
  end

  def get_current_mtime([head | tail], mtimes, cwd) do
    mtime =
      case File.dir?("#{cwd}/#{head}") do
        true -> get_current_mtime("#{cwd}/#{head}")
        false -> File.stat!("#{cwd}/#{head}").mtime
      end

    get_current_mtime(tail, [mtime | mtimes], cwd)
  end
end