flow-models/macros/evm/udf_get_evm_chainhead.sql

{% macro run_create_udf_get_evm_chainhead() %}
    {% set sql %}

        CREATE 
            OR REPLACE FUNCTION {{ target.database }}.streamline.udf_get_evm_chainhead(
                network STRING DEFAULT 'mainnet'
            )
        RETURNS INTEGER
        AS
        $$
            SELECT
            utils.udf_hex_to_int(
                live.udf_api(
                    'POST',
                    '{Service}',
                    {},
                    OBJECT_CONSTRUCT(
                        'method', 'eth_blockNumber',
                        'id', 1,
                        'jsonrpc', '2.0',
                        'params', []
                    ),
                    'Vault/{{ target.name }}/flow/evm/' || lower(network)
                ):data:result
            ) :: INTEGER AS block_number
        $$

     {% endset %}
    {% do run_query(sql) %}
{% endmacro %}