forked from duneanalytics/spellbook
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Nexus Mutual - staking rewards & staked history (duneanalytics#6861)
* refactor: staking events * fix: amend product_id to non-nullable & trigger incremental re-run * feat: add staking rewards and staked per pool & token * fix: staking deposit entensions uniqueness
- Loading branch information
Showing
10 changed files
with
482 additions
and
34 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
90 changes: 90 additions & 0 deletions
90
...ly_spellbook/models/nexusmutual/ethereum/staking/nexusmutual_ethereum_staked_per_pool.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,90 @@ | ||
| {{ | ||
| config( | ||
| schema = 'nexusmutual_ethereum', | ||
| alias = 'staked_per_pool', | ||
| materialized = 'view', | ||
| unique_key = ['block_date', 'pool_id'], | ||
| post_hook = '{{ expose_spells(blockchains = \'["ethereum"]\', | ||
| spell_type = "project", | ||
| spell_name = "nexusmutual", | ||
| contributors = \'["tomfutago"]\') }}' | ||
| ) | ||
| }} | ||
|
|
||
| with | ||
|
|
||
| staking_pools as ( | ||
| select distinct | ||
| sp.pool_id, | ||
| sp.pool_address, | ||
| se.first_stake_event_date | ||
| from {{ ref('nexusmutual_ethereum_staking_pools') }} sp | ||
| inner join ( | ||
| select | ||
| pool_address, | ||
| cast(min(block_time) as date) as first_stake_event_date | ||
| from {{ ref('nexusmutual_ethereum_staking_events') }} | ||
| group by 1 | ||
| ) se on sp.pool_address = se.pool_address | ||
| ), | ||
|
|
||
| staking_pool_day_sequence as ( | ||
| select | ||
| sp.pool_id, | ||
| sp.pool_address, | ||
| s.block_date | ||
| from staking_pools sp | ||
| cross join unnest ( | ||
| sequence( | ||
| cast(date_trunc('day', sp.first_stake_event_date) as timestamp), | ||
| cast(date_trunc('day', now()) as timestamp), | ||
| interval '1' day | ||
| ) | ||
| ) as s(block_date) | ||
| ), | ||
|
|
||
| staked_nxm_per_pool as ( | ||
| select | ||
| block_date, | ||
| pool_id, | ||
| pool_address, | ||
| sum(coalesce(total_amount, 0)) as total_staked_nxm, | ||
| dense_rank() over (partition by pool_id order by block_date desc) as pool_date_rn | ||
| from ( | ||
| -- deposits & deposit extensions | ||
| select | ||
| d.block_date, | ||
| d.pool_id, | ||
| d.pool_address, | ||
| sum(se.amount) as total_amount | ||
| from staking_pool_day_sequence d | ||
| left join {{ ref('nexusmutual_ethereum_staking_deposit_extensions') }} se | ||
| on d.pool_address = se.pool_address | ||
| and d.block_date >= se.stake_start_date | ||
| and d.block_date < se.stake_end_date | ||
| group by 1, 2, 3 | ||
| union all | ||
| -- withdrawals & burns | ||
| select | ||
| d.block_date, | ||
| d.pool_id, | ||
| d.pool_address, | ||
| sum(se.amount) as total_amount | ||
| from staking_pool_day_sequence d | ||
| left join {{ ref('nexusmutual_ethereum_staking_events') }} se | ||
| on d.pool_address = se.pool_address | ||
| and d.block_date >= date_trunc('day', se.block_time) | ||
| and d.block_date < coalesce(se.tranche_expiry_date, current_date) | ||
| where flow_type in ('withdraw', 'stake burn') | ||
| group by 1, 2, 3 | ||
| ) t | ||
| group by 1, 2, 3 | ||
| ) | ||
|
|
||
| select | ||
| block_date, | ||
| pool_id, | ||
| pool_address, | ||
| total_staked_nxm, | ||
| pool_date_rn | ||
| from staked_nxm_per_pool |
98 changes: 98 additions & 0 deletions
98
...y_spellbook/models/nexusmutual/ethereum/staking/nexusmutual_ethereum_staked_per_token.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| {{ | ||
| config( | ||
| schema = 'nexusmutual_ethereum', | ||
| alias = 'staked_per_token', | ||
| materialized = 'view', | ||
| unique_key = ['block_date', 'pool_id', 'token_id'], | ||
| post_hook = '{{ expose_spells(blockchains = \'["ethereum"]\', | ||
| spell_type = "project", | ||
| spell_name = "nexusmutual", | ||
| contributors = \'["tomfutago"]\') }}' | ||
| ) | ||
| }} | ||
|
|
||
| with | ||
|
|
||
| staking_pools as ( | ||
| select distinct | ||
| sp.pool_id, | ||
| sp.pool_address, | ||
| se.first_stake_event_date | ||
| from {{ ref('nexusmutual_ethereum_staking_pools') }} sp | ||
| inner join ( | ||
| select | ||
| pool_address, | ||
| cast(min(block_time) as date) as first_stake_event_date | ||
| from {{ ref('nexusmutual_ethereum_staking_events') }} | ||
| group by 1 | ||
| ) se on sp.pool_address = se.pool_address | ||
| ), | ||
|
|
||
| staking_pool_day_sequence as ( | ||
| select | ||
| sp.pool_id, | ||
| sp.pool_address, | ||
| s.block_date | ||
| from staking_pools sp | ||
| cross join unnest ( | ||
| sequence( | ||
| cast(date_trunc('day', sp.first_stake_event_date) as timestamp), | ||
| cast(date_trunc('day', now()) as timestamp), | ||
| interval '1' day | ||
| ) | ||
| ) as s(block_date) | ||
| ), | ||
|
|
||
| staked_nxm_per_pool_n_token as ( | ||
| select | ||
| block_date, | ||
| pool_id, | ||
| pool_address, | ||
| token_id, | ||
| sum(coalesce(total_amount, 0)) as total_staked_nxm, | ||
| max(stake_expiry_date) as stake_expiry_date, | ||
| dense_rank() over (partition by pool_id, token_id order by block_date desc) as token_date_rn | ||
| from ( | ||
| -- deposits & deposit extensions | ||
| select | ||
| d.block_date, | ||
| d.pool_id, | ||
| d.pool_address, | ||
| se.token_id, | ||
| sum(se.amount) as total_amount, | ||
| max(se.stake_end_date) as stake_expiry_date | ||
| from staking_pool_day_sequence d | ||
| left join {{ ref('nexusmutual_ethereum_staking_deposit_extensions') }} se | ||
| on d.pool_address = se.pool_address | ||
| and d.block_date >= se.stake_start_date | ||
| and d.block_date < se.stake_end_date | ||
| group by 1, 2, 3, 4 | ||
| union all | ||
| -- withdrawals & burns? | ||
| select | ||
| d.block_date, | ||
| d.pool_id, | ||
| d.pool_address, | ||
| se.token_id, | ||
| sum(se.amount) as total_amount, | ||
| cast(null as date) as stake_expiry_date -- no point pulling stake_expiry_date for withdrawals | ||
| from staking_pool_day_sequence d | ||
| left join {{ ref('nexusmutual_ethereum_staking_events') }} se | ||
| on d.pool_address = se.pool_address | ||
| and d.block_date >= date_trunc('day', se.block_time) | ||
| and d.block_date < coalesce(se.tranche_expiry_date, current_date) | ||
| where flow_type in ('withdraw', 'stake burn') | ||
| group by 1, 2, 3, 4 | ||
| ) t | ||
| group by 1, 2, 3, 4 | ||
| ) | ||
|
|
||
| select | ||
| block_date, | ||
| pool_id, | ||
| pool_address, | ||
| token_id, | ||
| total_staked_nxm, | ||
| stake_expiry_date, | ||
| token_date_rn | ||
| from staked_nxm_per_pool_n_token |
Oops, something went wrong.