There’s a party at Alexa’s place

mkdkir myproject && cd myproject
mkdir bin
echo “puts ‘OK’ > config.ru
echo “source ‘http://rubygems.org’\n gem ‘rack’” > Gemfile
#Open your project folder and modify the Gemfile to replace the “\n” with an actual break line…
bundle install
git init . && git add . && git commit –m “Init”
heroku apps:create myproject –stack=cedar
git push heroku master
#Copy and paste the content of my installR.sh into the /bin folder of your project
git add . && git commit –am “message” && git push heroku master
heroku ps:scale web=0

#!/bin/bash

function download() {
  if [ ! -f "$2" ]; then
    echo Downloading $2...
    curl $1 -o $2
  else
    echo Got $2...
  fi
}

set -e
 
r_version="${1:-3.2.3}"
r_version_major=${r_version:0:1}
 
if [ -z "$r_version" ]; then
  echo "USAGE: $0 VERSION"
  exit 1
fi
 
basedir="$( cd -P "$( dirname "$0" )" && pwd )"
 
# create output directory
vendordir=/app/vendor
mkdir -p $vendordir

# R
download http://cran.r-project.org/src/base/R-$r_version_major/R-$r_version.tar.gz R-$r_version.tar.gz
tar xzf R-$r_version.tar.gz

# build R
echo ============================================================
echo Building R
echo ============================================================
cd $basedir/R-$r_version/

./configure --prefix=$vendordir/R --with-blas --with-lapack --enable-R-shlib --with-readline=no --with-x=yes
make

cd /app/bin
ln -s R-$r_version/bin/R

rm R-3.2.3.tar.gz
rm -rf erb gem irb rake rdoc ri ruby testrb
rm ruby.exe

cd /app/bin/R-$r_version

rm -rf src
rm Make*
rm -rf doc
rm -rf tests
rm README ChangeLog COPYING INSTALL SVN-REVISION VERSION

https://github.com/ddollar/heroku-buildpack-apt
https://github.com/heroku/heroku-buildpack-ruby

gfortran
libatlas-base-dev
libatlas-dev
liblapack-dev

git add . && git commit –am “message” && git push heroku master
heroku ps:scale web=0
heroku run bash
cd bin/
./installR.sh

#This will open R on Heroku…
R
#This will install the libraries with their corresponding dependencies
install.packages("Rook",dependencies=TRUE)
install.packages("Cairo",dependencies=TRUE)
install.packages("maps",dependencies=TRUE)
install.packages("forecast",dependencies=TRUE)
install.packages("plotrix",dependencies=TRUE)
install.packages("ggplot2",dependencies=TRUE)
install.packages("ggmap",dependencies=TRUE)
install.packages("rJava",dependencies=TRUE)
install.packages("RJDBC",dependencies=TRUE)
q()

`/app/bin/R-3.2.3/bin/R –e “source(‘/app/demo.R’)”`

library("Rook")
library("ggmap")
library("maptools")
library("maps")
library("Cairo")
library("RJDBC")

myPort <- as.numeric(Sys.getenv("PORT"))
#myPort <- 8000
myInterface <- "0.0.0.0"
status <- .Call(tools:::startHTTPD, myInterface, myPort)

