#!/bin/bash
 set -e
 # This is a script to deploy NodeJs artifacts.
 # Note: The script doesn't handle the token expiry or any API exceptions/errors.

 # A function to end script with failed state.
err() {
  echo "Failed to deploy the artifact, check the task log for more details at $PIPELINE_JOB_URL"
  exit 1
}

if [[ -z "${TARGET_ENV_NAME}" ]]
then
  echo "Target environment name is not defined, make sure that TARGET_ENV_NAME environment variable is set"
  err
fi

if [[ -z "${PIPELINE_ARTIFACT_START_LOG}" ]]
then
  echo "Pipeline artifact start log is not defined, make sure that PIPELINE_ARTIFACT_START_LOG environment variable is set"
  err
fi

# Get Cloud Authentication token. For more details: https://docs.acquia.com/acquia-cloud/develop/api/auth/

TOKEN=$(curl -sS -X POST -u "${CLOUD_API_KEY}:${CLOUD_API_SECRET}" -d "grant_type=client_credentials" https://accounts.acquia.com/api/auth/oauth/token | python -c "import sys, json; print json.load(sys.stdin)['access_token']")

# Get target environment Id.

TARGET_ENV_ID=$(curl -sS -X GET "https://cloud.acquia.com/api/applications/$PIPELINE_APPLICATION_ID/environments" -H "Content-Type: application/json" -H "Authorization: Bearer ${TOKEN}" | python -c "import sys, json; envs=json.load(sys.stdin)['_embedded']['items']; print [x for x in envs if x['name'] == '$TARGET_ENV_NAME'][0]['id']")

echo TARGET_ENV_ID is $TARGET_ENV_ID

 # Get artifact id from pipeline-artifact start log.

 ARTIFACT_ID=$(grep artifactId $PIPELINE_ARTIFACT_START_LOG | cut -d ' ' -f3)

 echo ARTIFACT_ID is $ARTIFACT_ID

 # Put artifact id into pipeline metadata, so you can get it later if necessary.

 pipelines_metadata artifact_id $ARTIFACT_ID

 # Deploy artifact to target environment. Use the notification URL returned to get the task's status.
 # For more details: http://cloudapi-docs.acquia.com/#/Environments/postDeployArtifact

 NOTIFICATION_LINK=$(curl -sS -X POST -d "{\"artifact_id\":\"$ARTIFACT_ID\"}" "https://cloud.acquia.com/api/environments/$TARGET_ENV_ID/artifacts/actions/switch" -H "Content-Type: application/json" -H "Authorization: Bearer ${TOKEN}" | python -c "import sys, json; print json.load(sys.stdin)['_links']['notification']['href']")

 # Poll NOTIFICATION_LINK to know the task status, the status will be 'in-progress' until the task is finished. For more details: https://cloudapi-docs.acquia.com/#/Notifications/getNotificationByUuid

 DEPLOY_STATUS=$(curl -sS -X GET "$NOTIFICATION_LINK" -H "Content-Type: application/json" -H "Authorization: Bearer ${TOKEN}" | python -c "import sys, json; print json.load(sys.stdin)['status']");

 echo "Waiting for the deployment to be finished, current status: $DEPLOY_STATUS."

 while [ $DEPLOY_STATUS == 'in-progress' ]; do
    sleep 60
    TOKEN=$(curl -sS -X POST -u "${CLOUD_API_KEY}:${CLOUD_API_SECRET}" -d "grant_type=client_credentials" https://accounts.acquia.com/api/auth/oauth/token | python -c "import sys, json; print json.load(sys.stdin)['access_token']");

    echo "New TOKEN generated";

    DEPLOY_STATUS=$(curl -sS -X GET "$NOTIFICATION_LINK" -H "Content-Type: application/json" -H "Authorization: Bearer ${TOKEN}" | python -c "import sys, json; print json.load(sys.stdin)['status']");

    echo "Waiting for the deployment to be finished, current status: $DEPLOY_STATUS.";
 done

 echo $DEPLOY_STATUS

 # Exit with 1 if the final status is 'failed'. Do nothing if the final status is 'completed' which means the deployment was successful.

 if [ "$DEPLOY_STATUS" == 'failed' ]
 then
   err
 fi