#!/bin/sh

# This script is executed on each boot as it is
# completed. It is best to edit the middle of the file as
# noted below so custom commands are executed before
# the script notifies confluent that install is fully complete.
ntpsrvs=""
nodename=$(grep ^NODENAME /etc/confluent/confluent.info|awk '{print $2}')
confluent_apikey=$(cat /etc/confluent/confluent.apikey)
v4meth=$(grep ^ipv4_method: /etc/confluent/confluent.deploycfg|awk '{print $2}')
if [ "$v4meth" = "null" -o -z "$v4meth" ]; then
    confluent_mgr=$(grep ^deploy_server_v6: /etc/confluent/confluent.deploycfg|awk '{print $2}')
fi
if [ -z "$confluent_mgr" ]; then
    confluent_mgr=$(grep ^deploy_server: /etc/confluent/confluent.deploycfg|awk '{print $2}')
fi
confluent_profile=$(grep ^profile: /etc/confluent/confluent.deploycfg|awk '{print $2}')
timedatectl set-timezone $(grep ^timezone: /etc/confluent/confluent.deploycfg|awk '{print $2}')
hostnamectl set-hostname $nodename


if grep ^ntpservers: /etc/confluent/confluent.deploycfg > /dev/null; then
    for ntpsrv in $(sed -n '/^ntpservers:/,/^[^-]/p' /etc/confluent/confluent.deploycfg|sed 1d|sed '$d' | sed -e 's/^- //'); do
        echo "server ${ntpsrv} iburst " >> /tmp/timeservers
    done
fi

if [ -f /tmp/timeservers ]; then

ntpsrvs=$(cat /tmp/timeservers)

sed -i "1,/^pool * /c\\

${ntpsrvs//$'\n'/\\$'\n'}" /etc/chrony.conf


systemctl restart chronyd

rm -f /tmp/timeservers
fi

export nodename confluent_mgr confluent_profile
. /etc/confluent/functions
mkdir -p /var/log/confluent
chmod 700 /var/log/confluent
exec >> /var/log/confluent/confluent-onboot.log
exec 2>> /var/log/confluent/confluent-onboot.log
chmod 600 /var/log/confluent/confluent-onboot.log
tail -f /var/log/confluent/confluent-onboot.log > /dev/console &
logshowpid=$!

rpm --import /etc/pki/rpm-gpg/*

run_remote_python add_local_repositories
run_remote_python syncfileclient
run_remote_python confignet -c $confluent_mgr

run_remote onboot.custom
# onboot scripts may be placed into onboot.d, e.g. onboot.d/01-firstaction.sh, onboot.d/02-secondaction.sh
run_remote_parts onboot.d

# Induce execution of remote configuration, e.g. ansible plays in ansible/onboot.d/
run_remote_config onboot.d

if [ -f /run/confluent/onboot_sleep.pid ]; then
    loopdev=$(losetup -j /mnt/remoteimg/rootimg.sfs|cut -d: -f 1)
    if [ -n "$loopdev" ]; then
        losetup "$loopdev" --direct-io=on
    fi
    sleeppid=$(cat /run/confluent/onboot_sleep.pid)
    kill "$sleeppid"
    rm -f /run/confluent/onboot_sleep.pid
fi

#curl -X POST -d 'status: booted' -H "CONFLUENT_NODENAME: $nodename" -H "CONFLUENT_APIKEY: $confluent_apikey" https://$confluent_mgr/confluent-api/self/updatestatus
kill $logshowpid