defmodule Plausible.IngestRepo do
  @moduledoc """
  Write-centric Clickhouse access interface
  """

  use Ecto.Repo,
    otp_app: :plausible,
    adapter: Ecto.Adapters.ClickHouse

  defmacro __using__(_) do
    quote do
      alias Plausible.IngestRepo
      import Ecto
      import Ecto.Query, only: [from: 1, from: 2]
    end
  end

  def clustered_table?(table) do
    replica_count(table) > 1
  end

  def replica_count(table) do
    {:ok, %{rows: [[count]]}} =
      query("SELECT sum(active_replicas) FROM system.replicas WHERE table = '#{table}'")

    count
  end
end