#!/bin/bash
set -e # Fail on error
trap "trap - SIGTERM && kill -- -$$" SIGINT SIGTERM EXIT # Kill subprocesses on exit

highlight() { grep --color -E "\S|$" "${@:1}" ; }
echo "Comments and Results => Black"
highlightServer () { export GREP_COLORS='ms=0;32'; highlight ; }
echo "Server => Green" | highlightServer
highlightClient () { export GREP_COLORS='ms=0;34'; highlight ; }
echo "Client => Blue" | highlightClient
highlightSupport () { export GREP_COLORS='ms=0;33'; highlight ; }
echo "Support => Yellow" | highlightSupport
highlightGradle () { export GREP_COLORS='ms=0;36'; highlight ; }
echo "Gradle => Cyan" | highlightGradle
lastStartedPid () { jobs -p  | tail -n 1; }

build() {
	echo "Building project"
	./gradlew clean --console=plain |& highlightGradle
	./gradlew build --console=plain |& highlightGradle
	sleep 2s
}

## Local
localTest() {
	echo "Starting Local test"

	# Run environment
	./gradlew :example:local-grpc-server:bootRun -x jar -x classes --console=plain |& highlightServer &
	LOCAL_SERVER=`lastStartedPid`
	sleep 10s # Wait for the server to start
	./gradlew :example:local-grpc-client:bootRun -x jar -x classes --console=plain |& highlightClient &
	LOCAL_CLIENT=`lastStartedPid`
	sleep 30s # Wait for the client to start and the server to be ready

	# Test
	RESPONSE=$(curl -s localhost:8080/)
	echo "Response:"
	echo "$RESPONSE"
	EXPECTED=$(echo -e "Hello ==> Michael")
	echo "Expected:"
	echo "$EXPECTED"
	sleep 1s # Give the user a chance to look at the result

	# Shutdown
	echo "Triggering shutdown"
	kill -s TERM $LOCAL_SERVER
	kill -s TERM $LOCAL_CLIENT
	sleep 1s # Wait for the shutdown logs to pass 

	# Verify
	if [ "$RESPONSE" = "$EXPECTED" ]; then
		echo "#----------------------#"
		echo "| Local example works! |"
		echo "#----------------------#"
	else
		echo "#-----------------------#"
		echo "| Local example failed! |"
		echo "#-----------------------#"
		exit 1
	fi
}

