#!/bin/sh
if [ ! -z "$DEBUG" ]; then
    set -ex
else
    set -e
fi

KUIPER_HOME=${KUIPER_HOME:-"/kuiper"}

CLIENT_CONFIG="$KUIPER_HOME/etc/client.yaml"

if [ ! -z "$CLIENT_HOST" ]; then
    sed -i '/basic:/ ,/host/{/host/d}' $CLIENT_CONFIG
    sed -i "/basic:/a\  host: $CLIENT_HOST" $CLIENT_CONFIG
    echo "kuiper.basic.host = $CLIENT_HOST"
fi

if [ ! -z "$CLIENT_PORT" ]; then
    sed -i '/basic:/ ,/port/{/port/d}' $CLIENT_CONFIG
    sed -i "/basic:/a\  port: $CLIENT_PORT" $CLIENT_CONFIG
    echo "kuiper.basic.port = $CLIENT_PORT"
fi

KUIPER_CONFIG="$KUIPER_HOME/etc/kuiper.yaml"

if [ ! -z "$KUIPER_DEBUG" ]; then
    sed -i '/basic:/ ,/debug/{/debug/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  debug: $KUIPER_DEBUG" $KUIPER_CONFIG
    echo "kuiper.basic.debug = $KUIPER_DEBUG"
fi

if [ ! -z "$KUIPER_CONSOLE_LOG" ]; then
    sed -i '/basic:/ ,/consoleLog/{/consoleLog/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  consoleLog: $KUIPER_CONSOLE_LOG" $KUIPER_CONFIG
    echo "kuiper.basic.consoleLog = $KUIPER_CONSOLE_LOG"
fi

if [ ! -z "$KUIPER_FILE_LOG" ]; then
    sed -i '/basic:/ ,/fileLog/{/fileLog/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  fileLog: $KUIPER_FILE_LOG" $KUIPER_CONFIG
    echo "kuiper.basic.fileLog = $KUIPER_FILE_LOG"
fi

if [ ! -z "$KUIPER_PORT" ]; then
    sed -i '/basic:/ ,/port/{/port/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  port: $KUIPER_PORT" $KUIPER_CONFIG
    echo "kuiper.basic.port = $KUIPER_PORT"
fi

if [ ! -z "$KUIPER_REST_PORT" ]; then
    sed -i '/basic:/ ,/restPort/{/restPort/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  restPort: $KUIPER_REST_PORT" $KUIPER_CONFIG
    echo "kuiper.basic.restPort = $KUIPER_REST_PORT"
fi

if [ ! -z "$KUIPER_PROMETHEUS" ]; then
    sed -i '/basic:/ ,/prometheus/{/prometheus/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  prometheus: $KUIPER_PROMETHEUS" $KUIPER_CONFIG
    echo "kuiper.basic.prometheus = $KUIPER_PROMETHEUS"
fi

if [ ! -z "$KUIPER_PROMETHEUS_PORT" ]; then
    sed -i '/basic:/ ,/prometheusPort/{/prometheusPort/d}' $KUIPER_CONFIG
    sed -i "/basic:/a\  prometheusPort: $KUIPER_PROMETHEUS_PORT" $KUIPER_CONFIG
    echo "kuiper.basic.prometheusPort = $KUIPER_PROMETHEUS_PORT"
fi

MQTT_CONFIG="$KUIPER_HOME/etc/mqtt_source.yaml"

if [ ! -z "$MQTT_BROKER_ADDRESS" ]; then
    sed -i '/default:/ ,/servers/{/servers/d}' $MQTT_CONFIG
    sed -i "/default:/a\  servers: [$MQTT_BROKER_ADDRESS]" $MQTT_CONFIG
    echo "mqtt.default.servers = $MQTT_BROKER_ADDRESS"
fi

if [ ! -z "$MQTT_BROKER_SHARED_SUBSCRIPTION" ]; then
    sed -i '/default:/ ,/sharedSubscription/{/sharedSubscription/d}' $MQTT_CONFIG
    sed -i "/default:/a\  sharedSubscription: $MQTT_BROKER_SHARED_SUBSCRIPTION" $MQTT_CONFIG
    echo "mqtt.default.sharedSubscription = $MQTT_BROKER_SHARED_SUBSCRIPTION"
