ewd-document-store/examples/CacheExpress.js

/*

 ----------------------------------------------------------------------------
 | ewd-document-store: Persistent JavaScript Objects and Document Database  |
 |                      using Global Storage                                |
 |                                                                          |
 | Copyright (c) 2017 M/Gateway Developments Ltd,                           |
 | Reigate, Surrey UK.                                                      |
 | All rights reserved.                                                     |
 |                                                                          |
 | http://www.mgateway.com                                                  |
 | Email: rtweed@mgateway.com                                               |
 |                                                                          |
 |                                                                          |
 | Licensed under the Apache License, Version 2.0 (the "License");          |
 | you may not use this file except in compliance with the License.         |
 | You may obtain a copy of the License at                                  |
 |                                                                          |
 |     http://www.apache.org/licenses/LICENSE-2.0                           |
 |                                                                          |
 | Unless required by applicable law or agreed to in writing, software      |
 | distributed under the License is distributed on an "AS IS" BASIS,        |
 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
 | See the License for the specific language governing permissions and      |
 |  limitations under the License.                                          |
 ----------------------------------------------------------------------------

  7 September 2017

*/

// Demonstrates use of CacheModule.js worker module which connects each
// worker process to the Cache database, intergrated with Express

// Start using:
// $ node examples/CacheExpress.js
// You may need to run this as sudo due to Cache permissions

'use strict';

require('dotenv').config();

var express = require('express');
var bodyParser = require('body-parser');
var qoper8 = require('ewd-qoper8');
var qx = require('ewd-qoper8-express');

var app = express();
app.use(bodyParser.json());

var q = new qoper8.masterProcess();
qx.init(q);

app.post('/qoper8', function (req, res) {
  q.handleMessage(req.body, function (resultObj) {
    delete resultObj.finished;
    res.send(resultObj);
  });
});

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

q.on('start', function () {
  this.worker.module = process.cwd() + '/examples/CacheModule';
});

q.on('started', function () {
  var server = app.listen(8080, function () {
    var host = server.address().address;
    var port = server.address().port;

    console.log('EWD-Express listening at http://%s:%s', host, port);
    console.log('__dirname = ' + __dirname);
  });

  var io = require('socket.io')(server);
  io.on('connection', function (socket) {
    socket.on('my-request', function (data) {
      q.handleMessage(data, function (resultObj) {
        delete resultObj.finished;
        socket.emit('my-response', resultObj);
      });
    });
  });
});

q.start();