orderGateway.js

// Created by Max Angelma on 5.4.2017

// Modified for FIS course on 23.4.2017

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var request = require('request');
var port = 4099;
var bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
var tilaus;

// JSON-order is sent here
function send(order) {

    console.log("sending:");
    console.log(order);

    request.post({
        headers: { "content-type" : "application/json" },
        url: 'http://localhost:4107/order',
        json: order
    }, function(error, response, body){
        //console.log(body);
        if (error) { console.log(error); }
    });
}

// JSON-order is sent here
function schedule(order) {

    console.log("scheduling execution");
    console.log("Order lenght: " + order.length);
    //console.log(order[0]);
    console.log(order);

    /*
     request.post({
     headers: { "content-type" : "application/json" },
     url: 'http://localhost:4107/order',
     json: order
     }, function(error, response, body){
     //console.log(body);
     if (error) { console.log(error); }
     });

     */
}

function releaseNext() {
    //console.log(tilaus);

    //console.log(tilaus);

    if (tilaus.length >= 1) {
        send(tilaus[tilaus.length-1]);
        tilaus.pop();
        console.log("next released");
    } else {
        console.log("empty queue")
    }
    //console.log(tilaus);
}

function pollSimulator() {

    request.get({
        url: 'http://localhost:3000/RTU/CNV7/data/S1'
    }, function(error, response, body){
        //console.log(body);
        if (error) {
            var fault = error.code;
            console.log(fault);
            io.emit('simulatorState', fault);
            //throw TypeError ("Simulator is offline, please come next year");
        } else {
            //console.log("simulator is alive");
            io.emit('simulatorState', "OK");
        }
    });
}

// listening to port 4099
http.listen(port, function(){
    console.log('The order gateway is listening to ' + port);
    console.log('\n');
});

// GET sends index.html
app.get('/', function(req, res){
    res.sendFile(__dirname + '/index.html');
});

var i = 0;

// Socket.io magic happens here
io.on('connection', function(socket){

    socket.on('moveToProd', function(order){

        //console.log("MovetoProd socket io received");
        //console.log(order);

        if (order != "0") {
            i++;
            //send(order);

            tilaus = order;

            releaseNext();

            //console.log("Order: " + i);
            //io.emit('emitOrder', order);

        }
    });

    socket.on('queue', function(order){

        console.log("Queue socket io received, not executing anything. Should I do something?");
        //console.log(order);
/*
        if (order != "0") {
            i++;
            send(order);
            console.log("Order: " + i);

            setTimeout(function() {
                io.emit('emitOrder', order);
            },1000);

        } */
    });

});

// POSTs handled here, no functionality yet
app.post('/', function(req, res){
    console.log("order ready?");
    console.log(req.body);
    io.emit('finishedOrder', req.body);

    setTimeout(function() {
        releaseNext();
    }, 3000);

    res.end('\n ordering system received information');
});

// POSTs handled here, no functionality yet
app.post('/update', function(req, res){
    console.log("/update received post with body: ");
    console.log(req.body);
    io.emit('updateOrder', req.body);
    res.end('\n updating...');
});



setInterval(pollSimulator, 5000);