Skip to content

Add stablecoin_blacklist_events for USDT/USDC/PYUSD blacklist events #9064

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

Draft
wants to merge 2 commits into
base: main
Choose a base branch
from
+206 −0
Draft

Add stablecoin_blacklist_events for USDT/USDC/PYUSD blacklist events #9064

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
8375b2a
add stablecoin_blacklist_events model
beetle-new Nov 24, 2025
9530d4f
add schema for stablecoin_blacklist_events
beetle-new Nov 24, 2025
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
32 changes: 32 additions & 0 deletions dbt_subprojects/daily_spellbook/models/_sector/stablecoins/schema.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
version: 2

models:
- name: stablecoin_blacklist_events
description: >
Cross-chain blacklist, unblacklist, and destroy events for USDT, USDC,
and PYUSD on Ethereum and Arbitrum.
columns:
- name: blockchain
description: "Blockchain name (e.g. ethereum, arbitrum)."
- name: block_time
description: "Timestamp of the blacklist-related event."
- name: issuer
description: "Token issuer (tether, circle, paypal)."
- name: token
description: "Token symbol (USDT, USDC, PYUSD)."
- name: address
description: "Account affected by the event."
- name: usd_destroy
description: "Amount of funds destroyed for this event, in token units where applicable."
- name: tx_hash
description: "Transaction hash for the event."
- name: event_type
description: "Event type: blacklist, unblacklist, DestroyBlockedFunds."

data_tests:
- dbt_utils.unique_combination_of_columns:
combination_of_columns:
- blockchain
- tx_hash
- event_type
- address
174 changes: 174 additions & 0 deletions dbt_subprojects/daily_spellbook/models/_sector/stablecoins/stablecoin_blacklist_events
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,174 @@
{{ config(
materialized = 'view'
) }}

-- Cross-chain blacklist / unblacklist / destroy events for USDT, USDC, and PYUSD on Ethereum and Arbitrum.

WITH usdt_ethereum AS (
SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'tether' AS issuer
, 'USDT' AS token
, _user AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('tether_ethereum', 'tether_usd_evt_addedblacklist') }}

UNION ALL

SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'tether' AS issuer
, 'USDT' AS token
, _user AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'unblacklist' AS event_type
FROM {{ source('tether_ethereum', 'tether_usd_evt_removedblacklist') }}

UNION ALL

SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'tether' AS issuer
, 'USDT' AS token
, _blackListedUser AS address
, _balance / 1e6 AS usd_destroy
, evt_tx_hash AS tx_hash
, 'DestroyBlockedFunds' AS event_type
FROM {{ source('tether_ethereum', 'tether_usd_evt_destroyedblackfunds') }}
),

usdt_arbitrum AS (
SELECT
'arbitrum' AS blockchain
, evt_block_time AS block_time
, 'tether' AS issuer
, 'USDT' AS token
, _user AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('tether_arbitrum', 'arbitrumextension_evt_blockplaced') }}

UNION ALL

SELECT
'arbitrum' AS blockchain
, evt_block_time AS block_time
, 'tether' AS issuer
, 'USDT' AS token
, _blockedUser AS address
, _balance / 1e6 AS usd_destroy
, evt_tx_hash AS tx_hash
, 'DestroyBlockedFunds' AS event_type
FROM {{ source('tether_arbitrum', 'arbitrumextension_evt_destroyedblockedfunds') }}
),

usdc_ethereum AS (
SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'circle' AS issuer
, 'USDC' AS token
, _account AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('usdc_mk_v1_ethereum', 'fiattokenv2_1_evt_blacklisted') }}

UNION ALL

SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'circle' AS issuer
, 'USDC' AS token
, _account AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'unblacklist' AS event_type
FROM {{ source('usdc_mk_v1_ethereum', 'fiattokenv2_1_evt_unblacklisted') }}
),

usdc_arbitrum AS (
SELECT
'arbitrum' AS blockchain
, evt_block_time AS block_time
, 'circle' AS issuer
, 'USDC' AS token
, _account AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('circle_arbitrum', 'fiattokenv2_2_evt_blacklisted') }}

UNION ALL

SELECT
'arbitrum' AS blockchain
, evt_block_time AS block_time
, 'circle' AS issuer
, 'USDC' AS token
, _account AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'unblacklist' AS event_type
FROM {{ source('circle_arbitrum', 'fiattokenv2_2_evt_unblacklisted') }}
),

pyusd_ethereum AS (
SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'paypal' AS issuer
, 'PYUSD' AS token
, addr AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('paypal_pyusd_ethereum', 'pyusdimplementation_evt_addressfrozen') }}

UNION ALL

SELECT
'ethereum' AS blockchain
, evt_block_time AS block_time
, 'paypal' AS issuer
, 'PYUSD' AS token
, addr AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'unblacklist' AS event_type
FROM {{ source('paypal_pyusd_ethereum', 'pyusdimplementation_evt_addressunfrozen') }}
),

pyusd_arbitrum AS (
SELECT
'arbitrum' AS blockchain
, evt_block_time AS block_time
, 'paypal' AS issuer
, 'PYUSD' AS token
, addr AS address
, CAST(NULL AS double) AS usd_destroy
, evt_tx_hash AS tx_hash
, 'blacklist' AS event_type
FROM {{ source('paypal_arbitrum', 'pyusd_evt_freezeaddress') }}
)

SELECT *
FROM usdt_ethereum
UNION ALL
SELECT * FROM usdt_arbitrum
UNION ALL
SELECT * FROM usdc_ethereum
UNION ALL
SELECT * FROM usdc_arbitrum
UNION ALL
SELECT * FROM pyusd_ethereum
UNION ALL
SELECT * FROM pyusd_arbitrum;
Loading