From 40d09d0eb7fc02efc4ad561ddcbb5d288c413eae Mon Sep 17 00:00:00 2001 From: Austin <93135983+austinFlipside@users.noreply.github.com> Date: Tue, 18 Feb 2025 20:34:51 -0500 Subject: [PATCH] qn (#411) --- .../streamline__get_evm_blocks_history.sql | 4 +-- .../streamline__get_evm_receipts_history.sql | 4 +-- .../streamline__get_evm_traces_history.sql | 4 +-- .../streamline__get_evm_blocks_realtime.sql | 4 +-- .../streamline__get_evm_receipts_realtime.sql | 4 +-- .../streamline__get_evm_traces_realtime.sql | 4 +-- .../core/streamline__evm_blocks.sql | 9 +----- .../core/streamline__evm_chainhead.sql | 28 +++++++++++++++++++ 8 files changed, 41 insertions(+), 20 deletions(-) create mode 100644 models/evm/streamline/core/streamline__evm_chainhead.sql diff --git a/models/evm/streamline/core/history/streamline__get_evm_blocks_history.sql b/models/evm/streamline/core/history/streamline__get_evm_blocks_history.sql index c527b35..3dd1281 100644 --- a/models/evm/streamline/core/history/streamline__get_evm_blocks_history.sql +++ b/models/evm/streamline/core/history/streamline__get_evm_blocks_history.sql @@ -35,7 +35,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -53,7 +53,7 @@ SELECT TRUE -- Include transactions ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM tbl diff --git a/models/evm/streamline/core/history/streamline__get_evm_receipts_history.sql b/models/evm/streamline/core/history/streamline__get_evm_receipts_history.sql index 654ba0d..f9e689c 100644 --- a/models/evm/streamline/core/history/streamline__get_evm_receipts_history.sql +++ b/models/evm/streamline/core/history/streamline__get_evm_receipts_history.sql @@ -41,7 +41,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -58,7 +58,7 @@ SELECT utils.udf_int_to_hex(block_number) ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM ready_blocks diff --git a/models/evm/streamline/core/history/streamline__get_evm_traces_history.sql b/models/evm/streamline/core/history/streamline__get_evm_traces_history.sql index 07bff88..0e3a520 100644 --- a/models/evm/streamline/core/history/streamline__get_evm_traces_history.sql +++ b/models/evm/streamline/core/history/streamline__get_evm_traces_history.sql @@ -44,7 +44,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -65,7 +65,7 @@ SELECT ) ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM ready_blocks diff --git a/models/evm/streamline/core/realtime/streamline__get_evm_blocks_realtime.sql b/models/evm/streamline/core/realtime/streamline__get_evm_blocks_realtime.sql index 17ad7db..43669f2 100644 --- a/models/evm/streamline/core/realtime/streamline__get_evm_blocks_realtime.sql +++ b/models/evm/streamline/core/realtime/streamline__get_evm_blocks_realtime.sql @@ -63,7 +63,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -81,7 +81,7 @@ SELECT TRUE -- Include transactions ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM tbl diff --git a/models/evm/streamline/core/realtime/streamline__get_evm_receipts_realtime.sql b/models/evm/streamline/core/realtime/streamline__get_evm_receipts_realtime.sql index 7c1ff2a..9312510 100644 --- a/models/evm/streamline/core/realtime/streamline__get_evm_receipts_realtime.sql +++ b/models/evm/streamline/core/realtime/streamline__get_evm_receipts_realtime.sql @@ -74,7 +74,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -91,7 +91,7 @@ SELECT utils.udf_int_to_hex(block_number) ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM ready_blocks diff --git a/models/evm/streamline/core/realtime/streamline__get_evm_traces_realtime.sql b/models/evm/streamline/core/realtime/streamline__get_evm_traces_realtime.sql index 3a25cd3..8152f59 100644 --- a/models/evm/streamline/core/realtime/streamline__get_evm_traces_realtime.sql +++ b/models/evm/streamline/core/realtime/streamline__get_evm_traces_realtime.sql @@ -71,7 +71,7 @@ SELECT ) :: INT AS partition_key, {{ target.database }}.live.udf_api( 'POST', - '{Service}', + '{Service}/{Authentication}', OBJECT_CONSTRUCT( 'Content-Type', 'application/json' @@ -92,7 +92,7 @@ SELECT ) ) ), - 'Vault/{{ target.name }}/flow/evm/mainnet' + 'Vault/prod/flow/quicknode/mainnet' ) AS request FROM ready_blocks diff --git a/models/evm/streamline/core/streamline__evm_blocks.sql b/models/evm/streamline/core/streamline__evm_blocks.sql index b0d8638..c3c41ee 100644 --- a/models/evm/streamline/core/streamline__evm_blocks.sql +++ b/models/evm/streamline/core/streamline__evm_blocks.sql @@ -3,13 +3,6 @@ tags = ['streamline_realtime_evm', 'streamline_history_evm'] ) }} -{% if execute %} - {% set height = run_query("SELECT streamline.udf_get_evm_chainhead()") %} - {% set block_number = height.columns [0].values() [0] %} -{% else %} - {% set block_number = 0 %} -{% endif %} - SELECT _id AS block_number FROM @@ -18,4 +11,4 @@ FROM 'number_sequence' ) }} WHERE - _id <= {{ block_number }} + _id <= (SELECT block_number FROM {{ ref('streamline__evm_chainhead') }}) \ No newline at end of file diff --git a/models/evm/streamline/core/streamline__evm_chainhead.sql b/models/evm/streamline/core/streamline__evm_chainhead.sql new file mode 100644 index 0000000..18e3037 --- /dev/null +++ b/models/evm/streamline/core/streamline__evm_chainhead.sql @@ -0,0 +1,28 @@ +{{ config ( + materialized = 'table', + tags = ['streamline_realtime_evm', 'streamline_history_evm'] +) }} + +SELECT + live.udf_api( + 'POST', + '{Service}/{Authentication}', + OBJECT_CONSTRUCT( + 'Content-Type', 'application/json', + 'fsc-quantum-state', 'LiveQuery' + ), + OBJECT_CONSTRUCT( + 'id', + 0, + 'jsonrpc', + '2.0', + 'method', + 'eth_blockNumber', + 'params', + [] + ), + 'Vault/prod/flow/quicknode/mainnet' + ) AS resp, + utils.udf_hex_to_int( + resp :data :result :: STRING + ) AS block_number \ No newline at end of file