property_damage

defmodule Mix.Tasks.Pd.Validate do
  @moduledoc """
  Validates a PropertyDamage model and adapter configuration.

  This task checks that your model is correctly configured before running tests,
  catching common mistakes early.

  ## Usage

      mix pd.validate MyApp.TestModel MyApp.TestAdapter

  ## What Gets Checked

  ### Errors (validation fails)
  - Model module exists and implements required callbacks
  - Adapter module exists and implements required callbacks
  - All command modules exist and implement required callbacks
  - All projection modules exist
  - Injectable events are covered by injector adapters

  ### Warnings (validation passes with warnings)
  - Commands missing `downstream_observables/0`
  - Events produced but not handled by assertion projections
  - Missing optional callbacks that may be useful

  ## Options

      --verbose    Show detailed information about the model
      --strict     Treat warnings as errors

  ## Examples

      # Basic validation
      mix pd.validate MyApp.TestModel MyApp.TestAdapter

      # With verbose output
      mix pd.validate MyApp.TestModel MyApp.TestAdapter --verbose

      # Fail on warnings
      mix pd.validate MyApp.TestModel MyApp.TestAdapter --strict
  """

  use Mix.Task

  @shortdoc "Validate PropertyDamage model configuration"

  @impl true
  def run(args) do
    args |> exec() |> halt_on_error()
  end

  # Run the validation and return its status (`:ok` or `:error`) without halting.
  # This is the testable seam: `run/1` is a thin wrapper that calls `exec/1` and
  # translates an `:error` status into a non-zero `System.halt`, so the decision
  # logic can be exercised in-process without killing the VM.
  @doc false
  @spec exec([String.t()]) :: :ok | :error
  def exec(args) do
    {opts, argv, _} = OptionParser.parse(args, strict: [verbose: :boolean, strict: :boolean])
    verbose = Keyword.get(opts, :verbose, false)
    strict = Keyword.get(opts, :strict, false)

    dispatch(argv, verbose, strict)
  end

  defp dispatch([model_str, adapter_str], verbose, strict) do
    # Ensure code is compiled
    Mix.Task.run("compile", [])

    # Convert strings to modules
    model = parse_module(model_str)
    adapter = parse_module(adapter_str)

    validate_and_report(model, adapter, verbose, strict)
  end

  defp dispatch([model_str], verbose, strict) do
    # Only model provided - show helpful message
    Mix.Task.run("compile", [])
    model = parse_module(model_str)

    IO.puts("\n")
    print_color(:yellow, "Note: No adapter specified. Validating model only.\n")
    validate_model_only(model, verbose, strict)
  end

  defp dispatch([], _verbose, _strict) do
    print_usage()
    :ok
  end

  defp dispatch(_argv, _verbose, _strict) do
    print_color(:red, "Error: Expected 1 or 2 arguments (model and optional adapter)\n")
    print_usage()
    :error
  end

  defp halt_on_error(:error), do: System.halt(1)
  defp halt_on_error(_), do: :ok

  defp parse_module(string) do
    string
    |> String.replace(~r/^Elixir\./, "")
    |> then(&("Elixir." <> &1))
    |> String.to_atom()
  end

  defp validate_and_report(model, adapter, verbose, strict) do
    IO.puts("\n")
    print_header("PropertyDamage Validation")
    IO.puts("")

    # Check if modules exist
    model_exists = Code.ensure_loaded?(model)
    adapter_exists = Code.ensure_loaded?(adapter)

    cond do
      not model_exists ->
        print_color(:red, "ERROR: Model module #{inspect(model)} does not exist\n")
        print_hint("Make sure the module is defined and the project is compiled.")
        :error

      not adapter_exists ->
        print_color(:red, "ERROR: Adapter module #{inspect(adapter)} does not exist\n")
        print_hint("Make sure the module is defined and the project is compiled.")
        :error

      true ->
        # Run validation
        case PropertyDamage.Validation.validate!(model, adapter) do
          {:ok, base_warnings} ->
            # Surface declared-but-unchecked invariants (static vacuity, DR-026)
            # so they fail under --strict alongside the other warnings.
            warnings = base_warnings ++ invariant_warnings(model)

            if verbose do
              PropertyDamage.Validation.print_summary(model, adapter, base_warnings)
              print_invariant_catalog(model)
            end

            print_validation_results(model, adapter, warnings, verbose)

            if strict and warnings != [] do
              IO.puts("")
              print_color(:red, "FAILED: #{length(warnings)} warning(s) in strict mode\n")
              :error
            else
              print_color(:green, "\nVALIDATION PASSED\n")
              :ok
            end
        end
    end
  rescue
    e in ArgumentError ->
      IO.puts("")
      print_color(:red, "VALIDATION FAILED\n")
      IO.puts("")
      print_errors_with_hints(e.message)
      :error
  end

  defp validate_model_only(model, verbose, strict) do
    if Code.ensure_loaded?(model) do
      validate_loaded_model_only(model, verbose, strict)
    else
      print_color(:red, "ERROR: Model module #{inspect(model)} does not exist\n")
      :error
    end
  end

  defp validate_loaded_model_only(model, verbose, strict) do
    case missing_required_callbacks(model) do
      [] ->
        report_model_only(model, verbose, strict)

      missing ->
        print_color(:red, "ERRORS:\n")
        Enum.each(missing, fn error -> IO.puts("  - #{error}") end)
        :error
    end
  end

  defp missing_required_callbacks(model) do
    for callback <- [:commands, :command_sequence_projection],
        not function_exported?(model, callback, 0) do
      "Model missing required callback #{callback}/0"
    end
  end

  defp report_model_only(model, verbose, strict) do
    # Check commands
    commands = model.commands() |> PropertyDamage.Model.normalize_commands()

    errors =
      for {_weight, cmd, _spec} <- commands, not Code.ensure_loaded?(cmd) do
        "Command module #{inspect(cmd)} does not exist"
      end

    # Check command callbacks
    errors =
      for {_weight, cmd, _spec} <- commands,
          Code.ensure_loaded?(cmd),
          not function_exported?(cmd, :generator, 1),
          reduce: errors do
        acc -> ["Command #{inspect(cmd)} missing generator/1" | acc]
      end

    # Check projections
    state_proj = model.command_sequence_projection()

    errors =
      if Code.ensure_loaded?(state_proj) do
        errors
      else
        ["State projection #{inspect(state_proj)} does not exist" | errors]
      end

    extra_projs =
      if function_exported?(model, :assertion_projections, 0) do
        model.assertion_projections()
      else
        []
      end

    errors =
      for proj <- extra_projs, not Code.ensure_loaded?(proj), reduce: errors do
        acc -> ["Extra projection #{inspect(proj)} does not exist" | acc]
      end

    # Collect warnings
    warnings =
      for {_weight, cmd, _spec} <- commands,
          Code.ensure_loaded?(cmd),
          not function_exported?(cmd, :downstream_observables, 0) do
        "Command #{cmd |> Module.split() |> List.last()} missing downstream_observables/0"
      end

    warnings = warnings ++ invariant_warnings(model)

    if verbose do
      print_model_summary(model, commands)
      print_invariant_catalog(model)
    end

    cond do
      errors != [] ->
        print_color(:red, "\nERRORS:\n")
        Enum.each(errors, fn error -> IO.puts("  - #{error}") end)
        :error

      strict and warnings != [] ->
        print_warnings(warnings)
        print_color(:red, "\nFAILED: #{length(warnings)} warning(s) in strict mode\n")
        :error

      true ->
        print_warnings(warnings)
        print_color(:green, "\nMODEL VALIDATION PASSED\n")
        :ok
    end
  end

  # Declared-but-unchecked invariants (static vacuity, DR-026): a guarantee the
  # model claims but no assertion verifies.
  defp invariant_warnings(model) do
    for %{projection: projection, id: id, checks: []} <- safe_catalog(model) do
      "Invariant #{short_module(projection)}.#{id} declared but never checked (statically vacuous)"
    end
  end

  defp safe_catalog(model) do
    PropertyDamage.Model.assertion_catalog(model)
  rescue
    _ -> []
  end

  defp print_invariant_catalog(model) do
    catalog = safe_catalog(model)

    IO.puts("")
    IO.puts("Invariants (#{length(catalog)}):")

    if catalog == [] do
      IO.puts("  (none declared)")
    else
      for %{projection: projection, id: id, invariant: invariant, checks: checks} <- catalog do
        description = if invariant.description, do: " — #{invariant.description}", else: ""

        check_str =
          case checks do
            [] -> "no checks (vacuous)"
            cs -> Enum.map_join(cs, ", ", fn c -> "#{c.name} (#{c.kind})" end)
          end

        IO.puts("  #{short_module(projection)}.#{id}#{description}")
        IO.puts("      checks: #{check_str}")
      end
    end
  end

  defp short_module(module), do: module |> Module.split() |> List.last()

  defp print_warnings([]), do: :ok

  defp print_warnings(warnings) do
    print_color(:yellow, "\nWARNINGS:\n")
    Enum.each(warnings, fn warning -> IO.puts("  - #{warning}") end)
  end

  defp print_validation_results(model, adapter, warnings, _verbose) do
    commands = model.commands() |> PropertyDamage.Model.normalize_commands()

    extra_projs =
      if function_exported?(model, :assertion_projections, 0) do
        model.assertion_projections()
      else
        []
      end

    IO.puts("Model:      #{inspect(model)}")
    IO.puts("Adapter:    #{inspect(adapter)}")
    IO.puts("Commands:   #{length(commands)}")
    IO.puts("Extra:      #{length(extra_projs)}")

    if warnings != [] do
      IO.puts("")
      print_color(:yellow, "WARNINGS (#{length(warnings)}):\n")

      for warning <- warnings do
        IO.puts("  - #{warning}")
      end
    end
  end

  defp print_model_summary(model, commands) do
    state_proj = model.command_sequence_projection()

    extra_projs =
      if function_exported?(model, :assertion_projections, 0) do
        model.assertion_projections()
      else
        []
      end

    IO.puts("Model: #{inspect(model)}")
    IO.puts("")
    IO.puts("Commands (#{length(commands)}):")

    for {weight, cmd, _spec} <- commands do
      name = cmd |> Module.split() |> List.last()
      IO.puts("  #{String.pad_trailing(name, 25)} weight: #{weight}")
    end

    IO.puts("")
    IO.puts("State Projection: #{inspect(state_proj)}")
    IO.puts("Extra Projections: #{length(extra_projs)}")

    for proj <- extra_projs do
      name = proj |> Module.split() |> List.last()
      IO.puts("  - #{name}")
    end
  end

  defp print_errors_with_hints(message) do
    # Parse the error message and provide hints
    lines = String.split(message, "\n")

    for line <- lines do
      cond do
        String.contains?(line, "does not exist") ->
          IO.puts(line)
          print_hint("Check the module name spelling and ensure the code is compiled.")

        String.contains?(line, "missing required callback") ->
          IO.puts(line)
          print_hint("Add the missing callback to implement the behaviour.")

        String.contains?(line, "not covered by any InjectorAdapter") ->
          IO.puts(line)
          print_hint("Add the event to an injector adapter's @emits list.")

        true ->
          IO.puts(line)
      end
    end
  end

  defp print_hint(text) do
    print_color(:cyan, "    Hint: #{text}\n")
  end

  defp print_header(text) do
    border = String.duplicate("=", String.length(text) + 4)
    IO.puts(border)
    IO.puts("  #{text}")
    IO.puts(border)
  end

  defp print_color(color, text) do
    IO.puts([color_code(color), text, IO.ANSI.reset()])
  end

  defp color_code(:red), do: IO.ANSI.red()
  defp color_code(:green), do: IO.ANSI.green()
  defp color_code(:yellow), do: IO.ANSI.yellow()
  defp color_code(:cyan), do: IO.ANSI.cyan()

  defp print_usage do
    IO.puts("""

    Usage: mix pd.validate MODEL [ADAPTER] [OPTIONS]

    Arguments:
      MODEL     The model module (e.g., MyApp.TestModel)
      ADAPTER   The adapter module (e.g., MyApp.HTTPAdapter) [optional]

    Options:
      --verbose    Show detailed information about the configuration
      --strict     Treat warnings as errors (exit code 1)

    Examples:
      mix pd.validate MyApp.TestModel MyApp.HTTPAdapter
      mix pd.validate MyApp.TestModel MyApp.HTTPAdapter --verbose
      mix pd.validate MyApp.TestModel --strict
    """)
  end
end