AWS IoT SiteWise

# Coreflux REST_API template — AWS IoT SiteWise curated slice
# Auth: SigV4 via {value.json.authorization}, {value.json.x_amz_date},
#       {value.json.x_amz_content_sha256}
# BASE_ADDRESS: https://data.iotsitewise.eu-west-1.amazonaws.com (data plane)

DEFINE CONNECTOR AwsIotSitewiseRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://data.iotsitewise.eu-west-1.amazonaws.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT BatchPutAssetPropertyValue
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/properties/batch-put"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/properties/batch-put/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/properties"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
        WITH BODY "{payload}"
    ADD EVENT GetAssetPropertyValueHistory
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/properties/history"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/properties/history/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/properties/history?propertyAlias={value.json.property_alias}&startDate={value.json.start_date}&endDate={value.json.end_date}&maxResults={value.json.max_results}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
    ADD EVENT CreateAsset
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/assets/create"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/assets/create/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/assets"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"
        WITH BODY "{payload}"
    ADD EVENT ListAssets
        WITH SOURCE_TOPIC "cloud-iot/aws-iot-sitewise/assets/list"
        WITH DESTINATION_TOPIC "cloud-iot/aws-iot-sitewise/assets/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/assets?filter={value.json.filter}&maxResults={value.json.max_results}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
            ADD "x-amz-date" "{value.json.x_amz_date}"
            ADD "x-amz-content-sha256" "{value.json.x_amz_content_sha256}"