ChirpStack v4

# Coreflux REST_API template — ChirpStack v4 curated slice
# Auth: Authorization via {value.json.authorization} (Bearer API token)
# BASE_ADDRESS: https://localhost:8090  → substitute host / TLS

DEFINE CONNECTOR ChirpStackV4RestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://localhost:8090"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT ListDevices
        WITH SOURCE_TOPIC "cloud-iot/chirpstack-v4/device/list"
        WITH DESTINATION_TOPIC "cloud-iot/chirpstack-v4/device/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/api/devices?applicationId={value.json.applicationId}&limit={value.json.limit}&offset={value.json.offset}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
    ADD EVENT GetDevice
        WITH SOURCE_TOPIC "cloud-iot/chirpstack-v4/device/get"
        WITH DESTINATION_TOPIC "cloud-iot/chirpstack-v4/device/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/api/devices/{value.json.devEui}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
    ADD EVENT EnqueueDeviceQueue
        WITH SOURCE_TOPIC "cloud-iot/chirpstack-v4/device/queue/enqueue"
        WITH DESTINATION_TOPIC "cloud-iot/chirpstack-v4/device/queue/enqueue/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/api/devices/{value.json.devEui}/queue"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "{value.json.authorization}"
        WITH BODY "{payload}"
    ADD EVENT GetDeviceQueue
        WITH SOURCE_TOPIC "cloud-iot/chirpstack-v4/device/queue/get"
        WITH DESTINATION_TOPIC "cloud-iot/chirpstack-v4/device/queue/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/api/devices/{value.json.devEui}/queue"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"
    ADD EVENT GetApplication
        WITH SOURCE_TOPIC "cloud-iot/chirpstack-v4/application/get"
        WITH DESTINATION_TOPIC "cloud-iot/chirpstack-v4/application/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/api/applications/{value.json.applicationId}"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "{value.json.authorization}"