app.js

/**
 * Module dependencies.
 */

var express = require('express')
  , http = require('http')
  , io = require('socket.io');

var app = module.exports = express.createServer()
  , io = io.listen(app);

// realtime 'socket.io' events
io.sockets.on('connection', function (socket) {
  socket.emit('news', { hello: 'world' });
  socket.on('my other event', function (data) {
    console.log(data);
  });
});

// Custom Headers: CORS Middleware
var allowCrossDomain = function(req, res, next) {
  res.header('Access-Control-Allow-Origin', '*');
  res.header('Access-Control-Allow-Methods', 'GET,PUT,POST,DELETE');
  res.header('Access-Control-Allow-Headers', 'Content-Type');

  next();
}

// Configuration

app.configure(function(){
  app.set('views', __dirname + '/views');
  app.set('view engine', 'jade');
  app.use(express.bodyParser());
  app.use(express.methodOverride());
  app.use(express.logger({ format: ':method :url :response-time' }));
  app.use(require('stylus').middleware({ src: __dirname + '/public' }));
  app.use(express.cookieParser());
  app.use(express.session({ secret: "keyboard cat" }));
  app.use(allowCrossDomain);
  app.use(app.router);
  app.use(express.static(__dirname + '/public'));
});

app.configure('development', function(){
  app.use(express.errorHandler({ dumpExceptions: true, showStack: true })); 
});

app.configure('production', function(){
  app.use(express.errorHandler()); 
});

// Models
var AffiliateModel = require('./models/affiliate-model.js').AffiliateModel
  , CounterModel = require('./models/counter-model.js').CounterModel;

var affiliateModel = new AffiliateModel(process.env.MONGOHQ_URL)
  , counterModel = new CounterModel(process.env.MONGOHQ_URL);

// Services
var UserSvc = require('./models/user-model.js').UserSvc(process.env.MONGOHQ_URL);
var DealSvc = require('./models/deal-model.js').DealSvc(process.env.MONGOHQ_URL);

// CONNECTING TO SQB
var WorkspaceSvc = require('./models/workspace-model.js').WorkspaceSvc('http://172.21.4.177:8060/workspace/Workspace');
var UserPfmSvc = require('./models/userpfm-model.js').UserPfmSvc('http://172.21.4.157:8080/user/User');
var EncryptionSvc = require('./models/encryption-model.js').EncryptionSvc('http://172.21.4.158:8090/rbl/YsiEncryption');

// CONNECTING TO SFORCE
var SforceSvc = require('./models/sforce-model.js').SforceSvc('https://na12.salesforce.com');

// Routes
// Enforce Session To Be populated with userId at all times
app.all('/app/*', function (req, res, next) {
  if ( ( !req.session.userId || !req.session.accountId ) 
       && req.params != 'login' && req.params != 'account/create' 
       && req.params != 'api/userfm/login' && req.params != 'workspace' ) {
    res.redirect('/app/login');
  }
  else {
    next();
  }
});

/*****************************************************************************
 * YouSendIt Workspace API
 *****************************************************************************/
app.get('/app/workspace', function (req, res) {
  console.log("sforce_sid=%s",req.param("sforce_sid"));
  SforceSvc.getUserDetails({ sforce_sid: req.param("sforce_sid") }, function(err, user_rec) {
    console.log("err: %s, user_rec: %s",err,user_rec);
    if ( err ) {
      res.send({ error: err });
      return;
    }
    // 1. if link user record exists in PFM, Mongo
    //    a. fetch workspace info
    // 2. link user record to PFM, persist in Mongo
    //    do 1.a
    res.send({ user_details: user_rec });
  });
});

app.get('/api/workspace', function (req, res) {
  UserPfmSvc.getUserDetails({sessionId: req.param('sessionId')}, function (err, session_params) {
    if ( err ) {
      console.log(err);
      res.send({error: err});
      return;
    }
    var data_in = {};
    data_in.ownerId = session_params.defaultUserAcctId;
    data_in.ownerType = '1';
    if ( session_params.version === 'v2' ) {
      data_in.ownerId = session_params.userId;
      data_in.ownerType = '2';
    }
    
    WorkspaceSvc.getWorkSpace(data_in, function (err1, data_out) {
      if ( err1 ) {
        console.log(err1);
        res.send({error: err1});
        return;
      }
      res.send(data_out);
    });
  });
});

app.post('/api/userpfm/login', function(req, res) {
  var input = req.body;

  // encode the password; then login
  EncryptionSvc.encodeData({ value: input.password}, function (err, out) {
    if ( err || !out.encodeData ) {
      var msg = "error encoding value, error["+err+"]";
      console.log(msg);
      res.send({error: msg}); 
      return;
    }
    input.password = out.encodeData;
    UserPfmSvc.login(input, function (error, output) {
      if ( error ) {
        var msg = "error encoding value, error["+err+"]";
        console.log(msg);
        res.send({error: msg});
        return;
      }
      console.log("successfully logged in! %s",JSON.stringify(output));
      var ret = { 
          sessionId: output["sessionGuidRo"]
      };

      res.send(ret);
    });
  });

});
/*****************************************************************************
 * AFFILIATES manager app & relevant api                                     *
 *****************************************************************************/
