feat: add other evm chains

solana/models/_sector/dex/bot_trades/evm/banana_gun/banana_gun_evm_bot_trades.sql

@@ -13,13 +13,12 @@
 
 
 
-   {# ref('banana_gun_avalanche_c_bot_trades')
-    , ref('banana_gun_base_bot_trades')
-    , ref('banana_gun_blast_bot_trades')
-    , ref('banana_gun_bnb_bot_trades')
-    , #}
 {% set banana_gun_blockchains = [
-   ref('banana_gun_ethereum_bot_trades')
+  ref('banana_gun_avalanche_c_bot_trades')
+  , ref('banana_gun_ethereum_bot_trades')
+  , ref('banana_gun_base_bot_trades')
+  , ref('banana_gun_blast_bot_trades')
+  , ref('banana_gun_bnb_bot_trades')
 ] %}
 
 {% for blockchain in banana_gun_blockchains %}

solana/models/_sector/dex/bot_trades/evm/banana_gun/ethereum/banana_gun_avalanche_c_bot_trades.sql

@@ -0,0 +1,198 @@
+{{ config(
+    alias = 'bot_trades',
+    schema = 'banana_gun_avalanche_c',
+    partition_by = ['block_month'],
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+    unique_key = ['blockchain', 'tx_hash', 'evt_index']
+   )
+}}
+
+{% set project_start_date = '2024-03-15' %}
+{% set blockchain = 'avalanche_c' %}
+{% set bot_deployer_1 = '0x37aAb97476bA8dC785476611006fD5dDA4eed66B' %}
+{% set wavax = '0xB31f66AA3C1e785363F0875A1B74E27b85FD66c7' %}
+{% set fee_token_symbol = 'AVAX' %}
+
+WITH
+  botContracts AS (
+    SELECT
+      address
+    FROM
+      {{ source('avalanche_c','creation_traces') }}
+    WHERE
+      (
+        "from" = {{bot_deployer_1}}
+      )
+      AND block_time >= TIMESTAMP '{{project_start_date}}'
+  ),
+  botTrades AS (
+    SELECT
+      trades.block_time,
+      amount_usd,
+      IF(
+        token_sold_address = {{wavax}},
+        'Buy',
+        'Sell'
+      ) AS type,
+      token_bought_amount,
+      token_bought_symbol,
+      token_bought_address,
+      token_sold_amount,
+      token_sold_symbol,
+      token_sold_address,
+      project,
+      version,
+      token_pair,
+      project_contract_address,
+      tx_from AS user,
+      tx_to AS bot,
+      trades.tx_hash,
+      evt_index
+    FROM
+      {{ source('dex', 'trades') }} as trades
+      JOIN botContracts ON trades.tx_to = botContracts.address
+    WHERE
+      trades.blockchain = '{{blockchain}}'
+      AND trades.block_time >= TIMESTAMP '{{project_start_date}}'
+  ),
+  highestEventIndexForEachTrade AS (
+    SELECT
+      tx_hash,
+      MAX(evt_index) AS highestEventIndex
+    FROM
+      botTrades
+    GROUP BY
+      tx_hash
+  ),
+  botETHDeposits AS (
+    SELECT
+      tx_hash,
+      block_number,
+      CAST(value AS DECIMAL (38, 0)) AS deltaGwei,
+      CAST(value AS DECIMAL (38, 0)) AS depositGwei
+    FROM
+      {{ source('avalanche_c','traces') }}
+      JOIN botContracts ON to = botContracts.address
+    WHERE
+      block_time >= TIMESTAMP '{{project_start_date}}'
+      AND value > CAST(0 AS UINT256)
+  ),
+  botETHWithdrawals AS (
+    SELECT
+      tx_hash,
+      block_number,
+      CAST(value AS DECIMAL (38, 0)) * -1 AS deltaGwei,
+      0 AS depositGwei,
+      block_hash,
+      to
+    FROM
+      {{ source('avalanche_c','traces') }}
+      JOIN botContracts ON "from" = botContracts.address
+    WHERE
+      block_time >= TIMESTAMP '{{project_start_date}}'
+      AND value > CAST(0 AS UINT256)
+  ),
+  botEthTransfers AS (
+    /* Deposits */
+    (
+      SELECT
+        tx_hash,
+        block_number,
+        deltaGwei,
+        depositGwei
+      FROM
+        botETHDeposits
+    )
+    UNION ALL
+    /* Withdrawals */
+    (
+      SELECT
+        tx_hash,
+        block_number,
+        deltaGwei,
+        depositGwei
+      FROM
+        botETHWithdrawals
+    )
+  ),
+  botEthDeltas AS (
+    SELECT
+      tx_hash,
+      block_number,
+      SUM(deltaGwei) AS feeGwei,
+      SUM(depositGwei) AS depositGwei
+    FROM
+      botEthTransfers
+    GROUP BY
+      tx_hash,
+      block_number
+  ),
+  minerBribes AS (
+    SELECT
+      tx_hash,
+      SUM(deltaGwei * -1) / 1e18 AS bribeETH
+    FROM
+      botETHWithdrawals
+      JOIN {{ source('avalanche_c','blocks') }} AS blocks ON (
+        botETHWithdrawals.block_hash = blocks.hash
+        AND botETHWithdrawals.to = blocks.miner
+      )
+    GROUP BY
+      tx_hash
+  )
+SELECT
+  block_time,
+  date_trunc('day', botTrades.block_time) as block_date,
+  date_trunc('month', botTrades.block_time) as block_month,
+  block_number,
+  '{{blockchain}}' AS blockchain,
+  -- Trade
+  amount_usd,
+  type,
+  token_bought_amount,
+  token_bought_symbol,
+  CAST(token_bought_address AS VARCHAR) AS token_bought_address,
+  token_sold_amount,
+  token_sold_symbol,
+  CAST(token_sold_address AS VARCHAR) AS token_sold_address,
+  -- Fees
+  ROUND(
+    CAST(feeGwei AS DOUBLE) / CAST(depositGwei AS DOUBLE),
+    /* Round feePercentage to 0.01% steps */
+    4
+  ) AS fee_percentage_fraction,
+  (feeGwei / 1e18) * price AS fee_usd,
+  feeGwei / 1e18 fee_token_amount,
+  '{{fee_token_symbol}}' AS fee_token_symbol,
+  '{{wavax}}' AS fee_token_address,
+  -- Bribes
+  bribeETH * price AS bribe_usd,
+  bribeETH AS bribe_token_amount,
+  '{{fee_token_symbol}}' AS bribe_token_symbol,
+  '{{wavax}}' AS bribe_token_address,
+  -- Dex
+  project,
+  version,
+  token_pair,
+  CAST(project_contract_address AS VARCHAR) AS project_contract_address,
+  -- User
+  CAST(user AS VARCHAR) AS user,
+  CAST(botTrades.tx_hash AS VARCHAR) AS tx_hash,
+  evt_index,
+  IF(evt_index = highestEventIndex, true, false) AS is_last_trade_in_transaction
+FROM
+  botTrades
+  JOIN highestEventIndexForEachTrade ON botTrades.tx_hash = highestEventIndexForEachTrade.tx_hash
+  LEFT JOIN botETHDeltas ON botTrades.tx_hash = botETHDeltas.tx_hash
+  LEFT JOIN minerBribes ON botTrades.tx_hash = minerBribes.tx_hash
+  LEFT JOIN {{ source('prices', 'usd') }} ON (
+    blockchain = '{{blockchain}}'
+    AND contract_address = {{wavax}}
+    AND minute = DATE_TRUNC('minute', block_time)
+  )
+ORDER BY
+  block_time DESC,
+  evt_index DESC