fipamo/brain/data/Book.js

import fh from 'filehound';
import fs from 'fs-extra';
import metadataParser from 'markdown-yaml-metadata-parser';
import _ from 'lodash';
import * as DataEvent from '../../src/com/events/DataEvent';
import Navigation from './Navigation';
import Settings from './Settings';
import StringUtils from '../../src/com/utils/StringUtils';
import Render from './Render';
const moment = require('moment');
const nav = new Navigation();
const settings = new Settings();
const utils = new StringUtils();
const render = new Render();

/**
 *  Class for handling blog content pages
 */

export default class Book {
	//--------------------------
	// constructor
	//--------------------------
	constructor() {}
	//--------------------------
	// methods
	//--------------------------
	start() {}
	/**
	 * Retrieves single page or pages
	 * @parameter id: optional id if requesting a single Page
	 */
	getPage(id) {
		var self = this;
		return new Promise((resolve, reject) => {
			fh.create()
				.paths('content/pages')
				.ext('md')
				.find()
				.then(files => {
					let pages = [];
					for (let index = 0; index < files.length; index++) {
						fs.readFile(files[index], { encoding: 'utf8' }, (err, file) => {
							pages.push(metadataParser(file));
						});
					}
					if (id === null || id === null || id === undefined) {
						setTimeout(() => {
							//TODO: Duct tape solution until something better created
							self.organizeTags(pages);
							resolve(pages);
						}, 100);
					} else {
						setTimeout(() => {
							//TODO: Duct tape solution until something better created
							let page = _.find(pages, list => {
								return list.metadata.uuid === id;
							});
							resolve(page);
						}, 100);
					}
				})
				.catch(err => {
					reject(err);
				});
		});
	}
	/**
	 * Edits single page based on id and task
	 * @parameter body: object that contains all page information
	 * @parameter id: identifier for page being edited
	 * @parameter task: type of task being performed - listed in DataEvents Class
	 * @parameter user: object containin user information
	 */
	editPage(body, id, task, user) {
		return new Promise((resolve, reject) => {
			let self = this;
			let response = [];
			switch (task) {
				case DataEvent.API_PAGE_CREATE:
				case DataEvent.API_PAGE_WRITE:
					var pageWrite =
						'---\n' +
						'id: ' +
						body.id +
						'\n' +
						'uuid: ' +
						body.uuid +
						'\n' +
						'title: ' +
						body.title +
						'\n' +
						'feature: ' +
						body.feature +
						'\n' +
						'layout: ' +
						'page' +
						'\n' +
						'tags: ' +
						body.tags +
						'\n' +
						'author: ' +
						user.handle +
						'\n' +
						'created: ' +
						moment(body.created).format() +
						'\n' +
						'updated: ' +
						moment(Date.now()).format() +
						'\n' +
						'deleted: ' +
						body.deleted +
						'\n' +
						'menu: ' +
						body.menu +
						'\n' +
						'featured: ' +
						body.featured +
						'\n' +
						'published: ' +
						body.published +
						'\n' +
						'slug: ' +
						body.slug +
						'\n' +
						'---\n' +
						body.content;
					fs.writeFile('content/pages/' + body.slug + '.md', pageWrite, err => {
						// throws an error, you could also catch it here

						if (err) {
							response = { type: DataEvent.PAGE_ERROR, message: err };
							reject(response);
						}

						// success case, the file was saved
						if (task === DataEvent.API_PAGE_CREATE) {
							// if new file, update settings index and page count
							response = {
								type: DataEvent.PAGE_ADDED,
								message: 'New Page Created',
								id: body.page_uuid
							};
						} else {
							response = {
								type: DataEvent.PAGE_UPDATED,
								message: 'Page saved. Nice Work'
							};
							resolve(response);
						}
					});
					break;
				case DataEvent.API_PAGE_DELETE:
					this.getPage(id)
						.then(page => {
							let body = _.mapValues(page.metadata);
							body.content = page.content;
							body.deleted = moment(Date.now()).format();
							self.editPage(body, body.uuid, DataEvent.API_PAGE_WRITE, user)
								.then(() => {
									let item = {
										title: body.title,
										id: body.id,
										slug: body.slug,
										uuid: body.uuid
									};
									nav.editMenu(DataEvent.MENU_DELETE_ITEM, item);
									response = {
										type: DataEvent.PAGE_DELETED,
										message: 'Page deleted, sport',
										data: { uuid: body.uuid }
									};
									resolve(response);
								})
								.catch(err => {
									response = { type: DataEvent.PAGE_ERROR, message: err };
									reject(response);
								});
						})
						.catch(err => {
							response = { type: DataEvent.PAGE_ERROR, message: err };
							reject(response);
						});
					break;
			}
		});
	}
	/**
	 * Retrieves single page or pages
	 * @parameter pages: payload of pages
	 */

	organizeTags(pages) {
		let tags = [];
		for (let index = 0; index < pages.length; index++) {
			const page = pages[index];
			let temp = [];
			temp = page.metadata.tags.split(',');
			for (let i = 0; i < temp.length; i++) {
				let label = temp[i].trim();
				if (!_.find(tags, { tag_name: label })) {
					tags.push({
						tag_name: label,
						slug: utils.cleanString(label),
						count: 1
					});
				} else {
					_.find(tags, { tag_name: label }).count++;
				}
			}
		}
		tags = _.orderBy(tags, ['tag_name'], ['asc']);
		settings.saveTags(tags).then(response => {
			console.log('RESPONSE', response);
			render
				.publishTags(pages)
				.then(response => {
					console.log(response);
				})
				.catch(err => {
					console.log(err);
				});
		});
	}

	//--------------------------
	// event handlers
	//--------------------------
}