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

DEFINE ROUTE DockerHubRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://hub.docker.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT Listrepos
        WITH SOURCE_TOPIC "devops/dockerhub/repos/list"
        WITH DESTINATION_TOPIC "devops/dockerhub/repos/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/v2/repositories/{value.json.namespace}/"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
    ADD EVENT Listtags
        WITH SOURCE_TOPIC "devops/dockerhub/tags/list"
        WITH DESTINATION_TOPIC "devops/dockerhub/tags/list/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/v2/repositories/{value.json.namespace}/{value.json.repository}/tags"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
    ADD EVENT Getrepo
        WITH SOURCE_TOPIC "devops/dockerhub/repos/get"
        WITH DESTINATION_TOPIC "devops/dockerhub/repos/get/response"
        WITH METHOD "GET"
        WITH ENDPOINT "/v2/repositories/{value.json.namespace}/{value.json.repository}/"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"

mosquitto_sub -t 'devops/dockerhub/repos/list/response' &
mosquitto_pub -t 'devops/dockerhub/repos/list' -m '{"api_token": "<api_token>", "namespace": "<namespace>"}'