newapp<-function(env){
  req<-Rook::Request$new(env)
  res<-Rook::Response$new()

  pass<-system('./hcp.sh',intern=T)
  jdbcDriver <- JDBC("com.sap.db.jdbc.Driver","ngdbc.jar", identifier.quote="`")
  conn_server <- dbConnect(jdbcDriver, "jdbc:sap://localhost:30015", "DEV_6O3Q8EAM96G64Q8M0P5KLA1A3",pass[1])
  airports_param<- dbGetQuery(conn_server, "SELECT ID FROM NEO_BLR8NOQVY6TG8KXKQJ003WVOJ.SAIRPORT")
  sairport<-data.frame(IATA=airports_param$ID)
  airports<-read.csv("airports.dat", header = FALSE)
  colnames(airports)<-c("ID", "name", "city", "country", "IATA", "ICAO", "lat", "lon")
  airports<-subset(airports, IATA %in% sairport$IATA)
  keeps <- c("city","country","IATA","lat","lon")
  airports<-airports[keeps]    
  
  if(req$params()$airports != '')
  {
    count_sairport<-nrow(airports)
    mp <- NULL
    mapWorld <- borders("world", colour="gray50")
    mp <- ggplot() + mapWorld
    CairoJPEG(filename = "R_Plot.jpg", width = 680, height = 680)
    mp <- mp+ geom_point(aes(x=airports$lon, y=airports$lat) ,color="red", size=3) 
    show(mp)
    dev.off()
  }else if(req$params()$us_airports != '')
  {
    US_Airports<-airports[airports$country == "United States", ]
    count_sairport<-nrow(US_Airports)
    mp <- NULL
    mapWorld <- borders("state", colour="gray50")
    mp <- ggplot() +  mapWorld
    mp <- mp+geom_point(aes(x=US_Airports$lon, y=US_Airports$lat) ,color="red", size=3)+
           geom_text(data=US_Airports, aes(US_Airports$lon, US_Airports$lat, label = US_Airports$city), size=6)
    CairoJPEG(filename = "R_Plot.jpg", width = 680, height = 680)
    show(mp)
    dev.off()
  }else if(req$params()$carriers != '')
  {
    US_Airports<-airports[airports$country == "United States", ]
    US_Airports<-as.vector(t(US_Airports))
    US_Airports<-paste(shQuote(US_Airports), collapse=", ")
    #query<-paste("SELECT CARRID, DISTANCE FROM NEO_BLR8NOQVY6TG8KXKQJ003WVOJ.SPFLI WHERE AIRPFROM IN (",US_Airports,")")
    query<-paste("SELECT SPFLI.CARRID,CARRNAME,DISTANCE FROM NEO_BLR8NOQVY6TG8KXKQJ003WVOJ.SPFLI 
             INNER JOIN NEO_BLR8NOQVY6TG8KXKQJ003WVOJ.SCARR ON SPFLI.CARRID = SCARR.CARRID
             WHERE AIRPFROM IN (",US_Airports,")")
    result<-dbGetQuery(conn_server,query)
    result$DISTANCE<-sub(",\\d+","",result$DISTANCE)
    result$DISTANCE<-sub("\\.","",result$DISTANCE)
    carriers<-data.frame(CARRID=result$CARRID,CARRNAME=result$CARRNAME,
                         DISTANCE=as.numeric(result$DISTANCE),stringsAsFactors = FALSE)
    carriers_sum<-aggregate(DISTANCE~CARRID + CARRNAME,data=carriers,FUN=sum)
    cols<-c('CARRNAME','DISTANCE')
    data <- apply( carriers_sum[ , cols ] , 1 , paste , collapse = " " )
    count_sairport<-paste(shQuote(data), collapse=", ")
    mp <- NULL
    CairoJPEG(filename = "R_Plot.jpg", width = 680, height = 680)
    mp<-ggplot(carriers_sum,aes(x=CARRID,y=DISTANCE,fill=CARRID))+
        geom_bar(position="dodge",stat="identity")
    show(mp)
    dev.off()
  }
  
  size <- as.integer(system("stat --format %s R_Plot.jpg", intern=T))
  to.read = file("R_Plot.jpg", "rb")
  #x<-readBin(to.read, raw(),n=18674)
  x<-readBin(to.read, raw(),n=size)
  hex<-paste(x, collapse = "")
  hex<-paste(hex,count_sairport,sep = "/")
  close(to.read)
  
  res$write(hex)
  res$finish()
}

unlockBinding("httpdPort", environment(tools:::startDynamicHelp))
assign("httpdPort", myPort, environment(tools:::startDynamicHelp))

server = Rhttpd$new()
server$listenAddr <- myInterface
server$listenPort <- myPort
server$add(app = newapp, name = "summarize")

while(T) {
  Sys.sleep(10000)
}

web: bundle exec rackup config.ru

#!/bin/bash -e

user=YourUserName
account=YourAccount
HCP_PASSWORD=YourPassword

json=$(tools/./neo.sh open-db-tunnel -i blaghanax -h hanatrial.ondemand.com -a 
       "$account" -u "$user" -p "$HCP_PASSWORD" --background --output json)
regex='.*"host":"([^"]*)".*"port":([^,]*),.*"instanceNumber":"([^"]*)".
        *"dbUser":"([^"]*)".*"dbUserPassword":"([^"]*)".*"sessionId":"([^"]*)".*'
[[ $json =~ $regex ]]
dbHost=${BASH_REMATCH[1]}
dbPort=${BASH_REMATCH[2]}
dbInstance=${BASH_REMATCH[3]}
dbUser=${BASH_REMATCH[4]}
dbPassword=${BASH_REMATCH[5]}
tunnelSessionId=${BASH_REMATCH[6]}