// main 'app' page
app.get('/app/affiliate/list', function(req, res){
  console.log("trying to find all affiliates for accountId: %s",req.session.accountId);
  affiliateModel.findAll(req.session.accountId, function(err, affiliates){
    if ( err ) {
      res.send("error calling /affiliate/all: "+err);
      return;
    }
    res.render('index.jade', {locals: {title: 'Pixel Container', affiliates: affiliates}});
  });
});

app.get('/app/affiliate/:id', function(req, res) {
  console.info("details of affiliate: %s",req.params.id);

  if ( req.params.id == 'create' ) {
    res.render('affiliate_new.jade', { locals: { title: 'Add Affiliate' } });
    return;
  }

  affiliateModel.findById({ affiliate_id: req.params.id, account_id: req.session.accountId} , function(err, affiliate){
    if ( err ) {
      console.log("error finding affiliate: %s!!",req.params.id);
      res.send("unable to find affiliate: "+req.params.id);
    }
    else res.render('affiliate_show.jade', { 
      locals: {
        title: "Edit Affiliate",
        affiliate: affiliate
      }
    });
  });
});

// get a list of affiliates
app.get('/api/affiliate/:id', function(req, res, next) {
  UserSvc.validateSession(req.param('sessionId'),function (err, accountId) {
    if ( err ) {
      console.log("error validating session: %s error: %s", req.param('sessionId'),err);
      res.send({error: "invalid session"});
      return;
    } 
    if ( req.params.id == 'create' ) { 
      next(); 
    }
    else if ( req.params.id == 'list' ) {
      console.info("trying to find affiliate: %s",req.params.id);
      affiliateModel.findAll(accountId,function(error, affiliates){
        if ( error ) {
          console.error("error getting affiliates");
          res.send({error: "error getting affiliates"});
        }
        res.send(affiliates);
      });
    } else {
      affiliateModel.findById({ affiliate_id: req.params.id, account_id: accountId }, function(error, affiliates) {
        if ( error ) {
          console.error("error finding affiliate: %s!!",req.params.id);
          res.send({ error: "error finding affiliate"});
        }
        res.send(affiliates);
      });
    }
  });
});

// read from form, and update the data record
app.post('/app/affiliate/create', function(req, res){
  var data = {
      name: req.param('name')
    , account_id: req.session.accountId
    , website: req.param('website')
    , created_by: req.param('created_by')
    , description: req.param('description')
  };
  console.info("creating new affiliate: %s",JSON.stringify(data));

  affiliateModel.save( data, function( err, affiliate_id ) {
    if ( err ) {
      var msg = 'failed creating affiliate: '+err+'';
      console.log(msg);
      res.send(msg);
      return;
    }
    console.log("created affiliate: %s",affiliate_id);
    res.redirect('/app/affiliate/list'); // goto main app page; which shows affiliate list
  });
});

app.post('/api/affiliate/create', function(req, res){
  UserSvc.validateSession(req.param('sessionId'),function (err, accountId) {
    if ( err ) {
      console.log("error validating session: %s error: %s", req.param('sessionId'),err);
      res.send({error: "invalid session"});
      return;
    }
    req.body.account_id = accountId;
    console.info("saving affiliate: %s",JSON.stringify(req.body));
    affiliateModel.save( req.body, function( error, affiliate_id ) {
      if ( error ) {
        console.log("error saving affiliate");
        res.send({ error: "error saving affiliate"});
      }
      res.send({affiliate_id: affiliate_id});
    });
  });
});

// add affiliate[API]
app.post('/app/affiliate/api/create', function(req, res) {
  var data = {
      affiliate_id: req.param('_id')
    , url: req.param('url')
    , account_id: req.session.accountId
    , webpage: req.param('webpage')
    , created_by: req.param('user')
    , updated_by: req.param('user')
  };

  affiliateModel.addApi(data.affiliate_id, data, function (err) {
    if ( err ) console.log("unable to save api: "+req.param('url'));
    res.redirect('/app/affiliate/' + req.param('_id'));
  });
});