## Cloud-Eureka
cloudTest() {
	echo "Starting Cloud $1 test"

	# Run environment
	if [[ "$1" = "consul" ]]; then
		CONSUL=`docker run --name=consul -d --rm -p 8500:8500 consul`
		docker logs -f $CONSUL |& highlightSupport &
		stopCloudEnv() {
			echo "Stopping consul server"
			docker stop $CONSUL
		}
	elif [[ "$1" == "eureka" ]]; then
		./gradlew :example:cloud-eureka-server:bootRun -x jar -x classes --console=plain |& highlightSupport &
		EUREKA=`lastStartedPid`
		stopCloudEnv() {
			echo "Stopping eureka server"
			kill -s TERM $EUREKA
		}
	elif [[ "$1" = "nacos" ]]; then
		NACOS=`docker run --env MODE=standalone --name nacos -d --rm -p 8848:8848 nacos/nacos-server`
		docker logs -f $NACOS |& highlightSupport &
		stopCloudEnv() {
			echo "Stopping nacos server"
			docker stop $NACOS
		}
	fi
	sleep 10s # Wait for the server to start

#	mkdir -p zipkin
#	cd zipkin
#	echo "*" > .gitignore
#	if [ ! -f zipkin.jar ]; then
#		curl -sSL https://zipkin.io/quickstart.sh | bash -s
#	fi
#	java -jar zipkin.jar &
#	ZIPKIN=`lastStartedPid`
#	sleep 10s # Wait for the server to start
#	cd ..

	./gradlew -Pdiscovery=$1 :example:cloud-grpc-server:bootRun -x jar -x classes --console=plain |& highlightServer &
	CLOUD_SERVER=`lastStartedPid`
	sleep 10s # Wait for the server to start

	./gradlew -Pdiscovery=$1 :example:cloud-grpc-client:bootRun -x jar -x classes --console=plain |& highlightClient &
	CLOUD_CLIENT=`lastStartedPid`
	sleep 30s # Wait for the client to start and the server to be ready
	sleep 60s # Wait for the discovery service to refresh

	# Test
	RESPONSE=$(curl -s localhost:8080/)
	echo "Response:"
	echo "$RESPONSE"
	EXPECTED=$(echo -e "Hello ==> Michael")
	echo "Expected:"
	echo "$EXPECTED"
	sleep 1s # Give the user a chance to look at the result

	# Crash server
	kill -s TERM $CLOUD_SERVER
	echo "The server crashed (expected)"
	sleep 1s # Wait for the shutdown logs to pass

	# and restart server
	./gradlew -Pdiscovery=$1 :example:cloud-grpc-server:bootRun -x jar -x classes --console=plain |& highlightServer &
	CLOUD_SERVER=`lastStartedPid`
	sleep 30s # Wait for the server to start
	sleep 60s # Wait for the discovery service to refresh
	
	# Test again
	RESPONSE2=$(curl -s localhost:8080/)
	echo "Response:"
	echo "$RESPONSE2"
	EXPECTED=$(echo -e "Hello ==> Michael")
	echo "Expected:"
	echo "$EXPECTED"
	sleep 1s # Give the user a chance to look at the result

	# Shutdown
	echo "Triggering shutdown"
	stopCloudEnv
	# kill -s TERM $ZIPKIN
	kill -s TERM $CLOUD_SERVER
	kill -s TERM $CLOUD_CLIENT
	sleep 1s # Wait for the shutdown logs to pass

	# Verify part 1
	if [ "$RESPONSE" = "$EXPECTED" ]; then
		echo "#------------------------------------#"
		echo "| Cloud $1 example part 1 works! |"
		echo "#------------------------------------#"
	else
		echo "#-------------------------------------#"
		echo "| Cloud $1 example part 1 failed! |"
		echo "#-------------------------------------#"
		exit 1
	fi

	# Verify part 2
	if [ "$RESPONSE2" = "$EXPECTED" ]; then
		echo "#------------------------------------#"
		echo "| Cloud $1 example part 2 works! |"
		echo "#------------------------------------#"
	else
		echo "#-------------------------------------#"
		echo "| Cloud $1 example part 2 failed! |"
		echo "#-------------------------------------#"
		exit 1
	fi
}

## Security Basic Auth
securityBasicAuthTest() {
	echo "Starting Security Basic Auth test"

	# Run environment
	./gradlew :example:security-grpc-server:bootRun -x jar -x classes --console=plain |& highlightServer &
	LOCAL_SERVER=`lastStartedPid`
	sleep 10s # Wait for the server to start
	./gradlew :example:security-grpc-client:bootRun -x jar -x classes --console=plain |& highlightClient &
	LOCAL_CLIENT=`lastStartedPid`
	sleep 30s # Wait for the client to start and the server to be ready

	# Test
	RESPONSE=$(curl -s localhost:8080/)
	echo "Response:"
	echo "$RESPONSE"
	EXPECTED=$(echo -e "Input:\n- name: Michael (Changeable via URL param ?name=X)\nRequest-Context:\n- auth user: user (Configure via application.yml)\nResponse:\nHello ==> Michael")
	echo "Expected:"
	echo "$EXPECTED"
	sleep 1s # Give the user a chance to look at the result

	# Shutdown
	echo "Triggering shutdown"
	kill -s TERM $LOCAL_SERVER
	kill -s TERM $LOCAL_CLIENT
	sleep 1s # Wait for the shutdown logs to pass

	# Verify
	if [ "$RESPONSE" = "$EXPECTED" ]; then
		echo "#------------------------------------#"
		echo "| Security Basic Auth example works! |"
		echo "#------------------------------------#"
	else
		echo "#-------------------------------------#"
		echo "| Security Basic Auth example failed! |"
		echo "#-------------------------------------#"
		exit 1
	fi
}

## Tests
build
localTest
cloudTest consul
cloudTest eureka
cloudTest nacos
securityBasicAuthTest