echo $dbPassword

git add .
git commit –am “message”
git push heroku master
heroku ps:scale web=1

{
  "dependencies": {
    "ws": "1.0.1",
    "request": "2.67.0",
    "express": "4.13.3",
    "phantomjs-prebuilt": "2.1.3"
  },
  "engines": {
    "node": "0.12.7"
  }
}

web: node index.js

var WebSocketServer = require("ws").Server
  , http = require("http")
  , express = require("express")
  , request = require('request')
  , fs = require('fs')
  , app = express()
  , arr = []
  , msg = ""
  , port = process.env.PORT || 5000
  , childProcess = require('child_process')
  , phantomjs = require('phantomjs-prebuilt')
  , path = require('path')
  , binPath = phantomjs.path;

app.use(express.static(__dirname + "/"))

var server = http.createServer(app)
server.listen(port)

var wss = new WebSocketServer({server: server})

var childArgs = [path.join(__dirname, 'phantom.js')]
var childStats = [path.join(__dirname, 'readphantom.js')]

app.get('/path', function (req, res) {
 if(req.query.command == 'map'){
  URL = "http://blagrookheroku.herokuapp.com/custom/summarize?airports=xyz&us_airports=&carriers=";
  request(URL, function (error, response, body) {
   if (!error) {
    arr = body.split("/");
    msg = "There are " + arr[1] + " airports around the world";
    var bitmap = new Buffer(arr[0], 'hex');
    var jpeg = new Buffer(bitmap,'base64');
    fs.writeFileSync('Graph.jpg', jpeg);
    res.redirect('/');
   };
  });
 }else if(req.query.command == 'usmap'){
  URL = "http://blagrookheroku.herokuapp.com/custom/summarize?airports=&us_airports=xyz&carriers=";
  request(URL, function (error, response, body) {
   if (!error) {
    arr = body.split("/");
    msg = "There are " + arr[1] + " airports in the US";
    var bitmap = new Buffer(arr[0], 'hex');
    var jpeg = new Buffer(bitmap,'base64');
    fs.writeFileSync('Graph.jpg', jpeg);
    res.redirect('/');
   };
  });
 }else if(req.query.command == 'carriers'){
  URL = "http://blagrookheroku.herokuapp.com/custom/summarize?airports=&us_airports=&carriers=xyz";
  request(URL, function (error, response, body) {
   if (!error) {
    arr = body.split("/");
    msg = "" + arr[1];
    var bitmap = new Buffer(arr[0], 'hex');
    var jpeg = new Buffer(bitmap,'base64');
    fs.writeFileSync('Graph.jpg', jpeg);
    res.redirect('/');
   };
  });
 }else if(req.query.command == 'stat') {
  childProcess.execFile(binPath, childArgs, function(err, stdout, stderr){
   if(!err){
    res.redirect('/');
   };
  });
 }else if(req.query.command == 'readstat') {
  childProcess.execFile(binPath, childStats, function(err, stdout, stderr){
   if(!err){
    res.write(stdout);
    res.end();
   };
  });  
 }else if(req.query.command == 'bye'){
  if(fs.existsSync('Graph.jpg')){
   fs.unlink('Graph.jpg');
  }
  res.redirect('/');
 }
});

wss.on("connection", function(ws) {
  var id = setInterval(function() {
   
  fs.readFile('Graph.jpg', function(err, data) {
    if(!err){
    ws.send(JSON.stringify("Graph.jpg/" + msg), function() {  })
 }else{
    ws.send(JSON.stringify("Gandalf.jpg/No problem...I'm crunching your data..."), function() {  })
 }
  });
  }, 3000)

  ws.on("close", function() {
    clearInterval(id)
  })
})

<html>
  <head>
 <title>I'm a NodeJS Page!</title> 
 <div id="container" align="center"/>
    <script>
      var host = location.origin.replace(/^http/, 'ws')
      var ws = new WebSocket(host);
      ws.onmessage = function (event) {
    var container = document.getElementById('container');
          var data = JSON.parse(event.data);
          data = data.split("/");
          var url = data[0];
          var msg = data[1];
          
          container.innerHTML = '<img src="' + url + '"></br><p><b>' + msg + '</b></p>';
      };
    </script>
  </head>
  <body>
  </body>
