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

Jump to bottom

Lifinity base trades and compatibility view #6296

Merged
merged 4 commits into from
Jul 4, 2024
Merged

Lifinity base trades and compatibility view #6296

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
9615986
Update dex_solana_base_trades.sql
andrewhong5297 Jul 1, 2024
f7e3a72
add lifinity base trades and compatibility view
0xRobin Jul 1, 2024
343deec
add lifinity base trades and compatibility view
0xRobin Jul 1, 2024
2acfe13
Merge branch 'main' into lifinity-base-trades
0xRobin Jul 2, 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
2 changes: 2 additions & 0 deletions solana/models/_sector/dex/dex_solana_base_trades.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,8 @@
ref('orca_whirlpool_trades')
, ref('raydium_v3_trades')
, ref('raydium_v4_trades')
, ref('lifinity_v1_base_trades')
, ref('lifinity_v2_base_trades')
, ref('phoenix_v1_trades')
, ref('meteora_v1_solana_trades')
, ref('meteora_v2_solana_trades')
Expand Down
140 changes: 140 additions & 0 deletions solana/models/_sector/dex/lifinity/lifinity_v1_base_trades.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,140 @@
{{
config(

schema = 'lifinity_v1',
alias = 'base_trades',
partition_by = ['block_month'],
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
unique_key = ['tx_id', 'outer_instruction_index', 'inner_instruction_index', 'tx_index','block_month'],
pre_hook='{{ enforce_join_distribution("PARTITIONED") }}'
)
}}

{% set project_start_date = '2022-01-26' %} --grabbed program deployed at time (account created at)

WITH
pools as (
-- we can get fees after they give us the right IDL for initializing the pool and updating configs
-- https://solscan.io/tx/DNXYzbhFnY9PwT4iwXNMpQq42kafcPaxSSgxsZ6XFLACvVNfpEfbJHG6VjPKevnH3aT4nwqPy4WFmQu4Y4NrY3e
SELECT
mintA.token_mint_address as tokenA
, ip.account_arguments[4] as tokenAVault
, mintB.token_mint_address as tokenB
, ip.account_arguments[5] as tokenBVault
, ip.account_arguments[6] as fee_account
, ip.account_arguments[2] as pool_id
, ip.account_arguments[3] as pool_mint_id
, ip.tx_id as init_tx
FROM (
SELECT
*
FROM {{ source('solana','instruction_calls') }}
WHERE cardinality(account_arguments) >= 5 --filter out broken cases/inits for now
and bytearray_substring(data,1,8) = 0xafaf6d1f0d989bed
and executing_account = 'EewxydAPCCVuNEyrVN68PuSYdQ7wKn27V9Gjeoi8dy3S'
and tx_success
and block_time > TIMESTAMP '2022-01-26'
) ip
INNER JOIN {{ ref('solana_utils_token_accounts') }} mintA ON mintA.address = ip.account_arguments[4]
AND mintA.account_type = 'fungible'
INNER JOIN {{ ref('solana_utils_token_accounts') }} mintB ON mintB.address = ip.account_arguments[5]
AND mintB.account_type = 'fungible'
)

