var Changeset = require("../Changeset"); var AttributePoolFactory = require("../AttributePoolFactory"); var db = require("../db").db; var async = require("async"); var settings = require('../settings'); /** * Copied from the Etherpad source code, don't know what its good for * @param txt */ exports.cleanText = function (txt) { return txt.replace(/\r\n/g,'\n').replace(/\r/g,'\n').replace(/\t/g, ' ').replace(/\xa0/g, ' '); } Class('Pad', { // these are the properties has : { atext : { is : 'rw', // readwrite init : function() { return Changeset.makeAText("\n"); } // first value }, // atext pool : { is: 'rw', init : function() { return AttributePoolFactory.createAttributePool(); }, getterName : 'apool' // legacy }, // pool head : { is : 'rw', init : -1, getterName : 'getHeadRevisionNumber' }, // head id : { is : 'r' } }, methods : { BUILD : function (id) { return { 'id' : id, } }, appendRevision : function(aChangeset, author) { if(!author) author = ''; var newAText = Changeset.applyToAText(aChangeset, this.atext, this.pool); Changeset.copyAText(newAText, this.atext); var newRev = ++this.head; var newRevData = {}; newRevData.changeset = aChangeset; newRevData.meta = {}; newRevData.meta.author = author; newRevData.meta.timestamp = new Date().getTime(); //ex. getNumForAuthor if(author != '') this.pool.putAttrib(['author', author || '']); if(newRev % 100 == 0) { newRevData.meta.atext = this.atext; } db.set("pad:"+this.id+":revs:"+newRev, newRevData); db.set("pad:"+this.id, {atext: this.atext, pool: this.pool.toJsonable(), head: this.head}); }, //appendRevision getRevisionChangeset : function(revNum, callback) { db.getSub("pad:"+this.id+":revs:"+revNum, ["changeset"], callback); }, // getRevisionChangeset getRevisionAuthor : function(revNum, callback) { db.getSub("pad:"+this.id+":revs:"+revNum, ["meta", "author"], callback); }, // getRevisionAuthor getAllAuthors : function() { var authors = []; for(key in this.pool.numToAttrib) { if(this.pool.numToAttrib[key][0] == "author" && this.pool.numToAttrib[key][1] != "") { authors.push(this.pool.numToAttrib[key][1]); } } return authors; }, text : function() { return this.atext.text; }, init : function (callback) { var _this = this; //try to load the pad db.get("pad:"+this.id, function(err, value) { if(err) { callback(err, null); return; } //if this pad exists, load it if(value != null) { _this.head = value.head; _this.atext = value.atext; _this.pool = _this.pool.fromJsonable(value.pool); } //this pad doesn't exist, so create it else { var firstChangeset = Changeset.makeSplice("\n", 0, 0, exports.cleanText(settings.defaultPadText)); _this.appendRevision(firstChangeset, ''); } callback(null); }); } }, // methods });