updated gas.fees model files due to changes in prices.usd_native (#8303)

* updated gas.fees model files due to changes in prices.usd_native

* fixed syntax

---------

Co-authored-by: jeff-dude <[email protected]>

Author: krishgka

dbt_subprojects/hourly_spellbook/models/_sector/gas/fees/apechain/gas_apechain_fees.sql

@@ -11,4 +11,83 @@
     ,incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
     )
 }}
-{{ arbitrum_orbit_stack_gas_fees(blockchain) }}
+
+WITH base_model as (
+    SELECT
+        txns.block_time
+        ,txns.block_number
+        ,txns.hash AS tx_hash
+        ,txns."from" AS tx_from
+        ,txns.to AS tx_to
+        ,cast(gas_price as uint256) as gas_price
+        ,txns.gas_used as gas_used
+        ,cast(base_fee_per_gas as uint256) * cast(txns.gas_used as uint256) as tx_fee_raw
+        ,map(array['base_fee'], array[cast(base_fee_per_gas as uint256) * cast(txns.gas_used as uint256)]) as tx_fee_breakdown_raw
+        ,0x7f9fbf9bdd3f4105c478b996b648fe6e828a1e98 as tx_fee_currency
+        ,blocks.miner AS block_proposer
+        ,txns.max_fee_per_gas
+        ,txns.priority_fee_per_gas
+        ,txns.max_priority_fee_per_gas
+        ,blocks.base_fee_per_gas
+        ,txns.gas_limit
+        ,CASE  --safe divide-by-zero
+            WHEN txns.gas_limit = 0 THEN NULL
+            WHEN txns.gas_limit != 0 THEN cast(txns.gas_used as double) / cast(txns.gas_limit as double)
+        END AS gas_limit_usage
+        {% if blockchain == 'apechain' %}
+        ,l1_gas_used
+        {% endif %}
+    FROM {{ source(blockchain, 'transactions') }} txns
+    INNER JOIN {{ source(blockchain, 'blocks') }} blocks
+        ON txns.block_number = blocks.number
+        {% if is_incremental() %}
+        AND {{ incremental_predicate('blocks.time') }}
+        {% endif %}
+    {% if test_short_ci %}
+    WHERE {{ incremental_predicate('txns.block_time') }}
+    OR txns.hash in (select tx_hash from {{ref('evm_gas_fees')}})
+    {% elif is_incremental() %}
+    WHERE {{ incremental_predicate('txns.block_time') }}
+    {% endif %}
+)
+
+SELECT
+    '{{blockchain}}' as blockchain
+    ,CAST(date_trunc('month', block_time) AS DATE) AS block_month
+    ,CAST(date_trunc('day', block_time) AS DATE) AS block_date
+    ,block_time
+    ,block_number
+    ,tx_hash
+    ,tx_from
+    ,tx_to
+    ,gas_price
+    ,gas_used
+    ,p.symbol as currency_symbol
+    ,coalesce(tx_fee_raw, 0) as tx_fee_raw
+    ,coalesce(tx_fee_raw, 0) / pow(10,p.decimals) as tx_fee
+    ,coalesce(tx_fee_raw, 0) / pow(10,p.decimals) * p.price as tx_fee_usd
+    ,transform_values(tx_fee_breakdown_raw,
+            (k,v) -> coalesce(v, cast(0 as uint256))) as tx_fee_breakdown_raw
+    ,transform_values(tx_fee_breakdown_raw,
+            (k,v) -> coalesce(v, cast(0 as uint256)) / pow(10,p.decimals) ) as tx_fee_breakdown
+    ,transform_values(tx_fee_breakdown_raw,
+            (k,v) -> coalesce(v, cast(0 as uint256)) / pow(10,p.decimals) * p.price) as tx_fee_breakdown_usd
+    ,tx_fee_currency
+    ,block_proposer
+    ,max_fee_per_gas
+    ,priority_fee_per_gas
+    ,max_priority_fee_per_gas
+    ,base_fee_per_gas
+    ,gas_limit
+    ,gas_limit_usage
+    {% if blockchain == 'apechain' %}
+    ,l1_gas_used
+    {% endif %}
+FROM base_model
+LEFT JOIN {{ ref('prices_usd_with_native') }} p
+    ON p.blockchain = '{{blockchain}}'
+    AND p.contract_address = tx_fee_currency
+    AND p.minute = date_trunc('minute', block_time)
+    {% if is_incremental() %}
+    AND {{ incremental_predicate('p.minute') }}
+    {% endif %}

dbt_subprojects/hourly_spellbook/models/_sector/gas/fees/mantle/gas_mantle_fees.sql

@@ -35,7 +35,7 @@ WITH base_model as (
                          )
                 end
         ) as tx_fee_breakdown_raw
-        ,{{var('ETH_ERC20_ADDRESS')}} as tx_fee_currency
+        ,0xdeaddeaddeaddeaddeaddeaddeaddeaddead0000 as tx_fee_currency
         ,blocks.miner AS block_proposer
         ,txns.max_fee_per_gas
         ,txns.priority_fee_per_gas

dbt_subprojects/hourly_spellbook/models/_sector/gas/fees/polygon/gas_polygon_fees.sql

@@ -34,7 +34,7 @@ WITH base_model as (
                             )
             end
         ) as tx_fee_breakdown_raw
-        ,{{var('ETH_ERC20_ADDRESS')}} as tx_fee_currency
+        ,0x0000000000000000000000000000000000001010 as tx_fee_currency
         ,blocks.miner AS block_proposer
         ,txns.max_fee_per_gas
         ,txns.priority_fee_per_gas

dbt_subprojects/hourly_spellbook/models/_sector/gas/fees/zksync/gas_zksync_fees.sql

@@ -28,7 +28,7 @@ WITH base_model as (
             map()
             ,map(array['base_fee'], array[(cast(gas_price as uint256) * cast(txns.gas_used as uint256))])
         ) as tx_fee_breakdown_raw
-        ,{{var('ETH_ERC20_ADDRESS')}} as tx_fee_currency
+        ,0x000000000000000000000000000000000000800a as tx_fee_currency
         ,blocks.miner AS block_proposer
         ,txns.max_fee_per_gas
         ,txns.priority_fee_per_gas