source/packages/services/assetlibrary/infrastructure/neptune_dbEngineVersion.bash

#!/bin/bash
#-----------------------------------------------------------------------------------------------------------------------
#   Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
#
#  Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance
#  with the License. A copy of the License is located at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
#  or in the 'license' file accompanying this file. This file is distributed on an 'AS IS' BASIS, WITHOUT WARRANTIES
#  OR CONDITIONS OF ANY KIND, express or implied. See the License for the specific language governing permissions
#  and limitations under the License.
#-----------------------------------------------------------------------------------------------------------------------

set -e
if [[ "$DEBUG" == "true" ]]; then
    set -x
fi

function dbEngineVersion_isAtLeast_help_message {
    cat << EOF

NAME
    neptune_functions.bash dbEngineVersion_isAtLeast

DESCRIPTION
    Determines whether the dbEngineVersion of a deployed AssetLibrary (full mode) Neptune cluster meets a required minimum.

MANDATORY ARGUMENTS:
    -n (string)   Neptune stack name.
    -b (string)   Bastion stack name.
    -k (string)   SSH key file.
    -v (string)   Minimum required Neptune version.

OPTIONAL ARGUMENTS
    -D (flag)     Debug mode.  Will print values.
    -R (string)   AWS region.
    -P (string)   AWS profile.

EOF
}

function _get_dbEngineVersion {

      # retrieve the Neptune endpoint
      stack_exports=$(aws cloudformation list-exports $AWS_ARGS)
      dbClusterEndpoint_param=${NEPTUNE_STACK_NAME}-DBClusterEndpoint
      dbClusterEndpoint=$(echo $stack_exports \
            | jq -r --arg dbClusterEndpoint_param "$dbClusterEndpoint_param" \
            '.Exports[] | select(.Name==$dbClusterEndpoint_param) | .Value')

      if [ -z "$dbClusterEndpoint" ]; then
        echo 'INVALID_NOT_DEPLOYED'
        exit
      fi

      # retrieve the bastion autposcaling group
      stack_resources=$(aws cloudformation describe-stack-resources --stack-name $BASTION_STACK_NAME $AWS_ARGS)
      bastion_autoscaling_group=$(echo $stack_resources | jq -r '.StackResources[] | select(.LogicalResourceId=="BastionAutoScalingGroup") | .PhysicalResourceId')

      if [ -z "$bastion_autoscaling_group" ]; then
        echo 'INVALID_NO_BASTION_AUTOSCALING_GROUP'
        exit
      fi

      # retrieve an instance from the group
      autoscaling_group=$(aws autoscaling describe-auto-scaling-groups --auto-scaling-group-names $bastion_autoscaling_group $AWS_ARGS)
      bastion_instanceId=$(echo $autoscaling_group | jq -r '.AutoScalingGroups[0].Instances[0].InstanceId')

      if [ -z "$bastion_instanceId" ]; then
        echo 'INVALID_NO_BASTION_INSTANCE'
        exit
      fi

      # retrieve bastion instance details
      bastion_ip=$(aws ec2 describe-instances --instance-ids $bastion_instance $AWS_ARGS | jq -r --arg instanceId "$bastion_instanceId" '.Reservations[].Instances[] | select(.InstanceId==$instanceId) | .PublicIpAddress')

      if [ -z "$bastion_ip" ]; then
        echo 'INVALID_NO_BASTION_IP'
        exit
      fi

      # retrieve engine version of an instance via the bastion
      dbEngineVersion=$(ssh -i $SSH_KEY  ec2-user@$bastion_ip curl -s https://$dbClusterEndpoint:8182/status -o "StrictHostKeyChecking=no" | jq -r '.dbEngineVersion')

      if [ -n "$DEBUG" ]; then
        echo dbClusterEndpoint: $dbClusterEndpoint >&2
        echo bastion_autoscaling_group: $bastion_autoscaling_group >&2
        echo bastion_instanceId: $bastion_instanceId >&2
        echo bastion_ip: $bastion_ip >&2
        echo dbEngineVersion: $dbEngineVersion >&2
      fi

      echo $dbEngineVersion

}

function _vercomp {
    if [[ $1 == $2 ]]; then
        echo '='
        exit
    fi
    local IFS=.
    local i ver1=($1) ver2=($2)
    # fill empty fields in ver1 with zeros
    for ((i=${#ver1[@]}; i<${#ver2[@]}; i++)); do
        ver1[i]=0
    done
    for ((i=0; i<${#ver1[@]}; i++)); do
        if [[ -z ${ver2[i]} ]]; then
            # fill empty fields in ver2 with zeros
            ver2[i]=0
        fi
        if ((10#${ver1[i]} > 10#${ver2[i]})); then
            echo '>'
            exit
        elif ((10#${ver1[i]} < 10#${ver2[i]})); then
            echo '<'
            exit
        fi
    done
    echo '='
}

while getopts ":n:b:k:v:DR:P:" opt; do
    case $opt in
        n  ) export NEPTUNE_STACK_NAME=$OPTARG;;
        b  ) export BASTION_STACK_NAME=$OPTARG;;
        k  ) export SSH_KEY=$OPTARG;;
        v  ) export MIN_REQUIRED_VERSION=$OPTARG;;

        D  ) export DEBUG_MODE=true;;
        R  ) export AWS_REGION=$OPTARG;;
        P  ) export AWS_PROFILE=$OPTARG;;
    esac
done

if [ -z "$NEPTUNE_STACK_NAME" ]; then
    echo 'INVALID_NO_NEPTUNE_STACK_NAME'
    exit
fi

if [ -z "$BASTION_STACK_NAME" ]; then
    echo 'INVALID_NO_BASTION_STACK_NAME'
fi

if [ -z "$SSH_KEY" ]; then
    echo 'INVALID_NO_SSH_KEY'
fi

if [ -z "$MIN_REQUIRED_VERSION" ]; then
    echo 'INVALID_NO_MIN_REQUIRED_VERSION'
fi

if [ -z "$AWS_REGION" ]; then
    AWS_REGION=$(aws configure get region $AWS_ARGS)
fi

AWS_ARGS="--region $AWS_REGION "

if [ -n "$AWS_PROFILE" ]; then
    AWS_ARGS="$AWS_ARGS--profile $AWS_PROFILE"
fi

current_ver=$(_get_dbEngineVersion)
if [[ $current_ver == INVALID_* ]]; then
    echo $current_ver
    exit 1
fi

compared=$(_vercomp $current_ver $MIN_REQUIRED_VERSION)

case $compared in
    '<'  ) exit 2;;
    '='  ) exit 0;;
    '>'  ) exit 0;;
    *    ) exit '2';;
esac