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

add metadata to decode log requests (#607)

Browse Source
This commit is contained in:
desmond-hui 2024-07-16 08:50:49 -07:00 committed by GitHub
parent ebfd7c2d56
commit 4ae84eda4f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 45 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
macros/helpers/decoded_logs_backfill_helpers.sql
View File

@ -59,6 +59,8 @@
i.value AS instruction,
e.block_id,
e.block_timestamp,
e.signers,
e.succeeded,
{{ dbt_utils.generate_surrogate_key(['e.block_id','e.tx_id','e.index','inner_index','log_index','inner_program_id']) }} as id
FROM
{{ ref('silver__events') }} e
@ -72,21 +74,26 @@
AND array_size(i.value:accounts::array) = 1
UNION ALL
SELECT
program_id,
tx_id,
index,
inner_index,
log_index,
object_construct('accounts',[],'data',data,'programId',program_id) as instruction,
block_id,
block_timestamp,
{{ dbt_utils.generate_surrogate_key(['block_id','tx_id','index','inner_index','log_index','program_id']) }} as id
l.program_id,
l.tx_id,
l.index,
l.inner_index,
l.log_index,
object_construct('accounts',[],'data',l.data,'programId',l.program_id) as instruction,
l.block_id,
l.block_timestamp,
t.signers,
t.succeeded,
{{ dbt_utils.generate_surrogate_key(['l.block_id','l.tx_id','l.index','l.inner_index','l.log_index','l.program_id']) }} as id
FROM
{{ ref('silver__transaction_logs_program_data') }}
{{ ref('silver__transaction_logs_program_data') }} l
JOIN
{{ ref('silver__transactions') }} t
USING(block_timestamp, tx_id)
WHERE
block_id between {{ start_block }} and {{ end_block }}
AND program_id = '{{ program_id }}'
AND succeeded
l.block_id between {{ start_block }} and {{ end_block }}
AND l.program_id = '{{ program_id }}'
AND l.succeeded
)
SELECT
e.inner_program_id as program_id,
@ -96,7 +103,9 @@
e.log_index,
e.instruction,
e.block_id,
e.block_timestamp
e.block_timestamp,
e.signers,
e.succeeded,
FROM
event_subset e
LEFT OUTER JOIN

35
models/streamline/decode_logs/streamline__decode_logs_realtime.sql
View File

@ -38,6 +38,8 @@ event_subset AS (
i.value AS instruction,
e.block_id,
e.block_timestamp,
e.signers,
e.succeeded,
{{ dbt_utils.generate_surrogate_key(['e.block_id','e.tx_id','e.index','inner_index','log_index','inner_program_id']) }} as id
FROM
{{ ref('silver__events') }} e
@ -54,20 +56,25 @@ event_subset AS (
AND array_size(i.value:accounts::array) = 1
UNION ALL
SELECT
program_id,
tx_id,
index,
inner_index,
log_index,
object_construct('accounts',[],'data',data,'programId',program_id) as instruction,
block_id,
block_timestamp,
{{ dbt_utils.generate_surrogate_key(['block_id','tx_id','index','inner_index','log_index','program_id']) }} as id
l.program_id,
l.tx_id,
l.index,
l.inner_index,
l.log_index,
object_construct('accounts',[],'data',l.data,'programId',l.program_id) as instruction,
l.block_id,
l.block_timestamp,
t.signers,
t.succeeded,
{{ dbt_utils.generate_surrogate_key(['l.block_id','l.tx_id','l.index','l.inner_index','l.log_index','l.program_id']) }} as id
FROM
{{ ref('silver__transaction_logs_program_data') }}
{{ ref('silver__transaction_logs_program_data') }} l
JOIN
{{ ref('silver__transactions') }} t
USING(block_timestamp, tx_id)
WHERE
block_timestamp >= CURRENT_DATE - 2
AND program_id = 'TSWAPaqyCSx2KABk68Shruf4rp7CxcNi8hAsbdwmHbN'
l.block_timestamp >= CURRENT_DATE - 2
AND l.program_id = 'TSWAPaqyCSx2KABk68Shruf4rp7CxcNi8hAsbdwmHbN'
),
completed_subset AS (
SELECT
@ -92,7 +99,9 @@ SELECT
e.log_index,
e.instruction,
e.block_id,
e.block_timestamp
e.block_timestamp,
e.signers,
e.succeeded
FROM
event_subset e
LEFT OUTER JOIN