mirror of
https://github.com/FlipsideCrypto/solana-models.git
synced 2026-02-06 13:46:42 +00:00
f2ac04fa83
* initial model * add test cases * add tests * add signer/authority * add mint_authority/signer cols * tests and cleanup * exclude model from incremental * grab entire signers array * change col name * add not-null test for col * load start date
105 lines
2.6 KiB
SQL
105 lines
2.6 KiB
SQL
{{ config(
|
|
materialized = 'incremental',
|
|
unique_key = "CONCAT_WS('-', tx_id, event_type, mint)",
|
|
incremental_strategy = 'delete+insert',
|
|
cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'],
|
|
full_refresh = false
|
|
) }}
|
|
|
|
WITH base_events AS (
|
|
|
|
SELECT
|
|
*
|
|
FROM
|
|
{{ ref('silver__events') }}
|
|
{% if is_incremental() and env_var(
|
|
'DBT_IS_BATCH_LOAD',
|
|
"false"
|
|
) == "true" %}
|
|
WHERE
|
|
block_id BETWEEN (
|
|
SELECT
|
|
LEAST(COALESCE(MAX(block_id), 31310775)+1,151386092)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
AND (
|
|
SELECT
|
|
LEAST(COALESCE(MAX(block_id), 31310775)+4000000,151386092)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
{% elif is_incremental() %}
|
|
WHERE
|
|
_inserted_timestamp >= (
|
|
SELECT
|
|
MAX(_inserted_timestamp)
|
|
FROM
|
|
{{ this }}
|
|
)
|
|
{% else %}
|
|
WHERE
|
|
block_id between 31310775 and 32310775
|
|
{% endif %}
|
|
)
|
|
SELECT
|
|
block_id,
|
|
block_timestamp,
|
|
tx_id,
|
|
succeeded,
|
|
index,
|
|
null as inner_index,
|
|
event_type,
|
|
instruction :parsed :info :mint :: STRING AS mint,
|
|
instruction :parsed :info :decimals :: INTEGER AS DECIMAL,
|
|
COALESCE(
|
|
instruction :parsed :info :amount :: INTEGER,
|
|
instruction :parsed :info :tokenAmount: amount :: INTEGER
|
|
) AS mint_amount,
|
|
COALESCE(
|
|
instruction :parsed :info :mintAuthority :: string,
|
|
instruction :parsed :info :multisigAuthority :: string
|
|
) AS mint_authority,
|
|
instruction :parsed :info :signers :: string AS signers,
|
|
_inserted_timestamp
|
|
FROM
|
|
base_events
|
|
WHERE
|
|
event_type IN (
|
|
'mintTo',
|
|
'initializeMint',
|
|
'mintToChecked',
|
|
'initializeMint2'
|
|
)
|
|
UNION
|
|
SELECT
|
|
block_id,
|
|
block_timestamp,
|
|
tx_id,
|
|
succeeded,
|
|
e.index,
|
|
i.index as inner_index,
|
|
i.value :parsed :type :: STRING AS event_type,
|
|
i.value :parsed :info :mint :: STRING AS mint,
|
|
i.value :parsed :info :decimals :: INTEGER AS DECIMAL,
|
|
COALESCE(
|
|
i.value :parsed :info :amount :: INTEGER,
|
|
i.value :parsed :info :tokenAmount: amount :: INTEGER
|
|
) AS mint_amount,
|
|
COALESCE(
|
|
i.value :parsed :info :mintAuthority :: string,
|
|
i.value :parsed :info :multisigAuthority :: string
|
|
) AS mint_authority,
|
|
i.value :parsed :info :signers :: string AS signers,
|
|
_inserted_timestamp
|
|
FROM
|
|
base_events e,
|
|
TABLE(FLATTEN(inner_instruction :instructions)) i
|
|
WHERE
|
|
i.value :parsed :type :: STRING IN (
|
|
'mintTo',
|
|
'initializeMint',
|
|
'mintToChecked',
|
|
'initializeMint2'
|
|
)
|