feat: add Tempo DEXs

[jeff-dude]

Thank you for contributing to Spellbook 🪄

Description:

Adds DEX trading support for the Tempo blockchain, wiring four protocols into the full dex.trades lineage.

Tempo Exchange (tempo_exchange_tempo_base_trades.sql):

• Standalone inline SQL model sourcing from two decoded call tables:
  • tempoexchange_tempo.stablecoindex_call_swapexactamountin — exact input swaps
  • tempoexchange_tempo.stablecoindex_call_swapexactamountout — exact output swaps
• Unions both swap types, mapping tokenIn/tokenOut and actual amounts to the standard base trades schema
• Filters on call_success = true; uses incremental_predicate for incremental runs

Uniswap V2 (uniswap_v2_tempo_base_trades.sql):

• Uses the shared uniswap_compatible_v2_trades macro with pair_evt_swap and uniswapv2factory_evt_paircreated sources

Uniswap V3 (uniswap_v3_tempo_base_trades.sql):

• Uses the shared uniswap_compatible_v3_trades macro with uniswapv3pool_evt_swap and uniswapv3factory_evt_poolcreated sources

Uniswap V4 (uniswap_v4_tempo_base_trades.sql):

• Uses the shared uniswap_compatible_v4_trades macro with PoolManager_call_Swap source

Chain-level models (new tempo/ directory):

• dex_tempo_base_trades.sql — unions all four platform base trades with add_tx_columns
• dex_tempo_trades.sql — enriches with token metadata and USD pricing via enrich_dex_trades
• dex_tempo_token_volumes_daily.sql — daily token volume aggregation

Infrastructure:

• Sources YAML at sources/_sector/dex/trades/tempo/_sources.yml declaring decoded tables for all protocols
• Uniswap-specific sources at sources/uniswap/tempo/uniswap_tempo_sources.yml
• Schema YAML with uniqueness tests and seed test references for all platforms
• Seed CSVs with column types registered in seeds/trades/_schema.yml
• 'tempo' added to the chains list in dex_trades.sql
• Temporary 14-day non-incremental filter in dex_trades.sql to expedite CI (to be reverted before merge)

All models compile successfully via dbt compile.

---

quick links for more information:

• README.md
• spellbook docs
• CONTRIBUTING.md

Linear Issue: CUR2-1693

  

[jeff-dude]

@cursor push a temp commit in dex_trades model to filter non-incremental runs to last 14 days to expedite CI runs

[cursor]

Added a temporary 14-day filter on non-incremental runs in dex_trades.sql — both the chain_trades and as_is_dexs CTEs now include WHERE block_time >= now() - interval '14' day on full-refresh paths. This will limit the data scanned during CI. Committed and pushed with a reminder that it must be reverted before merge.

  

[jeff-dude]

@cursor apply above suggest changes in comment

[cursor]

Applied all four review suggestions from @jeff-dude to tempo_exchange_tempo_base_trades.sql:

• Removed unnecessary CAST(... AS uint256) on amount columns (amountIn, output_amountOut, output_amountIn, amountOut)
• Changed ROW_NUMBER() ordering from call_block_time to call_trace_address
• Added call_block_date AS block_date to both CTEs and used dexs.block_date directly instead of CAST(date_trunc('day', ...) AS date)
• Replaced CAST(NULL AS VARBINARY) AS taker with call_tx_from AS taker sourced from the CTEs

  

[jeff-dude]

@cursor can you add the uniswap v2 and v3 models for tempo too? similar to v4, there are existing macros we can use. here are tables:

uniswap_v2_tempo.uniswapv2factory_evt_paircreated
uniswap_v2_tempo.pair_evt_swap
uniswap_v3_tempo.uniswapv3factory_evt_poolcreated
uniswap_v3_tempo.uniswapv3pool_evt_swap

[cursor]

Added Uniswap V2 and V3 models for the Tempo chain:

• uniswap_v2_tempo_base_trades.sql — uses the uniswap_compatible_v2_trades macro with pair_evt_swap and uniswapv2factory_evt_paircreated sources
• uniswap_v3_tempo_base_trades.sql — uses the uniswap_compatible_v3_trades macro with uniswapv3pool_evt_swap and uniswapv3factory_evt_poolcreated sources
• Added V2/V3 source declarations in _sources.yml, schema entries with seed tests (shared uniswap_tempo_base_trades_seed, filtered by version 2/3), and wired both into dex_tempo_base_trades union (now 4 platforms total)

All models compile successfully.

  

[jeff-dude]

todo:

• - wait for v2/3 decoded tables to have data backfilled
• - rerun CI
• - remove temp commit to dex trades

[cursor]

Cursor Bugbot has reviewed your changes and found 3 potential issues.

Bugbot Autofix prepared fixes for all 3 issues found in the latest run.

• ✅ Fixed: Temporary CI window limits production history
  • Removed the WHERE block_time >= now() - interval '14' day filter from both the chain_trades and as_is_dexs non-incremental paths in dex_trades.sql, restoring full-refresh behavior.
