Overleaf/services/web/public/js/libs/sharejs.js

var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();

var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };

var _slicedToArray = function () { function sliceIterator(arr, i) { var _arr = []; var _n = true; var _d = false; var _e = undefined; try { for (var _i = arr[Symbol.iterator](), _s; !(_n = (_s = _i.next()).done); _n = true) { _arr.push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } finally { try { if (!_n && _i["return"]) _i["return"](); } finally { if (_d) throw _e; } } return _arr; } return function (arr, i) { if (Array.isArray(arr)) { return arr; } else if (Symbol.iterator in Object(arr)) { return sliceIterator(arr, i); } else { throw new TypeError("Invalid attempt to destructure non-iterable instance"); } }; }();

function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }

/* eslint-disable
    camelcase,
    max-len,
    no-class-assign,
    no-return-assign,
    no-undef,
    no-unused-vars,
    no-use-before-define,
    standard/object-curly-even-spacing,
*/
// TODO: This file was created by bulk-decaffeinate.
// Fix any style issues and re-enable lint.
/*
 * decaffeinate suggestions:
 * DS101: Remove unnecessary use of Array.from
 * DS102: Remove unnecessary code created because of implicit returns
 * DS205: Consider reworking code to avoid use of IIFEs
 * DS207: Consider shorter variations of null checks
 * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
 */
