mosquitto_pub -t '$SYS/Coreflux/Command' -m "-routeCode SNOWFLAKE_SQL_API"

DEFINE ROUTE SnowflakeRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://ACCOUNT.snowflakecomputing.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT Submitstatement
        WITH SOURCE_TOPIC "analytics/snowflake/statements/submit"
        WITH DESTINATION_TOPIC "analytics/snowflake/statements/submit/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/api/v2/statements"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
            ADD "X-Snowflake-Authorization-Token-Type" "{value.json.token_type}"
        WITH BODY "{value.json.body}"
    ADD EVENT Getstatement
        WITH SOURCE_TOPIC "analytics/snowflake/statements/get"
        WITH DESTINATION_TOPIC "analytics/snowflake/statements/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/api/v2/statements/{value.json.statement_handle}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
            ADD "X-Snowflake-Authorization-Token-Type" "{value.json.token_type}"

mosquitto_sub -t 'analytics/snowflake/statements/submit/response' &
mosquitto_pub -t 'analytics/snowflake/statements/submit' -m '{"api_token": "<api_token>", "body": {}, "token_type": "<token_type>"}'