#!/bin/bash -e

set -x

if [ "$DELAYEDJOB_SPLIT_LOGS" == 'Yes' ]; then
    export DELAYED_JOB_LOG_SPLIT_MODE=split
fi

if [ "$DELAYEDJOB" == 'Yes' ]; then
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && source /etc/profile.d/s3EnvVar.sh && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m start'
else
    echo "Delayed jobs (default) set to no"
fi

if [ "$DELAYEDJOB_EXTRA" == 'Yes' ]; then
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && source /etc/profile.d/s3EnvVar.sh && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 1 --queue=default start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && source /etc/profile.d/s3EnvVar.sh && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 2 --queue=remote_reports_job_q start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && source /etc/profile.d/s3EnvVar.sh && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 4 --queue=statements_run_job_q start'
else
    echo "Delayed jobs (Extra) set to no"
fi

if [ "$DELAYEDJOB_MIGRATION" == 'Yes' ]; then
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && source /etc/profile.d/s3EnvVar.sh && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 3 --queue=account_migration_job_q start'
else
    echo "Delayed job for Data Migrations set to no"
fi

if [ "$DELAYEDJOB_NAE" == 'Yes' ]; then
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 1 --queue=default start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 2 --queue=mass_client_import start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 3 --queue=zuora_billing start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 4 --queue=mailers start'
else
    echo "Delayed jobs (Accountant Edition) set to no"
fi

if [ "$DELAYEDJOB_TAX" == 'Yes' ]; then
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 1 --queue=default start'
else
    echo "Delayed jobs (Corporation Tax) set to no"
fi

if [ "$DELAYEDJOB_TAX_DISCRETE" == 'Yes' ]; then
#    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 1 --queue=submission_jobs start'
    su $USER_ACCOUNT -c 'cd /var/www/sage_one_app_git && mkdir -p tmp && RAILS_ENV=$ENVIRONMENT_CONFIG_NAME bundle exec script/delayed_job -m -i 2 --queue=submission_jobs start'
else
    echo "Delayed jobs (Corporation Tax Discrete DJ server) set to no"
fi

# configure delayed_jobs monitoring
if [ "$DATADOG_MONITORED" == "Yes" ] && [ ! -z "$MYSQL_DJ_MONITOR_USER" ] && [ ! -z "$MYSQL_DJ_MONITOR_PASSWORD" ]; then
  tag_environment=$( rs_tag -l -f yaml | awk -F= '$1=="- ec2:environment" { print $2 }' )
  tag_landscape=$( rs_tag -l -f yaml | awk -F= '$1=="- ec2:landscape" { print $2 }' )
  tag_product=$( rs_tag -l -f yaml | awk -F= '$1=="- ec2:product" { print $2 }' )

  cat > /etc/dd-agent/conf.d/delayedjob.yaml <<EOF
init_config:
  mysql_user: $MYSQL_DJ_MONITOR_USER
  mysql_table: delayed_jobs
  mysql_host: $MYSQL_VIP
  mysql_database: $MYSQL_DATABASE_NAME
  mysql_password: $MYSQL_DJ_MONITOR_PASSWORD
  dd_hostname: $( echo $RS_SERVER_NAME | cut -d- -f1-3 )
  tag_environment: ${tag_environment}
  tag_landscape: ${tag_landscape}
  tag_product: ${tag_product}
  min_collection_interval: 60
instances:
  - server: localhost
EOF
fi