app.post('/api/affiliate/api/create', function(req, res) {
  UserSvc.validateSession(req.param('sessionId'),function (err, accountId) {
    if ( err ) {
      console.log("error validating session: %s error: %s", req.param('sessionId'),err);
      res.send({error: "invalid session"});
      return;
    }
    console.info(req.body);
    affiliateModel.addApi(req.body.affiliate_id, {
        url: req.body.url
      , webpage: req.body.webpage
      , account_id: accountId
      , created_by: req.body.user
      , updated_by: req.body.user
    } , function( error, api_id ) {
      if ( error ) {
        console.error("unable to save api: %s",req.body.url);
        res.send({ error: "unable to add api" });
        return;
      }
      res.send({ api_id: api_id});
    });
  });
});

// lookup affiliates by webpage
app.get('/api/affiliate/webpage/:id', function(req, res) {
  UserSvc.validateSession(req.param('sessionId'),function (err, accountId) {
    if ( err ) {
      console.log("error validating session: %s error: %s", req.param('sessionId'),err);
      res.send({error: "invalid session"});
      return;
    }
    console.info(req.params.id);
    affiliateModel.getAffiliateApi({ webpage: req.params.id, account_id: accountId}, function(error, urls) {
      if ( error ) {
        console.log("unable to fetch any affiliates for webpage: "+req.params.id);
        urls = [];
      }
      else {
        if ( typeof(urls.length)=="undefined" ) urls = [urls];
        // fire and forget call for tracking
        for (var i=0;i<urls.length;i++) 
          counterModel.save({name: urls[i].url, type: urls[i].webpage, subtype: ""},null);
      }
      res.send(urls);
    });
  });
});

/*****************************************************************************
 * DEALS                                                                     *
 *****************************************************************************/

function execSvc(req, res, cb_svc) {
  UserSvc.validateSession(req.param('sessionId'), function (err, account_id) {
    if ( err ) {
      console.log(err.msg);
      res.send({error: err.msg});
      return;
    }
    var data_in = req.body?req.body:{};
    data_in.account_id = account_id;
    cb_svc(data_in, function (error, data_out) {
      if ( error ) {
        console.log(error.msg);
        res.send({error: error.msg});
        return;
      }
      res.send(data_out);
    });
  });
};

// create customer
app.post('/api/deal/createCustomer', function(req,res) {
  execSvc(req, res, DealSvc.createCustomer);
});

// customer adds a deal
app.post('/api/deal/add', function(req,res) {
  execSvc(req, res, DealSvc.addDeal);
});

// deals available to *customer's* customers
app.get('/app/deal/finder', function(req,res) {
  res.render('dealfinder.jade', {locals: {title: 'Find Me Some Deals!!'}});
});

/*****************************************************************************
 * ACCOUNTS                                                                  *
 *****************************************************************************/
// create a new account
app.get('/app/account/create', function(req, res){
  res.render('account_create.jade', { title: 'Create Account' });
});

app.post('/app/account/create', function(req, res) {
  var data = { 
      acct_name: req.param('acct_name')
    , acct_description: req.param('acct_description')
    , identity: req.param('identity')
    , name: req.param('name')
    , email: req.param('email')
    , passwd: req.param('passwd')
    , owa_url: req.param('owa_url')
  };

  console.info("creating account: %s",JSON.stringify(data));

  UserSvc.createAccount( data, function (error, userId) {
    if ( error === null ) console.log('error: %s',error);
    res.redirect("/app/login");
  });

});

app.post('/api/account/create', function(req, res) {
  console.log(req.body);
  var data = req.body;

  UserSvc.createAccount( data, function (error, userId) {
    if ( error ) {
      console.log("error saving account: "+req.param('acct_name'));
      res.send({ error: "error saving account" });
    }
    else {
      console.log("succesfully saved account: %s user: %s",req.param('acct_name'),userId);
      res.send({user: userId});
    }
  });
});

// login
app.get('/', function(req, res){
  res.render('login.jade', { title: 'Login' });
});

app.get('/app/login', function(req, res){
  res.render('login.jade', { title: 'Login' });
});

app.post('/app/login', function(req, res){
  var data = { email: req.param('email') , password: req.param('password') };
  //console.info("logging into: %s",JSON.stringify(data));

  UserSvc.login(data, function (error, doc) {
    if ( error ) {
      console.log("unable to login user");
      res.send("unable to login user: "+req.param('email')+" error: "+error);
      return;
    }
    for (var x in doc) req.session[x] = doc[x];
    console.log("logged in userId:%s accountId:%s sessionId:%s",req.session['userId'],req.session['accountId'],req.session['sessionId']);
    console.log("redirecting to /app/affiliate/list");
    res.redirect('/app/affiliate/list');
  });
});

app.post('/api/login', function(req, res) {
  console.info(req.body);
  var input = req.body;

  UserSvc.login(input, function (error, output) {
    if ( error ) {
      console.log("error logging in error: %s",error);
      res.send({error: "error logging in: "+error+"!"});
    }
    else {
      console.log("successfully logged in! %s",JSON.stringify(output));
      res.send(output);
    }
  });
});


app.listen(process.env.PORT);
console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);