Update balancer_v2_arbitrum_trades.sql

Steakhouse-Financial · Aug 15, 2023 · b1e3362 · b1e3362
1 parent 83ca534
commit b1e3362
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/models/balancer/arbitrum/balancer_v2_arbitrum_trades.sql b/models/balancer/arbitrum/balancer_v2_arbitrum_trades.sql
@@ -1,13 +1,13 @@
 {{ config(
-    schema = 'balancer_v2_ethereum',
+    schema = 'balancer_v2_arbitrum',
     tags = ['dunesql'],
     alias = alias('trades'),
     partition_by = ['block_date'],
     materialized = 'incremental',
     file_format = 'delta',
     incremental_strategy = 'merge',
     unique_key = ['block_date', 'blockchain', 'project', 'version', 'tx_hash', 'evt_index', 'trace_address'],
-    post_hook = '{{ expose_spells(\'["ethereum"]\',
+    post_hook = '{{ expose_spells(\'["arbitrum"]\',
                                 "project",
                                 "balancer_v2",
                                 \'["mendesfabio", "jacektrocinski", "thetroyharris"]\') }}'
@@ -26,8 +26,8 @@ WITH
             bytearray_substring(swaps.poolId, 1, 20) AS contract_address,
             fees.swap_fee_percentage,
             ROW_NUMBER() OVER (PARTITION BY poolId, evt_tx_hash, evt_index ORDER BY block_number DESC, index DESC) AS rn
-        FROM {{ source ('balancer_v2_ethereum', 'Vault_evt_Swap') }} swaps
-        LEFT JOIN {{ ref('balancer_v2_ethereum_pools_fees') }} fees
+        FROM {{ source ('balancer_v2_arbitrum', 'Vault_evt_Swap') }} swaps
+        LEFT JOIN {{ ref('balancer_v2_arbitrum_pools_fees') }} fees
             ON fees.contract_address = bytearray_substring(swaps.poolId, 1, 20)
             AND ARRAY[fees.block_number] || ARRAY[fees.index] < ARRAY[swaps.evt_block_number] || ARRAY[swaps.evt_index]
         {% if is_incremental() %}
@@ -53,7 +53,7 @@ WITH
             swap.evt_index
         FROM
             swap_fees
-            INNER JOIN {{ source ('balancer_v2_ethereum', 'Vault_evt_Swap') }} swap
+            INNER JOIN {{ source ('balancer_v2_arbitrum', 'Vault_evt_Swap') }} swap
                 ON swap.evt_block_number = swap_fees.evt_block_number
                 AND swap.evt_tx_hash = swap_fees.evt_tx_hash
                 AND swap.evt_index = swap_fees.evt_index
@@ -72,7 +72,7 @@ WITH
             MAX(bpt_prices.hour) AS bpa_max_block_time
         FROM
             dexs
-            LEFT JOIN {{ ref('balancer_v2_ethereum_bpt_prices') }} bpt_prices
+            LEFT JOIN {{ ref('balancer_v2_arbitrum_bpt_prices') }} bpt_prices
                 ON bpt_prices.contract_address = CAST(dexs.token_bought_address AS VARCHAR)
                 AND bpt_prices.hour <= dexs.block_time
                 {% if not is_incremental() %}
@@ -93,7 +93,7 @@ WITH
             MAX(bpt_prices.hour) AS bpb_max_block_time
         FROM
             dexs
-            LEFT JOIN {{ ref('balancer_v2_ethereum_bpt_prices') }} bpt_prices
+            LEFT JOIN {{ ref('balancer_v2_arbitrum_bpt_prices') }} bpt_prices
                 ON bpt_prices.contract_address = CAST(dexs.token_sold_address AS VARCHAR)
                 AND bpt_prices.hour <= dexs.block_time
                 {% if not is_incremental() %}
@@ -106,7 +106,7 @@ WITH
     )
 
 SELECT
-    'ethereum' AS blockchain,
+    'arbitrum' AS blockchain,
     'balancer' AS project,
     '2' AS version,
     DATE_TRUNC('DAY', dexs.block_time) AS block_date,
@@ -143,7 +143,7 @@ SELECT
     dexs.evt_index
 FROM
     dexs
-    INNER JOIN {{ source ('ethereum', 'transactions') }} tx
+    INNER JOIN {{ source ('arbitrum', 'transactions') }} tx
         ON tx.hash = dexs.tx_hash
         {% if not is_incremental() %}
         AND tx.block_time >= CAST('{{ project_start_date }}' AS TIMESTAMP)
@@ -153,14 +153,14 @@ FROM
         {% endif %}
     LEFT JOIN {{ ref ('tokens_erc20') }} erc20a
         ON erc20a.contract_address = dexs.token_bought_address
-        AND erc20a.blockchain = 'ethereum'
+        AND erc20a.blockchain = 'arbitrum'
     LEFT JOIN {{ ref ('tokens_erc20') }} erc20b
         ON erc20b.contract_address = dexs.token_sold_address
-        AND erc20b.blockchain = 'ethereum'
+        AND erc20b.blockchain = 'arbitrum'
     LEFT JOIN {{ source ('prices', 'usd') }} p_bought
         ON p_bought.minute = DATE_TRUNC('minute', dexs.block_time)
         AND p_bought.contract_address = dexs.token_bought_address
-        AND p_bought.blockchain = 'ethereum'
+        AND p_bought.blockchain = 'arbitrum'
         {% if not is_incremental() %}
         AND p_bought.minute >= CAST('{{ project_start_date }}' AS TIMESTAMP)
         {% endif %}
@@ -170,7 +170,7 @@ FROM
     LEFT JOIN {{ source ('prices', 'usd') }} p_sold
         ON p_sold.minute = DATE_TRUNC('minute', dexs.block_time)
         AND p_sold.contract_address = dexs.token_sold_address
-        AND p_sold.blockchain = 'ethereum'
+        AND p_sold.blockchain = 'arbitrum'
         {% if not is_incremental() %}
         AND p_sold.minute >= CAST('{{ project_start_date }}' AS TIMESTAMP)
         {% endif %}
@@ -181,7 +181,7 @@ FROM
         ON bpa.evt_block_number = dexs.evt_block_number
         AND bpa.tx_hash = dexs.tx_hash
         AND bpa.evt_index = dexs.evt_index
-    LEFT JOIN {{ ref('balancer_v2_ethereum_bpt_prices') }} bpa_bpt_prices
+    LEFT JOIN {{ ref('balancer_v2_arbitrum_bpt_prices') }} bpa_bpt_prices
         ON bpa_bpt_prices.contract_address = bpa.contract_address
         AND bpa_bpt_prices.hour = bpa.bpa_max_block_time
         {% if not is_incremental() %}
@@ -194,7 +194,7 @@ FROM
         ON bpb.evt_block_number = dexs.evt_block_number
         AND bpb.tx_hash = dexs.tx_hash
         AND bpb.evt_index = dexs.evt_index
-    LEFT JOIN {{ ref('balancer_v2_ethereum_bpt_prices') }} bpb_bpt_prices
+    LEFT JOIN {{ ref('balancer_v2_arbitrum_bpt_prices') }} bpb_bpt_prices
         ON bpb_bpt_prices.contract_address = bpb.contract_address
         AND bpb_bpt_prices.hour = bpb.bpb_max_block_time
         {% if not is_incremental() %}