From 0e9bf5f2a40c6054f32b1c58087396be5ccd41f0 Mon Sep 17 00:00:00 2001 From: WHYTEWYLL <49686519+WHYTEWYLL@users.noreply.github.com> Date: Wed, 20 Mar 2024 15:04:35 -0600 Subject: [PATCH] add old one --- macros/udfs/create_udf_get_chainhead.sql | 27 ++++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 macros/udfs/create_udf_get_chainhead.sql diff --git a/macros/udfs/create_udf_get_chainhead.sql b/macros/udfs/create_udf_get_chainhead.sql new file mode 100644 index 0000000..0e5c6cf --- /dev/null +++ b/macros/udfs/create_udf_get_chainhead.sql @@ -0,0 +1,27 @@ +{% macro create_UDF_GET_CHAINHEAD() %} + {% set sql %} + CREATE + OR REPLACE FUNCTION {{ target.database }}.STREAMLINE.UDF_GET_CHAINHEAD( + ) returns INTEGER + AS $$ + SELECT + {{ target.database }}.live.udf_api( + 'POST', + 'https://rpc.mainnet.near.org', + { + 'Content-Type': 'application/json' + }, + { + 'jsonrpc': '2.0', + 'id': 'dontcare', + 'method' :'status', + 'params':{ + 'finality': 'final' + } + } + ) :data :result :sync_info :latest_block_height :: INT AS block_id + + $$ + {% endset %} + {% do run_query(sql) %} +{% endmacro %} \ No newline at end of file