homebrewery/server/brew.data.js

const _ = require('lodash');
const shortid = require('shortid');
const mongoose = require('./db.js').instance;

const Error = require('./error.js');
const utils = require('./utils.js');

const BrewSchema = mongoose.Schema({
	shareId : {type : String, default: shortid.generate, index: { unique: true }},
	editId  : {type : String, default: shortid.generate, index: { unique: true }},

	text : {type : String, default : ""},

	title       : {type : String, default : ""},
	description : {type : String, default : ""},
	tags        : {type : String, default : ""},
	systems     : [String],
	authors     : [String],
	published   : {type : Boolean, default : false},

	createdAt  : { type: Date, default: Date.now },
	updatedAt  : { type: Date, default: Date.now},
	lastViewed : { type: Date, default: Date.now},
	views      : {type:Number, default:0},
	version : {type: Number, default:1}
}, {
	versionKey: false,
	toJSON : {
		transform: (doc, ret, options) => {
			delete ret._id;
			return ret;
		}
	}
});

BrewSchema.index({ title: "text", description: "text" });

BrewSchema.methods.increaseView = function(){
	this.views = this.views + 1;
	return this.save();
};


const Brew = mongoose.model('Brew', BrewSchema);



const BrewData = {
	schema : BrewSchema,
	model  : Brew,

	get : (query) => {
		return Brew.findOne(query).exec()
			.then((brew) => {
				if(!brew) throw Error.noBrew();
				return brew;
			});
	},
	create : (brew) => {
		delete brew.shareId;
		delete brew.editId;
		if(!brew.title) brew.title = utils.getGoodBrewTitle(brew.text);
		return (new Brew(brew)).save();
	},
	update : (editId, newBrew) => {
		return BrewData.get({ editId })
			.then((brew) => {
				delete newBrew.shareId;
				delete newBrew.editId;
				brew = _.merge(brew, newBrew, { updatedAt : Date.now() });

				brew.markModified('authors');
				brew.markModified('systems');
				return brew.save();
			});
	},
	remove : (editId) => {
		return Brew.find({ editId }).remove().exec();
	},
	removeAll : ()=>{
		return Brew.find({}).remove().exec();
	},

	//////// Special

	getByShare : (shareId) => {
		return BrewData.get({ shareId : shareId})
			.then((brew) => {
				brew.increaseView();
				const brewJSON = brew.toJSON();
				delete brewJSON.editId;
				return brewJSON;
			});
	},
	getByEdit : (editId) => {
		return BrewData.get({ editId });
	},

	search : (searchTerms, pagination, sorting, fullAccess = true) => {
		let query = {};
		if(searchTerms){
			query = {$text: {
				//Wrap terms in quots to perform an AND operator
				$search: _.map(searchTerms.split(' '), (term)=>{
					return `\"${term}\"`;
				}).join(' '),
				$caseSensitive : false
			}};
		}

		pagination = _.defaults(pagination, {
			limit : 25,
			page  : 0
		});
		sorting = _.defaults(sorting, {
			'views' : 1
		});
		let filter = {
			//editId : 0,
			text   : 0
		};


		if(!fullAccess){
			filter.editId = 0;
			query.published = false;
		}

		const searchQuery = Brew
			.find(query)
			.sort(sorting)
			.select(filter)
			.limit(pagination.limit)
			.skip(pagination.page * pagination.limit)
			.exec();

		const countQuery = Brew.count(query).exec();

		return Promise.all([searchQuery, countQuery])
			.then((result) => {
				return {
					brews : result[0],
					total : result[1]
				}
			});
	},


};

module.exports = BrewData;