Revert "temp: revert DEX changes due to dbt cloud bug (duneanalytics#8530)" (duneanalytics#8531)

This reverts commit 4528233.

Author: jeff-dude

dbt_subprojects/dex/macros/models/_project/native_compatible_trades.sql

@@ -0,0 +1,52 @@
+{% macro native_compatible_trades(
+    blockchain = null,
+    project = null,
+    sources = []
+    )
+%}
+
+WITH dexs AS (
+    {% for src in sources %}
+        SELECT
+            '{{ src["version"] }}' as version,
+            t.evt_block_number AS block_number,
+            t.evt_block_time AS block_time,
+            t.evt_tx_from as taker,
+            CAST(NULL AS VARBINARY) AS maker,
+            t.sellerTokenAmount as token_sold_amount_raw,
+            t.buyerTokenAmount as token_bought_amount_raw,
+            t.sellerToken as token_sold_address,
+            t.buyerToken as token_bought_address,
+            t.contract_address AS project_contract_address,
+            t.evt_tx_hash AS tx_hash,
+            t.evt_index
+        FROM {{ source('native_' ~ blockchain, src["source"] )}} t
+        {% if is_incremental() %}
+        WHERE {{ incremental_predicate('evt_block_time') }}
+        {% endif %}
+        {% if not loop.last %}
+        UNION ALL
+        {% endif %}
+    {% endfor %}
+)
+
+SELECT
+    '{{ blockchain }}' AS blockchain,
+    '{{ project }}' AS project,
+    dexs.version,
+    CAST(date_trunc('month', dexs.block_time) AS date) AS block_month,
+    CAST(date_trunc('day', dexs.block_time) AS date) AS block_date,
+    dexs.block_time,
+    dexs.block_number,
+    dexs.token_bought_amount_raw,
+    dexs.token_sold_amount_raw,
+    dexs.token_bought_address,
+    dexs.token_sold_address,
+    dexs.taker,
+    dexs.maker,
+    dexs.project_contract_address,
+    dexs.tx_hash,
+    dexs.evt_index
+FROM dexs
+
+{% endmacro %}

dbt_subprojects/dex/models/_projects/cow_protocol/polygon/cow_protocol_polygon_trades.sql

@@ -188,7 +188,7 @@ valued_trades as (
            -- ETH Flow orders have trader = sender of orderCreation.
            case when sender is not null then sender else trader end as trader,
            sell_token_address,
-           case when sender is not null then 'AVAX' else sell_token end as sell_token,
+           case when sender is not null then 'POL' else sell_token end as sell_token,
            buy_token_address,
            buy_token,
            case

dbt_subprojects/dex/models/_projects/paraswap/base/paraswap_base_trades.sql

@@ -7,10 +7,9 @@
 
 {% set paraswap_models = [
 ref('paraswap_v5_base_trades')
-,ref('paraswap_v6_base_trades')
 ,ref('paraswap_delta_v2_base_trades')
  ] %}
-
+--exclude trouble model: ,ref('paraswap_v6_base_trades')
 
 SELECT *
 FROM (

dbt_subprojects/dex/models/dex_info.sql

@@ -222,4 +222,5 @@ FROM (VALUES
     , ('rooster_protocol', 'Rooster Protocol', 'Direct', 'roosterprotocol')
     , ('mindgames', 'Mindgames', 'Direct', 'mindgames_io')
     , ('yeiswap', 'YeiSwap', 'Direct', 'YeiFinance')
+    , ('native', 'Native', 'Direct', 'Native')
 ) AS temp_table (project, name, marketplace_type, x_username)

dbt_subprojects/dex/models/trades/arbitrum/_schema.yml

@@ -886,5 +886,24 @@ models:
             - evt_index
       - check_dex_base_trades_seed:
           seed_file: ref('fluid_arbitrum_base_trades_seed')
+          filter:
+            version: 1
+
+  - name: native_arbitrum_base_trades
+    meta:
+      blockchain: arbitrum
+      sector: dex
+      project: native
+      contributors: j92z
+    config:
+      tags: ["arbitrum", "dex", "trades", "native"]
+    description: "native arbitrum base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('native_arbitrum_base_trades_seed')
           filter:
             version: 1

dbt_subprojects/dex/models/trades/arbitrum/dex_arbitrum_base_trades.sql

@@ -54,6 +54,7 @@
     , ref('akronswap_arbitrum_base_trades')
     , ref('mindgames_arbitrum_base_trades')
     , ref('fluid_v1_arbitrum_base_trades')
+    , ref('native_arbitrum_base_trades')
 ] %}
 
 WITH base_union AS (

dbt_subprojects/dex/models/trades/arbitrum/platforms/fluid_v1_arbitrum_base_trades.sql

@@ -10,7 +10,7 @@
     )
 }}
 
-{% set native_address = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2' %}
+{% set native_address = '0x82aF49447D8a07e3bd95BD0d56f35241523fBab1' %}
 
 WITH 
   decoded_events AS (

dbt_subprojects/dex/models/trades/arbitrum/platforms/native_arbitrum_base_trades.sql

@@ -0,0 +1,25 @@
+{{
+    config(
+        schema = 'native_arbitrum',
+        alias = 'base_trades',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'evt_index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{%
+    set config_sources = [
+        {'version': '1', 'source': 'NativeRFQPool_evt_RFQTrade'},
+    ]
+%}
+
+{{
+    native_compatible_trades(
+        blockchain = 'arbitrum',
+        project = 'native',
+        sources = config_sources
+    )
+}}

dbt_subprojects/dex/models/trades/base/_schema.yml

@@ -1153,3 +1153,22 @@ models:
           seed_file: ref('fluid_base_base_trades_seed')
           filter:
             version: 1
+
+  - name: native_base_base_trades
+    meta:
+      blockchain: base
+      sector: dex
+      project: native
+      contributors: j92z
+    config:
+      tags: ["base", "dex", "trades", "native"]
+    description: "native base base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('native_base_base_trades_seed')
+          filter:
+            version: 1

dbt_subprojects/dex/models/trades/base/dex_base_base_trades.sql

@@ -60,6 +60,7 @@
     , ref('otsea_base_base_trades')
     , ref('tapio_base_base_trades')
     , ref('fluid_v1_base_base_trades')
+    , ref('native_base_base_trades')
 ] %}
 
 WITH base_union AS (