[STREAM-1065] Add ez decoded event logs

macros/evm/evm.yaml.sql

@@ -404,6 +404,7 @@
     COMMENT = $$Returns the decoded event logs data for a given block height. If to_latest is true, it will continue fetching blocks until the latest block. Otherwise, it will fetch blocks until the block height is reached.$$
   sql: |
     {{ evm_live_view_fact_decoded_event_logs(schema, blockchain, network) | indent(4) -}}
+
 - name: {{ schema -}}.tf_fact_traces
   signature:
     - [block_height, INTEGER, The start block height to get the transfers from]
@@ -432,6 +433,21 @@
   sql: |
     {{ evm_live_view_fact_transactions(schema,  blockchain, network) | indent(4) -}}
 
+- name: {{ schema -}}.tf_ez_decoded_event_logs
+  signature:
+    - [block_height, INTEGER, The start block height to get the logs from]
+    - [to_latest, BOOLEAN, Whether to continue fetching logs until the latest block or not]
+  return_type:
+    - "TABLE(block_number INTEGER, block_timestamp TIMESTAMP_NTZ, tx_hash STRING, event_index INTEGER, contract_address STRING, contract_name STRING, event_name STRING, decoded_log OBJECT, full_decoded_log VARIANT, origin_function_signature STRING, origin_from_address STRING, origin_to_address STRING, topics VARIANT, data STRING, event_removed BOOLEAN, tx_status STRING, ez_decoded_event_logs_id STRING, inserted_timestamp TIMESTAMP_NTZ, modified_timestamp TIMESTAMP_NTZ)"
+  options: |
+    NOT NULL
+    RETURNS NULL ON NULL INPUT
+    VOLATILE
+    COMMENT = $$Returns the ez decoded event logs data for a given block height. If to_latest is true, it will continue fetching blocks until the latest block. Otherwise, it will fetch blocks until the block height is reached.$$
+  sql: |
+    {{ evm_live_view_ez_decoded_event_logs(schema, blockchain, network) | indent(4) -}}
+
+
 - name: {{ schema -}}.tf_ez_native_transfers
   signature:
     - [block_height, INTEGER, The start block height to get the transfers from]

macros/evm/evm_live_views.sql

@@ -652,93 +652,23 @@ FROM logs
 {% endmacro %}
 
 {% macro evm_live_view_fact_decoded_event_logs(schema, blockchain, network) %}
