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 remove pools CTE #6344

Merged
merged 7 commits into from
Aug 1, 2024
Merged

lifinity remove pools CTE #6344

Show file tree
Hide file tree
Changes from 6 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
f851782
don't need pools anymore
andrewhong5297 Jul 9, 2024
198b111
namne fix
andrewhong5297 Jul 9, 2024
1a61e9f
col
andrewhong5297 Jul 9, 2024
3d8e8e7
fix
andrewhong5297 Jul 9, 2024
00c8aa3
Merge branch 'main' into lifinity-fix
andrewhong5297 Jul 11, 2024
cfeccde
Merge branch 'main' into lifinity-fix
jeff-dude Jul 12, 2024
876100c
Merge branch 'main' into lifinity-fix
jeff-dude Aug 1, 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
50 changes: 6 additions & 44 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
Expand Up @@ -16,35 +16,7 @@
{% 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 (
all_swaps as (
SELECT
sp.call_block_time as block_time
, sp.call_block_slot as block_slot
Expand All @@ -57,31 +29,21 @@ WITH
-- 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.account_amm as 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
, COALESCE(tr_2.token_mint_address, cast(null as varchar)) as token_bought_mint_address
, COALESCE(tr_1.token_mint_address, cast(null as varchar)) as token_sold_mint_address
, tr_2.from_token_account as token_bought_vault
, tr_1.to_token_account 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
Expand Down
50 changes: 6 additions & 44 deletions solana/models/_sector/dex/lifinity/lifinity_v2_base_trades.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,35 +16,7 @@
{% set project_start_date = '2022-09-13' %} --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 = '2wT8Yq49kHgDzXuPxZSaeLaH1qbmGXtEyPy64bL7aD3c'
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 (
all_swaps as (
SELECT
sp.call_block_time as block_time
, sp.call_block_slot as block_slot
Expand All @@ -57,31 +29,21 @@ WITH
-- 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.account_amm as 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
, COALESCE(tr_2.token_mint_address, cast(null as varchar)) as token_bought_mint_address
, COALESCE(tr_1.token_mint_address, cast(null as varchar)) as token_sold_mint_address
, tr_2.from_token_account as token_bought_vault
, tr_1.to_token_account 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_v2_solana', 'lifinity_amm_v2_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
Expand Down
Loading