osmosis-models/macros/streamline/streamline_udfs.sql
xiuy001 e4c9432131
Add streamline models (#136)
* updated and added the rest api client and call

* updated

* increased sql limit

* updated params

* refresh

* updated

* updated the rest api call format

* updated

* updated

* updated
2023-09-26 16:03:26 -04:00

37 lines
1.8 KiB
SQL

{% macro create_udf_get_chainhead() %}
{% if target.name == "prod" %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_get_chainhead() returns variant api_integration = aws_osmosis_api AS
'https://99iu3zvgd9.execute-api.us-east-1.amazonaws.com/prod/get_chainhead'
{% else %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_get_chainhead() returns variant api_integration = aws_osmosis_dev_api AS
'https://8lng1cjnel.execute-api.us-east-1.amazonaws.com/dev/get_chainhead'
{%- endif %};
{% endmacro %}
{% macro create_udf_bulk_json_rpc() %}
{% if target.name == "prod" %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_json_rpc(
json OBJECT
) returns ARRAY api_integration = aws_osmosis_api AS
'https://99iu3zvgd9.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_json_rpc'
{% else %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_json_rpc(
json OBJECT
) returns ARRAY api_integration = aws_osmosis_dev_api AS
'https://8lng1cjnel.execute-api.us-east-1.amazonaws.com/dev/udf_bulk_json_rpc'
{%- endif %};
{% endmacro %}
{% macro create_udf_bulk_rest_api() %}
{% if target.name == "prod" %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_rest_api(
json OBJECT
) returns ARRAY api_integration = aws_osmosis_api AS
'https://99iu3zvgd9.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_rest_api'
{% else %}
CREATE OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_rest_api(
json OBJECT
) returns ARRAY api_integration = aws_osmosis_dev_api AS
'https://8lng1cjnel.execute-api.us-east-1.amazonaws.com/dev/udf_bulk_rest_api'
{%- endif %};
{% endmacro %}