/** * WHITEBOPHIR SERVER ********************************************************* * @licstart The following is the entire license notice for the * JavaScript code in this page. * * Copyright (C) 2013-2014 Ophir LOJKINE * * * The JavaScript code in this page is free software: you can * redistribute it and/or modify it under the terms of the GNU * General Public License (GNU GPL) as published by the Free Software * Foundation, either version 3 of the License, or (at your option) * any later version. The code is distributed WITHOUT ANY WARRANTY; * without even the implied warranty of MERCHANTABILITY or FITNESS * FOR A PARTICULAR PURPOSE. See the GNU GPL for more details. * * As additional permission under GNU GPL version 3 section 7, you * may distribute non-source (e.g., minimized or compacted) forms of * that code without the copy of the GNU GPL normally required by * section 4, provided you include this license notice and a URL * through which recipients can access the Corresponding Source. * * @licend * @module boardData */ var fs = require('fs'), path = require("path"), util = require("util"), events = require("events"); /** @constant @type {string} @default Path to the file where boards will be saved by default */ var HISTORY_DIR = path.join(__dirname, "../server-data/"); /** @constant @type {Number} @default Number of seconds of inactivity after which the board should be saved to a file */ var SAVE_INTERVAL = 1000 * 2; //Save every 2 seconds of inactivity /** * Represents a board. * @constructor */ var BoardData = function(name) { var that = this; this.name = name; this.board = {}; this.ready = false; this.file = path.join(HISTORY_DIR, "board-" + encodeURIComponent(name) + ".json"); //Loads the file. This will emit the "ready" event this.load(this.file); this.on("ready", function(){ that.ready = true; }); }; //Allows to use BoardData.emit() and BoardData.on() util.inherits(BoardData, events.EventEmitter); /** Adds data to the board */ BoardData.prototype.set = function (id, data) { //KISS this.board[id] = data; this.delaySave(); }; /** Adds a child to an element that is already in the board * @param {string} id - Identifier of the parent element. * @param {object} child - Object containing the the values to update. * @param {boolean} [create=true] - Whether to create an empty parent if it doesn't exist * @returns {boolean} - True if the child was added, else false */ BoardData.prototype.addChild = function (parentId, child, create) { if (create===undefined) create = true; var obj = this.board[parentId]; if (typeof obj !== "object") { if (create) obj = this.board[parentId] = {}; else return false; } if (Array.isArray(obj._children)) obj._children.push(child); else obj._children = [child]; this.delaySave(); return true; }; /** Update the data in the board * @param {string} id - Identifier of the data to update. * @param {object} data - Object containing the the values to update. * @param {boolean} create - True if the object should be created if it's not currently in the DB. */ BoardData.prototype.update = function (id, data, create) { var obj = this.board[id]; if (typeof obj === "object") { for (var i in data) { obj[i] = data[i]; } } else if (create || obj !== undefined) { this.board[id] = data; } this.delaySave(); }; /** Removes data from the board * @param {string} id - Identifier of the data to delete. */ BoardData.prototype.delete = function (id) { //KISS delete this.board[id]; this.delaySave(); }; /** Reads data from the board * @param {string} id - Identifier of the element to get. * @returns {object} The element with the given id, or undefined if no element has this id */ BoardData.prototype.get = function (id, children) { return this.board[id]; }; /** Reads data from the board * @param {string} [id] - Identifier of the first element to get. * @param {BoardData~processData} callback - Function to be called with each piece of data read */ BoardData.prototype.getAll = function (id, callback) { if (!callback) callback = id; for (var i in this.board) { if (!id || i > id) { callback(this.board[i]); } } }; /** * This callback is displayed as part of the BoardData class. * Describes a function that processes data that comes from the board * @callback BoardData~processData * @param {object} data */ /** Delays the triggering of auto-save by SAVE_INTERVAL seconds */ BoardData.prototype.delaySave = function (file) { if (this.saveTimeoutId !== undefined) clearTimeout(this.saveTimeoutId); var that = this; this.saveTimeoutId = setTimeout(function(){that.save()}, SAVE_INTERVAL); }; /** Saves the data in the board to a file. * @param {string} [file=this.file] - Path to the file where the board data will be saved. */ BoardData.prototype.save = function (file) { if (!file) file = this.file; var board_txt = JSON.stringify(this.board); var that = this; fs.writeFile(file, board_txt, function (err) { if (err) that.emit("error", err); }); }; /** Load the data in the board from a file. * @param {string} file - Path to the file where the board data will be read. */ BoardData.prototype.load = function (file) { var that = this; fs.readFile(file, function (err, data) { try { if (err) throw err; that.board = JSON.parse(data); } catch (e) { console.error("Unable to read history from "+file+". The following error occured: " + e); console.log("Creating an empty board."); that.board = {} } that.emit("ready"); }); }; module.exports.BoardData = BoardData;