add groupby address, remove unlabelled metric

Author: tspenov

lib/sanbase/clickhouse/metric/sql_query/metric_histogram_sql_query.ex

@@ -246,61 +246,6 @@ defmodule Sanbase.Clickhouse.MetricAdapter.HistogramSqlQuery do
     Sanbase.Clickhouse.Query.new(sql, params)
   end
 
-  def histogram_data_query(
-        "eth2_unlabeled_staker_inflow_sources",
-        "ethereum",
-        from,
-        to,
-        _interval,
-        limit
-      ) do
-    sql = """
-    SELECT
-      label,
-      sumKahan(address_inflow) AS value
-    FROM (
-      SELECT
-        address,
-        address_inflow,
-        #{label_select(label_as: "label", label_str_as: "label_str")}
-      FROM (
-          SELECT
-            from AS address,
-            sumKahan(value / 1e18) AS address_inflow
-          FROM eth_transfers
-          WHERE to GLOBAL IN (
-            SELECT address
-            FROM (
-              SELECT
-                address,
-                dictGet('default.eth_label_dict', 'labels', (cityHash64(address), toUInt64(0))) AS label_str
-              FROM (
-                SELECT DISTINCT(address)
-                FROM eth2_staking_transfers_v2 FINAL
-                WHERE
-                  dt < toDateTime({{to}})
-                  #{if from, do: "AND dt >= toDateTime({{from}})"}
-              )
-            )
-            WHERE label_str = ''
-          )
-        GROUP BY address
-      )
-    )
-    GROUP BY label
-    ORDER BY value DESC
-    LIMIT {{limit}}
-    """
-
-    params = %{
-      from: from && from |> DateTime.to_unix(),
-      to: to |> DateTime.to_unix(),
-      limit: limit
-    }
-
-    Sanbase.Clickhouse.Query.new(sql, params)
-  end
-
   def histogram_data_query(
         "eth2_top_stakers",
         "ethereum",
@@ -326,11 +271,8 @@ defmodule Sanbase.Clickhouse.MetricAdapter.HistogramSqlQuery do
 
     SELECT
         lock_addresses.address as address,
-        multiIf(
-                m.key = 'owner', m.value,
-                m.key
-        ) as label,
-        lock_addresses.locked_value as staked
+        arrayStringConcat(groupUniqArray(multiIf(m.key = 'owner', m.value, m.key)), ', ') AS labels,
+        max(lock_addresses.locked_value) AS max_staked
     FROM lock_addresses
     LEFT JOIN (
         SELECT
@@ -358,7 +300,8 @@ defmodule Sanbase.Clickhouse.MetricAdapter.HistogramSqlQuery do
         FROM label_metadata
     ) AS m
     ON cla.label_id = m.label_id
-    ORDER BY staked DESC
+    GROUP BY lock_addresses.address
+    ORDER BY max_staked DESC
     """
 
     params = %{
@@ -758,29 +701,4 @@ defmodule Sanbase.Clickhouse.MetricAdapter.HistogramSqlQuery do
 
     Sanbase.Clickhouse.Query.new(sql, params)
   end
-
-  defp label_select(opts) do
-    label_as = Keyword.get(opts, :label_as, "label")
-    label_str_as = Keyword.get(opts, :label_str_as, "label_str")
-
-    """
-    dictGet('default.eth_label_dict', 'labels', (cityHash64(address), toUInt64(0))) AS #{label_str_as},
-    splitByChar(',', #{label_str_as}) AS label_arr_internal,
-    multiIf(
-      has(label_arr_internal, 'decentralized_exchange'), 'DEX',
-      hasAny(label_arr_internal, ['centralized_exchange', 'deposit']), 'CEX',
-      has(label_arr_internal, 'defi'), 'DeFi',
-      has(label_arr_internal, 'genesis'), 'Genesis',
-      has(label_arr_internal, 'miner'), 'Miner',
-      has(label_arr_internal, 'makerdao-cdp-owner'), 'CDP Owner',
-      has(label_arr_internal, 'whale'), 'Whale',
-      hasAll(label_arr_internal, ['dex_trader', 'withdrawal']), 'CEX & DEX Trader',
-      has(label_arr_internal, 'withdrawal'), 'CEX Trader',
-      has(label_arr_internal, 'proxy'), 'Proxy',
-      has(label_arr_internal, 'dex_trader'), 'DEX Trader',
-      #{label_str_as} = '', 'Unlabeled',
-      label_arr_internal[1]
-      ) AS #{label_as}
-    """
-  end
 end