mirror of
https://github.com/FlipsideCrypto/flow-models.git
synced 2026-02-06 11:26:53 +00:00
119 lines
6.2 KiB
SQL
119 lines
6.2 KiB
SQL
{% macro create_udf_get_chainhead() %}
|
|
{{ log("Creating udf get_chainhead for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_get_chainhead() returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod AS 'https://quxfxtl934.execute-api.us-east-1.amazonaws.com/prod/get_chainhead'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_dev_2 AS 'https://sicl8dvvv9.execute-api.us-east-1.amazonaws.com/dev/get_chainhead'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx get_chainhead", info=True) }}
|
|
aws_flow_api_sbx AS 'https://bc5ejedoq8.execute-api.us-east-1.amazonaws.com/sbx/get_chainhead'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_get_chainhead_testnet() %}
|
|
{{ log("Creating udf get_chainhead_testnet for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_get_chainhead_testnet() returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod_us_east_2 AS 'https://78rpbojpue.execute-api.us-east-2.amazonaws.com/prod/get_chainhead_testnet'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_dev_2 AS 'https://sicl8dvvv9.execute-api.us-east-1.amazonaws.com/dev/get_chainhead_testnet'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx get_chainhead_testnet", info=True) }}
|
|
aws_flow_api_sbx AS 'https://bc5ejedoq8.execute-api.us-east-1.amazonaws.com/sbx/get_chainhead_testnet'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_bulk_grpc() %}
|
|
{{ log("Creating udf udf_bulk_grpc for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_grpc(json variant) returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod AS 'https://quxfxtl934.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_grpc'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_dev_2 AS 'https://sicl8dvvv9.execute-api.us-east-1.amazonaws.com/dev/udf_bulk_grpc'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx udf_bulk_grpc", info=True) }}
|
|
aws_flow_api_sbx AS 'https://bc5ejedoq8.execute-api.us-east-1.amazonaws.com/sbx/udf_bulk_grpc'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_bulk_grpc_v2() %}
|
|
{{ log("Creating udf udf_bulk_grpc_v2 for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_grpc_v2(json variant) returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod_v2 AS 'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_grpc'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_stg_v2 AS 'https://2hcu4hei27.execute-api.us-east-1.amazonaws.com/stg/udf_bulk_grpc'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx udf_bulk_grpc_v2", info=True) }}
|
|
aws_flow_api_stg_v2 AS 'https://2hcu4hei27.execute-api.us-east-1.amazonaws.com/stg/udf_bulk_grpc'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_bulk_grpc_us_east_2() %}
|
|
{{ log("Creating udf udf_bulk_grpc for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_grpc_us_east_2(json variant) returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod_us_east_2 AS 'https://78rpbojpue.execute-api.us-east-2.amazonaws.com/prod/udf_bulk_grpc'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_dev_3 AS 'https://j6qalrfe69.execute-api.us-east-2.amazonaws.com/dev/udf_bulk_grpc'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx udf_bulk_grpc", info=True) }}
|
|
aws_flow_api_sbx AS 'https://bc5ejedoq8.execute-api.us-east-1.amazonaws.com/sbx/udf_bulk_grpc'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_api() %}
|
|
{{ log("Creating udf udf_bulk_grpc for target:" ~ target.name ~ ", schema: " ~ target.schema, info=True) }}
|
|
{{ log("role:" ~ target.role ~ ", user:" ~ target.user, info=True) }}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_api(
|
|
method VARCHAR,
|
|
url VARCHAR,
|
|
headers OBJECT,
|
|
DATA OBJECT,
|
|
user_id VARCHAR,
|
|
secret_name VARCHAR
|
|
) returns variant api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_api_prod AS 'https://quxfxtl934.execute-api.us-east-1.amazonaws.com/prod/udf_api'
|
|
{% elif target.name == "dev" %}
|
|
aws_flow_api_dev_2 AS 'https://sicl8dvvv9.execute-api.us-east-1.amazonaws.com/dev/udf_api'
|
|
{% elif target.name == "sbx" %}
|
|
{{ log("Creating sbx udf_api", info=True) }}
|
|
aws_flow_api_sbx AS 'https://bc5ejedoq8.execute-api.us-east-1.amazonaws.com/sbx/udf_api'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_bulk_rest_api_v2() %}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_rest_api_v2(
|
|
json OBJECT
|
|
) returns ARRAY api_integration =
|
|
{% if target.name == "prod" %}
|
|
aws_flow_evm_api_prod AS 'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/udf_bulk_rest_api'
|
|
{% else %}
|
|
aws_flow_evm_api_dev AS 'https://pfv9lhg3kg.execute-api.us-east-1.amazonaws.com/stg/udf_bulk_rest_api'
|
|
{%- endif %};
|
|
{% endmacro %}
|
|
|
|
{% macro create_udf_bulk_decode_logs() %}
|
|
CREATE
|
|
OR REPLACE EXTERNAL FUNCTION streamline.udf_bulk_decode_logs_v2(
|
|
json OBJECT
|
|
) returns ARRAY api_integration = {% if target.name == "prod" %}
|
|
AWS_FLOW_EVM_API_PROD AS 'https://rajpkbgko9.execute-api.us-east-1.amazonaws.com/prod/bulk_decode_logs'
|
|
{% else %}
|
|
AWS_FLOW_EVM_API_DEV AS'https://pfv9lhg3kg.execute-api.us-east-1.amazonaws.com/stg/bulk_decode_logs'
|
|
{%- endif %};
|
|
{% endmacro %} |