#!/bin/bash

# usage
usage() {
  cat <<USG
Usage: bash $0 [OPTIONS]
  OPTIONS:
  -r|--kubesat-repo-dir    NATS server hostname/ip-address
                           default: /tmp/spacetech-kubesat
  -b|--branch              Branch to clone from
                           default: master
  -h|--help                Show help/usage
USG
}

# clone git repo
kubesat_repo="/tmp/spacetech-kubesat"
git_branch="master"
while (( "$#" )); do
  case "$1" in
    -r|--kubesat-repo-dir)
      kubesat_repo="$2"
      shift 2
      ;;
    -b|--git-branch)
      git_branch="$2"
      shift 2
      ;;
    -h|--help)
      usage
      exit 0
      ;;
    *)
      echo -e "Error. Invalid arg(s)" |tee -a $log
      usage
      exit 1
      ;;
  esac
done
echo "Begin..."
echo "kubesat repo will be cloned to: ${kubesat_repo}"
echo "branch name: ${git_branch}"
if [ -d "${kubesat_repo}" ]; then
  mv ${kubesat_repo} \
  "$(dirname ${kubesat_repo})/$(basename ${kubesat_repo})-$(date +"%Y%m%d-%H%M%S")"
  mkdir -p ${kubesat_repo}
  echo "${kubesat_repo} - directory already exists. Backed up."
fi
echo "Cloning git repo..."
git clone https://github.com/IBM/spacetech-kubesat \
  --branch ${git_branch} --single-branch ${kubesat_repo}

# create kubesat conda env
cat <<EOF >${kubesat_repo}/simulation/devtest/conda-manifest.yaml
channels:
  - anaconda
  - defaults
  - conda-forge
dependencies:
  - orekit==10.1
  - python==3.8.3
  - pip==20.1.1
  - pip:
    - pytest==5.4.3
    - jsonschema==3.2.0
    - aiologger==0.5.0
    - aiohttp==3.6.2
    - uvicorn==0.11.5
    - fastapi==0.58.1
    - asyncio-nats-client==0.10.0
    - redis==3.5.3
    - numpy==1.19.0
    - gym==0.17.2
    - tensorflow==2.2.0
    - keras-rl2==1.0.4
    - pandas==1.0.5
EOF

# create kubesat setup
cat <<EOF >${kubesat_repo}/simulation/devtest/setup.sh
#!/bin/bash
apk update
apk --no-cache add git bash curl wget unzip tar git vim docker
echo "setting up conda environment..."
conda env create -n kubesat -f ${kubesat_repo}/simulation/devtest/conda-manifest.yaml
[ $? -eq 0 ] && conda init bash
source /home/anaconda/.profile
conda activate kubesat
conda clean -afy
echo "downloading orekit data..."
mkdir -p \$HOME/orekit
wget https://gitlab.orekit.org/orekit/orekit-data/-/archive/master/orekit-data-master.zip -O "\$HOME/orekit-data.zip"
EOF

# run kubesat
cat <<EOF >${kubesat_repo}/simulation/devtest/run.sh
#!/bin/bash

kubesat_repo=${kubesat_repo}

sats_count=1
iot_count=1
ground_count=1

pkill python

docker stop dev-redis
docker rm dev-redis
docker run -d --name dev-redis -p 6379:6379 redis
redis=\$(docker inspect -f '{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' dev-redis)

docker stop dev-nats
docker rm dev-nats
docker run -d --name dev-nats -p 4222:4222 nats
nats=\$(docker inspect -f '{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' dev-nats)

cd \${kubesat_repo}/ && python setup.py install
simhost=\$(docker inspect -f '{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' dev-kubesat)
port=8001

start_svc() {
  echo "Starting service \$1..."
  cd \${kubesat_repo}/simulation/\$1 && nohup python -u run.py -a \$simhost -s \$nats -d \$redis -t \$port > \${kubesat_repo}/simulation/devtest/\$1.log &
  echo "\$! \$1"
  port=\$(( port+ 1 )) && sleep 5
}

for s in config logging czml; do
  start_svc \$s
done

for (( i=1; i <= \$iot_count; i++ )) ; do
  start_svc "iot"
done

for (( i=1; i <= \$ground_count; i++ )) ; do
  start_svc "groundstation"
done

for (( i=1; i <= \$sats_count; i++ )) ; do
  start_svc "orbits"
  start_svc "data"
  start_svc "rl"
  start_svc "agriculture"
  start_svc "cluster"
  start_svc "rl-training"
done

# dashboard service
dashboard_imgid=\$(docker images -q kubesat-dashboard:1.0)
[[ -n "\$dashboard_imgid" ]] || \
docker build \${kubesat_repo}/simulation/dashboard -t kubesat-dashboard:1.0
docker stop dev-dashboard
docker rm dev-dashboard
docker run -d --name dev-dashboard -p 8080:8080 kubesat-dashboard:1.0 node app.js -s \$nats

# clock service
start_svc "clock"

# done
echo -e "\\nkubesat services started successfully"
echo "Dashboard is now available at http://localhost:8080"
echo -e "\\nRe-run following command to test any code changes made in ${kubesat_repo}"
echo "docker exec -t dev-kubesat bash run.sh"
EOF

# create dockerfile
cat <<EOF >${kubesat_repo}/simulation/devtest/Dockerfile
FROM continuumio/miniconda3:4.8.2-alpine
USER root
WORKDIR ${kubesat_repo}/simulation/devtest
EXPOSE 8080
ENV PYTHONDONTWRITEBYTECODE=true
ENV PATH /opt/conda/condabin:\$PATH
ENV PATH /opt/conda/envs/kubesat/bin/:\$PATH
EOF

# build
docker build -t dev-kubesat:1.0 ${kubesat_repo}/simulation/devtest
docker stop dev-kubesat
docker rm dev-kubesat
docker run --name dev-kubesat -td \
  -v /var/run/docker.sock:/var/run/docker.sock \
  -v ${kubesat_repo}:${kubesat_repo} dev-kubesat:1.0
echo "Run setup..."
docker exec -t dev-kubesat sh setup.sh
echo "Start kubesat services..."
docker exec -t dev-kubesat bash run.sh
echo "Done"