-WITH _fact_event_logs AS (
-    {{ evm_live_view_fact_event_logs(schema, blockchain, network) | indent(4) -}}
-),
-
-_silver_decoded_logs AS (
-    SELECT
-        block_number,
-        block_timestamp,
-        tx_hash,
-        origin_function_signature,
-        origin_from_address,
-        origin_to_address,
-        event_index,
-        topics,
-        DATA,
-        contract_address,
-        OBJECT_CONSTRUCT('topics', topics, 'data', data, 'address', contract_address) AS event_data,
-        abi,
-        utils.udf_evm_decode_log(abi, event_data)[0] AS decoded_data,
-        event_removed,
-        decoded_data:name::string AS event_name,
-        {{ blockchain }}.utils.udf_transform_logs(decoded_data) AS transformed,
-        _log_id,
-        inserted_timestamp,
-        tx_status
-    FROM
-        _fact_event_logs
-    JOIN
-        {{ blockchain }}.core.dim_contract_abis
-    USING
-        (contract_address)
-    WHERE
-        tx_status = 'SUCCESS'
-),
-
-_flatten_logs AS (
-    SELECT
-        b.tx_hash,
-        b.block_number,
-        b.event_index,
-        b.event_name,
-        b.contract_address,
-        b.decoded_data,
-        b.transformed,
-        b._log_id,
-        b.inserted_timestamp,
-        OBJECT_AGG(
-            DISTINCT CASE
-                WHEN v.value :name = '' THEN CONCAT(
-                    'anonymous_',
-                    v.index
-                )
-                ELSE v.value :name
-            END,
-            v.value :value
-        ) AS decoded_flat
-    FROM
-        _silver_decoded_logs b,
-        LATERAL FLATTEN(
-            input => b.transformed :data
-        ) v
-    GROUP BY
-        b.tx_hash,
-        b.block_number,
-        b.event_index,
-        b.event_name,
-        b.contract_address,
-        b.decoded_data,
-        b.transformed,
-        b._log_id,
-        b.inserted_timestamp
+WITH _ez_decoded_event_logs AS (
+    {{ evm_live_view_ez_decoded_event_logs(schema, blockchain, network) | indent(4) -}}
 )
 
 SELECT
     block_number,
-    C.block_timestamp,
-    B.tx_hash,
-    B.event_index,
-    B.contract_address,
-    B.event_name,
-    B.decoded_flat AS decoded_log,
-    B.decoded_data AS full_decoded_log,
-    md5(_log_id) AS fact_decoded_event_logs_id,
-    SYSDATE() AS inserted_timestamp,
-    SYSDATE() AS modified_timestamp
-FROM _flatten_logs AS B
-LEFT JOIN _silver_decoded_logs AS C USING (block_number, _log_id)
+    block_timestamp,
+    tx_hash,
+    event_index,
+    contract_address,
+    event_name,
+    decoded_log,
+    full_decoded_log,
+    fact_decoded_event_logs_id,
+    inserted_timestamp,
+    modified_timestamp
+FROM _ez_decoded_event_logs
 {% endmacro %}
 
 {% macro evm_live_view_fact_transactions(schema, blockchain, network) %}
@@ -881,6 +811,106 @@ FROM traces_final
 {% endmacro %}
 
 -- Get EVM chain ez data
+{% macro evm_live_view_ez_decoded_event_logs(schema, blockchain, network) %}
+WITH _fact_event_logs AS (
+    {{ evm_live_view_fact_event_logs(schema, blockchain, network) | indent(4) -}}
+),
+
+_silver_decoded_logs AS (
+    SELECT
+        block_number,
+        block_timestamp,
+        tx_hash,
+        origin_function_signature,
+        origin_from_address,
+        origin_to_address,
+        event_index,
+        topics,
+        DATA,
+        contract_address,
+        OBJECT_CONSTRUCT('topics', topics, 'data', data, 'address', contract_address) AS event_data,
+        abi,
+        utils.udf_evm_decode_log(abi, event_data)[0] AS decoded_data,
+        event_removed,
+        decoded_data:name::string AS event_name,
+        {{ blockchain }}.utils.udf_transform_logs(decoded_data) AS transformed,
+        _log_id,
+        inserted_timestamp,
+        tx_status
+    FROM
+        _fact_event_logs
+    JOIN
+        {{ blockchain }}.core.dim_contract_abis
+    USING
+        (contract_address)
+    WHERE
+        tx_status = 'SUCCESS'
+),
+
+_flatten_logs AS (
+    SELECT
+        b.tx_hash,
+        b.block_number,
+        b.event_index,
+        b.event_name,
+        b.contract_address,
+        b.decoded_data,
+        b.transformed,
+        b._log_id,
+        b.inserted_timestamp,
+        OBJECT_AGG(
+            DISTINCT CASE
+                WHEN v.value :name = '' THEN CONCAT(
+                    'anonymous_',
+                    v.index
+                )
+                ELSE v.value :name
+            END,
+            v.value :value
+        ) AS decoded_flat
+    FROM
+        _silver_decoded_logs b,
+        LATERAL FLATTEN(
+            input => b.transformed :data
+        ) v
+    GROUP BY
+        b.tx_hash,
+        b.block_number,
+        b.event_index,
+        b.event_name,
+        b.contract_address,
+        b.decoded_data,
+        b.transformed,
+        b._log_id,
+        b.inserted_timestamp
+)
+
+SELECT
+    block_number,
+    C.block_timestamp,
+    B.tx_hash,
+    B.event_index,
+    B.contract_address,
+    D.name AS contract_name,
+    B.event_name,
+    B.decoded_flat AS decoded_log,
+    B.decoded_data AS full_decoded_log,
+    C.origin_function_signature,
+    C.origin_from_address,
+    C.origin_to_address,
+    C.topics,
+    C.DATA,
+    C.event_removed,
+    C.tx_status,
+    md5(_log_id) AS fact_decoded_event_logs_id,
+    SYSDATE() AS inserted_timestamp,
+    SYSDATE() AS modified_timestamp
+FROM _flatten_logs AS B
+LEFT JOIN _silver_decoded_logs AS C USING (block_number, _log_id)
+LEFT JOIN {{ blockchain }}.core.dim_contracts AS D
+    ON B.contract_address = D.address
+{% endmacro %}
+
 {% macro evm_live_view_ez_token_transfers(schema, blockchain, network) %}
 WITH fact_logs AS (
     {{ evm_live_view_fact_event_logs(schema, blockchain, network) | indent(4) -}}