• ✅ Fixed: Event index collisions across swap types
  • Moved ROW_NUMBER() computation from individual swap CTEs to after the UNION ALL in the final SELECT, so evt_index is assigned globally per tx_hash across both swap types.
• ✅ Fixed: Synthetic event indexes drop cross-protocol trades
  • Added project to the dedup partition in dex_tempo_base_trades.sql so that synthetic evt_index values from tempo_exchange cannot collide with real evt_index values from other protocols in the same transaction.

Or push these changes by commenting:

@cursor push 9a274a5a2a

Preview (9a274a5a2a)

diff --git a/dbt_subprojects/dex/models/trades/dex_trades.sql b/dbt_subprojects/dex/models/trades/dex_trades.sql
--- a/dbt_subprojects/dex/models/trades/dex_trades.sql
+++ b/dbt_subprojects/dex/models/trades/dex_trades.sql
@@ -110,8 +110,6 @@
     {%- else -%}
     {% if is_incremental() %}
     WHERE {{ incremental_predicate('block_time') }}
-    {% else %}
-    WHERE block_time >= now() - interval '14' day -- temp CI filter, revert before merge
     {% endif %}
     {%- endif %}
     {% if not loop.last %}
@@ -154,8 +152,6 @@
     {%- else -%}
     {% if is_incremental() %}
     WHERE {{ incremental_predicate('block_time') }}
-    {% else %}
-    WHERE block_time >= now() - interval '14' day -- temp CI filter, revert before merge
     {% endif %}
     {%- endif %}
     {% if not loop.last %}

diff --git a/dbt_subprojects/dex/models/trades/tempo/dex_tempo_base_trades.sql b/dbt_subprojects/dex/models/trades/tempo/dex_tempo_base_trades.sql
--- a/dbt_subprojects/dex/models/trades/tempo/dex_tempo_base_trades.sql
+++ b/dbt_subprojects/dex/models/trades/tempo/dex_tempo_base_trades.sql
@@ -64,7 +64,7 @@
 , final as (
     select
         *
-        , row_number() over (partition by tx_hash, evt_index order by tx_hash) as duplicates_rank
+        , row_number() over (partition by tx_hash, evt_index, project order by tx_hash) as duplicates_rank
     from
         add_tx_columns
 )

diff --git a/dbt_subprojects/dex/models/trades/tempo/platforms/tempo_exchange_tempo_base_trades.sql b/dbt_subprojects/dex/models/trades/tempo/platforms/tempo_exchange_tempo_base_trades.sql
--- a/dbt_subprojects/dex/models/trades/tempo/platforms/tempo_exchange_tempo_base_trades.sql
+++ b/dbt_subprojects/dex/models/trades/tempo/platforms/tempo_exchange_tempo_base_trades.sql
@@ -22,7 +22,7 @@
         , contract_address AS project_contract_address
         , call_tx_hash AS tx_hash
         , call_tx_from AS taker
-        , ROW_NUMBER() OVER (PARTITION BY call_tx_hash ORDER BY call_trace_address) AS row_num
+        , call_trace_address
     FROM {{ source('tempoexchange_tempo', 'stablecoindex_call_swapexactamountin') }}
     WHERE call_success = true
     {% if is_incremental() -%}
@@ -42,7 +42,7 @@
         , contract_address AS project_contract_address
         , call_tx_hash AS tx_hash
         , call_tx_from AS taker
-        , ROW_NUMBER() OVER (PARTITION BY call_tx_hash ORDER BY call_trace_address) AS row_num
+        , call_trace_address
     FROM {{ source('tempoexchange_tempo', 'stablecoindex_call_swapexactamountout') }}
     WHERE call_success = true
     {% if is_incremental() -%}
@@ -72,5 +72,5 @@
     , CAST(NULL AS VARBINARY) AS maker
     , dexs.project_contract_address
     , dexs.tx_hash
-    , dexs.row_num AS evt_index
+    , ROW_NUMBER() OVER (PARTITION BY dexs.tx_hash ORDER BY dexs.call_trace_address) AS evt_index
 FROM dexs

_{You can send follow-ups to this agent here.}

Comment @cursor review or bugbot run to trigger another review on this PR

[jeff-dude]

@cursor can you remove the seed files, seed schema additions and seed tests?

[cursor]

Removed all seed-related artifacts for tempo DEXs:

• Deleted both seed CSV files (tempo_exchange_tempo_base_trades_seed.csv and uniswap_tempo_base_trades_seed.csv)
• Removed both seed schema entries from seeds/trades/_schema.yml
• Removed all four check_dex_base_trades_seed test blocks from the model _schema.yml (tempo_exchange, uniswap v2, v3, v4)

All models still compile cleanly.

  

[jeff-dude]

@cursor revert temp commit which hardcoded time filter on dex_trades model

[cursor]

Reverted the temporary 14-day non-incremental filter from dex_trades.sql. Both the chain_trades and as_is_dexs CTEs are now back to the original behavior where non-incremental runs have no time restriction.

  

[tomfutago]

lgtm, just seeds missing and entry in dex_info (if that's still a thing)