, all_swaps as (
SELECT
sp.call_block_time as block_time
, sp.call_block_slot as block_slot
, 'lifinity' as project
, 1 as version
, 'solana' as blockchain
, case when sp.call_is_inner = False then 'direct'
else sp.call_outer_executing_account
end as trade_source
-- token bought is always the second instruction (transfer) in the inner instructions
, tr_2.amount as token_bought_amount_raw
, tr_1.amount as token_sold_amount_raw
, p.pool_id
, sp.call_tx_signer as trader_id
, sp.call_tx_id as tx_id
, sp.call_outer_instruction_index as outer_instruction_index
, COALESCE(sp.call_inner_instruction_index, 0) as inner_instruction_index
, sp.call_tx_index as tx_index
, case when tr_1.token_mint_address = p.tokenA then p.tokenB
else p.tokenA
end as token_bought_mint_address
, case when tr_1.token_mint_address = p.tokenA then p.tokenA
else p.tokenB
end as token_sold_mint_address
, case when tr_1.token_mint_address = p.tokenA then p.tokenBVault
else p.tokenAVault
end as token_bought_vault
, case when tr_1.token_mint_address = p.tokenA then p.tokenAVault
else p.tokenBVault
end as token_sold_vault
--swap out can be either 2nd or 3rd transfer, we need to filter for the first transfer out.
, tr_2.inner_instruction_index as transfer_out_index
, row_number() over (partition by sp.call_tx_id, sp.call_outer_instruction_index, sp.call_inner_instruction_index
order by COALESCE(tr_2.inner_instruction_index, 0) asc) as first_transfer_out
FROM {{ source('lifinity_amm_solana', 'lifinity_amm_call_swap') }} sp
INNER JOIN pools p
ON sp.account_amm = p.pool_id --account 2
INNER JOIN {{ ref('tokens_solana_transfers') }} tr_1
ON tr_1.tx_id = sp.call_tx_id
AND tr_1.outer_instruction_index = sp.call_outer_instruction_index
AND ((sp.call_is_inner = false AND tr_1.inner_instruction_index = 1)
OR (sp.call_is_inner = true AND tr_1.inner_instruction_index = sp.call_inner_instruction_index + 1))
AND tr_1.token_version = 'spl_token'
{% if is_incremental() %}
AND {{incremental_predicate('tr_1.block_time')}}
{% else %}
AND tr_1.block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
--swap out can be either 2nd or 3rd transfer.
INNER JOIN {{ ref('tokens_solana_transfers') }} tr_2
ON tr_2.tx_id = sp.call_tx_id
AND tr_2.outer_instruction_index = sp.call_outer_instruction_index
AND ((sp.call_is_inner = false AND (tr_2.inner_instruction_index = 2 OR tr_2.inner_instruction_index = 3))
OR (sp.call_is_inner = true AND (tr_2.inner_instruction_index = sp.call_inner_instruction_index + 2 OR tr_2.inner_instruction_index = sp.call_inner_instruction_index + 3))
)
AND tr_2.token_version = 'spl_token'
{% if is_incremental() %}
AND {{incremental_predicate('tr_2.block_time')}}
{% else %}
AND tr_2.block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
WHERE 1=1
{% if is_incremental() %}
AND {{incremental_predicate('sp.call_block_time')}}
{% else %}
AND sp.call_block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
)

SELECT
tb.blockchain
, tb.project
, tb.version
, CAST(date_trunc('month', tb.block_time) AS DATE) as block_month
, tb.block_time
, tb.block_slot
, tb.trade_source
, tb.token_bought_amount_raw
, tb.token_sold_amount_raw
, cast(null as double) as fee_tier
, tb.token_sold_mint_address
, tb.token_bought_mint_address
, tb.token_sold_vault
, tb.token_bought_vault
, tb.pool_id as project_program_id
, 'EewxydAPCCVuNEyrVN68PuSYdQ7wKn27V9Gjeoi8dy3S' as project_main_id
, tb.trader_id
, tb.tx_id
, tb.outer_instruction_index
, tb.inner_instruction_index
, tb.tx_index
FROM all_swaps tb
WHERE first_transfer_out = 1
182 changes: 3 additions & 179 deletions solana/models/_sector/dex/lifinity/lifinity_v1_trades.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,187 +3,11 @@

schema = 'lifinity_v1',
alias = 'trades',
partition_by = ['block_month'],
materialized = 'incremental',
file_format = 'delta',
incremental_strategy = 'merge',
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
unique_key = ['tx_id', 'outer_instruction_index', 'inner_instruction_index', 'tx_index','block_month'],
pre_hook='{{ enforce_join_distribution("PARTITIONED") }}',
materialized = 'view',
post_hook='{{ expose_spells(\'["solana"]\',
"project",
"lifinity",
\'["ilemi"]\') }}')
}}

{% set project_start_date = '2022-01-26' %} --grabbed program deployed at time (account created at)

