#!/bin/bash -eu
# export KUBEADM_TOKEN="1iopsj.8w8c5aacrt1zdl6z"
# export K8S_CONTROLPLANE_VIP="kates.lab.bowdre.net"

source ./env.txt

echo ">> Waiting up to 5 minutes for initial control-plane node..."
attempts_max=30
attempt=0
until nc "${K8S_CONTROLPLANE_VIP}" 6443 -w 1 2>/dev/null; do
  if [ ${attempt} -eq ${attempts_max} ]; then
    echo ">> [ERROR] Timeout waiting for control node! <<"
    exit 1
  fi
  attempt=$((attempt+1))
  sleep 10
done
echo ">> Continuing after $((attempt*10)) seconds."
echo ">> Waiting up to 10 minutes for all control-plane nodes..."
attempts_max=60
attempt=0
until [ "$(ssh -o StrictHostKeyChecking=no "${K8S_CONTROLPLANE_VIP}" kubectl get nodes | grep -c " control-plane ")" -eq "${K8S_CONTROLPLANE_COUNT}" ]; do
  if [ ${attempt} -eq ${attempts_max} ]; then
    echo ">> [ERROR] Timeout waiting for control-plane nodes! <<"
    exit 1
  fi
  attempt=$((attempt+1))
  sleep 10
done
echo ">> Continuing after $((attempt*10)) seconds."
echo ">> Joining cluster..."
attempts_max=6
attempt=0
until [ -f /etc/kubernetes/discovery.yaml ]; do
  scp -o StrictHostKeyChecking=no "${K8S_CONTROLPLANE_VIP}":discovery.yaml . 2>/dev/null
  sudo install -o root -g root -m 600 discovery.yaml /etc/kubernetes/discovery.yaml 2>/dev/null
  if [ ! -f /etc/kubernetes/discovery.yaml ]; then
    attempt=$((attempt+1))
    sleep 10
  fi
done

cat << EOF > kubeadmjoin.yaml
apiVersion: kubeadm.k8s.io/v1beta3
caCertPath: /etc/kubernetes/pki/ca.crt
discovery:
  file:
    kubeConfigPath: /etc/kubernetes/discovery.yaml
  timeout: 5m0s
  tlsBootstrapToken: ${KUBEADM_TOKEN}
kind: JoinConfiguration
nodeRegistration:
  kubeletExtraArgs:
    cloud-provider: external
EOF
if sudo kubeadm join "${K8S_CONTROLPLANE_VIP}":6443 --config kubeadmjoin.yaml; then
  echo ">> Node ${HOSTNAME} successfully initialized!"
  touch .k8s-node-success
  rm -f env.txt kubeadmjoin.yaml discovery.yaml join-workers.sh
else
  echo ">> [ERROR] Cluster initialization unsuccessful on ${HOSTNAME}! <<"
  exit 1
fi