flip/blast-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/blast-models.git synced 2026-02-06 14:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

tx and trace status

Browse Source
This commit is contained in:
drethereum 2025-01-28 14:42:35 -07:00
parent af7517a4ec
commit 4395c4e31b
28 changed files with 51 additions and 177 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
models/gold/core/core__ez_native_transfers.sql
View File

@ -13,7 +13,6 @@ SELECT
block_timestamp,
tx_position,
trace_index,
identifier, --deprecate
trace_address, --new column
origin_from_address,
origin_to_address,
@ -26,12 +25,13 @@ SELECT
amount_usd,
native_transfers_id AS ez_native_transfers_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp
SYSDATE() AS modified_timestamp,
identifier --deprecate
FROM
{{ ref('silver__native_transfers') }}
{% if is_incremental() %}
AND modified_timestamp > (
WHERE modified_timestamp > (
SELECT
COALESCE(MAX(modified_timestamp), '1970-01-01' :: TIMESTAMP) AS modified_timestamp
FROM

8
models/gold/core/core__fact_traces.sql
View File

@ -471,10 +471,10 @@ SELECT
error_reason,
revert_reason,
tx_succeeded,
identifier,
DATA,
tx_status,
trace_status,
identifier, --deprecate
DATA, --deprecate
tx_status, --deprecate
trace_status, --deprecate
{{ dbt_utils.generate_surrogate_key(
['tx_hash', 'trace_index']
) }} AS fact_traces_id,

5
models/silver/defi/bridge/across/silver_bridge__across_v3fundsdeposited.sql
View File

@ -49,10 +49,7 @@ WITH base_evt AS (
CONCAT('0x', SUBSTR(segmented_data [7] :: STRING, 25, 40)) AS recipient,
CONCAT('0x', SUBSTR(segmented_data [8] :: STRING, 25, 40)) AS exclusiveRelayer,
segmented_data [9] :: STRING AS message,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

10
models/silver/defi/bridge/axelar/silver_bridge__axelar_contractcallwithtoken.sql
View File

@ -35,10 +35,7 @@ WITH base_evt AS (
decoded_log :"symbol" :: STRING AS symbol,
decoded_log,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -92,10 +89,7 @@ native_gas_paid AS (
decoded_log :"symbol" :: STRING AS symbol,
decoded_log,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

20
models/silver/defi/bridge/hyperlane/silver_bridge__hyperlane_bridge.sql
View File

@ -24,10 +24,7 @@ WITH dispatch AS (
CONCAT('0x', SUBSTR(topics [3] :: STRING, 27, 40)) AS dst_bridge_token,
-- dst bridge token address, not recipient address
DATA,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -58,10 +55,7 @@ dispatch_id AS (
tx_hash,
event_index,
topics [1] :: STRING AS messageId,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -96,10 +90,7 @@ gas_payment AS (
regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data,
TRY_TO_NUMBER(utils.udf_hex_to_int(segmented_data [0] :: STRING)) AS gasAmount,
TRY_TO_NUMBER(utils.udf_hex_to_int(segmented_data [1] :: STRING)) AS payment,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -133,10 +124,7 @@ sent_transfer_remote AS (
CONCAT('0x', SUBSTR(topics [2] :: STRING, 27, 40)) AS recipient,
-- actual recipient
TRY_TO_NUMBER(utils.udf_hex_to_int(DATA :: STRING)) AS amount,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

20
models/silver/defi/bridge/layerzero/silver_bridge__layerzero_bridge_v2.sql
View File

@ -13,14 +13,8 @@ WITH oft_asset_contract_creation AS (
block_timestamp,
tx_hash,
from_address AS oft_address,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
tx_succeeded,
trace_succeeded,
modified_timestamp
FROM
{{ ref('core__fact_traces') }}
@ -57,14 +51,8 @@ oft_asset_base_token AS (
tx_hash,
from_address AS wrap_address,
to_address AS underlying_address,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
tx_succeeded,
trace_succeeded,
modified_timestamp
FROM
{{ ref('core__fact_traces') }}

5
models/silver/defi/bridge/symbiosis/silver_bridge__symbiosis_synthesizerequest.sql
View File

@ -36,10 +36,7 @@ WITH base_evt AS (
CONCAT('0x', SUBSTR(topics [3] :: STRING, 27, 40)) AS revertableAddress,
CONCAT('0x', SUBSTR(segmented_data [1] :: STRING, 25, 40)) AS to_address,
CONCAT('0x', SUBSTR(segmented_data [3] :: STRING, 25, 40)) AS token,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/bridge/synapse/silver_bridge__synapse_tokenredeem.sql
View File

@ -24,10 +24,7 @@ WITH base_evt AS (
topics [3] :: STRING AS topic_3,
DATA,
regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

2
models/silver/defi/dex/fenix/silver_dex__fenix_swaps_v3.sql
View File

@ -71,7 +71,7 @@ AND l.modified_timestamp >= (
FROM
{{ this }}
)
AND l._inserted_timestamp >= SYSDATE() - INTERVAL '7 day'
AND l.modified_timestamp >= SYSDATE() - INTERVAL '7 day'
{% endif %}
)
SELECT

10
models/silver/defi/lending/init/silver__init_asset_details.sql
View File

@ -44,10 +44,7 @@ underlying AS (
tx_hash,
block_timestamp,
block_number,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
from_address AS token_address,
to_address AS underlying_asset_address
FROM
@ -74,10 +71,7 @@ unwrapped AS (
SELECT
from_address AS underlying_asset_address,
to_address AS underlying_unwrap_address,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded
trace_succeeded
FROM
{{ ref('core__fact_traces') }}
WHERE

10
models/silver/defi/lending/init/silver__init_borrows.sql
View File

@ -48,10 +48,7 @@ init_borrows AS (
contract_address AS token,
'INIT Capital' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -121,10 +118,7 @@ native_transfer AS (
to_address,
value_precise_raw AS eth_value,
'WETH' AS eth_symbol,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
18 AS eth_decimals,
'0x4300000000000000000000000000000000000004' AS eth_address
FROM

10
models/silver/defi/lending/init/silver__init_deposits.sql
View File

@ -50,10 +50,7 @@ init_deposits AS (
-- receipt token
'INIT Capital' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -226,10 +223,7 @@ native_transfer AS (
to_address,
value_precise_raw AS eth_value,
'WETH' AS eth_symbol,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
18 AS eth_decimals,
'0x4300000000000000000000000000000000000004' AS eth_address
FROM

10
models/silver/defi/lending/init/silver__init_liquidations.sql
View File

@ -51,10 +51,7 @@ init_liquidations AS (
contract_address AS token,
'INIT Capital' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -132,10 +129,7 @@ position_owner AS (
utils.udf_hex_to_int(
topics [2] :: STRING
) :: STRING AS posId, -- using string as it handles better than float
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

10
models/silver/defi/lending/init/silver__init_repayments.sql
View File

@ -51,10 +51,7 @@ init_repayments AS (
contract_address AS token,
'INIT Capital' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -84,10 +81,7 @@ native_transfer AS (
to_address AS wrapped_address,
value_precise_raw AS eth_value,
'WETH' AS eth_symbol,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
18 AS eth_decimals,
'0x4300000000000000000000000000000000000004' AS eth_address
FROM

10
models/silver/defi/lending/init/silver__init_withdraws.sql
View File

@ -49,10 +49,7 @@ init_redemption AS (
) :: FLOAT AS redeemed_token_raw,
'INIT Capital' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -232,10 +229,7 @@ native_transfer AS (
from_address AS wrapped_address,
to_address,
value_precise_raw AS eth_value,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
'WETH' AS eth_symbol,
18 AS eth_decimals,
'0x4300000000000000000000000000000000000004' AS eth_address

20
models/silver/defi/lending/juice/silver__juice_asset_details.sql
View File

@ -78,10 +78,7 @@ tx_pull AS (
topics,
DATA,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -134,10 +131,7 @@ trace_pull AS (
) AS identifier,
DATA,
sub_traces,
CASE
WHEN trace_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS trace_succeeded,
trace_succeeded,
error_reason,
trace_index,
fact_traces_id,
@ -253,10 +247,7 @@ logs_pull AS (
regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data,
CONCAT('0x', SUBSTR(segmented_data [0], 25, 40)) AS contract_address,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -290,10 +281,7 @@ get_underlying AS (
topics,
DATA,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/juice/silver__juice_borrows.sql
View File

@ -43,10 +43,7 @@ juice_borrows AS (
contract_address AS pool_address,
'Juice' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/juice/silver__juice_deposits.sql
View File

@ -38,10 +38,7 @@ deposit_logs AS (
topics,
DATA,
event_removed,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

15
models/silver/defi/lending/juice/silver__juice_liquidations.sql
View File

@ -51,10 +51,7 @@ juice_liquidations AS (
) :: INTEGER AS debtamountneeded_raw,
'Juice' AS platform,
l.modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -87,10 +84,7 @@ token_transfer AS (
tx_hash,
utils.udf_hex_to_int(DATA) AS seizeTokens_raw,
event_index,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',
@ -130,10 +124,7 @@ debt_transfer AS (
debt_name,
debt_address AS debt_token,
debt_symbol AS debt_token_symbol,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/juice/silver__juice_repayments.sql
View File

@ -43,10 +43,7 @@ juice_repayments AS (
) :: INTEGER AS repayed_amount_raw,
'Juice' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/juice/silver__juice_withdraws.sql
View File

@ -38,10 +38,7 @@ withdraw_logs AS (
DATA,
topics,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_asset_details.sql
View File

@ -14,10 +14,7 @@ WITH log_pull_1 AS (
block_timestamp,
contract_address,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_borrows.sql
View File

@ -44,10 +44,7 @@ orbit_borrows AS (
contract_address AS token,
'Orbit' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_deposits.sql
View File

@ -41,10 +41,7 @@ orbit_deposits AS (
CONCAT('0x', SUBSTR(segmented_data [0] :: STRING, 25, 40)) AS supplier,
'Orbit' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_liquidations.sql
View File

@ -43,10 +43,7 @@ orbit_liquidations AS (
CONCAT('0x', SUBSTR(segmented_data [3] :: STRING, 25, 40)) AS tokenCollateral,
'Orbit' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_repayments.sql
View File

@ -38,10 +38,7 @@ orbit_repayments AS (
) :: INTEGER AS repayed_amount_raw,
'Orbit' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

5
models/silver/defi/lending/orbit/silver__orbit_withdraws.sql
View File

@ -41,10 +41,7 @@ orbit_redemptions AS (
CONCAT('0x', SUBSTR(segmented_data [0] :: STRING, 25, 40)) AS redeemer,
'Orbit' AS platform,
modified_timestamp,
CASE
WHEN tx_status = 'SUCCESS' THEN TRUE
ELSE FALSE
END AS tx_succeeded,
tx_succeeded,
CONCAT(
tx_hash :: STRING,
'-',

2
models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql
View File

@ -50,7 +50,7 @@ candidate_logs AS (
INNER JOIN {{ ref('core__fact_event_logs') }}
l USING (block_number)
WHERE
l.tx_status = 'SUCCESS'
l.tx_succeeded
AND l.inserted_timestamp :: DATE >= DATEADD('day', -5, SYSDATE())
)
SELECT