var path = require('path');
var app = require('express')();
var bodyParser = require('body-parser');
var cors = require('cors');
var createStore = require('./store');

module.exports.run = function(worker) {
  var httpServer = worker.httpServer;
  var scServer = worker.scServer;
  var store;

  httpServer.on('request', app);

  app.set('view engine', 'ejs');
  app.set('views', path.resolve(__dirname, '..', 'views'));
  
  app.get('/', function(req, res) {
    res.render('index', { port: worker.options.port });
  });

  app.use(cors({ methods: 'POST' }));
  app.use(bodyParser.json());
  app.post('/', function(req, res) {
    if (!req.body) return res.status(404).end();
    if (!store) store = createStore(worker.options);

    switch(req.body.op) {
      case 'get':
        store.get(req.body.id).then(function(r) {
          res.send(r || {});
        });
        break;
      default:
        store.add(req.body).then(function(r) {
          scServer.exchange.publish('log', req.body);
          res.send({ id: r.id, error: r.error });
        });
    }
  });

  scServer.addMiddleware(scServer.MIDDLEWARE_EMIT, function (req, next) {
    var channel = req.event;
    var data = req.data;
    if (channel.substr(0, 3) === 'sc-' || channel === 'respond' || channel === 'log') {
      scServer.exchange.publish(channel, data);
    } else if (channel === 'log-noid') {
      scServer.exchange.publish('log', { id: req.socket.id, data: data });
    }
    next();
  });

  scServer.on('connection', function(socket) {
    var channelToWatch, channelToEmit;
    socket.on('login', function (credentials, respond) {
      if (credentials === 'master') {
        channelToWatch = 'respond'; channelToEmit = 'log';
      } else {
        channelToWatch = 'log'; channelToEmit = 'respond';
      }
      worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) {
        socket.emit(channelToWatch, msg);
      });
      respond(null, channelToWatch);
    });
    socket.on('disconnect', function() {
      var channel = worker.exchange.channel('sc-' + socket.id);
      channel.unsubscribe(); channel.destroy();
      scServer.exchange.publish(
        channelToEmit,
        { id: socket.id, type: 'DISCONNECTED' }
      );
    });
  });
};