</html>

var page = require('webpage').create();
var fs = require('fs');
page.open('http://blagnodeheroku.herokuapp.com/', function () {
 window.setTimeout(function () {
    page.evaluate(function(){

    });

    fs.write('stats.html', page.content, 'w');
    phantom.exit();
},4000);
});

var page = require('webpage').create(),
    address = "stats.html";

    page.open(address, function (status) {
        if (status == 'success') {
                var results = page.evaluate(function() {
                    return document.querySelector('p').innerText.trim();
                });
 console.log(results);
 phantom.exit();
 }
    });

{
  "intents": [
    {
      "intent": "GetFlightsIntent",
      "slots": [
        {
          "name": "command",
          "type": "LITERAL"
        }
      ]
    },
    {
      "intent": "HelpIntent",
      "slots": []
    }
  ]
}

GetFlightsIntent airports from {around the world|command}
GetFlightsIntent airports from {united states|command}
GetFlightsIntent flight distance from {carriers|command}
GetFlightsIntent {thank you|command}

var request = require("request")
  , AlexaSkill = require('./AlexaSkill')
  , APP_ID     = 'amzn1.echo-sdk-ams.app.8c0bd993-723f-4ab2-80b5-84402a7a59ce';

var error = function (err, response, body) {
    console.log('ERROR [%s]', err);
};

var getJsonFromFlights = function(command, callback){
 var msg = "";
 if(command == "thank you"){
 request("http://blagnodeheroku.herokuapp.com/path/?command=bye", function (error, response, body) {
  if (!error) {
   console.log("Done");
  };
 });
 setTimeout(function() {
  callback("thank you");
 },2000);
}else if (command == "around the world"){
 request("http://blagnodeheroku.herokuapp.com/path/?command=bye", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=map", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=stat", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=readstat", function (error, response, body) {
 if (!error) {
 msg = body;
 };
 });
 };
 }); 
 };
 });
 }
 }); 
 setTimeout(function() {
  callback(msg.trim());
 },15000);
}else if (command == "united states"){
 request("http://blagnodeheroku.herokuapp.com/path/?command=bye", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=usmap", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=stat", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=readstat", function (error, response, body) {
 if (!error) {
 msg = body;
 };
 });
 };
 }); 
 };
 });
 }
 }); 
 setTimeout(function() {
  callback(msg.trim());
 },15000);
}else if (command == "carriers"){
 request("http://blagnodeheroku.herokuapp.com/path/?command=bye", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=carriers", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=stat", function (error, response, body) {
 if (!error) {
 request("http://blagnodeheroku.herokuapp.com/path/?command=readstat", function (error, response, body) {
 if (!error) {
 msg = body;
 };
 });
 };
 }); 
 };
 });
 }
 }); 
 setTimeout(function() {
  callback(msg.trim());
 },15000);
 }
};
var handleFlightsRequest = function(intent, session, response){
  getJsonFromFlights(intent.slots.command.value, function(data){
 if(data != "thank you"){
  var text = data;
  var reprompt = 'Please say a command?';
  response.ask(text, reprompt);
 }else{
  response.tell("You're welcome");
 }
  });
};

var Flights = function(){
  AlexaSkill.call(this, APP_ID);
};

Flights.prototype = Object.create(AlexaSkill.prototype);
Flights.prototype.constructor = Flights;

Flights.prototype.eventHandlers.onSessionStarted = function(sessionStartedRequest, session){
  console.log("onSessionStarted requestId: " + sessionStartedRequest.requestId
      + ", sessionId: " + session.sessionId);
};

Flights.prototype.eventHandlers.onLaunch = function(launchRequest, session, response){
  // This is when they launch the skill but don't specify what they want.
  var output = 'Welcome to Flights. ' +
    'Please, say a command.';

  var reprompt = 'Please, say a command?';

  response.ask(output, reprompt);

  console.log("onLaunch requestId: " + launchRequest.requestId
      + ", sessionId: " + session.sessionId);
};

Flights.prototype.intentHandlers = {
  GetFlightsIntent: function(intent, session, response){
    handleFlightsRequest(intent, session, response);
  },

  HelpIntent: function(intent, session, response){
    var speechOutput = 'Get the information for airports and flights. ' +
      'Please say a command?';
    response.ask(speechOutput);
  }
};

exports.handler = function(event, context) {
    var skill = new Flights();
    skill.execute(event, context);
};