WITH
pools as (
-- we can get fees after they give us the right IDL for initializing the pool and updating configs
-- https://solscan.io/tx/DNXYzbhFnY9PwT4iwXNMpQq42kafcPaxSSgxsZ6XFLACvVNfpEfbJHG6VjPKevnH3aT4nwqPy4WFmQu4Y4NrY3e
SELECT
tkA.symbol as tokenA_symbol
, tkA.decimals as tokenA_decimals
, mintA.token_mint_address as tokenA
, ip.account_arguments[4] as tokenAVault
, tkB.symbol as tokenB_symbol
, tkB.decimals as tokenB_decimals
, mintB.token_mint_address as tokenB
, ip.account_arguments[5] as tokenBVault
, ip.account_arguments[6] as fee_account
, ip.account_arguments[2] as pool_id
, ip.account_arguments[3] as pool_mint_id
, ip.tx_id as init_tx
FROM (
SELECT
*
FROM {{ source('solana','instruction_calls') }}
WHERE cardinality(account_arguments) >= 5 --filter out broken cases/inits for now
and bytearray_substring(data,1,8) = 0xafaf6d1f0d989bed
and executing_account = 'EewxydAPCCVuNEyrVN68PuSYdQ7wKn27V9Gjeoi8dy3S'
and tx_success
and block_time > TIMESTAMP '2022-01-26'
) ip
INNER JOIN {{ ref('solana_utils_token_accounts') }} mintA ON mintA.address = ip.account_arguments[4]
AND mintA.account_type = 'fungible'
INNER JOIN {{ ref('solana_utils_token_accounts') }} mintB ON mintB.address = ip.account_arguments[5]
AND mintB.account_type = 'fungible'
LEFT JOIN {{ ref('tokens_solana_fungible') }} tkA ON tkA.token_mint_address = mintA.token_mint_address
AND tkA.token_version = 'spl_token'
LEFT JOIN {{ ref('tokens_solana_fungible') }} tkB ON tkB.token_mint_address = mintB.token_mint_address
AND tkB.token_version = 'spl_token'
)

, all_swaps as (
SELECT
sp.call_block_time as block_time
, sp.call_block_slot as block_slot
, 'lifinity' as project
, 1 as version
, 'solana' as blockchain
, case when sp.call_is_inner = False then 'direct'
else sp.call_outer_executing_account
end as trade_source
,case
when lower(tokenA_symbol) > lower(tokenB_symbol) then concat(tokenB_symbol, '-', tokenA_symbol)
else concat(tokenA_symbol, '-', tokenB_symbol)
end as token_pair
, case when tr_1.token_mint_address = p.tokenA then COALESCE(tokenB_symbol, tokenB)
else COALESCE(tokenA_symbol, tokenA)
end as token_bought_symbol
-- token bought is always the second instruction (transfer) in the inner instructions
, tr_2.amount as token_bought_amount_raw
, tr_2.amount/pow(10,COALESCE(case when tr_1.token_mint_address = p.tokenA then p.tokenB_decimals else tokenA_decimals end,9)) as token_bought_amount
, case when tr_1.token_mint_address = p.tokenA then COALESCE(tokenA_symbol, tokenA)
else COALESCE(tokenB_symbol, tokenB)
end as token_sold_symbol
, tr_1.amount as token_sold_amount_raw
, tr_1.amount/pow(10,COALESCE(case when tr_1.token_mint_address = p.tokenA then p.tokenA_decimals else tokenB_decimals end,9)) as token_sold_amount
, p.pool_id
, sp.call_tx_signer as trader_id
, sp.call_tx_id as tx_id
, sp.call_outer_instruction_index as outer_instruction_index
, COALESCE(sp.call_inner_instruction_index, 0) as inner_instruction_index
, sp.call_tx_index as tx_index
, case when tr_1.token_mint_address = p.tokenA then p.tokenB
else p.tokenA
end as token_bought_mint_address
, case when tr_1.token_mint_address = p.tokenA then p.tokenA
else p.tokenB
end as token_sold_mint_address
, case when tr_1.token_mint_address = p.tokenA then p.tokenBVault
else p.tokenAVault
end as token_bought_vault
, case when tr_1.token_mint_address = p.tokenA then p.tokenAVault
else p.tokenBVault
end as token_sold_vault
--swap out can be either 2nd or 3rd transfer, we need to filter for the first transfer out.
, tr_2.inner_instruction_index as transfer_out_index
, row_number() over (partition by sp.call_tx_id, sp.call_outer_instruction_index, sp.call_inner_instruction_index
order by COALESCE(tr_2.inner_instruction_index, 0) asc) as first_transfer_out
FROM {{ source('lifinity_amm_solana', 'lifinity_amm_call_swap') }} sp
INNER JOIN pools p
ON sp.account_amm = p.pool_id --account 2
INNER JOIN {{ ref('tokens_solana_transfers') }} tr_1
ON tr_1.tx_id = sp.call_tx_id
AND tr_1.outer_instruction_index = sp.call_outer_instruction_index
AND ((sp.call_is_inner = false AND tr_1.inner_instruction_index = 1)
OR (sp.call_is_inner = true AND tr_1.inner_instruction_index = sp.call_inner_instruction_index + 1))
AND tr_1.token_version = 'spl_token'
{% if is_incremental() %}
AND {{incremental_predicate('tr_1.block_time')}}
{% else %}
AND tr_1.block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
--swap out can be either 2nd or 3rd transfer.
INNER JOIN {{ ref('tokens_solana_transfers') }} tr_2
ON tr_2.tx_id = sp.call_tx_id
AND tr_2.outer_instruction_index = sp.call_outer_instruction_index
AND ((sp.call_is_inner = false AND (tr_2.inner_instruction_index = 2 OR tr_2.inner_instruction_index = 3))
OR (sp.call_is_inner = true AND (tr_2.inner_instruction_index = sp.call_inner_instruction_index + 2 OR tr_2.inner_instruction_index = sp.call_inner_instruction_index + 3))
)
AND tr_2.token_version = 'spl_token'
{% if is_incremental() %}
AND {{incremental_predicate('tr_2.block_time')}}
{% else %}
AND tr_2.block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
WHERE 1=1
{% if is_incremental() %}
AND {{incremental_predicate('sp.call_block_time')}}
{% else %}
AND sp.call_block_time >= TIMESTAMP '{{project_start_date}}'
{% endif %}
)