define(['ace/ace','libs/sha1'], function () {
  var append = void 0,
      bootstrapTransform = void 0,
      exports = void 0,
      transformComponent = void 0;
  var WEB = true;
  window.sharejs = exports = {};
  var types = exports.types = {};
  // These methods let you build a transform function from a transformComponent function
  // for OT types like text and JSON in which operations are lists of components
  // and transforming them requires N^2 work.

  // Add transform and transformX functions for an OT type which has transformComponent defined.
  // transformComponent(destination array, component, other component, side)
  exports['_bt'] = bootstrapTransform = function bootstrapTransform(type, transformComponent, checkValidOp, append) {
    var _transformX = void 0;
    var transformComponentX = function transformComponentX(left, right, destLeft, destRight) {
      transformComponent(destLeft, left, right, 'left');
      return transformComponent(destRight, right, left, 'right');
    };

    // Transforms rightOp by leftOp. Returns ['rightOp', clientOp']
    type.transformX = type['transformX'] = _transformX = function transformX(leftOp, rightOp) {
      checkValidOp(leftOp);
      checkValidOp(rightOp);

      var newRightOp = [];

      var _iteratorNormalCompletion = true;
      var _didIteratorError = false;
      var _iteratorError = undefined;

      try {
        for (var _iterator = Array.from(rightOp)[Symbol.iterator](), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) {
          var rightComponent = _step.value;

          // Generate newLeftOp by composing leftOp by rightComponent
          var newLeftOp = [];

          var k = 0;
          while (k < leftOp.length) {
            var l;
            var nextC = [];
            transformComponentX(leftOp[k], rightComponent, newLeftOp, nextC);
            k++;

            if (nextC.length === 1) {
              rightComponent = nextC[0];
            } else if (nextC.length === 0) {
              var _iteratorNormalCompletion2 = true;
              var _didIteratorError2 = false;
              var _iteratorError2 = undefined;

              try {
                for (var _iterator2 = Array.from(leftOp.slice(k))[Symbol.iterator](), _step2; !(_iteratorNormalCompletion2 = (_step2 = _iterator2.next()).done); _iteratorNormalCompletion2 = true) {
                  l = _step2.value;
                  append(newLeftOp, l);
                }
              } catch (err) {
                _didIteratorError2 = true;
                _iteratorError2 = err;
              } finally {
                try {
                  if (!_iteratorNormalCompletion2 && _iterator2.return) {
                    _iterator2.return();
                  }
                } finally {
                  if (_didIteratorError2) {
                    throw _iteratorError2;
                  }
                }
              }

              rightComponent = null;
              break;
            } else {
              // Recurse.
              var _Array$from = Array.from(_transformX(leftOp.slice(k), nextC)),
                  _Array$from2 = _slicedToArray(_Array$from, 2),
                  l_ = _Array$from2[0],
                  r_ = _Array$from2[1];

              var _iteratorNormalCompletion3 = true;
              var _didIteratorError3 = false;
              var _iteratorError3 = undefined;

              try {
                for (var _iterator3 = Array.from(l_)[Symbol.iterator](), _step3; !(_iteratorNormalCompletion3 = (_step3 = _iterator3.next()).done); _iteratorNormalCompletion3 = true) {
                  l = _step3.value;
                  append(newLeftOp, l);
                }
              } catch (err) {
                _didIteratorError3 = true;
                _iteratorError3 = err;
              } finally {
                try {
                  if (!_iteratorNormalCompletion3 && _iterator3.return) {
                    _iterator3.return();
                  }
                } finally {
                  if (_didIteratorError3) {
                    throw _iteratorError3;
                  }
                }
              }

              var _iteratorNormalCompletion4 = true;
              var _didIteratorError4 = false;
              var _iteratorError4 = undefined;

              try {
                for (var _iterator4 = Array.from(r_)[Symbol.iterator](), _step4; !(_iteratorNormalCompletion4 = (_step4 = _iterator4.next()).done); _iteratorNormalCompletion4 = true) {
                  var r = _step4.value;
                  append(newRightOp, r);
                }
              } catch (err) {
                _didIteratorError4 = true;
                _iteratorError4 = err;
              } finally {
                try {
                  if (!_iteratorNormalCompletion4 && _iterator4.return) {
                    _iterator4.return();
                  }
                } finally {
                  if (_didIteratorError4) {
                    throw _iteratorError4;
                  }
                }
              }

              rightComponent = null;
              break;
            }
          }

          if (rightComponent != null) {
            append(newRightOp, rightComponent);
          }
          leftOp = newLeftOp;
        }
      } catch (err) {
        _didIteratorError = true;
        _iteratorError = err;
      } finally {
        try {
          if (!_iteratorNormalCompletion && _iterator.return) {
            _iterator.return();
          }
        } finally {
          if (_didIteratorError) {
            throw _iteratorError;
          }
        }
      }

      return [leftOp, newRightOp];
    };

    // Transforms op with specified type ('left' or 'right') by otherOp.
    return type.transform = type['transform'] = function (op, otherOp, type) {
      var _ = void 0;
      if (type !== 'left' && type !== 'right') {
        throw new Error("type must be 'left' or 'right'");
      }

      if (otherOp.length === 0) {
        return op;
      }

      // TODO: Benchmark with and without this line. I _think_ it'll make a big difference...?
      if (op.length === 1 && otherOp.length === 1) {
        return transformComponent([], op[0], otherOp[0], type);
      }

      if (type === 'left') {
        var left = void 0;

        var _Array$from3 = Array.from(_transformX(op, otherOp));

        var _Array$from4 = _slicedToArray(_Array$from3, 2);

        left = _Array$from4[0];
        _ = _Array$from4[1];

        return left;
      } else {
        var right = void 0;

        var _Array$from5 = Array.from(_transformX(otherOp, op));

        var _Array$from6 = _slicedToArray(_Array$from5, 2);

        _ = _Array$from6[0];
        right = _Array$from6[1];

        return right;
      }
    };
  };

  if (typeof WEB === 'undefined') {
    exports.bootstrapTransform = bootstrapTransform;
  }
  // A simple text implementation
  //
  // Operations are lists of components.
  // Each component either inserts or deletes at a specified position in the document.
  //
  // Components are either:
  //  {i:'str', p:100}: Insert 'str' at position 100 in the document
  //  {d:'str', p:100}: Delete 'str' at position 100 in the document
  //
  // Components in an operation are executed sequentially, so the position of components
  // assumes previous components have already executed.
  //
  // Eg: This op:
  //   [{i:'abc', p:0}]
  // is equivalent to this op:
  //   [{i:'a', p:0}, {i:'b', p:1}, {i:'c', p:2}]

  // NOTE: The global scope here is shared with other sharejs files when built with closure.
  // Be careful what ends up in your namespace.

  var text = {};

  text.name = 'text';

  text.create = function () {
    return '';
  };

  var strInject = function strInject(s1, pos, s2) {
    return s1.slice(0, pos) + s2 + s1.slice(pos);
  };

  var checkValidComponent = function checkValidComponent(c) {
    if (typeof c.p !== 'number') {
      throw new Error('component missing position field');
    }

    var i_type = _typeof(c.i);
    var d_type = _typeof(c.d);
    var c_type = _typeof(c.c);
    if (!(i_type === 'string' ^ d_type === 'string' ^ c_type === 'string')) {
      throw new Error('component needs an i, d or c field');
    }

    if (!(c.p >= 0)) {
      throw new Error('position cannot be negative');
    }
  };

  var checkValidOp = function checkValidOp(op) {
    var _iteratorNormalCompletion5 = true;
    var _didIteratorError5 = false;
    var _iteratorError5 = undefined;

    try {
      for (var _iterator5 = Array.from(op)[Symbol.iterator](), _step5; !(_iteratorNormalCompletion5 = (_step5 = _iterator5.next()).done); _iteratorNormalCompletion5 = true) {
        var c = _step5.value;
        checkValidComponent(c);
      }
    } catch (err) {
      _didIteratorError5 = true;
      _iteratorError5 = err;
    } finally {
      try {
        if (!_iteratorNormalCompletion5 && _iterator5.return) {
          _iterator5.return();
        }
      } finally {
        if (_didIteratorError5) {
          throw _iteratorError5;
        }
      }
    }

    return true;
  };

  text.apply = function (snapshot, op) {
    checkValidOp(op);
    var _iteratorNormalCompletion6 = true;
    var _didIteratorError6 = false;
    var _iteratorError6 = undefined;

    try {
      for (var _iterator6 = Array.from(op)[Symbol.iterator](), _step6; !(_iteratorNormalCompletion6 = (_step6 = _iterator6.next()).done); _iteratorNormalCompletion6 = true) {
        var component = _step6.value;

        if (component.i != null) {
          snapshot = strInject(snapshot, component.p, component.i);
        } else if (component.d != null) {
          var deleted = snapshot.slice(component.p, component.p + component.d.length);
          if (component.d !== deleted) {
            throw new Error('Delete component \'' + component.d + '\' does not match deleted text \'' + deleted + '\'');
          }
          snapshot = snapshot.slice(0, component.p) + snapshot.slice(component.p + component.d.length);
        } else if (component.c != null) {
          var comment = snapshot.slice(component.p, component.p + component.c.length);
          if (component.c !== comment) {
            throw new Error('Comment component \'' + component.c + '\' does not match commented text \'' + comment + '\'');
          }
        } else {
          throw new Error('Unknown op type');
        }
      }
    } catch (err) {
      _didIteratorError6 = true;
      _iteratorError6 = err;
    } finally {
      try {
        if (!_iteratorNormalCompletion6 && _iterator6.return) {
          _iterator6.return();
        }
      } finally {
        if (_didIteratorError6) {
          throw _iteratorError6;
        }
      }
    }

    return snapshot;
  };

  var cloneAndModify = function cloneAndModify(op, modifications) {
    var v = void 0;
    var newOp = {};
    for (var k in op) {
      v = op[k];
      newOp[k] = v;
    }
    for (k in modifications) {
      v = modifications[k];
      newOp[k] = v;
    }
    return newOp;
  };

  // Exported for use by the random op generator.
  //
  // For simplicity, this version of append does not compress adjacent inserts and deletes of
  // the same text. It would be nice to change that at some stage.
  text._append = append = function append(newOp, c) {
    if (c.i === '' || c.d === '') {
      return;
    }
    if (newOp.length === 0) {
      return newOp.push(c);
    } else {
      var last = newOp[newOp.length - 1];

      // Compose the insert into the previous insert if possible
      if (last.i != null && c.i != null && last.p <= c.p && c.p <= last.p + last.i.length && last.u === c.u) {
        return newOp[newOp.length - 1] = cloneAndModify(last, { i: strInject(last.i, c.p - last.p, c.i) });
      } else if (last.d != null && c.d != null && c.p <= last.p && last.p <= c.p + c.d.length && last.u === c.u) {
        return newOp[newOp.length - 1] = cloneAndModify(last, { d: strInject(c.d, last.p - c.p, last.d), p: c.p });
      } else {
        return newOp.push(c);
      }
    }
  };

  text.compose = function (op1, op2) {
    checkValidOp(op1);
    checkValidOp(op2);

    var newOp = op1.slice();
    var _iteratorNormalCompletion7 = true;
    var _didIteratorError7 = false;
    var _iteratorError7 = undefined;

    try {
      for (var _iterator7 = Array.from(op2)[Symbol.iterator](), _step7; !(_iteratorNormalCompletion7 = (_step7 = _iterator7.next()).done); _iteratorNormalCompletion7 = true) {
        var c = _step7.value;
        append(newOp, c);
      }
    } catch (err) {
      _didIteratorError7 = true;
      _iteratorError7 = err;
    } finally {
      try {
        if (!_iteratorNormalCompletion7 && _iterator7.return) {
          _iterator7.return();
        }
      } finally {
        if (_didIteratorError7) {
          throw _iteratorError7;
        }
      }
    }

    return newOp;
  };

  // Attempt to compress the op components together 'as much as possible'.
  // This implementation preserves order and preserves create/delete pairs.
  text.compress = function (op) {
    return text.compose([], op);
  };

  text.normalize = function (op) {
    var newOp = [];

    // Normalize should allow ops which are a single (unwrapped) component:
    // {i:'asdf', p:23}.
    // There's no good way to test if something is an array:
    // http://perfectionkills.com/instanceof-considered-harmful-or-how-to-write-a-robust-isarray/
    // so this is probably the least bad solution.
    if (op.i != null || op.p != null) {
      op = [op];
    }

    var _iteratorNormalCompletion8 = true;
    var _didIteratorError8 = false;
    var _iteratorError8 = undefined;

    try {
      for (var _iterator8 = Array.from(op)[Symbol.iterator](), _step8; !(_iteratorNormalCompletion8 = (_step8 = _iterator8.next()).done); _iteratorNormalCompletion8 = true) {
        var c = _step8.value;

        if (c.p == null) {
          c.p = 0;
        }
        append(newOp, c);
      }
    } catch (err) {
      _didIteratorError8 = true;
      _iteratorError8 = err;
    } finally {
      try {
        if (!_iteratorNormalCompletion8 && _iterator8.return) {
          _iterator8.return();
        }
      } finally {
        if (_didIteratorError8) {
          throw _iteratorError8;
        }
      }
    }

    return newOp;
  };

  // This helper method transforms a position by an op component.
  //
  // If c is an insert, insertAfter specifies whether the transform
  // is pushed after the insert (true) or before it (false).
  //
  // insertAfter is optional for deletes.
  var transformPosition = function transformPosition(pos, c, insertAfter) {
    if (c.i != null) {
      if (c.p < pos || c.p === pos && insertAfter) {
        return pos + c.i.length;
      } else {
        return pos;
      }
    } else if (c.d != null) {
      // I think this could also be written as: Math.min(c.p, Math.min(c.p - otherC.p, otherC.d.length))
      // but I think its harder to read that way, and it compiles using ternary operators anyway
      // so its no slower written like this.
      if (pos <= c.p) {
        return pos;
      } else if (pos <= c.p + c.d.length) {
        return c.p;
      } else {
        return pos - c.d.length;
      }
    } else if (c.c != null) {
      return pos;
    } else {
      throw new Error('unknown op type');
    }
  };

  // Helper method to transform a cursor position as a result of an op.
  //
  // Like transformPosition above, if c is an insert, insertAfter specifies whether the cursor position
  // is pushed after an insert (true) or before it (false).
  text.transformCursor = function (position, op, side) {
    var insertAfter = side === 'right';
    var _iteratorNormalCompletion9 = true;
    var _didIteratorError9 = false;
    var _iteratorError9 = undefined;

    try {
      for (var _iterator9 = Array.from(op)[Symbol.iterator](), _step9; !(_iteratorNormalCompletion9 = (_step9 = _iterator9.next()).done); _iteratorNormalCompletion9 = true) {
        var c = _step9.value;
        position = transformPosition(position, c, insertAfter);
      }
    } catch (err) {
      _didIteratorError9 = true;
      _iteratorError9 = err;
    } finally {
      try {
        if (!_iteratorNormalCompletion9 && _iterator9.return) {
          _iterator9.return();
        }
      } finally {
        if (_didIteratorError9) {
          throw _iteratorError9;
        }
      }
    }

    return position;
  };

  // Transform an op component by another op component. Asymmetric.
  // The result will be appended to destination.
  //
  // exported for use in JSON type
  text._tc = transformComponent = function transformComponent(dest, c, otherC, side) {
    var cIntersect = void 0,
        intersectEnd = void 0,
        intersectStart = void 0,
        newC = void 0,
        otherIntersect = void 0;
    checkValidOp([c]);
    checkValidOp([otherC]);

    if (c.i != null) {
      append(dest, cloneAndModify(c, { p: transformPosition(c.p, otherC, side === 'right') }));
    } else if (c.d != null) {
      // Delete
      if (otherC.i != null) {
        // delete vs insert
        var s = c.d;
        if (c.p < otherC.p) {
          append(dest, cloneAndModify(c, { d: s.slice(0, otherC.p - c.p) }));
          s = s.slice(otherC.p - c.p);
        }
        if (s !== '') {
          append(dest, cloneAndModify(c, { d: s, p: c.p + otherC.i.length }));
        }
      } else if (otherC.d != null) {
        // Delete vs delete
        if (c.p >= otherC.p + otherC.d.length) {
          append(dest, cloneAndModify(c, { p: c.p - otherC.d.length }));
        } else if (c.p + c.d.length <= otherC.p) {
          append(dest, c);
        } else {
          // They overlap somewhere.
          newC = cloneAndModify(c, { d: '' });
          if (c.p < otherC.p) {
            newC.d = c.d.slice(0, otherC.p - c.p);
          }
          if (c.p + c.d.length > otherC.p + otherC.d.length) {
            newC.d += c.d.slice(otherC.p + otherC.d.length - c.p);
          }

          // This is entirely optional - just for a check that the deleted
          // text in the two ops matches
          intersectStart = Math.max(c.p, otherC.p);
          intersectEnd = Math.min(c.p + c.d.length, otherC.p + otherC.d.length);
          cIntersect = c.d.slice(intersectStart - c.p, intersectEnd - c.p);
          otherIntersect = otherC.d.slice(intersectStart - otherC.p, intersectEnd - otherC.p);
          if (cIntersect !== otherIntersect) {
            throw new Error('Delete ops delete different text in the same region of the document');
          }

          if (newC.d !== '') {
            // This could be rewritten similarly to insert v delete, above.
            newC.p = transformPosition(newC.p, otherC);
            append(dest, newC);
          }
        }
      } else if (otherC.c != null) {
        append(dest, c);
      } else {
        throw new Error('unknown op type');
      }
    } else if (c.c != null) {
      // Comment
      if (otherC.i != null) {
        if (c.p < otherC.p && otherC.p < c.p + c.c.length) {
          var offset = otherC.p - c.p;
          var new_c = c.c.slice(0, +(offset - 1) + 1 || undefined) + otherC.i + c.c.slice(offset);
          append(dest, cloneAndModify(c, { c: new_c }));
        } else {
          append(dest, cloneAndModify(c, { p: transformPosition(c.p, otherC, true) }));
        }
      } else if (otherC.d != null) {
        if (c.p >= otherC.p + otherC.d.length) {
          append(dest, cloneAndModify(c, { p: c.p - otherC.d.length }));
        } else if (c.p + c.c.length <= otherC.p) {
          append(dest, c);
        } else {
          // Delete overlaps comment
          // They overlap somewhere.
          newC = cloneAndModify(c, { c: '' });
          if (c.p < otherC.p) {
            newC.c = c.c.slice(0, otherC.p - c.p);
          }
          if (c.p + c.c.length > otherC.p + otherC.d.length) {
            newC.c += c.c.slice(otherC.p + otherC.d.length - c.p);
          }

          // This is entirely optional - just for a check that the deleted
          // text in the two ops matches
          intersectStart = Math.max(c.p, otherC.p);
          intersectEnd = Math.min(c.p + c.c.length, otherC.p + otherC.d.length);
          cIntersect = c.c.slice(intersectStart - c.p, intersectEnd - c.p);
          otherIntersect = otherC.d.slice(intersectStart - otherC.p, intersectEnd - otherC.p);
          if (cIntersect !== otherIntersect) {
            throw new Error('Delete ops delete different text in the same region of the document');
          }

          newC.p = transformPosition(newC.p, otherC);
          append(dest, newC);
        }
      } else if (otherC.c != null) {
        append(dest, c);
      } else {
        throw new Error('unknown op type');
      }
    }

    return dest;
  };

  var invertComponent = function invertComponent(c) {
    if (c.i != null) {
      return { d: c.i, p: c.p };
    } else {
      return { i: c.d, p: c.p };
    }
  };

  // No need to use append for invert, because the components won't be able to
  // cancel with one another.
  text.invert = function (op) {
    return Array.from(op.slice().reverse()).map(function (c) {
      return invertComponent(c);
    });
  };

  if (WEB != null) {
    if (!exports.types) {
      exports.types = {};
    }

    // This is kind of awful - come up with a better way to hook this helper code up.
    bootstrapTransform(text, transformComponent, checkValidOp, append);

    // [] is used to prevent closure from renaming types.text
    exports.types.text = text;
  } else {
    module.exports = text;

    // The text type really shouldn't need this - it should be possible to define
    // an efficient transform function by making a sort of transform map and passing each
    // op component through it.
    require('./helpers').bootstrapTransform(text, transformComponent, checkValidOp, append);
  }

  // Text document API for text

  if (typeof WEB === 'undefined') {
    text = require('./text');
  }

  text.api = {
    provides: { text: true },

    // The number of characters in the string
    getLength: function getLength() {
      return this.snapshot.length;
    },


    // Get the text contents of a document
    getText: function getText() {
      return this.snapshot;
    },
    insert: function insert(pos, text, fromUndo, callback) {
      var op = { p: pos, i: text };
      if (fromUndo) {
        op.u = true;
      }
      op = [op];

      this.submitOp(op, callback);
      return op;
    },
    del: function del(pos, length, fromUndo, callback) {
      var op = { p: pos, d: this.snapshot.slice(pos, pos + length) };
      if (fromUndo) {
        op.u = true;
      }
      op = [op];

      this.submitOp(op, callback);
      return op;
    },
    _register: function _register() {
      return this.on('remoteop', function (op) {
        var _this = this;

        return function () {
          var result = [];
          var _iteratorNormalCompletion10 = true;
          var _didIteratorError10 = false;
          var _iteratorError10 = undefined;

          try {
            for (var _iterator10 = Array.from(op)[Symbol.iterator](), _step10; !(_iteratorNormalCompletion10 = (_step10 = _iterator10.next()).done); _iteratorNormalCompletion10 = true) {
              var component = _step10.value;

              if (component.i !== undefined) {
                result.push(_this.emit('insert', component.p, component.i));
              } else if (component.d !== undefined) {
                result.push(_this.emit('delete', component.p, component.d));
              } else {
                result.push(undefined);
              }
            }
          } catch (err) {
            _didIteratorError10 = true;
            _iteratorError10 = err;
          } finally {
            try {
              if (!_iteratorNormalCompletion10 && _iterator10.return) {
                _iterator10.return();
              }
            } finally {
              if (_didIteratorError10) {
                throw _iteratorError10;
              }
            }
          }

          return result;
        }();
      });
    }
  };
  // This is a simple port of microevent.js to Coffeescript. I've changed the
  // function names to be consistent with node.js EventEmitter.
  //
  // microevent.js is copyright Jerome Etienne, and licensed under the MIT license:
  // https://github.com/jeromeetienne/microevent.js

  var nextTick = WEB != null ? function (fn) {
    return setTimeout(fn, 0);
  } : process['nextTick'];

  var MicroEvent = function () {
    function MicroEvent() {
      _classCallCheck(this, MicroEvent);
    }

    _createClass(MicroEvent, [{
      key: 'on',
      value: function on(event, fct) {
        if (!this._events) {
          this._events = {};
        }
        if (!this._events[event]) {
          this._events[event] = [];
        }
        this._events[event].push(fct);
        return this;
      }
    }, {
      key: 'removeListener',
      value: function removeListener(event, fct) {
        var _this2 = this;

        if (!this._events) {
          this._events = {};
        }
        var listeners = this._events[event] || (this._events[event] = []);

        // Sadly, there's no IE8- support for indexOf.
        var i = 0;
        while (i < listeners.length) {
          if (listeners[i] === fct) {
            listeners[i] = undefined;
          }
          i++;
        }

        nextTick(function () {
          return _this2._events[event] = Array.from(_this2._events[event]).filter(function (x) {
            return x;
          });
        });

        return this;
      }
    }, {
      key: 'emit',
      value: function emit(event) {
        if (!(this._events != null ? this._events[event] : undefined)) {
          return this;
        }

        for (var _len = arguments.length, args = Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
          args[_key - 1] = arguments[_key];
        }

        var _iteratorNormalCompletion11 = true;
        var _didIteratorError11 = false;
        var _iteratorError11 = undefined;

        try {
          for (var _iterator11 = Array.from(this._events[event])[Symbol.iterator](), _step11; !(_iteratorNormalCompletion11 = (_step11 = _iterator11.next()).done); _iteratorNormalCompletion11 = true) {
            var fn = _step11.value;
            if (fn) {
              fn.apply(this, args);
            }
          }
        } catch (err) {
          _didIteratorError11 = true;
          _iteratorError11 = err;
        } finally {
          try {
            if (!_iteratorNormalCompletion11 && _iterator11.return) {
              _iterator11.return();
            }
          } finally {
            if (_didIteratorError11) {
              throw _iteratorError11;
            }
          }
        }

        return this;
      }
    }]);

    return MicroEvent;
  }();

  // mixin will delegate all MicroEvent.js function in the destination object


  MicroEvent.mixin = function (obj) {
    var proto = obj.prototype || obj;

    // Damn closure compiler :/
    proto.on = MicroEvent.prototype.on;
    proto.removeListener = MicroEvent.prototype.removeListener;
    proto.emit = MicroEvent.prototype.emit;
    return obj;
  };

  if (WEB == null) {
    module.exports = MicroEvent;
  }

  if (WEB == null) {
    types = require('../types');
  }

  if (WEB != null) {
    exports.extendDoc = function (name, fn) {
      return Doc.prototype[name] = fn;
    };
  }

  // A Doc is a client's view on a sharejs document.
  //
  // Documents are created by calling Connection.open().
  //
  // Documents are event emitters - use doc.on(eventname, fn) to subscribe.
  //
  // Documents get mixed in with their type's API methods. So, you can .insert('foo', 0) into
  // a text document and stuff like that.
  //
  // Events:
  //  - remoteop (op)
  //  - changed (op)
  //  - acknowledge (op)
  //  - error
  //  - open, closing, closed. 'closing' is not guaranteed to fire before closed.

  var Doc = function () {
    // connection is a Connection object.
    // name is the documents' docName.
    // data can optionally contain known document data, and initial open() call arguments:
    // {v[erson], snapshot={...}, type, create=true/false/undefined}
    // callback will be called once the document is first opened.
    function Doc(connection, name, openData) {
      _classCallCheck(this, Doc);

      // Any of these can be null / undefined at this stage.
      this.flush = this.flush.bind(this);
      this.setFlushDelay = this.setFlushDelay.bind(this);
      this.shout = this.shout.bind(this);
      this.connection = connection;
      this.name = name;
      if (!openData) {
        openData = {};
      }
      this.version = openData.v;
      this.snapshot = openData.snaphot;
      if (openData.type) {
        this._setType(openData.type);
      }

      this.state = 'closed';
      this.autoOpen = false;

      // Has the document already been created?
      this._create = openData.create;

      // The op that is currently roundtripping to the server, or null.
      //
      // When the connection reconnects, the inflight op is resubmitted.
      this.inflightOp = null;
      this.inflightCallbacks = [];
      // The auth ids which the client has previously used to attempt to send inflightOp. This is
      // usually empty.
      this.inflightSubmittedIds = [];

      // All ops that are waiting for the server to acknowledge @inflightOp
      this.pendingOp = null;
      this.pendingCallbacks = [];

      // Some recent ops, incase submitOp is called with an old op version number.
      this.serverOps = {};
    }

    // Transform a server op by a client op, and vice versa.


    _createClass(Doc, [{
      key: '_xf',
      value: function _xf(client, server) {
        if (this.type.transformX) {
          return this.type.transformX(client, server);
        } else {
          var client_ = this.type.transform(client, server, 'left');
          var server_ = this.type.transform(server, client, 'right');
          return [client_, server_];
        }
      }
    }, {
      key: '_otApply',
      value: function _otApply(docOp, isRemote, msg) {
        var oldSnapshot = this.snapshot;
        this.snapshot = this.type.apply(this.snapshot, docOp);

        // Its important that these event handlers are called with oldSnapshot.
        // The reason is that the OT type APIs might need to access the snapshots to
        // determine information about the received op.
        this.emit('change', docOp, oldSnapshot, msg);
        if (isRemote) {
          return this.emit('remoteop', docOp, oldSnapshot, msg);
        }
      }
    }, {
      key: '_connectionStateChanged',
      value: function _connectionStateChanged(state, data) {
        switch (state) {
          case 'disconnected':
            this.state = 'closed';
            // This is used by the server to make sure that when an op is resubmitted it
            // doesn't end up getting applied twice.
            if (this.inflightOp) {
              this.inflightSubmittedIds.push(this.connection.id);
            }

            this.emit('closed');
            break;

          case 'ok':
            // Might be able to do this when we're connecting... that would save a roundtrip.
            if (this.autoOpen) {
              this.open();
            }
            break;

          case 'stopped':
            if (typeof this._openCallback === 'function') {
              this._openCallback(data);
            }
            break;
        }

        return this.emit(state, data);
      }
    }, {
      key: '_setType',
      value: function _setType(type) {
        if (typeof type === 'string') {
          type = types[type];
        }

        if (!type || !type.compose) {
          throw new Error('Support for types without compose() is not implemented');
        }

        this.type = type;
        if (type.api) {
          for (var k in type.api) {
            var v = type.api[k];this[k] = v;
          }
          return typeof this._register === 'function' ? this._register() : undefined;
        } else {
          return this.provides = {};
        }
      }
    }, {
      key: '_onMessage',
      value: function _onMessage(msg) {
        // console.warn 's->c', msg
        if (msg.open === true) {
          // The document has been successfully opened.
          this.state = 'open';
          this._create = false; // Don't try and create the document again next time open() is called.
          if (this.created == null) {
            this.created = !!msg.create;
          }

          if (msg.type) {
            this._setType(msg.type);
          }
          if (msg.create) {
            this.created = true;
            this.snapshot = this.type.create();
          } else {
            if (this.created !== true) {
              this.created = false;
            }
            if (msg.snapshot !== undefined) {
              this.snapshot = msg.snapshot;
            }
          }

          if (msg.v != null) {
            this.version = msg.v;
          }

          // Resend any previously queued operation.
          if (this.inflightOp) {
            var response = {
              doc: this.name,
              op: this.inflightOp,
              v: this.version
            };
            if (this.inflightSubmittedIds.length) {
              response.dupIfSource = this.inflightSubmittedIds;
            }
            this.connection.send(response);
          } else {
            this.flush();
          }

          this.emit('open');

          return typeof this._openCallback === 'function' ? this._openCallback(null) : undefined;
        } else if (msg.open === false) {
          // The document has either been closed, or an open request has failed.
          if (msg.error) {
            // An error occurred opening the document.
            if (typeof console !== 'undefined' && console !== null) {
              console.error('Could not open document: ' + msg.error);
            }
            this.emit('error', msg.error);
            if (typeof this._openCallback === 'function') {
              this._openCallback(msg.error);
            }
          }

          this.state = 'closed';
          this.emit('closed');

          if (typeof this._closeCallback === 'function') {
            this._closeCallback();
          }
          return this._closeCallback = null;
        } else if (msg.op === null && error === 'Op already submitted') {
          // We've tried to resend an op to the server, which has already been received successfully. Do nothing.
          // The op will be confirmed normally when we get the op itself was echoed back from the server
          // (handled below).

        } else if (msg.op === undefined && msg.v !== undefined || msg.op && Array.from(this.inflightSubmittedIds).includes(msg.meta.source)) {
          // Our inflight op has been acknowledged.
          var callback = void 0;
          var oldInflightOp = this.inflightOp;
          this.inflightOp = null;
          this.inflightSubmittedIds.length = 0;

          if (this.pendingOp === null) {
            // All ops are acked
            this.emit('saved');
          }

          var error = msg.error;

          if (error) {
            // The server has rejected an op from the client for some reason.
            // We'll send the error message to the user and roll back the change.
            //
            // If the server isn't going to allow edits anyway, we should probably
            // figure out some way to flag that (readonly:true in the open request?)

            if (this.type.invert) {
              var undo = this.type.invert(oldInflightOp);

              // Now we have to transform the undo operation by any server ops & pending ops
              if (this.pendingOp) {
                var _Array$from7 = Array.from(this._xf(this.pendingOp, undo));

                var _Array$from8 = _slicedToArray(_Array$from7, 2);

                this.pendingOp = _Array$from8[0];
                undo = _Array$from8[1];
              }

              // ... and apply it locally, reverting the changes.
              //
              // This call will also call @emit 'remoteop'. I'm still not 100% sure about this
              // functionality, because its really a local op. Basically, the problem is that
              // if the client's op is rejected by the server, the editor window should update
              // to reflect the undo.
              this._otApply(undo, true, msg);
            } else {
              this.emit('error', 'Op apply failed (' + error + ') and the op could not be reverted');
            }

            var _iteratorNormalCompletion12 = true;
            var _didIteratorError12 = false;
            var _iteratorError12 = undefined;

            try {
              for (var _iterator12 = Array.from(this.inflightCallbacks)[Symbol.iterator](), _step12; !(_iteratorNormalCompletion12 = (_step12 = _iterator12.next()).done); _iteratorNormalCompletion12 = true) {
                callback = _step12.value;
                callback(error);
              }
            } catch (err) {
              _didIteratorError12 = true;
              _iteratorError12 = err;
            } finally {
              try {
                if (!_iteratorNormalCompletion12 && _iterator12.return) {
                  _iterator12.return();
                }
              } finally {
                if (_didIteratorError12) {
                  throw _iteratorError12;
                }
              }
            }
          } else {
            // The op applied successfully.

            // We may get multiple acks of the same message if we retried it,
            // so its ok if we receive an ack for a version that we've already gone past.
            // If so, just ignore it
            if (msg.v < this.version) {
              return;
            }

            if (msg.v !== this.version) {
              throw new Error('Invalid version from server');
            }

            this.serverOps[this.version] = oldInflightOp;
            this.version++;
            this.emit('acknowledge', oldInflightOp);
            var _iteratorNormalCompletion13 = true;
            var _didIteratorError13 = false;
            var _iteratorError13 = undefined;

            try {
              for (var _iterator13 = Array.from(this.inflightCallbacks)[Symbol.iterator](), _step13; !(_iteratorNormalCompletion13 = (_step13 = _iterator13.next()).done); _iteratorNormalCompletion13 = true) {
                callback = _step13.value;
                callback(null, oldInflightOp);
              }
            } catch (err) {
              _didIteratorError13 = true;
              _iteratorError13 = err;
            } finally {
              try {
                if (!_iteratorNormalCompletion13 && _iterator13.return) {
                  _iterator13.return();
                }
              } finally {
                if (_didIteratorError13) {
                  throw _iteratorError13;
                }
              }
            }
          }

          // Send the next op.
          return this.delayedFlush();
        } else if (msg.op) {
          // We got a new op from the server.
          // msg is {doc:, op:, v:}

          // There is a bug in socket.io (produced on firefox 3.6) which causes messages
          // to be duplicated sometimes.
          // We'll just silently drop subsequent messages.
          if (msg.v < this.version) {
            return;
          }

          if (msg.doc !== this.name) {
            return this.emit('error', 'Expected docName \'' + this.name + '\' but got ' + msg.doc);
          }
          if (msg.v !== this.version) {
            return this.emit('error', 'Expected version ' + this.version + ' but got ' + msg.v);
          }

          //    p "if: #{i @inflightOp} pending: #{i @pendingOp} doc '#{@snapshot}' op: #{i msg.op}"

          var op = msg.op;

          this.serverOps[this.version] = op;

          var docOp = op;
          if (this.inflightOp !== null) {
            var _Array$from9 = Array.from(this._xf(this.inflightOp, docOp));

            var _Array$from10 = _slicedToArray(_Array$from9, 2);

            this.inflightOp = _Array$from10[0];
            docOp = _Array$from10[1];
          }
          if (this.pendingOp !== null) {
            var _Array$from11 = Array.from(this._xf(this.pendingOp, docOp));

            var _Array$from12 = _slicedToArray(_Array$from11, 2);

            this.pendingOp = _Array$from12[0];
            docOp = _Array$from12[1];
          }

          this.version++;
          // Finally, apply the op to @snapshot and trigger any event listeners
          return this._otApply(docOp, true, msg);
        } else if (msg.meta) {
          var _msg$meta = msg.meta,
              path = _msg$meta.path,
              value = _msg$meta.value;


          switch (path != null ? path[0] : undefined) {
            case 'shout':
              return this.emit('shout', value);
            default:
              return typeof console !== 'undefined' && console !== null ? console.warn('Unhandled meta op:', msg) : undefined;
          }
        } else {
          return typeof console !== 'undefined' && console !== null ? console.warn('Unhandled document message:', msg) : undefined;
        }
      }

      // Send ops to the server, if appropriate.
      //
      // Only one op can be in-flight at a time, so if an op is already on its way then
      // this method does nothing.

    }, {
      key: 'flush',
      value: function flush() {
        this.flushTimeout = null;
        // console.log "CALLED FLUSH"

        if (this.connection.state !== 'ok' || this.inflightOp !== null || this.pendingOp === null) {
          return;
        }

        // Rotate null -> pending -> inflight
        this.inflightOp = this.pendingOp;
        this.inflightCallbacks = this.pendingCallbacks;

        this.pendingOp = null;
        this.pendingCallbacks = [];

        this.emit('flipped_pending_to_inflight');

        if (window.useShareJsHash || window.sl_debugging) {
          var now = Date.now()
          var age = this.__lastSubmitTimestamp && (now - this.__lastSubmitTimestamp)
          var RECOMPUTE_HASH_INTERVAL = 5000
          // check the document hash regularly (but not if we have checked in the last 5 seconds)
          var needToRecomputeHash = !this.__lastSubmitTimestamp || (age > RECOMPUTE_HASH_INTERVAL) || (age < 0) 
          if (needToRecomputeHash || window.sl_debugging) {
            // send git hash of current snapshot
            var sha1 = CryptoJS.SHA1("blob " + this.snapshot.length + "\x00" + this.snapshot).toString()
            this.__lastSubmitTimestamp = now;
          }
        }

        // console.log "SENDING OP TO SERVER", @inflightOp, @version
        var lastVersion = this.__lastVersion;
        this.__lastVersion = this.version;
        return this.connection.send({ doc: this.name, op: this.inflightOp, v: this.version, lastV: lastVersion, hash: sha1});
      }

      // Submit an op to the server. The op maybe held for a little while before being sent, as only one
      // op can be inflight at any time.

    }, {
      key: 'submitOp',
      value: function submitOp(op, callback) {
        if (this.type.normalize != null) {
          op = this.type.normalize(op);
        }

        var oldSnapshot = this.snapshot;
        // If this throws an exception, no changes should have been made to the doc
        this.snapshot = this.type.apply(this.snapshot, op);

        if (this.pendingOp !== null) {
          this.pendingOp = this.type.compose(this.pendingOp, op);
        } else {
          this.pendingOp = op;
        }

        if (callback) {
          this.pendingCallbacks.push(callback);
        }

        this.emit('change', op, oldSnapshot);

        return this.delayedFlush();
      }
    }, {
      key: 'delayedFlush',
      value: function delayedFlush() {
        if (this.flushTimeout == null) {
          return this.flushTimeout = setTimeout(this.flush, this._flushDelay || 0);
        }
      }
    }, {
      key: 'setFlushDelay',
      value: function setFlushDelay(delay) {
        return this._flushDelay = delay;
      }
    }, {
      key: 'shout',
      value: function shout(msg) {
        // Meta ops don't have to queue, they can go direct. Good/bad idea?
        return this.connection.send({ doc: this.name, meta: { path: ['shout'], value: msg } });
      }

      // Open a document. The document starts closed.

    }, {
      key: 'open',
      value: function open(callback) {
        var _this3 = this;

        this.autoOpen = true;
        if (this.state !== 'closed') {
          return;
        }

        var message = {
          doc: this.name,
          open: true
        };

        if (this.snapshot === undefined) {
          message.snapshot = null;
        }
        if (this.type) {
          message.type = this.type.name;
        }
        if (this.version != null) {
          message.v = this.version;
        }
        if (this._create) {
          message.create = true;
        }

        this.connection.send(message);

        this.state = 'opening';

        return this._openCallback = function (error) {
          _this3._openCallback = null;
          return typeof callback === 'function' ? callback(error) : undefined;
        };
      }

      // Close a document.

    }, {
      key: 'close',
      value: function close(callback) {
        this.autoOpen = false;
        if (this.state === 'closed') {
          return typeof callback === 'function' ? callback() : undefined;
        }

        this.connection.send({ doc: this.name, open: false });

        // Should this happen immediately or when we get open:false back from the server?
        this.state = 'closed';

        this.emit('closing');
        return this._closeCallback = callback;
      }
    }]);

    return Doc;
  }();

  // Make documents event emitters


  if (WEB == null) {
    MicroEvent = require('./microevent');
  }

  MicroEvent.mixin(Doc);

  exports.Doc = Doc;
  // This is some utility code to connect an ace editor to a sharejs document.

  var _ace$require = ace.require('ace/range'),
      Range = _ace$require.Range;

  // Convert an ace delta into an op understood by share.js


  var applyAceToShareJS = function applyAceToShareJS(editorDoc, delta, doc, fromUndo) {
    // Get the start position of the range, in no. of characters
    var getStartOffsetPosition = function getStartOffsetPosition(start) {
      // This is quite inefficient - getLines makes a copy of the entire
      // lines array in the document. It would be nice if we could just
      // access them directly.
      var lines = editorDoc.getLines(0, start.row);

      var offset = 0;

      for (var i = 0; i < lines.length; i++) {
        var line = lines[i];
        offset += i < start.row ? line.length : start.column;
      }

      // Add the row number to include newlines.
      return offset + start.row;
    };

    var pos = getStartOffsetPosition(delta.start);

    switch (delta.action) {
      case 'insert':
        text = delta.lines.join('\n');
        doc.insert(pos, text, fromUndo);
        break;

      case 'remove':
        text = delta.lines.join('\n');
        doc.del(pos, text.length, fromUndo);
        break;

      default:
        throw new Error('unknown action: ' + delta.action);
    }
  };

  // Attach an ace editor to the document. The editor's contents are replaced
  // with the document's contents unless keepEditorContents is true. (In which case the document's
  // contents are nuked and replaced with the editor's).
  window.sharejs.extendDoc('attach_ace', function (editor, keepEditorContents, maxDocLength) {
    if (!this.provides['text']) {
      throw new Error('Only text documents can be attached to ace');
    }

    var doc = this;
    var editorDoc = editor.getSession().getDocument();
    editorDoc.setNewLineMode('unix');

    var check = function check() {
      return window.setTimeout(function () {
        var editorText = editorDoc.getValue();
        var otText = doc.getText();

        if (editorText !== otText) {
          doc.emit('error','Text does not match in ace')
          console.error('Text does not match!');
          console.error('editor: ' + editorText);
          return console.error('ot:     ' + otText);
        }
      }
      // Should probably also replace the editor text with the doc snapshot.
      , 0);
    };

    if (keepEditorContents) {
      doc.del(0, doc.getText().length);
      doc.insert(0, editorDoc.getValue());
    } else {
      editorDoc.setValue(doc.getText());
    }

    check();

    // When we apply ops from sharejs, ace emits edit events. We need to ignore those
    // to prevent an infinite typing loop.
    var suppress = false;

    // Listen for edits in ace
    var editorListener = function editorListener(change) {
      if (suppress) {
        return;
      }

      if (maxDocLength != null && editorDoc.getValue().length > maxDocLength) {
        doc.emit('error', new Error('document length is greater than maxDocLength'));
        return;
      }

      var fromUndo = !!(editor.getSession().$fromUndo || editor.getSession().$fromReject);

      applyAceToShareJS(editorDoc, change, doc, fromUndo);

      return check();
    };

    editorDoc.on('change', editorListener);

    // Horribly inefficient.
    var offsetToPos = function offsetToPos(offset) {
      // Again, very inefficient.
      var lines = editorDoc.getAllLines();

      var row = 0;
      for (row = 0; row < lines.length; row++) {
        var line = lines[row];
        if (offset <= line.length) {
          break;
        }

        // +1 for the newline.
        offset -= lines[row].length + 1;
      }

      return { row: row, column: offset };
    };

    // We want to insert a remote:true into the delta if the op comes from the
    // underlying sharejs doc (which means it is from a remote op), so we have to do
    // the work of editorDoc.insert and editorDoc.remove manually. These methods are
    // copied from ace.js doc#insert and #remove, and then inject the remote:true
    // flag into the delta.
    var onInsert = function onInsert(pos, text) {
      if (editorDoc.getLength() <= 1) {
        editorDoc.$detectNewLine(text);
      }

      var lines = editorDoc.$split(text);
      var position = offsetToPos(pos);
      var start = editorDoc.clippedPos(position.row, position.column);
      var end = {
        row: start.row + lines.length - 1,
        column: (lines.length === 1 ? start.column : 0) + lines[lines.length - 1].length
      };

      suppress = true;
      editorDoc.applyDelta({
        start: start,
        end: end,
        action: 'insert',
        lines: lines,
        remote: true
      });
      suppress = false;
      return check();
    };

    var onDelete = function onDelete(pos, text) {
      var range = Range.fromPoints(offsetToPos(pos), offsetToPos(pos + text.length));
      var start = editorDoc.clippedPos(range.start.row, range.start.column);
      var end = editorDoc.clippedPos(range.end.row, range.end.column);
      suppress = true;
      editorDoc.applyDelta({
        start: start,
        end: end,
        action: 'remove',
        lines: editorDoc.getLinesForRange({ start: start, end: end }),
        remote: true
      });
      suppress = false;
      return check();
    };

    doc.on('insert', onInsert);
    doc.on('delete', onDelete);

    doc.detach_ace = function () {
      doc.removeListener('insert', onInsert);
      doc.removeListener('delete', onDelete);
      editorDoc.removeListener('change', editorListener);
      return delete doc.detach_ace;
    };
  });

  // This is some utility code to connect a CodeMirror editor
  // to a sharejs document.
  // It is heavily inspired from the Ace editor hook.

  // Convert a CodeMirror delta into an op understood by share.js
  var applyCMToShareJS = function applyCMToShareJS(editorDoc, delta, doc) {
    // CodeMirror deltas give a text replacement.
    // I tuned this operation a little bit, for speed.
    var startPos = 0; // Get character position from # of chars in each line.
    var i = 0; // i goes through all lines.
    // Compute the position from the shareJS snapshot because we are in the CodeMirror
    // change event, where the change has already been applied to the editorDoc
    var docLines = doc.snapshot.split('\n', delta.from.line) // only split the document as far as we need to
    while (i < delta.from.line) {
      startPos += docLines[i].length + 1; // Add 1 for '\n'
      i++;
    }
    startPos += delta.from.ch;

    if (delta.removed) {
      doc.del(startPos, delta.removed.join('\n').length);
    }
    if (delta.text) {
      return doc.insert(startPos, delta.text.join('\n'));
    }
  };

  // Attach a CodeMirror editor to the document. The editor's contents are replaced
  // with the document's contents unless keepEditorContents is true. (In which case
  // the document's contents are nuked and replaced with the editor's).
  window.sharejs.extendDoc('attach_cm', function (editor, keepEditorContents) {
    if (!this.provides.text) {
      throw new Error('Only text documents can be attached to CodeMirror2');
    }

    var sharedoc = this;
    var editorDoc = editor.getDoc();

    var check = function check() {
      return window.setTimeout(function () {
        var editorText = editor.getValue();
        var otText = sharedoc.getText();

        if (editorText !== otText) {
          sharedoc.emit('error','Text does not match in CodeMirror')
          console.error('Text does not match!');
          console.error('editor: ' + editorText);
          return console.error('ot:     ' + otText);
        }
      }
      // Removed editor.setValue here as it would cause recursive loops if
      // consistency check failed - because setting the value would trigger
      // the change event
      , 0);
    };

    if (keepEditorContents) {
      this.del(0, sharedoc.getText().length);
      this.insert(0, editor.getValue());
    } else {
      editor.setValue(sharedoc.getText());
    }

    check();

    // When we apply ops from sharejs, CodeMirror emits edit events.
    // We need to ignore those to prevent an infinite typing loop.
    var suppress = false;

    // Listen for edits in CodeMirror.
    var editorListener = function editorListener(ed, change) {
      if (suppress) {
        return;
      }
      applyCMToShareJS(editorDoc, change, sharedoc);
      return check();
    };

    editorDoc.on('change', editorListener);

    var onInsert = function onInsert(pos, text) {
      suppress = true;
      // All the primitives we need are already in CM's API.
      editor.replaceRange(text, editor.posFromIndex(pos));
      // Clear CM's undo/redo history on remote edit. This prevents issues where
      // a user can accidentally remove another user's edits
      editor.clearHistory();
      suppress = false;
      return check();
    };

    var onDelete = function onDelete(pos, text) {
      suppress = true;
      var from = editor.posFromIndex(pos);
      var to = editor.posFromIndex(pos + text.length);
      editor.replaceRange('', from, to);
      // Clear CM's undo/redo history on remote edit. This prevents issues where
      // a user can accidentally remove another user's edits
      editor.clearHistory()
      suppress = false;
      return check();
    };

    this.on('insert', onInsert);
    this.on('delete', onDelete);

    this.detach_cm = function () {
      this.removeListener('insert', onInsert);
      this.removeListener('delete', onDelete);
      editorDoc.off('change', editorListener);
      return delete this.detach_cm;
    };
  });

  return window.sharejs;
});