solana-models/models/silver/nfts/silver__nft_sales_solanart.sql

{{ config(
    materialized = 'incremental',
    unique_key = "CONCAT_WS('-', tx_id, mint)",
    incremental_strategy = 'delete+insert',
    cluster_by = ['block_timestamp::DATE','modified_timestamp::DATE'],
    full_refresh = false,
    enabled = false,
) }}

WITH sales_inner_instructions AS (

    SELECT
        block_timestamp,
        block_id,
        tx_id,
        succeeded,
        program_id,
        e.index,
        COALESCE(
            i.value :parsed :info :lamports :: NUMBER,
            0
        ) AS amount,
        instruction :accounts [0] :: STRING AS purchaser,
        instruction :accounts [3] :: STRING AS seller,
        instruction :accounts [1] :: STRING AS nft_account,
        _inserted_timestamp
    FROM
        {{ ref('silver__events') }}
        e
        LEFT OUTER JOIN TABLE(FLATTEN(inner_instruction :instructions)) i
    WHERE
        e.program_id = 'CJsLwbP1iu5DuUikHEJnLfANgKy6stB2uFgvBBHoyxwz' -- Solanart Program ID

{% if is_incremental() %}
AND _inserted_timestamp >= (
    SELECT
        MAX(_inserted_timestamp)
    FROM
        {{ this }}
)
{% else %}
AND 
    block_timestamp :: date >= '2021-08-01'
{% endif %}
),
post_token_balances AS (
    SELECT
        tx_id,
        account,
        mint
    FROM
        {{ ref('silver___post_token_balances') }}
        p
    WHERE
        amount <> 0 -- Removes random account transfers with no NFT

{% if is_incremental() %}
AND _inserted_timestamp >= (
    SELECT
        MAX(_inserted_timestamp)
    FROM
        {{ this }}
)
{% else %}
AND block_timestamp :: date >= '2021-08-01'
{% endif %}
)
SELECT
    s.block_timestamp,
    s.block_id,
    s.tx_id,
    s.succeeded,
    s.program_id,
    s.index,
    NULL as inner_index,
    p.mint AS mint,
    s.purchaser,
    s.seller, 
    SUM(
        s.amount
    ) / pow(
        10,
        9
    ) AS sales_amount,
    s._inserted_timestamp,
    {{ dbt_utils.generate_surrogate_key(
        ['s.tx_id','p.mint']
    ) }} AS nft_sales_solanart_id,
    SYSDATE() AS inserted_timestamp,
    SYSDATE() AS modified_timestamp,
    '{{ invocation_id }}' AS _invocation_id
FROM
    sales_inner_instructions s
    INNER JOIN post_token_balances p
    ON s.tx_id = p.tx_id
    AND s.nft_account = p.account
GROUP BY
    s.block_timestamp,
    s.block_id,
    s.tx_id,
    s.succeeded,
    s.program_id,
    s.index,
    p.mint,
    s.purchaser,
    s.seller, 
    s._inserted_timestamp,
    nft_sales_solanart_id,
    inserted_timestamp,
    modified_timestamp,
    _invocation_id
HAVING
    SUM(
        s.amount
    ) > 0 -- Removes transfers