#!/bin/bash

set -e

#Wait for ZooKeeper servers to be launched
cpsvc zookeeper client-metadata-wait
#Wait for Kafka brokers to be launched
cpsvc kafka client-metadata-wait

ZK_CONNECT=$(cpsvc zookeeper client-config)
BOOSTRAP_SERSVERS=$(cpsvc kafka client-bootstrap-servers)

ROCK_CONFIG_FILE="/opt/rock/rock.properties"
cat <<- EOF > $ROCK_CONFIG_FILE
    zookeeper.connect=${ZK_CONNECT}
    bootstrap.servers=${BOOSTRAP_SERSVERS}
EOF

echo "$(cat $ROCK_CONFIG_FILE)"

#Wait for ZK ensemble
cpsvc zookeeper client-up-wait
#Wait for Kafka cluster
cpsvc kafka client-up-wait

echo "Starting Rock Application"
exec /opt/rock/bin/rock --config $ROCK_CONFIG_FILE
