Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

C911: Updating Solana Schema's #384

Merged
merged 2 commits into from
Aug 11, 2024
Merged

C911: Updating Solana Schema's #384

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
49be612
updating schema for solana flipside tales
SebMelendez01 Aug 11, 2024
d1291ae
fixing bug in solana token transfers
SebMelendez01 Aug 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 8 additions & 24 deletions macros/p2p/filter_p2p_token_transfers.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,33 +24,17 @@
{% else %}
with
{% if chain == "solana" %}
token_prices as (
select
hour::date as date,
token_address,
avg(price) as price
from solana_flipside.price.ez_prices_hourly
{% if is_incremental() %}
where block_timestamp >= (
select dateadd('day', -3, max(block_timestamp))
from {{ this }}
)
{% endif %}
group by date, token_address
),
dex_swap_liquidity_pairs as (
select
t1.swap_from_mint as token_in,
t1.swap_to_mint as token_out,
sum(swap_from_amount * t2.price) as amount_in_usd
from solana_flipside.defi.fact_swaps t1
left join token_prices t2 on t2.token_address = t1.swap_from_mint and t1.block_timestamp::date = t2.date
left join token_prices t3 on t3.token_address = t1.swap_to_mint and t1.block_timestamp::date = t3.date
where swap_to_amount = 0 and swap_from_amount = 0
and swap_from_amount * t2.price is null and swap_to_amount * t3.price is null
swap_from_amount_usd as amount_in_usd
from solana_flipside.defi.ez_dex_swaps t1
where (swap_from_amount_usd is not null and swap_to_amount_usd is not null)
and (swap_from_amount_usd <> 0 and swap_to_amount_usd <> 0) and
and abs(
ln(coalesce(nullif(swap_from_amount * t2.price, 0), 1)) / ln(10)
- ln(coalesce(nullif(swap_to_amount * t3.price, 0), 1)) / ln(10)
ln(coalesce(nullif(swap_from_amount_usd, 0), 1)) / ln(10)
- ln(coalesce(nullif(swap_to_amount_usd, 0), 1)) / ln(10)
)
< 1
group by token_in, token_out
Expand All @@ -59,12 +43,12 @@
),
tokens as (
select distinct swap_from_mint as token
from {{ chain }}_flipside.defi.fact_swaps
from solana_flipside.defi.ez_dex_swaps
where lower(swap_from_mint) not in (select lower(contract_address) from {{ref("fact_" ~ chain ~ "_stablecoin_contracts") }})
and lower(swap_from_mint) in (select lower(token_in) from dex_swap_liquidity_pairs)
union
select distinct swap_to_mint as token
from {{ chain }}_flipside.defi.fact_swaps
from solana_flipside.defi.ez_dex_swaps
where lower(swap_to_mint) not in (select lower(contract_address) from {{ref("fact_" ~ chain ~ "_stablecoin_contracts") }})
and lower(swap_to_mint) in (select lower(token_out) from dex_swap_liquidity_pairs)
)
Expand Down
Loading