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

heal (#182)

Browse Source
This commit is contained in:
drethereum 2024-07-01 16:17:57 -06:00 committed by GitHub
parent 96c5502bbd
commit f5c49dc205
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 80 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
models/silver/protocols/olas/silver_olas__service_registrations.sql
View File

@ -3,7 +3,7 @@
incremental_strategy = 'delete+insert',
unique_key = 'block_number',
cluster_by = ['block_timestamp::DATE'],
tags = ['curated','reorg']
tags = ['curated','reorg','heal']
) }}
WITH registry_evt AS (
@ -101,19 +101,12 @@ services AS (
r.origin_to_address,
r.contract_address,
r.event_index,
r.topic_0,
r.topic_1,
r.topic_2,
r.topic_3,
r.event_name,
r.data,
r.segmented_data,
TRY_TO_NUMBER(utils.udf_hex_to_int(r.topic_1)) AS service_id,
CONCAT(
'0x',
r.segmented_data [0] :: STRING
) AS config_hash,
t.from_address,
t.to_address AS owner_address,
m.multisig_address,
r._log_id,
@ -129,6 +122,84 @@ services AS (
AND service_id = m.id
WHERE
r.event_name = 'CreateService'
),
{% if is_incremental() and var(
'HEAL_MODEL'
) %}
heal_model AS (
SELECT
t0.block_number,
t0.block_timestamp,
t0.tx_hash,
t0.origin_function_signature,
t0.origin_from_address,
t0.origin_to_address,
t0.contract_address,
t0.event_index,
t0.event_name,
t0.service_id,
t0.config_hash,
t0.owner_address,
m.multisig_address, --fill late-arriving or replace with current multisig
t0._log_id,
t0._inserted_timestamp
FROM
{{ this }}
t0
LEFT JOIN multisigs m
ON t0.contract_address = m.contract_address
AND t0.service_id = m.id
WHERE
t0.block_number IN (
SELECT
t1.block_number
FROM
{{ this }}
t1
WHERE
CONCAT(
COALESCE(
t1.multisig_address,
'0x'
),
'-',
t1.service_id
) NOT IN (
SELECT
CONCAT(
multisig_address,
'-',
id
)
FROM
multisigs
)
AND t1.service_id IN (
SELECT
DISTINCT id
FROM
multisigs
)
)
),
{% endif %}
FINAL AS (
SELECT
*
FROM
services
{% if is_incremental() and var(
'HEAL_MODEL'
) %}
UNION ALL
SELECT
*
FROM
heal_model
{% endif %}
)
SELECT
block_number,
@ -153,6 +224,6 @@ SELECT
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
services qualify(ROW_NUMBER() over (PARTITION BY _log_id
FINAL qualify(ROW_NUMBER() over (PARTITION BY _log_id
ORDER BY
_inserted_timestamp DESC)) = 1