#!/bin/bash
#
# Run the offline publishing integration test.
#
#
# Check to make sure the top-level test directory is defined.
#
if [ $NPMTEST_DIR"" = "" ]
then
   echo ${0##*/}": NPMTEST_DIR must be defined!"
   exit 1
fi
#
# Set the name of the node executable (it should be in our path)
#
NODE=node
#
# Set a randomized test tag to isolate this test run from others within
# the AWS account associated with our Odin material set.  This ensures
# that all topic names used are unique to this test run.
#
TEST_TAG="test-"$RANDOM
export HOSTNAME="ajje7lpljulm4-ats.iot.us-east-1.amazonaws.com"
export CUSTOM_AUTH_HOST=$(aws --region us-east-1 secretsmanager get-secret-value --secret-id "unit-test/endpoint" --query "SecretString" | cut -f2 -d":" | sed -e 's/[\\\"\}]//g')
#
# Capture the exit code of the first command which fails in a pipeline.
#
set -o pipefail
#
# The integration tests pass a number of updates between two partner
# processes.  Because these are QoS 0, delivery isn't guaranteed, but
# we should expect to receive most of them.  In this test, the transmitting
# process is subjected to simulated network failures; since offline
# publish queueing is enabled, published messages are stored until it
# reconnects and are then drained out.  The receiving process should
# receive all of these if everything is working correctly.
#
# The transmitting process sends messages with a monotonically increasing
# value, starting at 1.  The receiving process maintains a running sum of
# these values, as well as a running sum of the message numbers received.
# At the end of the test, the ratio of these sums is calculated; if no
# messages are missing at the receiver, this ratio will be exactly 1.0.
# Any messages which weren't received will cause this ratio to be less than
# 1.0.  Since QoS 0 is used for the test, this is possible so a very small
# error difference is allowed.
#
RECEIVES_REQUIRED=46
TRANSMITS_TOTAL=48
#
# Process output will be captured in these files.
#
PROC1_OUTFILE=$NPMTEST_DIR/${0##*/}-$RANDOM-$RANDOM-proc-1.out
PROC2_OUTFILE=$NPMTEST_DIR/${0##*/}-$RANDOM-$RANDOM-proc-2.out
#
# Move the test javascript programs to the installed SDK
# directory
#
INT_TEST_DIR=$NPMTEST_DIR/aws-iot-device-sdk-js/integration-test
mkdir -p $INT_TEST_DIR
cp ${0%/*}/offline-publishing-test.js $INT_TEST_DIR
#
# Start the two partner processes for the offline publishing integration test and
# save their PIDs.
#
if [ $AUTHENTICATION_TYPE"" == "certificate" ]
then
    echo "###################################################################"
    echo ${0##*/}": running thing integration test (certificate auth)"
    echo "###################################################################"
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $HOSTNAME -f $CERT_DIR -t1 --debug=true -T $TEST_TAG | tee $PROC1_OUTFILE &
    PROC1_PID=$!
    sleep 3       # wait 3 seconds prior to starting transmitting process
    #
    # transmit 4x/second
    #
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $HOSTNAME -f $CERT_DIR -t2 --debug=true --delay-ms=250 -T $TEST_TAG | tee $PROC2_OUTFILE &
    PROC2_PID=$!
elif [ $AUTHENTICATION_TYPE"" == "custom-auth" ]
then
    echo "###################################################################"
    echo ${0##*/}": running device integration test (websocket/custom auth)"
    echo "###################################################################"
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $CUSTOM_AUTH_HOST -P=wss-custom-auth -t1 --debug=true -T $TEST_TAG | tee $PROC1_OUTFILE &
    PROC1_PID=$!
    sleep 3       # wait 3 seconds prior to starting transmitting process
    #
    # transmit 4x/second
    #
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $CUSTOM_AUTH_HOST -P=wss-custom-auth -t2 --debug=true --delay-ms=250 -T $TEST_TAG | tee $PROC2_OUTFILE &
    PROC2_PID=$!
else
    echo "###################################################################"
    echo ${0##*/}": running thing integration test (websocket/sigv4)"
    echo "###################################################################"
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $HOSTNAME -P=wss -t1 --debug=true -T $TEST_TAG | tee $PROC1_OUTFILE &
    PROC1_PID=$!
    sleep 3       # wait 3 seconds prior to starting transmitting process
    #
    # transmit 4x/second
    #
    $NODE $INT_TEST_DIR/offline-publishing-test.js -H $HOSTNAME -P=wss -t2 --debug=true --delay-ms=250 -T $TEST_TAG | tee $PROC2_OUTFILE &
    PROC2_PID=$!
fi
#
# Wait on the two partner processes and record their exit codes.
#
wait $PROC1_PID
PROC1_EXIT_CODE=$?
wait $PROC2_PID
PROC2_EXIT_CODE=$?
#
# Combine the two exit codes; if either process exited abnormally, this
# test is a failure.
#
COMBINED_EXIT_CODE=$((PROC1_EXIT_CODE | PROC_2_EXIT_CODE))
if [ $COMBINED_EXIT_CODE"" = "0" ]
then
   #
   # Print out the received quality for debugging.
   #
   cat $PROC1_OUTFILE | grep -E '^quality' |awk '{print $NF}'
   receiveQuality=`cat $PROC1_OUTFILE | grep -E '^quality' |awk '{print $NF}'`

   #
   # We should receive all of these; allow only a very small error margin.
   #
   minAcceptableQuality=0.99
   qualityGtMinAcceptable=`echo $receiveQuality"" \> $minAcceptableQuality"" | bc -l`
   #
   # The quality ratio should never exceed 1.0.
   #
   maxAcceptableQuality=1.00001
   qualityLtMaxAcceptable=`echo $maxAcceptableQuality"" \> $receiveQuality"" | bc -l`

   if [ $qualityGtMinAcceptable"" -eq 1 ] && [ $qualityLtMaxAcceptable"" -eq 1 ]
   then
      echo "########################################################"
      echo "   TEST SUCCEEDED: PROC 1 QUALITY "$receiveQuality", "$minAcceptableQuality" required"
      echo "########################################################"
   else
      echo "########################################################"
      echo "   TEST FAILED: PROC 1 QUALITY "$receiveQuality", "$minAcceptableQuality" required"
      echo "########################################################"
      exit 2
   fi
else
   echo ${0##*/}": FAILED ("$PROC1_EXIT_CODE":"$PROC2_EXIT_CODE")"
   exit $COMBINED_EXIT_CODE
fi
rm $PROC1_OUTFILE $PROC2_OUTFILE