index.js

'use strict';
var _ = require('lodash');
var jsonServer = require('json-server');
var utils = require('gulp-util');
var fs = require('fs');

var GulpJsonServer = function(options){
	this.server = null;
	this.instance = null;
	this.router = null;
	this.serverStarted = false;

	this.options = {
		data: 'db.json',
		port: 3000,
		rewriteRules: null,
		baseUrl: null,
		id: 'id',
		deferredStart: false,
		static: null
	};
	_.assign(this.options, options || {});

	this.start = function () {
		if(this.serverStarted){
			utils.log('JSON server already started');
			return this.instance;
		}

		var server = jsonServer.create();
		if (this.options.static) {
			server.use(jsonServer.defaults({static: this.options.static}));
		} else {
			server.use(jsonServer.defaults());
		}

		if(this.options.rewriteRules){
			server.use(jsonServer.rewriter(this.options.rewriteRules));
		}

		var router = jsonServer.router(this.options.data);
		if(this.options.baseUrl) {
			server.use(this.options.baseUrl, router);
		}
		else{
			server.use(router);
		}

		if(this.options.id){
			router.db._.id = this.options.id;
		}

		this.server = server;
		this.router = router;
		this.instance = server.listen(this.options.port);
		this.serverStarted = true;

		return this.instance;
	};

	var ensureServerStarted = function(){
		if(this.instance === null){
			throw 'JSON server not started';
		}
	}.bind(this);

	this.kill = function(){
		ensureServerStarted();
		this.instance.close();
	};

	this.reload = function(data){
		ensureServerStarted();

		var isDataFile = typeof this.options.data === 'string';
		var newDb = null;

		if(typeof(data) === 'undefined'){
			if(!isDataFile){
				// serving in-memory DB, exit without changes
				return;
			}

			utils.log('reload from default file', utils.colors.yellow(this.options.data));
			newDb = JSON.parse(fs.readFileSync(this.options.data));
		}
		else if(data !== null){
			if(typeof data === 'string'){
				// attempt to reload file
				utils.log('reload from file', utils.colors.yellow(data));
				newDb = JSON.parse(fs.readFileSync(data));
			}
			else{
				// passed new DB object, store it
				utils.log('reload from object');
				newDb = data;
			}
		}

		if(newDb === null){
			throw 'No valid data passed for reloading. You should pass either data file path or new DB in-memory object';
		}

		this.router.db.object = newDb;
		utils.log(utils.colors.magenta('server reloaded'));
	};

	// ==== Initialization ====
	if(!this.options.deferredStart){
		this.start();
	}
};


module.exports = {
	start: function(options){
		return new GulpJsonServer(options);
	}
};