var Post, Posts, _ = require('underscore'), uuid = require('node-uuid'), when = require('when'), errors = require('../errorHandling'), Showdown = require('showdown'), github = require('../../shared/vendor/showdown/extensions/github'), converter = new Showdown.converter({extensions: [github]}), User = require('./user').User, config = require('../../../config'), Tag = require('./tag').Tag, Tags = require('./tag').Tags, GhostBookshelf = require('./base'); Post = GhostBookshelf.Model.extend({ tableName: 'posts', permittedAttributes: [ 'id', 'uuid', 'title', 'slug', 'markdown', 'html', 'meta_title', 'meta_description', 'featured', 'image', 'status', 'language', 'author_id', 'created_at', 'created_by', 'updated_at', 'updated_by', 'published_at', 'published_by' ], defaults: function () { return { uuid: uuid.v4(), status: 'draft' }; }, initialize: function () { this.on('creating', this.creating, this); this.on('saving', this.updateTags, this); this.on('saving', this.saving, this); this.on('saving', this.validate, this); }, validate: function () { GhostBookshelf.validator.check(this.get('title'), "Post title cannot be blank").notEmpty(); return true; }, saving: function () { var self = this; // Remove any properties which don't belong on the post model this.attributes = this.pick(this.permittedAttributes); this.set('html', converter.makeHtml(this.get('markdown'))); this.set('title', this.get('title').trim()); if (this.hasChanged('status') && this.get('status') === 'published') { if (!this.get('published_at')) { this.set('published_at', new Date()); } // This will need to go elsewhere in the API layer. this.set('published_by', 1); } GhostBookshelf.Model.prototype.saving.call(this); if (this.hasChanged('slug')) { // Pass the new slug through the generator to strip illegal characters, detect duplicates return this.generateSlug(Post, this.get('slug')) .then(function (slug) { self.set({slug: slug}); }); } }, creating: function () { // set any dynamic default properties var self = this; if (!this.get('author_id')) { this.set('author_id', 1); } GhostBookshelf.Model.prototype.creating.call(this); if (!this.get('slug')) { // Generating a slug requires a db call to look for conflicting slugs return this.generateSlug(Post, this.get('title')) .then(function (slug) { self.set({slug: slug}); }); } }, updateTags: function (newTags) { var self = this; if (newTags === this) { newTags = this.get('tags'); } if (!newTags || !this.id) { return; } return Post.forge({id: this.id}).fetch({withRelated: ['tags']}).then(function (thisPostWithTags) { var existingTags = thisPostWithTags.related('tags').toJSON(), tagOperations = [], tagsToDetach = [], tagsToAttach = []; // First find any tags which have been removed _.each(existingTags, function (existingTag) { if (!_.some(newTags, function (newTag) { return newTag.name === existingTag.name; })) { tagsToDetach.push(existingTag.id); } }); if (tagsToDetach.length > 0) { tagOperations.push(self.tags().detach(tagsToDetach)); } // Next check if new tags are all exactly the same as what is set on the model _.each(newTags, function (newTag) { if (!_.some(existingTags, function (existingTag) { return newTag.name === existingTag.name; })) { // newTag isn't on this post yet tagsToAttach.push(newTag); } }); if (tagsToAttach) { return Tags.forge().query('whereIn', 'name', _.pluck(tagsToAttach, 'name')).fetch().then(function (matchingTags) { _.each(matchingTags.toJSON(), function (matchingTag) { tagOperations.push(self.tags().attach(matchingTag.id)); tagsToAttach = _.reject(tagsToAttach, function (tagToAttach) { return tagToAttach.name === matchingTag.name; }); }); _.each(tagsToAttach, function (tagToCreateAndAttach) { var createAndAttachOperation = Tag.add({name: tagToCreateAndAttach.name}).then(function (createdTag) { return self.tags().attach(createdTag.id, createdTag.name); }); tagOperations.push(createAndAttachOperation); }); return when.all(tagOperations); }); } return when.all(tagOperations); }); }, // Relations user: function () { return this.belongsTo(User, 'created_by'); }, author: function () { return this.belongsTo(User, 'author_id'); }, tags: function () { return this.belongsToMany(Tag); } }, { // #### findAll // Extends base model findAll to eager-fetch author and user relationships. findAll: function (options) { options = options || {}; options.withRelated = [ 'author', 'user', 'tags' ]; return GhostBookshelf.Model.findAll.call(this, options); }, // #### findOne // Extends base model findOne to eager-fetch author and user relationships. findOne: function (args, options) { options = options || {}; options.withRelated = [ 'author', 'user', 'tags' ]; return GhostBookshelf.Model.findOne.call(this, args, options); }, // #### findPage // Find results by page - returns an object containing the // information about the request (page, limit), along with the // info needed for pagination (pages, total). // **response:** // { // posts: [ // {...}, {...}, {...} // ], // page: __, // limit: __, // pages: __, // total: __ // } /* * @params opts */ findPage: function (opts) { var postCollection; // Allow findPage(n) if (_.isString(opts) || _.isNumber(opts)) { opts = {page: opts}; } opts = _.extend({ page: 1, limit: 15, where: {}, status: 'published', orderBy: ['published_at', 'DESC'] }, opts); postCollection = Posts.forge(); // Unless `all` is passed as an option, filter on // the status provided. if (opts.status !== 'all') { opts.where.status = opts.status; } // If there are where conditionals specified, add those // to the query. if (opts.where) { postCollection.query('where', opts.where); } opts.withRelated = [ 'author', 'user', 'tags' ]; // Set the limit & offset for the query, fetching // with the opts (to specify any eager relations, etc.) // Omitting the `page`, `limit`, `where` just to be sure // aren't used for other purposes. return postCollection .query('limit', opts.limit) .query('offset', opts.limit * (opts.page - 1)) .query('orderBy', opts.orderBy[0], opts.orderBy[1]) .fetch(_.omit(opts, 'page', 'limit', 'where', 'status', 'orderBy')) .then(function (collection) { var qb; // After we're done, we need to figure out what // the limits are for the pagination values. qb = GhostBookshelf.Knex(_.result(collection, 'tableName')); if (opts.where) { qb.where(opts.where); } return qb.count(_.result(collection, 'idAttribute')).then(function (resp) { var totalPosts = resp[0].aggregate, data = { posts: collection.toJSON(), page: parseInt(opts.page, 10), limit: opts.limit, pages: Math.ceil(totalPosts / opts.limit), total: totalPosts }; if (data.pages > 1) { if (data.page === 1) { data.next = data.page + 1; } else if (data.page === data.pages) { data.prev = data.page - 1; } else { data.next = data.page + 1; data.prev = data.page - 1; } } return data; }, errors.logAndThrowError); }, errors.logAndThrowError); }, permissable: function (postModelOrId, userId, action_type, userPermissions) { var self = this, hasPermission, postModel = postModelOrId; // If we passed in an id instead of a model, get the model // then check the permissions if (_.isNumber(postModelOrId) || _.isString(postModelOrId)) { return this.read({id: postModelOrId}).then(function (foundPostModel) { return self.permissable(foundPostModel, userId, action_type, userPermissions); }, errors.logAndThrowError); } // Check if any permissions apply for this user and post. hasPermission = _.any(userPermissions, function (perm) { // Check for matching action type and object type if (perm.get('action_type') !== action_type || perm.get('object_type') !== 'post') { return false; } // If asking whether we can create posts, // and we have a create posts permission then go ahead and say yes if (action_type === 'create' && perm.get('action_type') === action_type) { return true; } // Check for either no object id or a matching one return !perm.get('object_id') || perm.get('object_id') === postModel.id; }); // If this is the author of the post, allow it. // Moved below the permissions checks because there may not be a postModel // in the case like canThis(user).create.post() hasPermission = hasPermission || (postModel && userId === postModel.get('author_id')); // Resolve if we have appropriate permissions if (hasPermission) { return when.resolve(); } // Otherwise, you shall not pass. return when.reject(); }, add: function (newPostData, options) { return GhostBookshelf.Model.add.call(this, newPostData, options).tap(function (post) { // associated models can't be created until the post has an ID, so run this after return post.updateTags(newPostData.tags); }); } }); Posts = GhostBookshelf.Collection.extend({ model: Post }); module.exports = { Post: Post, Posts: Posts };