#!/bin/bash
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

RECIPIENTS_FILE="recipients.txt"
CHECK_INTERVAL="1m"
GIT_REPO="https://github.com/apache/incubator-gearpump.git"

# Read recipients from file
if [ ! -f $RECIPIENTS_FILE ]; then
  echo "Please specify recipients into \"$RECIPIENTS_FILE\" first."
  exit 1
fi
RECIPIENTS=$(grep -E "^$|^#" -v $RECIPIENTS_FILE | tr '\n' ';')

# Function to send mail
function mail_to {
  SUBJECT=$1; shift
  BODY=$1; shift
  echo -n "Sending mail ... "
  echo -e "$BODY" | mutt "$RECIPIENTS" -s "$SUBJECT" "$@"
  echo "done"
}

# Clone source code and go
BUILD_DIR=$(pwd)/gearpump
if [[ ! -d $BUILD_DIR ]]; then
  echo "Clone the project in $BUILD_DIR ..."
  git clone $GIT_REPO "$BUILD_DIR"
fi
cd "$BUILD_DIR" || exit 1
git checkout -q master

# Define the variables
DIST_DIR=output/target/pack
LOG_DIR=/tmp/gearpump
ATTACHMENT=everything.zip
REPORT_DIR=report
COMMIT_REV=''

# Function to check new commit and run tests
function run_test_if_new_commit_found {
  echo -n "Checking new Git commit ($(date)) ... "
  _=$(git pull -q --rebase)
  NEW_COMMIT_REV=$(git log -n 1 --pretty=format:'%h')
  if [[ $NEW_COMMIT_REV == "$COMMIT_REV" ]]; then
    echo "none"
    return
  fi

  echo "$NEW_COMMIT_REV detected"
  COMMIT_REV=$NEW_COMMIT_REV
  COMMIT_LOG=$(git log -1)

  rm -Rf $DIST_DIR $LOG_DIR $ATTACHMENT
  echo "Rebuild the project ..."
  sbt clean assembly packArchiveZip
  if [ $? -ne 0 ]; then
    mail_to \
      "Gearpump build failed $COMMIT_REV" \
      "Failed to build source code.\n\n$COMMIT_LOG"
    return
  fi

  echo "Run tests ... (it will take couple of minutes or longer)"
  sbt "it:test-only *Suite* -- -h $REPORT_DIR" | tee $REPORT_DIR/console.out
  if [ $? -eq 0 ]; then
    grep -q "sbt.TestsFailedException: Tests unsuccessful" $REPORT_DIR/console.out
    if [ $? -ne 0 ]; then
      mail_to \
        "Gearpump test passed $COMMIT_REV" \
        "All tests passed.\n\n$COMMIT_LOG"
      return
    fi
  fi

  echo "Copy test logs into report directory ..."
  SELECTION="$REPORT_DIR $LOG_DIR"
  zip -q -r $ATTACHMENT $SELECTION
  rm -Rf $SELECTION

  mail_to \
    "Gearpump test failed $COMMIT_REV" \
    "Integration test failed. Please check attached files.\n\n$COMMIT_LOG" \
    -a $ATTACHMENT
}

while true; do
  run_test_if_new_commit_found
  echo -n "Sleep $CHECK_INTERVAL ... "
  sleep $CHECK_INTERVAL
done