Add getLabelBasedMetricOwners API

.gitignore

@@ -7,6 +7,7 @@
 /.history/
 !.env.example
 !app/.env
+.elixir-tools/
 
 # Generated on crash by the VM
 erl_crash.dump

lib/sanbase/clickhouse/exchanges/exchange_metric.ex → lib/sanbase/clickhouse/exchanges/exchanges.ex

@@ -1,8 +1,13 @@
-defmodule Sanbase.Clickhouse.Exchanges.ExchangeMetric do
+defmodule Sanbase.Clickhouse.Exchanges do
+ alias Sanbase.Clickhouse.MetricAdapter.FileHandler
+
  import Sanbase.Metric.SqlQuery.Helper, only: [asset_id_filter: 2, additional_filters: 3]
 
  require Sanbase.ClickhouseRepo, as: ClickhouseRepo
 
+ @name_to_metric_map FileHandler.name_to_metric_map()
+ @table_map FileHandler.table_map()
+
  def top_exchanges_by_balance(%{slug: slug_or_slugs}, limit, opts \\ []) do
  filters = Keyword.get(opts, :additional_filters, [])
  query_struct = top_exchanges_by_balance_query(slug_or_slugs, limit, filters)
@@ -24,8 +29,41 @@ defmodule Sanbase.Clickhouse.Exchanges.ExchangeMetric do
  )
  end
 
+ def owners_by_slug_and_metric(metric, slug) do
+ table = Map.get(@table_map, metric)
+
+ case not is_nil(table) && table =~ "label" do
+ true ->
+ query_struct =
+ owners_by_slug_and_metric_query(metric, slug)
+ |> IO.inspect(label: "38", limit: :infinity)
+
+ ClickhouseRepo.query_transform(query_struct, fn [owner] -> owner end)
+
+ false ->
+ {:error, "The provided metric #{metric} is not a label-based metric"}
+ end
+ end
+
  # Private functions
 
+ defp owners_by_slug_and_metric_query(metric, slug) do
+ params = %{
+ metric: Map.get(@name_to_metric_map, metric),
+ slug: slug
+ }
+
+ sql = """
+ SELECT DISTINCT owner
+ FROM #{Map.get(@table_map, metric)}
+ WHERE
+ metric_id = get_metric_id({{metric}})
+ #{if slug, do: "AND asset_id = get_asset_id({{slug}})"}
+ """
+
+ Sanbase.Clickhouse.Query.new(sql, params)
+ end
+
  defp top_exchanges_by_balance_query(slug_or_slugs, limit, filters) do
  params = %{slug: slug_or_slugs, limit: limit}
 

lib/sanbase/run_examples.ex

@@ -641,7 +641,7 @@ defmodule Sanbase.RunExamples do
  )
 
  {:ok, _} =
- Sanbase.Clickhouse.Exchanges.ExchangeMetric.top_exchanges_by_balance(
+ Sanbase.Clickhouse.Exchanges.top_exchanges_by_balance(
  %{slug: "ethereum"},
  1,
  additional_filters: [

lib/sanbase_web/graphql/resolvers/exchange_resolver.ex

@@ -12,6 +12,10 @@ defmodule SanbaseWeb.Graphql.Resolvers.ExchangeResolver do
  ExchangeAddress.exchange_names(slug, Map.get(args, :is_dex, nil))
  end
 
+ def get_label_based_metric_owners(_root, %{metric: metric} = args, _resolution) do
+ Exchanges.owners_by_slug_and_metric(metric, args[:slug])
+ end
+
  def top_exchanges_by_balance(
  _root,
  args,
@@ -26,7 +30,7 @@ defmodule SanbaseWeb.Graphql.Resolvers.ExchangeResolver do
  end
 
  with {:ok, selector} <- Sanbase.Project.Selector.args_to_selector(args),
- {:ok, result} <- Exchanges.ExchangeMetric.top_exchanges_by_balance(selector, limit, opts) do
+ {:ok, result} <- Exchanges.top_exchanges_by_balance(selector, limit, opts) do
  {:ok, result}
  end
  |> maybe_handle_graphql_error(fn error ->

lib/sanbase_web/graphql/schema/queries/blockchain_metric_queries.ex

@@ -369,6 +369,18 @@ defmodule SanbaseWeb.Graphql.Schema.BlockchainMetricQueries do
  cache_resolve(&ClickhouseResolver.daily_active_deposits/3)
  end
 
+ @desc ~s"""
+ List all exchanges
+ """
+ field :get_label_based_metric_owners, list_of(:string) do
+ meta(access: :free)
+
+ arg(:metric, non_null(:string))
+ arg(:slug, :string)
+
+ cache_resolve(&ExchangeResolver.get_label_based_metric_owners/3)
+ end
+
  @desc "List all exchanges"
  field :all_exchanges, list_of(:string) do
  meta(access: :free)