server.js

const express = require('express');
const bodyParser = require('body-parser');
const exec = require('child_process').exec;
const app = express();


const REALM = process.env.REALM;
const STAGE = process.env.STAGE;
var PREFIX = ( REALM === "growth" ) ? "gr-" : "" ;

const commands = [
  `bash base-image.sh ${REALM} ${STAGE}`,
  `bash custom-image.sh ${REALM} ${STAGE}`
];

function checkServiceWhitelist( appName )
{
  var whitelist = [ "ecs", "image", "pag", "page", "recommendation", "search", "user-activity", "web", "mini", "follow", "category-datasync", "social", "pwg", "library", "event", "notification", "content", "cms", "report", "init","oasis" ];
  if( STAGE === "devo" ) {
    whitelist.push( "pratilipi" );
    whitelist.push( "author" );
    whitelist.push( "user" );
    whitelist.push( "auth" );
  }
  if( STAGE === "prod" && REALM === "product" ) {
    whitelist.push( "datastore-util" );
  }
  if( whitelist.indexOf( appName ) === -1 ) {
    console.log( `${appName}***** service: ${appName} is not whitelisted.` );
    return false;
  } else {
    console.log( `${appName}***** service: ${appName} whitelisted.` );
    return true;
  }
}

function getServiceCommand( appName, callback )
{
  var state = "";
  if( checkServiceWhitelist( appName ) ) {
    var command = `aws ecs list-services --cluster ${PREFIX}${STAGE}-ecs | jq '.serviceArns[]' | jq 'split(":")[5]' | jq 'split("/")[1]'`;
    console.log( `${appName}***** Running command: ${command}` );
    var cmdProcess = exec( command, { maxBuffer: 2 * 1024 * 1024 }, function( error, stdout, stderr ) {
      if( error != null ) {
        console.error( `${appName}***** Failed to execute command: ${command}` );
        console.error( String( error ) );
        callback( error, null );
      } else {
        var services = stdout.split( "\n" );
        services.pop();
        if( services.indexOf( `\"${appName}\"` ) === -1 ) {
          console.log( `${appName}***** service: ${appName} not exists.` );
          console.log( `${appName}***** service: creating ${appName}.` );
          state = "create";
        } else {
          console.log( `${appName}***** service: ${appName} exists.` );
          console.log( `${appName}***** service: updating ${appName}.` );
          state = "update";
        }
        callback( null, state );
      }
    } );
    cmdProcess.stdout.pipe( process.stdout );
    cmdProcess.stderr.pipe( process.stdout );
  } else {
    callback( null, state );
  }
}


(function run() {

  if( commands.length == 0 ) {
    console.log("***** ecs:sleeping for 5 seconds. TATA Good Night");
    return setTimeout( run, 5 * 1000 );
  }

  commands.reverse();
  var command = commands.pop();
  commands.reverse();

  console.log( `***** Running command: ${command}` );
  var cmdProcess = exec( command, { maxBuffer: 2 * 1024 * 1024 }, function( error, stdout, stderr ) {
    if( error != null ) {
      console.error( `Failed to execute command: ${command}` );
      console.error( String( error ) );
    }
    run();
  } );
  cmdProcess.stdout.pipe( process.stdout );
  cmdProcess.stderr.pipe( process.stdout );

} )();


app.use( bodyParser.urlencoded({ extended:true }) );
app.use( bodyParser.json() );

app.get( '/health', function ( req, res ) {
  res.send( 'Realm:' + REALM + ', Stage:' + STAGE );
} );

app.post( '/*', function ( req, res ) {

  req.body = JSON.parse( req.body.payload );
  
  if( ( STAGE == 'devo' && req.body.ref != 'refs/heads/devo' )
      || ( STAGE == 'gamma' && req.body.ref != 'refs/heads/gamma' )
      || ( STAGE == 'prod' && req.body.ref != 'refs/heads/master') ) {
    res.status( 400 ).send( `No deployment in ${REALM}/${STAGE} for commit in ${req.body.repository.name}/${req.body.ref.substr(11)} branch.` );
    return;
  }
  
  if( req.body.deleted ) {
    res.status( 400 ).send( `No deployment in ${REALM}/${STAGE} for deleted ${req.body.repository.name}/${req.body.ref.substr(11)} branch.` );
    return;
  }

  var appName = req.body.repository.name;
  if( appName === 'pratilipi' ) {
    res.status( 400 ).send( `No deployment in ${REALM}/${STAGE} for repository: ${appName}.` );
    return;
  }
  if( appName.startsWith( 'ecs-' ) ) {
    appName = appName.substr( 4 );
  }
  var appVersion = Math.round( new Date().getTime() / 1000 / 60 );

  getServiceCommand( appName, function( error, command ) {
    if( error != null ) {
      res.status( 400 ).send( `Not Deploying to ${REALM}/${STAGE}/${appName} from ${req.body.ref.substr(11)} branch due to an error.` );
    } else {
      if( command === "" ) {
        res.status( 400 ).send( `Not Deploying to ${REALM}/${STAGE}/${appName} from ${req.body.ref.substr(11)} branch due to service: ${appName} not being in whitelist.` );
      } else {
        commands.push( `bash app-deploy.sh ${command} ${REALM} ${STAGE} ${appName} ${appVersion}` );
        res.send( `Deploying to ${REALM}/${STAGE}/${appName} from ${req.body.ref.substr(11)} branch.` );
      }
    }
  } );
} );

app.listen( 80 );