app.js

/**
 * created by maning
 */
var express = require('express')
  , mongodb = require('mongodb')
  , bodyParser = require('body-parser')
  , cookieParser = require('cookie-parser')
  , session = require('express-session');
  // get the IP and PM2.5
  
  var logInfos = require('./public/modules/module_getIpAndPm25');
  var logInfo = logInfos.getIpAndPm25();

  // get the products from Tmall
  var products = require('./public/modules/module_getProudctTmall');
  var productList = products.getProduct();

/**
 * create the app
 */
app = express();

/**
 * set view item
 */
app.set('view engine', 'jade');

/**
 * set static path
 */
app.use(express.static('views'));
app.use(express.static('public'));

/**
 * set the middleware
 */
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(cookieParser());
app.use(session({
    resave: false,
    saveUninitialized: true,
    secret : 'my secret'
}));

/**
 * authenticated check
 */
app.use(function (req, res, next) {
  if (req.session.loggedIn) {
    var objectID = mongodb.ObjectID;
    res.locals.authenticated = true;
    app.users.findOne({ _id: objectID(req.session.loggedIn) }, function (err, doc) {
      if (err) return next(err);
      res.locals.me = doc;
      next();
    });
  } else {
    res.locals.authenticated = false;
    next();
  }
});

/**
 * default route
 */
app.get('/', function (req, res) {
  res.locals.loggedCity = logInfo.loggedCity;
  res.locals.loggedPm25 = logInfo.loggedPm25;
  res.locals.productList = productList;
  res.render('index');
});

/**
 * login route
 */
 app.get('/login', function (req, res) {
  res.render('login');
});

 /**
 * logined route
 */
app.get('/login/:signupEmail', function (req, res) {
    res.render('login', { signupEmail : req.params.signupEmail });
});

/**
 * login post route
 */
app.post('/login', function (req, res) {
  app.users.findOne({ email : req.body.user.email, password : req.body.user.password },
    function (err, doc) {
      if (err) return next(err);
      if (!doc) return res.send('<p>User not found. Go back and try again.</p>');
      req.session.loggedIn = doc._id.toString();
      res.redirect('/');
    });
});

/**
 * signup route
 */
app.get('/signup', function (req, res) {
  res.render('signup');
});

/**
 * signup post route
 */
app.post('/signup', function (req, res, next) {
  app.users.insertOne(req.body.user, function (err, doc) {
    if (err) return next(err);
    res.redirect('/login/' + doc.ops[0].email);
  })
});

/**
 * logout route
 */
app.get('/logout', function (req, res) {
  req.session.loggedIn = null;
  res.redirect('/');
});

/**
 * connect to db
 */
var MongoClient = mongodb.MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/test';

MongoClient.connect(DB_CONN_STR, function(err, db) {
  if (err) throw err;
  app.users = db.collection('maning');
  console.log('\033[96m + \033[39m connected to mongodb');

  db.ensureIndex('users', 'email', function (err) {
    if (err) throw err;
    db.ensureIndex('users', 'email', function (err) {
      if (err) throw err;
      console.log('\033[96m + \033[39m ensered indexes');
    });
  });
});

/**
 * listener
 */
app.listen(3000);