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

DEFINE ROUTE OpsgenieRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://api.opsgenie.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT Createalert
        WITH SOURCE_TOPIC "monitoring/opsgenie/alerts/create"
        WITH DESTINATION_TOPIC "monitoring/opsgenie/alerts/create/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v2/alerts"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "GenieKey {value.json.api_token}"
        WITH BODY "{value.json.body}"
    ADD EVENT Getalert
        WITH SOURCE_TOPIC "monitoring/opsgenie/alerts/get"
        WITH DESTINATION_TOPIC "monitoring/opsgenie/alerts/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/v2/alerts/{value.json.alert_id}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "GenieKey {value.json.api_token}"
    ADD EVENT Acknowledgealert
        WITH SOURCE_TOPIC "monitoring/opsgenie/alerts/acknowledge"
        WITH DESTINATION_TOPIC "monitoring/opsgenie/alerts/acknowledge/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v2/alerts/{value.json.alert_id}/acknowledge"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "GenieKey {value.json.api_token}"
        WITH BODY "{value.json.body}"
    ADD EVENT Closealert
        WITH SOURCE_TOPIC "monitoring/opsgenie/alerts/close"
        WITH DESTINATION_TOPIC "monitoring/opsgenie/alerts/close/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v2/alerts/{value.json.alert_id}/close"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "GenieKey {value.json.api_token}"
        WITH BODY "{value.json.body}"

mosquitto_sub -t 'monitoring/opsgenie/alerts/create/response' &
mosquitto_pub -t 'monitoring/opsgenie/alerts/create' -m '{"api_token": "<api_token>", "body": {}}'