more thenify in node/utils/*

pull/3559/head
Ray Bellis 2019-01-22 17:30:33 +00:00
parent 584e481430
commit 5ef4a2d1d5
5 changed files with 26 additions and 21 deletions

View File

@ -18,8 +18,9 @@
var async = require("async"); var async = require("async");
var db = require("../db/DB").db; var db = require("../db/DB").db;
var ERR = require("async-stacktrace"); var ERR = require("async-stacktrace");
const thenify = require("thenify").withCallback;
exports.getPadRaw = function(padId, callback){ exports.getPadRaw = thenify(function(padId, callback){
async.waterfall([ async.waterfall([
function(cb){ function(cb){
db.get("pad:"+padId, cb); db.get("pad:"+padId, cb);
@ -69,4 +70,4 @@ exports.getPadRaw = function(padId, callback){
], function(err, data){ ], function(err, data){
callback(null, data); callback(null, data);
}); });
} });

View File

@ -25,6 +25,7 @@ var hooks = require('ep_etherpad-lite/static/js/pluginfw/hooks');
var eejs = require('ep_etherpad-lite/node/eejs'); var eejs = require('ep_etherpad-lite/node/eejs');
var _analyzeLine = require('./ExportHelper')._analyzeLine; var _analyzeLine = require('./ExportHelper')._analyzeLine;
var _encodeWhitespace = require('./ExportHelper')._encodeWhitespace; var _encodeWhitespace = require('./ExportHelper')._encodeWhitespace;
const thenify = require("thenify").withCallback;
function getPadHTML(pad, revNum, callback) function getPadHTML(pad, revNum, callback)
{ {
@ -67,7 +68,7 @@ function getPadHTML(pad, revNum, callback)
}); });
} }
exports.getPadHTML = getPadHTML; exports.getPadHTML = thenify(getPadHTML);
exports.getHTMLFromAtext = getHTMLFromAtext; exports.getHTMLFromAtext = getHTMLFromAtext;
function getHTMLFromAtext(pad, atext, authorColors) function getHTMLFromAtext(pad, atext, authorColors)
@ -459,7 +460,7 @@ function getHTMLFromAtext(pad, atext, authorColors)
return pieces.join(''); return pieces.join('');
} }
exports.getPadHTMLDocument = function (padId, revNum, callback) exports.getPadHTMLDocument = thenify(function (padId, revNum, callback)
{ {
padManager.getPad(padId, function (err, pad) padManager.getPad(padId, function (err, pad)
{ {
@ -484,7 +485,7 @@ exports.getPadHTMLDocument = function (padId, revNum, callback)
}); });
}); });
}); });
}; });
// copied from ACE // copied from ACE
var _REGEX_WORDCHAR = /[\u0030-\u0039\u0041-\u005A\u0061-\u007A\u00C0-\u00D6\u00D8-\u00F6\u00F8-\u00FF\u0100-\u1FFF\u3040-\u9FFF\uF900-\uFDFF\uFE70-\uFEFE\uFF10-\uFF19\uFF21-\uFF3A\uFF41-\uFF5A\uFF66-\uFFDC]/; var _REGEX_WORDCHAR = /[\u0030-\u0039\u0041-\u005A\u0061-\u007A\u00C0-\u00D6\u00D8-\u00F6\u00F8-\u00FF\u0100-\u1FFF\u3040-\u9FFF\uF900-\uFDFF\uFE70-\uFEFE\uFF10-\uFF19\uFF21-\uFF3A\uFF41-\uFF5A\uFF66-\uFFDC]/;

View File

@ -17,8 +17,9 @@
var log4js = require('log4js'); var log4js = require('log4js');
var async = require("async"); var async = require("async");
var db = require("../db/DB").db; var db = require("../db/DB").db;
const thenify = require("thenify").withCallback;
exports.setPadRaw = function(padId, records, callback) exports.setPadRaw = thenify(function(padId, records, callback)
{ {
records = JSON.parse(records); records = JSON.parse(records);
@ -70,4 +71,4 @@ exports.setPadRaw = function(padId, records, callback)
function() { function() {
callback(null, true); callback(null, true);
}); });
} });

View File

@ -5,8 +5,9 @@
var log4js = require('log4js'); var log4js = require('log4js');
var settings = require('./Settings'); var settings = require('./Settings');
var spawn = require('child_process').spawn; var spawn = require('child_process').spawn;
const thenify = require("thenify").withCallback;
exports.tidy = function(srcFile, callback) { exports.tidy = thenify(function(srcFile, callback) {
var logger = log4js.getLogger('TidyHtml'); var logger = log4js.getLogger('TidyHtml');
// Don't do anything if Tidy hasn't been enabled // Don't do anything if Tidy hasn't been enabled
@ -38,4 +39,4 @@ exports.tidy = function(srcFile, callback) {
return callback('Tidy died with exit code ' + code); return callback('Tidy died with exit code ' + code);
} }
}); });
}; });

View File

@ -1,6 +1,7 @@
var Changeset = require("../../static/js/Changeset"); var Changeset = require("../../static/js/Changeset");
var async = require("async"); var async = require("async");
var exportHtml = require('./ExportHtml'); var exportHtml = require('./ExportHtml');
const thenify = require("thenify").withCallback;
function PadDiff (pad, fromRev, toRev) { function PadDiff (pad, fromRev, toRev) {
// check parameters // check parameters
@ -78,7 +79,7 @@ PadDiff.prototype._isClearAuthorship = function(changeset) {
return true; return true;
}; };
PadDiff.prototype._createClearAuthorship = function(rev, callback) { PadDiff.prototype._createClearAuthorship = thenify(function(rev, callback) {
var self = this; var self = this;
this._pad.getInternalRevisionAText(rev, function(err, atext) { this._pad.getInternalRevisionAText(rev, function(err, atext) {
if (err) { if (err) {
@ -92,9 +93,9 @@ PadDiff.prototype._createClearAuthorship = function(rev, callback) {
callback(null, changeset); callback(null, changeset);
}); });
}; });
PadDiff.prototype._createClearStartAtext = function(rev, callback) { PadDiff.prototype._createClearStartAtext = thenify(function(rev, callback) {
var self = this; var self = this;
// get the atext of this revision // get the atext of this revision
@ -119,9 +120,9 @@ PadDiff.prototype._createClearStartAtext = function(rev, callback) {
callback(null, newAText); callback(null, newAText);
}); });
}); });
}; });
PadDiff.prototype._getChangesetsInBulk = function(startRev, count, callback) { PadDiff.prototype._getChangesetsInBulk = thenify(function(startRev, count, callback) {
var self = this; var self = this;
// find out which revisions we need // find out which revisions we need
@ -150,7 +151,7 @@ PadDiff.prototype._getChangesetsInBulk = function(startRev, count, callback) {
function(err) { function(err) {
callback(err, changesets, authors); callback(err, changesets, authors);
}); });
}; });
PadDiff.prototype._addAuthors = function(authors) { PadDiff.prototype._addAuthors = function(authors) {
var self = this; var self = this;
@ -163,7 +164,7 @@ PadDiff.prototype._addAuthors = function(authors) {
}); });
}; };
PadDiff.prototype._createDiffAtext = function(callback) { PadDiff.prototype._createDiffAtext = thenify(function(callback) {
var self = this; var self = this;
var bulkSize = 100; var bulkSize = 100;
@ -237,9 +238,9 @@ PadDiff.prototype._createDiffAtext = function(callback) {
} }
); );
}); });
}; });
PadDiff.prototype.getHtml = function(callback) { PadDiff.prototype.getHtml = thenify(function(callback) {
// cache the html // cache the html
if (this._html != null) { if (this._html != null) {
return callback(null, this._html); return callback(null, this._html);
@ -283,9 +284,9 @@ PadDiff.prototype.getHtml = function(callback) {
function(err) { function(err) {
callback(err, html); callback(err, html);
}); });
}; });
PadDiff.prototype.getAuthors = function(callback) { PadDiff.prototype.getAuthors = thenify(function(callback) {
var self = this; var self = this;
// check if html was already produced, if not produce it, this generates the author array at the same time // check if html was already produced, if not produce it, this generates the author array at the same time
@ -300,7 +301,7 @@ PadDiff.prototype.getAuthors = function(callback) {
} else { } else {
callback(null, self._authors); callback(null, self._authors);
} }
}; });
PadDiff.prototype._extendChangesetWithAuthor = function(changeset, author, apool) { PadDiff.prototype._extendChangesetWithAuthor = function(changeset, author, apool) {
// unpack // unpack