flip/near-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/near-models.git synced 2026-02-06 14:11:54 +00:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

refactor chainhead

Browse Source
This commit is contained in:
WHYTEWYLL 2024-03-19 13:53:39 -06:00
parent fbfdf39db8
commit 4b4614174c
1 changed files with 37 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
macros/udfs/create_udf_get_chainhead.sql
View File

@ -1,27 +1,41 @@
{% 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 %}
CREATE OR REPLACE PROCEDURE {{ target.database }}.STREAMLINE.UDF_GET_CHAINHEAD(
) RETURNS STRING
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS
$$
let resultFound = false;
let blockId = 0;
while (!resultFound) {
var stmt = snowflake.createStatement({
sqlText: `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;`
});
var result = stmt.execute();
result.next();
res_temp = result.getColumnValue(1);
if (res_temp != null) {
res = res_temp;
resultFound = true;
}
}
return res;
$$;
{% endset %}
{% do run_query(sql) %}
{% endmacro %}