mirror of
https://github.com/FlipsideCrypto/solana-models.git
synced 2026-02-06 11:47:08 +00:00
4bf749bcb7
* initial models * descriptions for liquidity pool columns * WIP * get mints that occur during swaps * correct description tag * update ymls * correct model references * update yml * update model references and column names * update incremental logic * update yml definitions * revise unique col combo * wip * remove null amounts * additional filter * add index+inner_index to unique key * create final joined table * set inner_index to -1 instead of null * inner_index refactoring * additional tests * exclude models from incremental
60 lines
1.5 KiB
SQL
60 lines
1.5 KiB
SQL
{{ config(
|
|
materialized = 'incremental',
|
|
unique_key = ["block_id","tx_id","index","inner_index"],
|
|
incremental_predicates = ['DBT_INTERNAL_DEST.block_timestamp::date >= LEAST(current_date-7,(select min(block_timestamp)::date from ' ~ generate_tmp_view_name(this) ~ '))'],
|
|
cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE']
|
|
) }}
|
|
-- Get whirlpool LP burns by finding existing whirlpool mints
|
|
WITH base_burn_actions AS (
|
|
|
|
SELECT
|
|
*
|
|
FROM
|
|
{{ ref('silver__burn_actions') }}
|
|
{% if is_incremental() %}
|
|
where _inserted_timestamp >= (
|
|
SELECT
|
|
MAX(_inserted_timestamp)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
{% else %}
|
|
where block_timestamp :: DATE >= '2022-03-10'
|
|
{% endif %}
|
|
),
|
|
base_whirlpool_mints AS (
|
|
SELECT
|
|
*
|
|
FROM
|
|
{{ ref('silver__mints_orca_whirlpool') }}
|
|
{% if is_incremental() %}
|
|
where _inserted_timestamp >= (
|
|
SELECT
|
|
MAX(_inserted_timestamp)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
{% else %}
|
|
where block_timestamp :: DATE >= '2022-03-10'
|
|
{% endif %}
|
|
)
|
|
SELECT
|
|
b.block_id,
|
|
b.block_timestamp,
|
|
b.tx_id,
|
|
b.succeeded,
|
|
b.index,
|
|
COALESCE(b.inner_index, -1) AS inner_index,
|
|
m.program_id,
|
|
b.event_type AS action,
|
|
b.mint,
|
|
b.burn_amount AS amount,
|
|
b.burn_authority AS liquidity_provider,
|
|
m.liquidity_pool_address,
|
|
b._inserted_timestamp
|
|
FROM
|
|
base_burn_actions b
|
|
INNER JOIN base_whirlpool_mints m
|
|
ON b.mint = m.mint
|
|
qualify(row_number() over (partition by b.block_id, b.tx_id, b.index,b.inner_index order by b.index,b.inner_index)) = 1
|