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

STREAM-1049 Secrets interpolate fact_blocks macros

Browse Source
This commit is contained in:
shah 2024-10-16 15:16:17 -07:00 committed by Julius Remigio
parent 0bc02b03a5
commit 80590d8f9d
1 changed files with 11 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
macros/evm/evm_live_views.sql
View File

@ -1,12 +1,6 @@
{% macro evm_live_view_latest_block_height(blockchain, network) %}
{% macro evm_live_view_latest_block_height(schema, blockchain, network) %}
SELECT
live.udf_api(
'{service}/{Authentication}',
utils.udf_json_rpc_call(
'eth_blockNumber',
[]
)
):data AS result,
{{ schema }}.udf_rpc('eth_blockNumber', []) as result,
utils.udf_hex_to_int(result:result)::integer AS latest_block_height,
COALESCE(
block_height,
@ -19,9 +13,9 @@
) AS max_height
{% endmacro %}
{% macro evm_live_view_target_blocks(blockchain, network) %}
{% macro evm_live_view_target_blocks(schema, blockchain, network) %}
WITH heights AS (
{{ evm_live_view_latest_block_height(blockchain, network) | indent(4) -}}
{{ evm_live_view_latest_block_height(schema, blockchain, network) | indent(4) -}}
)
SELECT
ROW_NUMBER() OVER (
@ -42,16 +36,12 @@
{% endmacro %}
-- Get Raw EVM chain data
{% macro evm_live_view_bronze_blocks(table_name) %}
{% macro evm_live_view_bronze_blocks(schema, table_name) %}
SELECT
block_number,
live.udf_api(
'{service}/{Authentication}',
utils.udf_json_rpc_call(
'eth_getBlockByNumber',
[utils.udf_int_to_hex(block_number), true]
)
):data.result AS DATA
{{ schema }}.udf_rpc(
'eth_getBlockByNumber',
[utils.udf_int_to_hex(block_number), true]) AS DATA
FROM
{{ table_name }}
{% endmacro %}
@ -247,10 +237,10 @@ FROM
-- Get EVM chain fact data
{% macro evm_live_view_fact_blocks(schema, blockchain, network) %}
WITH spine AS (
{{ evm_live_view_target_blocks(blockchain, network) | indent(4) -}}
{{ evm_live_view_target_blocks(schema, blockchain, network) | indent(4) -}}
),
raw_block_txs AS (
{{ evm_live_view_bronze_blocks('spine') | indent(4) -}}
{{ evm_live_view_bronze_blocks( schema, 'spine') | indent(4) -}}
),
silver_blocks AS (
{{ evm_live_view_silver_blocks('raw_block_txs') | indent(4) -}}
@ -330,7 +320,7 @@ WITH spine AS (
{% macro evm_live_view_fact_logs(schema, blockchain, network) %}
WITH spine AS (
{{ evm_live_view_target_blocks(blockchain, network) | indent(4) -}}
{{ evm_live_view_target_blocks(schema, blockchain, network) | indent(4) -}}
),
raw_block_txs AS (
{{ evm_live_view_bronze_blocks('spine') | indent(4) -}}