defmodule PolicyService.Queries.PolicyQueries do
  import Ecto.Query

  alias PolicyService.Repo
  alias PolicyService.Projections.PolicyApplication

  def list_by_org(org_id, params \\ %{}) do
    base = from(p in PolicyApplication, where: p.org_id == ^org_id)
    Flop.validate_and_run(base, params, for: PolicyApplication)
  end

  def get_by_application_id(org_id, application_id) do
    case Repo.get_by(PolicyApplication,
           application_id: application_id,
           org_id: org_id
         ) do
      nil -> {:error, :not_found}
      p -> {:ok, p}
    end
  end
end