SELECT
tb.blockchain
, tb.project
, tb.version
, CAST(date_trunc('month', tb.block_time) AS DATE) as block_month
, tb.block_time
, tb.block_slot
, tb.token_pair
, tb.trade_source
, tb.token_bought_symbol
, tb.token_bought_amount
, tb.token_bought_amount_raw
, tb.token_sold_symbol
, tb.token_sold_amount
, tb.token_sold_amount_raw
, case when p_sold.price is not null and p_bought.price is not null
then least(tb.token_sold_amount * p_sold.price, tb.token_bought_amount * p_bought.price)
else COALESCE(tb.token_sold_amount * p_sold.price, tb.token_bought_amount * p_bought.price)
end as amount_usd
, cast(null as double) as fee_tier
, cast(null as double) as fee_usd
, tb.token_sold_mint_address
, tb.token_bought_mint_address
, tb.token_sold_vault
, tb.token_bought_vault
, tb.pool_id as project_program_id
, 'EewxydAPCCVuNEyrVN68PuSYdQ7wKn27V9Gjeoi8dy3S' as project_main_id
, tb.trader_id
, tb.tx_id
, tb.outer_instruction_index
, tb.inner_instruction_index
, tb.tx_index
FROM all_swaps tb
LEFT JOIN {{ source('prices', 'usd') }} p_bought ON p_bought.blockchain = 'solana'
AND date_trunc('minute', tb.block_time) = p_bought.minute
AND token_bought_mint_address = toBase58(p_bought.contract_address)
{% if is_incremental() %}
AND {{incremental_predicate('p_bought.minute')}}
{% else %}
AND p_bought.minute >= TIMESTAMP '{{project_start_date}}'
{% endif %}
LEFT JOIN {{ source('prices', 'usd') }} p_sold ON p_sold.blockchain = 'solana'
AND date_trunc('minute', tb.block_time) = p_sold.minute
AND token_sold_mint_address = toBase58(p_sold.contract_address)
{% if is_incremental() %}
AND {{incremental_predicate('p_sold.minute')}}
{% else %}
AND p_sold.minute >= TIMESTAMP '{{project_start_date}}'
{% endif %}
WHERE first_transfer_out = 1
select * from {{ ref('dex_solana_trades' )}}
where project = 'lifinity' and version = 1
Loading
Loading