Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 | 1x 4x 4x 1x 1x 58x 4x 58x 1x 25x 25x 16x 25x 25x 25x 8x 8x 25x 17x 102x 33x 1x 1x 17x 17x 17x 17x 17x 1x 1x 1x 16x 16x 4x 16x 16x 16x 16x 16x 17x 17x | /*!
* VisualEditor DataModel rebase server class.
*
* @copyright See AUTHORS.txt
*/
'use strict';
/**
* DataModel rebase server
*
* @class
*
* @constructor
* @param {Function} [logCallback]
*/
ve.dm.RebaseServer = function VeDmRebaseServer( logCallback ) {
this.stateForDoc = new Map();
this.logEvent = logCallback || function () {};
};
OO.initClass( ve.dm.RebaseServer );
/* Methods */
/**
* Get the state of a document by name.
*
* @param {string} doc Name of a document
* @return {ve.dm.RebaseDocState} Document state
*/
ve.dm.RebaseServer.prototype.getDocState = function ( doc ) {
if ( !this.stateForDoc.has( doc ) ) {
this.stateForDoc.set( doc, new ve.dm.RebaseDocState() );
}
return this.stateForDoc.get( doc );
};
/**
* Update document history
*
* @param {string} doc Name of a document
* @param {number|null} authorId Author ID
* @param {ve.dm.Change} [newHistory] New history to append
* @param {Object} [authorDataChanges] New values for author data (modified keys only)
*/
ve.dm.RebaseServer.prototype.updateDocState = function updateDocState( doc, authorId, newHistory, authorDataChanges ) {
const state = this.getDocState( doc );
if ( newHistory ) {
state.history.push( newHistory );
}
Iif ( !authorId ) {
return;
}
let authorData = state.authors.get( authorId );
if ( !authorData ) {
authorData = state.constructor.static.newAuthorData();
state.authors.set( authorId, authorData );
}
if ( authorDataChanges ) {
for ( const key in authorData ) {
if ( authorDataChanges[ key ] !== undefined ) {
authorData[ key ] = authorDataChanges[ key ];
}
}
}
};
/**
* Forget all history for a document
*
* @param {string} doc Name of a document
*/
ve.dm.RebaseServer.prototype.clearDocState = function clearDocState( doc ) {
const state = this.stateForDoc.get( doc );
if ( !state ) {
return;
}
state.clearHistory();
};
/**
* Attempt to rebase and apply a change to a document.
*
* The change can be a new change, or a continued change. A continuated change means one that
* follows on immediately from the author's last submitted change, other than possibly being
* rebased onto some more recent committed history.
*
* @param {string} doc Document name
* @param {number} authorId Author ID
* @param {number} backtrack How many transactions are backtracked from the previous submission
* @param {ve.dm.Change} change Change to apply
* @return {ve.dm.Change} Accepted change (or initial segment thereof), as rebased
*/
ve.dm.RebaseServer.prototype.applyChange = function applyChange( doc, authorId, backtrack, change ) {
const state = this.getDocState( doc ),
authorData = state.authors.get( authorId );
let appliedChange;
let base = ( authorData && authorData.continueBase ) || change.truncate( 0 );
let rejections = ( authorData && authorData.rejections ) || 0;
if ( rejections > backtrack ) {
// Follow-on does not fully acknowledge outstanding conflicts: reject entirely
rejections = rejections - backtrack + change.transactions.length;
this.updateDocState( doc, authorId, null, { rejections: rejections } );
// FIXME argh this publishes an empty change, which is not what we want
appliedChange = state.history.truncate( 0 );
} else Iif ( rejections < backtrack ) {
throw new Error( 'Backtrack=' + backtrack + ' > ' + rejections + '=rejections' );
} else {
if ( change.start > base.start ) {
// Remote has rebased some committed changes into its history since base was built.
// They are guaranteed to be equivalent to the start of base. See mathematical
// docs for proof (Cuius rei demonstrationem mirabilem sane deteximus hanc marginis
// exiguitas non caperet).
base = base.mostRecent( change.start );
}
base = base.concat( state.history.mostRecent( base.start + base.getLength() ) );
const result = ve.dm.Change.static.rebaseUncommittedChange( base, change );
rejections = result.rejected ? result.rejected.getLength() : 0;
this.updateDocState( doc, authorId, result.rebased, {
rejections: rejections,
continueBase: result.transposedHistory
} );
appliedChange = result.rebased;
}
this.logEvent( {
type: 'applyChange',
doc: doc,
authorId: authorId,
incoming: change,
applied: appliedChange,
backtrack: backtrack,
rejections: rejections
} );
return appliedChange;
};
|