flip/ethereum-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/ethereum-models.git synced 2026-02-06 13:46:47 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

history model change (#1141)

Browse Source
This commit is contained in:
Austin 2025-09-15 10:13:15 -04:00 committed by GitHub
parent 9fecca9852
commit c358fa3480
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 32 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
models/streamline/silver/balances/history/streamline__token_balances_history.sql
View File

@ -13,35 +13,35 @@
tags = ['streamline_balances_history']
) }}
WITH last_3_days AS (
SELECT
block_number
FROM
{{ ref("_max_block_by_date") }}
qualify ROW_NUMBER() over (
ORDER BY
block_number DESC
) = 3
),
relevant_contracts AS (
select contract_address, count(*)
from {{ ref("core__ez_token_transfers") }}
where block_timestamp > current_date() - 60 and token_is_verified
group by all
order by 2 desc
limit 100
WITH verified_contracts as (
select token_address
from {{ ref('price__ez_asset_metadata') }}
where is_verified
),
logs as (
select
to_address as address1,
from_address as address2,
contract_address,
block_number
from {{ ref("core__ez_token_transfers") }}
where contract_address in (select contract_address from relevant_contracts union select '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2')
and block_number > 21000000
and block_number < (select block_number from last_3_days)
SELECT
CONCAT('0x', SUBSTR(l.topics [1] :: STRING, 27, 42)) AS address1,
CONCAT('0x', SUBSTR(l.topics [2] :: STRING, 27, 42)) AS address2,
l.contract_address,
l.block_number
FROM
{{ ref('core__fact_event_logs') }} l
INNER JOIN verified_contracts m
on l.contract_address = m.token_address
WHERE
(
l.topics [0] :: STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef'
OR (
l.topics [0] :: STRING = '0x7fcf532c15f0a6db0bd6d0e038bea71d30d808c7d98cb3bf7268a95bf5081b65'
AND l.contract_address = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
)
OR (
l.topics [0] :: STRING = '0xe1fffcc4923d04b559f4d29a8bfc6cda04eb5b0d3c460751c2402c5c5cc9109c'
AND l.contract_address = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
)
)
AND block_number >= 22000000
and block_timestamp::date < dateadd('day', -1, sysdate())
),
transfers AS (
SELECT
@ -79,16 +79,11 @@ to_do AS (
address,
contract_address
FROM
{{ ref("streamline__complete_token_balances") }}
WHERE
block_number < (
SELECT
block_number
FROM
last_3_days
)
AND block_number IS NOT NULL
AND block_number > 21000000
{{ ref("streamline__complete_token_balances") }} t
INNER JOIN verified_contracts m
on t.contract_address = m.token_address
WHERE
block_number >= 22000000
)
SELECT
block_number,