test/dubbo-scenario-builder/src/main/resources/scenario.sh

#!/usr/bin/env 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.

PRG="$0"
PRGDIR=`dirname "$PRG"`
[ -z "$SCENARIO_HOME" ] && SCENARIO_HOME=`cd "$PRGDIR" >/dev/null; pwd`
cd $SCENARIO_HOME

# set vars from freemarker
testcase_name=${scenario_name}-${scenario_version}
debug_mode=${debug_mode}
timeout=${timeout}
scenario_name=${scenario_name}
scenario_version=${scenario_version}
compose_file="${docker_compose_file}"
project_name=$(echo "${scenario_name}_${scenario_version}" |sed -e "s/\.//g" |awk '{print tolower($0)}')
test_service_name="${test_service_name}_1"
network_name="${network_name}"

service_names=( \
<#list services as service>
  "${service.name}" \
</#list>
  )

service_size=${services?size}

export service_names=$service_names
export service_size=$service_size

<#noparse>
function redirect_all_container_logs() {
  #redirect logs
  echo "Redirecting all container logs: ${service_names[@]}  .." >> $scenario_log

  while [ 1==1 ]; do
    redirect_count=0
    for service_name in ${service_names[@]};do
      redirect_container_logs "$service_name"
      result=$?
      if [ "$result" -eq 0 ];then
        redirect_count=$(( redirect_count + 1 ))
      fi
    done

    if [ "$redirect_count" == $service_size ];then
      echo "Redirect all containers logs."  >> $scenario_log
      break
    fi

    sleep 3
  done
}

function redirect_container_logs() {
  service_name=$1
  container_name=${project_name}_${service_name}_1
  # only redirect once
  ps -ef | grep "docker logs -f $container_name" | grep -v grep > /dev/null
  result=$?
  if [ $result -eq 0 ]; then
    return 0
  fi

  container_id=`docker ps -qf "name=${container_name}"`
  if [[ -z "${container_id}" ]]; then
    return 1
  fi

  echo "Redirect container logs: $container_name" >> $scenario_log
  if [ "$debug_mode" == "1" ]; then
    # redirect container logs to file and display debug message
    docker logs -f $container_name 2>&1 | tee $SCENARIO_HOME/logs/${service_name}.log | grep "dt_socket" &
  else
    docker logs -f $container_name &> $SCENARIO_HOME/logs/${service_name}.log &
  fi
  return 0

}

function wait_container_exit() {
  container_name=$1
  start=$2
  timeout=$3

  # check and get exit code
  while [ 1 = 1 ];
  do
    sleep 2
    status=`docker inspect $container_name --format='{{.State.Status}}'`
    # test container may pending start cause by depends_on condition
#    result=$?
#    if [ $result -ne 0 ];then
#      echo "check container status failure: $result"
#      return 1
#    fi
    if [ "$status" == "exited" ];then
        return 0
    fi

    duration=$(( SECONDS - start ))
    if [ $duration -gt $timeout ];then
      echo "wait for container is timeout: $duration s"
      return 1
    fi
  done
}

status=1
start=$SECONDS

mkdir -p ${SCENARIO_HOME}/logs
scenario_log=${SCENARIO_HOME}/logs/scenario.log
rm -f $scenario_log

echo "[$scenario_name] debug_mode: $debug_mode" >> $scenario_log
echo "[$scenario_name] timeout: $timeout" >> $scenario_log

#Starting test containers
container_name="${project_name}_${test_service_name}"

#kill and clean first
echo "[$scenario_name] Killing containers .." | tee -a $scenario_log
docker-compose -p ${project_name} -f ${compose_file} kill 2>&1 | tee -a $scenario_log > /dev/null

echo "[$scenario_name] Removing containers .." | tee -a $scenario_log
docker-compose -p ${project_name} -f ${compose_file} rm -f 2>&1 | tee -a $scenario_log > /dev/null

#run async, cause depends_on service healthy blocking docker-compose up
redirect_all_container_logs &

# complete pull fail interactive by <<< "NN"
echo "[$scenario_name] Starting containers .." | tee -a $scenario_log
docker-compose -p ${project_name} -f ${compose_file} up -d 2>&1 <<< "NNN" | tee -a $scenario_log > /dev/null

sleep 5

# test container may pending start cause by depends_on condition
#container_id=`docker ps -qf "name=${container_name}"`
#if [[ -z "${container_id}" ]]; then
#    echo "[$scenario_name] docker startup failure!" | tee -a $scenario_log
#    status=1
#else
    echo "[$scenario_name] Waiting for test container .." | tee -a $scenario_log
    # check and get exit code
    wait_container_exit ${container_name} $start $timeout
    result=$?
    if [ $result -eq 0 ]; then
        result=`docker inspect ${container_name} --format='{{.State.ExitCode}}'`
        if [ $result -eq 0 ]; then
            status=0
            echo "[$scenario_name] Run tests successfully" | tee -a $scenario_log
        else
            status=$result
            echo "[$scenario_name] Run tests failed" | tee -a $scenario_log
        fi
    else
        status=1
        echo "[$scenario_name] Run tests timeout" | tee -a $scenario_log
    fi

    echo "[$scenario_name] Stopping containers .." | tee -a $scenario_log
    docker-compose -p ${project_name} -f ${compose_file} kill 2>&1 | tee -a $scenario_log > /dev/null
    docker wait ${container_name} > /dev/null
#fi

if [[ $status == 0 ]];then
    docker-compose -p $project_name -f $compose_file rm -f 2>&1 | tee -a $scenario_log > /dev/null
    ${removeImagesScript}
else
    for service_name in ${service_names[@]};do
        echo "docker inspect ${project_name}_${service_name}_1 :"
        docker inspect ${project_name}_${service_name}_1 >> $scenario_log
        echo ""
    done
fi

# rm network
docker network rm $network_name 2>&1 | tee -a $scenario_log > /dev/null

exit $status

</#noparse>