upd to local udf and add to create_udfs

This commit is contained in:
forgash_ 2024-01-25 16:56:13 -07:00
parent a2f78e1214
commit 83e5ca556b
2 changed files with 23 additions and 26 deletions

View File

@ -11,6 +11,7 @@
{{ create_udf_s3_copy_objects_overwrite() }}
{{ create_UDTF_CALL_CONTRACT_FUNCTION() }}
{{ create_UDTF_CALL_CONTRACT_FUNCTION_BY_HEIGHT() }}
{{ create_UDF_GET_CHAINHEAD() }}
{% endset %}
{% do run_query(sql) %}
{{- fsc_utils.create_udfs() -}}

View File

@ -1,31 +1,27 @@
{% macro create_UDF_GET_CHAINHEAD() %}
{% set sql %}
{#
EXECUTE A method
ON A deployed near smart contract USING THE `finality` block PARAMETER BY DEFAULT.signature STRING,
STRING,
OBJECT #}
CREATE
OR REPLACE FUNCTION {{ target.database }}.CORE.UDF_GET_CHAINHEAD(
) returns INTEGER
AS $$
SELECT
ethereum.streamline.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
$$
CREATE
OR REPLACE FUNCTION {{ target.database }}.CORE.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 %}