app.js 4.59 KB
/**
 * yohobuy app
 * @author: xuqi<qi.xu@yoho.cn>
 * @date: 2016/4/25
 */
'use strict';

const config = require('./config/common');

// use one apm
if (config.useOneapm) {
    require('oneapm');
}

const _ = require('lodash');
const express = require('express');
const path = require('path');
const bodyParser = require('body-parser');
const cookieParser = require('cookie-parser');
const favicon = require('serve-favicon');
const CookieSession = require('client-sessions');
const MemcachedSession = require('yoho-express-session');
const memcached = require('connect-memcached');
const MemcachedStore = memcached(MemcachedSession);
const hbs = require('express-handlebars');
const multer = require('connect-multiparty');
const pkg = require('./package.json');
const yohoLib = require('yoho-node-lib');
const helpersHbs = require('./utils/helpers');

const app = express();

// 全局注册library
yohoLib.global(config);

global.middleware = path.resolve('./doraemon/middleware');
global.utils = path.resolve('./utils');

// 向模板注入变量
app.locals.devEnv = app.get('env') === 'development';
app.locals.version = pkg.version;

app.set('view engine', '.hbs');
app.set('views', './doraemon/views');
app.engine('.hbs', hbs({
    extname: '.hbs',
    defaultLayout: 'layout',
    layoutsDir: './doraemon/views',
    partialsDir: './doraemon/views/partial',
    helpers: Object.assign(global.yoho.helpers, helpersHbs)
}));

app.use(favicon(path.join(__dirname, '/public/favicon.ico')));
app.use(express.static(path.join(__dirname, 'public')));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
app.use(cookieParser());
app.use(multer());

app.use(MemcachedSession({  // eslint-disable-line
    proxy: true,
    resave: false,
    saveUninitialized: true,
    unset: 'destroy',
    secret: '82dd7e724f2c6870472c89dfa43cf48d',
    name: 'yohoblk-session',
    cookie: {
        domain: 'yohoblk.com',
        httpOnly: false
    },
    store: new MemcachedStore({
        hosts: config.memcache.session,
        prefix: 'yohoblk-session:',
        reconnect: 5000,
        timeout: 1000,
        retries: 0
    })
}));

app.use(CookieSession({ // eslint-disable-line
    requestKey: 'session2',
    cookieName: 'yohoblk-session',
    secret: '82dd7e724f2c6870472c89dfa43cf48d',
    cookie: {
        domain: config.cookieDomain,
        ephemeral: true
    }
}));
app.use((req, res, next) => {
    if (req.session) {
        let sessionKeys = Object.keys(req.session || {});
        let backSessionKeys = Object.keys(req.session2.sessionBack || {});

        if (backSessionKeys.length > sessionKeys.length) {
            let differences = _.difference(backSessionKeys, sessionKeys);

            _.forEach(differences, d => {
                req.session[d] = req.session2.sessionBack[d];
            });
        }
        req.session2.sessionBack = req.session;
    } else {
        req.session = new MemcachedSession.Session(req);
        req.session.cookie = new MemcachedSession.Cookie({
            domain: 'yohoblk.com',
            httpOnly: false
        });
        req.session = _.assign(req.session, req.session2.sessionBack);
    }

    if (typeof req.session.reset !== 'function') {
        req.session.reset = function() {
            req.session = null;
            req.session2.reset();
        };
    }
    next();
});
app.use((req, res, next) => {
    req.user = {}; // 全局的用户数据
    req.yoho = {}; // req和res绑定yoho对象,用于传递全局数据, 如req.yoho.channel等

    if (!req.session) {
        req.session = {};
    }
    next();
});

const logger = global.yoho.logger;

// dispatcher
try {
    const mobileCheck = require(`${global.middleware}/mobile-check`);
    const user = require(`${global.middleware}/user`);
    const seo = require(`${global.middleware}/seo`);
    const setYohoData = require(`${global.middleware}/set-yoho-data`);

    const errorHanlder = require(`${global.middleware}/error-handler`);
    const setPageInfo = require(`${global.middleware}/set-pageinfo`);
    const display = require(`${global.middleware}/display`);
    const safeRedirect = require(`${global.middleware}/safe-redirect`).middleware;

    // YOHO 前置中间件
    app.use(mobileCheck());
    app.use(setYohoData());
    app.use(safeRedirect());
    app.use(user());
    app.use(seo());
    app.use(setPageInfo());
    app.use(display());

    require('./dispatch')(app);

    app.all('*', errorHanlder.notFound()); // 404

    // YOHO 后置中间件
    app.use(errorHanlder.serverError());
} catch (err) {
    logger.error(err);
}

// listener
app.listen(config.port, function() {
    logger.info('yohoblk start');
});