fi

if [ ! -z "$MQTT_BROKER_QOS" ]; then
    sed -i '/default:/ ,/qos/{/qos/d}' $MQTT_CONFIG
    sed -i "/default:/a\  qos: $MQTT_BROKER_QOS" $MQTT_CONFIG
    echo "mqtt.default.qos = $MQTT_BROKER_QOS"
fi

if [ ! -z "$MQTT_BROKER_USERNAME" ]; then
    sed -i '/default:/ ,/username/{/username/d}' $MQTT_CONFIG
    sed -i "/default:/a\  username: $MQTT_BROKER_USERNAME" $MQTT_CONFIG
    echo "mqtt.default.username = $MQTT_BROKER_USERNAME"
fi

if [ ! -z "$MQTT_BROKER_PASSWORD" ]; then
    sed -i '/default:/ ,/password/{/password/d}' $MQTT_CONFIG
    sed -i "/default:/a\  password: $MQTT_BROKER_PASSWORD" $MQTT_CONFIG
    echo "mqtt.default.password = $MQTT_BROKER_PASSWORD"
fi

if [ ! -z "$MQTT_BROKER_CER_PATH" ]; then
    sed -i '/default:/ ,/certificationPath/{/certificationPath/d}' $MQTT_CONFIG
    sed -i "/default:/a\  certificationPath: $MQTT_BROKER_CER_PATH" $MQTT_CONFIG
    echo "mqtt.default.certificationPath = $MQTT_BROKER_CER_PATH"
fi

if [ ! -z "$MQTT_BROKER_KEY_PATH" ]; then
    sed -i '/default:/ ,/privateKeyPath/{/privateKeyPath/d}' $MQTT_CONFIG
    sed -i "/default:/a\  privateKeyPath: $MQTT_BROKER_KEY_PATH" $MQTT_CONFIG
    echo "mqtt.default.privateKeyPath = $MQTT_BROKER_KEY_PATH"
fi

EDGEX_CONFIG="$KUIPER_HOME/etc/sources/edgex.yaml"

if [ ! -z "$EDGEX_PROTOCOL" ]; then
    sed -i '/default:/ ,/protocol/{/protocol/d}' $EDGEX_CONFIG
    sed -i "/default:/a\  protocol: $EDGEX_PROTOCOL" $EDGEX_CONFIG
    echo "edgex.default.protocol = $EDGEX_PROTOCOL"
fi

if [ ! -z "$EDGEX_SERVER" ]; then
    sed -i '/default:/ ,/server/{/server/d}' $EDGEX_CONFIG
    sed -i "/default:/a\  server: $EDGEX_SERVER" $EDGEX_CONFIG
    echo "edgex.default.server = $EDGEX_SERVER"
fi

if [ ! -z "$EDGEX_PORT" ]; then
    sed -i '/default:/ ,/port/{/port/d}' $EDGEX_CONFIG
    sed -i "/default:/a\  port: $EDGEX_PORT" $EDGEX_CONFIG
    echo "edgex.default.port = $EDGEX_PORT"
fi

if [ ! -z "$EDGEX_TOPIC" ]; then
    sed -i '/default:/ ,/topic/{/topic/d}' $EDGEX_CONFIG
    sed -i "/default:/a\  topic: $EDGEX_TOPIC" $EDGEX_CONFIG
    echo "edgex.default.topic = $EDGEX_TOPIC"
fi

if [ ! -z "$EDGEX_SERVICE_SERVER" ]; then
    sed -i '/default:/ ,/serviceServer/{/serviceServer/d}' $EDGEX_CONFIG
    sed -i "/default:/a\  serviceServer: $EDGEX_SERVICE_SERVER" $EDGEX_CONFIG
    echo "edgex.default.serviceServer = $EDGEX_SERVICE_SERVER"
fi

exec "$@"