index.js

'use strict';

var path = require('path');
var cmp = require('semver-compare');
var watchr = require('watchr');
var bodyParser = require('body-parser');
var query = require('connect-query');
var cookieParser = require('cookie-parser');

var mockMiddleware = require('./lib/mockMiddleware');
var fetchConfFile = require('./lib/fetchConfFile');
var fetchRules = require('./lib/fetchRules');
var requireUncached = require('./lib/util/fs').requireUncached;
var logMockError = require('./lib/util/log').logMockError;
var store = require('./lib/store');

var isConfFileHandled = false;

module.exports = {
    config: function(options, cwd) {
        return {
            modifyWebpackConfig: function(config) {
                var self = this;

                var isStartingServer = process.argv[2] === 's' || process.argv[2] === 'server';
                var mockingDisabled = process.argv.some(function(param) {
                    return param.split('=').length > 1 && param.split('=')[0] === 'mock' && param.split('=')[1] === 'false'
                })
                if (self.env !== 'local' || !isStartingServer || mockingDisabled) {
                    return config;
                }

                if (!isConfFileHandled) {
                    isConfFileHandled = true;

                    if (!global.ykitVer || !cmp(global.ykitVer, '0.4.1')) {
                        return logWarn('ykit-config-mock only supports ykit version >= 0.5.0');
                    }

                    try {
                        var confFile = fetchConfFile.bind(self)(options.confPath);
                        store.set('rules', fetchRules.bind(self)(confFile));
                        store.set('confFileDir', path.dirname(confFile));

                        // Create the stalker for the mock config file
                        var stalker = watchr.create(confFile)
                        stalker.on('change', function(changeType) {
                            if (changeType === 'update') {
                                store.set('rules', fetchRules.bind(self)(confFile, true));
                            }
                        });
                        stalker.setConfig({catchupDelay: 500});
                        stalker.watch(function() {});
                    } catch (e) {
                        logError(e.stack);
                    }
                }

                // add middlewares
                self.applyMiddleware(query(), {global: true})
                self.applyMiddleware(cookieParser(), {global: true})
                self.applyMiddleware(bodyParser.urlencoded({extended: false}), {global: true})
                self.applyMiddleware(bodyParser.json(), {global: true})
                self.applyMiddleware(mockMiddleware.bind(self), {global: true});

                return config;
            }
        }
    }
}