Compare commits
4 Commits
develop
...
lint-chang
Author | SHA1 | Date |
---|---|---|
John McLear | 703bd414af | |
John McLear | 5e384cca2b | |
John McLear | f26045423a | |
John McLear | 1bac65a190 |
File diff suppressed because it is too large
Load Diff
|
@ -1,3 +1,4 @@
|
||||||
|
'use strict';
|
||||||
/**
|
/**
|
||||||
* This module contains several helper Functions to build Changesets
|
* This module contains several helper Functions to build Changesets
|
||||||
* based on a SkipList
|
* based on a SkipList
|
||||||
|
@ -18,7 +19,7 @@
|
||||||
* See the License for the specific language governing permissions and
|
* See the License for the specific language governing permissions and
|
||||||
* limitations under the License.
|
* limitations under the License.
|
||||||
*/
|
*/
|
||||||
exports.buildRemoveRange = function (rep, builder, start, end) {
|
exports.buildRemoveRange = (rep, builder, start, end) => {
|
||||||
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
||||||
const endLineOffset = rep.lines.offsetOfIndex(end[0]);
|
const endLineOffset = rep.lines.offsetOfIndex(end[0]);
|
||||||
|
|
||||||
|
@ -30,7 +31,7 @@ exports.buildRemoveRange = function (rep, builder, start, end) {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
exports.buildKeepRange = function (rep, builder, start, end, attribs, pool) {
|
exports.buildKeepRange = (rep, builder, start, end, attribs, pool) => {
|
||||||
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
||||||
const endLineOffset = rep.lines.offsetOfIndex(end[0]);
|
const endLineOffset = rep.lines.offsetOfIndex(end[0]);
|
||||||
|
|
||||||
|
@ -42,7 +43,7 @@ exports.buildKeepRange = function (rep, builder, start, end, attribs, pool) {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
exports.buildKeepToStartOfRange = function (rep, builder, start) {
|
exports.buildKeepToStartOfRange = (rep, builder, start) => {
|
||||||
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
const startLineOffset = rep.lines.offsetOfIndex(start[0]);
|
||||||
|
|
||||||
builder.keep(startLineOffset, start[0]);
|
builder.keep(startLineOffset, start[0]);
|
||||||
|
|
|
@ -1,3 +1,4 @@
|
||||||
|
'use strict';
|
||||||
/**
|
/**
|
||||||
* This code is mostly from the old Etherpad. Please help us to comment this code.
|
* This code is mostly from the old Etherpad. Please help us to comment this code.
|
||||||
* This helps other people to understand this code better and helps them to improve it.
|
* This helps other people to understand this code better and helps them to improve it.
|
||||||
|
@ -23,7 +24,7 @@
|
||||||
const AttributePool = require('./AttributePool');
|
const AttributePool = require('./AttributePool');
|
||||||
const Changeset = require('./Changeset');
|
const Changeset = require('./Changeset');
|
||||||
|
|
||||||
function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
const makeChangesetTracker = (scheduler, apool, aceCallbacksProvider) => {
|
||||||
// latest official text from server
|
// latest official text from server
|
||||||
let baseAText = Changeset.makeAText('\n');
|
let baseAText = Changeset.makeAText('\n');
|
||||||
// changes applied to baseText that have been submitted
|
// changes applied to baseText that have been submitted
|
||||||
|
@ -42,30 +43,30 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
|
|
||||||
let changeCallbackTimeout = null;
|
let changeCallbackTimeout = null;
|
||||||
|
|
||||||
function setChangeCallbackTimeout() {
|
const setChangeCallbackTimeout = () => {
|
||||||
// can call this multiple times per call-stack, because
|
// can call this multiple times per call-stack, because
|
||||||
// we only schedule a call to changeCallback if it exists
|
// we only schedule a call to changeCallback if it exists
|
||||||
// and if there isn't a timeout already scheduled.
|
// and if there isn't a timeout already scheduled.
|
||||||
if (changeCallback && changeCallbackTimeout === null) {
|
if (changeCallback && changeCallbackTimeout == null) {
|
||||||
changeCallbackTimeout = scheduler.setTimeout(() => {
|
changeCallbackTimeout = scheduler.setTimeout(() => {
|
||||||
try {
|
try {
|
||||||
changeCallback();
|
changeCallback();
|
||||||
} catch (pseudoError) {} finally {
|
} catch (pseudoError) {
|
||||||
|
// allow empty block :)
|
||||||
|
} finally {
|
||||||
changeCallbackTimeout = null;
|
changeCallbackTimeout = null;
|
||||||
}
|
}
|
||||||
}, 0);
|
}, 0);
|
||||||
}
|
}
|
||||||
}
|
};
|
||||||
|
|
||||||
let self;
|
let self;
|
||||||
return self = {
|
return self = {
|
||||||
isTracking() {
|
isTracking: () => tracking,
|
||||||
return tracking;
|
setBaseText: (text) => {
|
||||||
},
|
|
||||||
setBaseText(text) {
|
|
||||||
self.setBaseAttributedText(Changeset.makeAText(text), null);
|
self.setBaseAttributedText(Changeset.makeAText(text), null);
|
||||||
},
|
},
|
||||||
setBaseAttributedText(atext, apoolJsonObj) {
|
setBaseAttributedText: (atext, apoolJsonObj) => {
|
||||||
aceCallbacksProvider.withCallbacks('setBaseText', (callbacks) => {
|
aceCallbacksProvider.withCallbacks('setBaseText', (callbacks) => {
|
||||||
tracking = true;
|
tracking = true;
|
||||||
baseAText = Changeset.cloneAText(atext);
|
baseAText = Changeset.cloneAText(atext);
|
||||||
|
@ -83,7 +84,7 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
composeUserChangeset(c) {
|
composeUserChangeset: (c) => {
|
||||||
if (!tracking) return;
|
if (!tracking) return;
|
||||||
if (applyingNonUserChanges) return;
|
if (applyingNonUserChanges) return;
|
||||||
if (Changeset.isIdentity(c)) return;
|
if (Changeset.isIdentity(c)) return;
|
||||||
|
@ -91,7 +92,7 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
|
|
||||||
setChangeCallbackTimeout();
|
setChangeCallbackTimeout();
|
||||||
},
|
},
|
||||||
applyChangesToBase(c, optAuthor, apoolJsonObj) {
|
applyChangesToBase: (c, optAuthor, apoolJsonObj) => {
|
||||||
if (!tracking) return;
|
if (!tracking) return;
|
||||||
|
|
||||||
aceCallbacksProvider.withCallbacks('applyChangesToBase', (callbacks) => {
|
aceCallbacksProvider.withCallbacks('applyChangesToBase', (callbacks) => {
|
||||||
|
@ -111,8 +112,10 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
|
|
||||||
const preferInsertingAfterUserChanges = true;
|
const preferInsertingAfterUserChanges = true;
|
||||||
const oldUserChangeset = userChangeset;
|
const oldUserChangeset = userChangeset;
|
||||||
userChangeset = Changeset.follow(c2, oldUserChangeset, preferInsertingAfterUserChanges, apool);
|
userChangeset =
|
||||||
const postChange = Changeset.follow(oldUserChangeset, c2, !preferInsertingAfterUserChanges, apool);
|
Changeset.follow(c2, oldUserChangeset, preferInsertingAfterUserChanges, apool);
|
||||||
|
const postChange =
|
||||||
|
Changeset.follow(oldUserChangeset, c2, !preferInsertingAfterUserChanges, apool);
|
||||||
|
|
||||||
const preferInsertionAfterCaret = true; // (optAuthor && optAuthor > thisAuthor);
|
const preferInsertionAfterCaret = true; // (optAuthor && optAuthor > thisAuthor);
|
||||||
applyingNonUserChanges = true;
|
applyingNonUserChanges = true;
|
||||||
|
@ -123,7 +126,7 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
prepareUserChangeset() {
|
prepareUserChangeset: () => {
|
||||||
// If there are user changes to submit, 'changeset' will be the
|
// If there are user changes to submit, 'changeset' will be the
|
||||||
// changeset, else it will be null.
|
// changeset, else it will be null.
|
||||||
let toSubmit;
|
let toSubmit;
|
||||||
|
@ -132,39 +135,38 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
// that includes old submittedChangeset
|
// that includes old submittedChangeset
|
||||||
toSubmit = Changeset.compose(submittedChangeset, userChangeset, apool);
|
toSubmit = Changeset.compose(submittedChangeset, userChangeset, apool);
|
||||||
} else {
|
} else {
|
||||||
// add forEach function to Array.prototype for IE8
|
|
||||||
if (!('forEach' in Array.prototype)) {
|
|
||||||
Array.prototype.forEach = function (action, that /* opt*/) {
|
|
||||||
for (let i = 0, n = this.length; i < n; i++) if (i in this) action.call(that, this[i], i, this);
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get my authorID
|
// Get my authorID
|
||||||
const authorId = parent.parent.pad.myUserInfo.userId;
|
const authorId = parent.parent.pad.myUserInfo.userId;
|
||||||
|
|
||||||
// Sanitize authorship
|
// Sanitize authorship
|
||||||
// We need to replace all author attribs with thisSession.author, in case they copy/pasted or otherwise inserted other peoples changes
|
// We need to replace all author attribs with thisSession.author,
|
||||||
|
// in case they copy/pasted or otherwise inserted other peoples changes
|
||||||
|
let authorAttr;
|
||||||
if (apool.numToAttrib) {
|
if (apool.numToAttrib) {
|
||||||
for (const attr in apool.numToAttrib) {
|
for (const attr in apool.numToAttrib) {
|
||||||
if (apool.numToAttrib[attr][0] == 'author' && apool.numToAttrib[attr][1] == authorId) var authorAttr = Number(attr).toString(36);
|
if (apool.numToAttrib[attr][0] === 'author' &&
|
||||||
|
apool.numToAttrib[attr][1] === authorId) {
|
||||||
|
authorAttr = Number(attr).toString(36);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Replace all added 'author' attribs with the value of the current user
|
// Replace all added 'author' attribs with the value of the current user
|
||||||
var cs = Changeset.unpack(userChangeset);
|
const cs = Changeset.unpack(userChangeset);
|
||||||
const iterator = Changeset.opIterator(cs.ops);
|
const iterator = Changeset.opIterator(cs.ops);
|
||||||
let op;
|
let op;
|
||||||
|
let newAttrs;
|
||||||
const assem = Changeset.mergingOpAssembler();
|
const assem = Changeset.mergingOpAssembler();
|
||||||
|
|
||||||
while (iterator.hasNext()) {
|
while (iterator.hasNext()) {
|
||||||
op = iterator.next();
|
op = iterator.next();
|
||||||
if (op.opcode == '+') {
|
if (op.opcode === '+') {
|
||||||
var newAttrs = '';
|
newAttrs = '';
|
||||||
|
|
||||||
op.attribs.split('*').forEach((attrNum) => {
|
op.attribs.split('*').forEach((attrNum) => {
|
||||||
if (!attrNum) return;
|
if (!attrNum) return;
|
||||||
const attr = apool.getAttrib(parseInt(attrNum, 36));
|
const attr = apool.getAttrib(parseInt(attrNum, 36));
|
||||||
if (!attr) return;
|
if (!attr) return;
|
||||||
if ('author' == attr[0]) {
|
if ('author' === attr[0]) {
|
||||||
// replace that author with the current one
|
// replace that author with the current one
|
||||||
newAttrs += `*${authorAttr}`;
|
newAttrs += `*${authorAttr}`;
|
||||||
} else { newAttrs += `*${attrNum}`; } // overtake all other attribs as is
|
} else { newAttrs += `*${attrNum}`; } // overtake all other attribs as is
|
||||||
|
@ -181,7 +183,7 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
else toSubmit = userChangeset;
|
else toSubmit = userChangeset;
|
||||||
}
|
}
|
||||||
|
|
||||||
var cs = null;
|
let cs = null;
|
||||||
if (toSubmit) {
|
if (toSubmit) {
|
||||||
submittedChangeset = toSubmit;
|
submittedChangeset = toSubmit;
|
||||||
userChangeset = Changeset.identity(Changeset.newLen(toSubmit));
|
userChangeset = Changeset.identity(Changeset.newLen(toSubmit));
|
||||||
|
@ -201,7 +203,7 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
};
|
};
|
||||||
return data;
|
return data;
|
||||||
},
|
},
|
||||||
applyPreparedChangesetToBase() {
|
applyPreparedChangesetToBase: () => {
|
||||||
if (!submittedChangeset) {
|
if (!submittedChangeset) {
|
||||||
// violation of protocol; use prepareUserChangeset first
|
// violation of protocol; use prepareUserChangeset first
|
||||||
throw new Error('applySubmittedChangesToBase: no submitted changes to apply');
|
throw new Error('applySubmittedChangesToBase: no submitted changes to apply');
|
||||||
|
@ -210,13 +212,11 @@ function makeChangesetTracker(scheduler, apool, aceCallbacksProvider) {
|
||||||
baseAText = Changeset.applyToAText(submittedChangeset, baseAText, apool);
|
baseAText = Changeset.applyToAText(submittedChangeset, baseAText, apool);
|
||||||
submittedChangeset = null;
|
submittedChangeset = null;
|
||||||
},
|
},
|
||||||
setUserChangeNotificationCallback(callback) {
|
setUserChangeNotificationCallback: (callback) => {
|
||||||
changeCallback = callback;
|
changeCallback = callback;
|
||||||
},
|
},
|
||||||
hasUncommittedChanges() {
|
hasUncommittedChanges: () => !!(submittedChangeset || (!Changeset.isIdentity(userChangeset))),
|
||||||
return !!(submittedChangeset || (!Changeset.isIdentity(userChangeset)));
|
};
|
||||||
},
|
|
||||||
};
|
};
|
||||||
}
|
|
||||||
|
|
||||||
exports.makeChangesetTracker = makeChangesetTracker;
|
exports.makeChangesetTracker = makeChangesetTracker;
|
||||||
|
|
Loading…
Reference in New Issue