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

upd udtf same name diff signature

Browse Source
This commit is contained in:
Jack Forgash 2023-08-17 17:01:22 -06:00
parent a0fc276333
commit decf7b535a
2 changed files with 97 additions and 86 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
macros/udfs/create_udtf_call_contract_block_height.sql
View File

@ -2,19 +2,21 @@
{% set sql %}
{#
Execute a method on a contract at a specific block height.
This function is equivalent to the one defined in macro create_UDTF_CALL_CONTRACT_FUNCTION, except for the block height input parameter.
Signature STRING, STRING, OBJECT, NUMBER
#}
CREATE OR REPLACE FUNCTION
{{ target.database }}.SILVER.UDTF_CALL_CONTRACT_FUNCTION_BY_HEIGHT(
{{ target.database }}.SILVER.UDTF_CALL_CONTRACT_FUNCTION(
contract_address STRING,
method_name STRING,
block_id NUMBER,
args OBJECT
args OBJECT,
block_id NUMBER
)
RETURNS TABLE (
BLOCK_HEIGHT NUMBER,
DATA VARIANT,
DECODED_RESULT VARIANT,
ERROR STRING
ERROR VARIANT
)
AS
$$
@ -22,11 +24,12 @@ WITH params AS (
SELECT
lower(contract_address) AS contract_address,
lower(method_name) AS method,
block_id as block_id,
block_id,
BASE64_ENCODE(args::STRING) AS arg_base64
),
call_function AS (
SELECT
block_id,
ethereum.streamline.udf_api(
'POST',
'https://archival-rpc.mainnet.near.org',
@ -50,17 +53,22 @@ call_function AS (
),
response AS (
SELECT
block_id,
res,
res :data ::VARIANT as data,
res :data :result :block_height :: NUMBER AS block_height,
res :data :result :result :: ARRAY AS res_array,
res :data :result :error ::STRING as error
TRY_PARSE_JSON(
COALESCE(
res :data :result :error :: STRING,
res :data :error :: STRING
)
) AS error
FROM
call_function
),
try_decode_hex AS (
SELECT
block_height,
block_id,
b.value AS raw,
b.index,
LPAD(TRIM(to_char(b.value :: INT, 'XXXXXXX')) :: STRING, 2, '0') AS hex
@ -75,7 +83,7 @@ try_decode_hex AS (
),
decoded_response AS (
SELECT
block_height,
block_id,
ARRAY_TO_STRING(ARRAY_AGG(hex) within GROUP (
ORDER BY
INDEX ASC), '') AS decoded_response
@ -85,12 +93,12 @@ decoded_response AS (
1
)
select
r.block_height,
r.block_id,
r.DATA,
TRY_PARSE_JSON(livequery.utils.udf_hex_to_string(decoded_response)) as decoded_result,
r.error
from response r
LEFT JOIN decoded_response d using (block_height)
LEFT JOIN decoded_response d using (block_id)
$$
{% endset %}

153
macros/udfs/create_udtf_call_contract_finality.sql
View File

@ -1,36 +1,34 @@
{% macro create_UDTF_CALL_CONTRACT_FUNCTION() %}
{% set sql %}
{#
Execute a method on a deployed NEAR smart contract using the `finality` block parameter.
#}
CREATE OR REPLACE FUNCTION
{{ target.database }}.SILVER.UDTF_CALL_CONTRACT_FUNCTION(
{% 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 }}.silver.udtf_call_contract_function(
contract_address STRING,
method_name STRING,
finality STRING,
args OBJECT
)
RETURNS TABLE (
BLOCK_HEIGHT NUMBER,
DATA VARIANT,
DECODED_RESULT VARIANT,
ERROR STRING
)
AS
$$
WITH params AS (
SELECT
lower(contract_address) AS contract_address,
lower(method_name) AS method,
lower(finality) as finality,
BASE64_ENCODE(args::STRING) AS arg_base64
),
call_function AS (
SELECT
) returns TABLE (
block_height NUMBER,
DATA variant,
decoded_result variant,
error VARIANT
) AS $$ WITH params AS (
SELECT
LOWER(contract_address) AS contract_address,
LOWER(method_name) AS method,
'final' AS finality,
BASE64_ENCODE(
args :: STRING
) AS arg_base64
),
call_function AS (
SELECT
ethereum.streamline.udf_api(
'POST',
'https://archival-rpc.mainnet.near.org',
'https://rpc.mainnet.near.org',
{
'Content-Type': 'application/json'
},
@ -46,54 +44,59 @@ call_function AS (
'args_base64': arg_base64 }
}
) AS res
FROM
params p
),
response AS (
SELECT
res,
res :data ::VARIANT as data,
res :data :result :block_height :: NUMBER AS block_height,
res :data :result :result :: ARRAY AS res_array,
res :data :result :error ::STRING as error
FROM
call_function
),
try_decode_hex AS (
SELECT
block_height,
b.value AS raw,
b.index,
LPAD(TRIM(to_char(b.value :: INT, 'XXXXXXX')) :: STRING, 2, '0') AS hex
FROM
response A,
TABLE(FLATTEN(res_array, recursive => TRUE)) b
WHERE
IS_ARRAY(res_array) = TRUE
ORDER BY
1,
3
),
decoded_response AS (
SELECT
block_height,
ARRAY_TO_STRING(ARRAY_AGG(hex) within GROUP (
ORDER BY
INDEX ASC), '') AS decoded_response
FROM
try_decode_hex
GROUP BY
1
)
select
FROM
params p
),
response AS (
SELECT
res,
res :data :: variant AS DATA,
res :data :result :block_height :: NUMBER AS block_height,
res :data :result :result :: ARRAY AS res_array,
TRY_PARSE_JSON(
COALESCE(
res :data :result :error :: STRING,
res :data :error :: STRING
)
) AS error
FROM
call_function
),
try_decode_hex AS (
SELECT
block_height,
b.value AS raw,
b.index,
LPAD(TRIM(to_char(b.value :: INT, 'XXXXXXX')) :: STRING, 2, '0') AS hex
FROM
response A,
TABLE(FLATTEN(res_array, recursive => TRUE)) b
WHERE
IS_ARRAY(res_array) = TRUE
ORDER BY
1,
3
),
decoded_response AS (
SELECT
block_height,
ARRAY_TO_STRING(ARRAY_AGG(hex) within GROUP (
ORDER BY
INDEX ASC), '') AS decoded_response
FROM
try_decode_hex
GROUP BY
1
)
SELECT
r.block_height,
r.DATA,
TRY_PARSE_JSON(livequery.utils.udf_hex_to_string(decoded_response)) as decoded_result,
r.data,
TRY_PARSE_JSON(
livequery.utils.udf_hex_to_string(decoded_response)
) AS decoded_result,
r.error
from response r
LEFT JOIN decoded_response d using (block_height)
$$
{% endset %}
{% do run_query(sql) %}
FROM
response r
LEFT JOIN decoded_response d USING (block_height) $$ {% endset %}
{% do run_query(sql) %}
{% endmacro %}