v13.0.0-37 -- distribution files

examples/drawing/index.html

@@ -12,8 +12,12 @@
   </style>
   <button type="button" id="clearDrawingCanvas">Clear Drawing</button>
   <svg id="drawingCanvas" viewbox="0 0 100 100" width="100%"></svg>
-  <script src="../yjs-dist.js"></script>
+  <script src="../../y.js"></script>
-  <script src="../bower_components/d3/d3.min.js"></script>
+  <script src="../../../y-array/y-array.js"></script>
+  <script src="../../../y-map/dist/y-map.js"></script>
+  <script src="../../../y-memory/y-memory.js"></script>
+  <script src="../../../y-websockets-client/y-websockets-client.js"></script>
+  <script src="../bower_components/d3/d3.js"></script>
   <script src="./index.js"></script>
 </body>
 </html>

examples/drawing/index.js

@@ -1,76 +1,84 @@
 /* globals Y, d3 */
+'strict mode'
 
-let y = new Y({
+Y({
+  db: {
+    name: 'memory'
+  },
   connector: {
     name: 'websockets-client',
-    url: 'http://127.0.0.1:1234',
+    room: 'drawing-example',
-    room: 'drawing-example'
+    url: 'localhost:1234'
-    // maxBufferLength: 100
+  },
+  sourceDir: '/bower_components',
+  share: {
+    drawing: 'Array'
   }
-})
+}).then(function (y) {
+  window.yDrawing = y
+  var drawing = y.share.drawing
+  var renderPath = d3.svg.line()
+    .x(function (d) { return d[0] })
+    .y(function (d) { return d[1] })
+    .interpolate('basis')
 
-window.yDrawing = y
+  var svg = d3.select('#drawingCanvas')
-var drawing = y.define('drawing', Y.Array)
+    .call(d3.behavior.drag()
-var renderPath = d3.svg.line()
+      .on('dragstart', dragstart)
-  .x(function (d) { return d[0] })
+      .on('drag', drag)
-  .y(function (d) { return d[1] })
+      .on('dragend', dragend))
-  .interpolate('basic')
 
-var svg = d3.select('#drawingCanvas')
+  // create line from a shared array object and update the line when the array changes
-  .call(d3.behavior.drag()
+  function drawLine (yarray) {
-    .on('dragstart', dragstart)
+    var line = svg.append('path').datum(yarray.toArray())
-    .on('drag', drag)
-    .on('dragend', dragend))
-
-// create line from a shared array object and update the line when the array changes
-function drawLine (yarray) {
-  var line = svg.append('path').datum(yarray.toArray())
-  line.attr('d', renderPath)
-  yarray.observe(function (event) {
-    line.remove()
-    line = svg.append('path').datum(yarray.toArray())
     line.attr('d', renderPath)
-  })
+    yarray.observe(function (event) {
-}
+      // we only implement insert events that are appended to the end of the array
-// call drawLine every time an array is appended
+      event.values.forEach(function (value) {
-drawing.observe(function (event) {
+        line.datum().push(value)
-  event.removedElements.forEach(function () {
+      })
-    // if one is deleted, all will be deleted!!
+      line.attr('d', renderPath)
-    svg.selectAll('path').remove()
+    })
-  })
+  }
-  event.addedElements.forEach(function (path) {
+  // call drawLine every time an array is appended
-    drawLine(path)
+  y.share.drawing.observe(function (event) {
-  })
+    if (event.type === 'insert') {
-})
+      event.values.forEach(drawLine)
-// draw all existing content
+    } else {
-for (var i = 0; i < drawing.length; i++) {
+      // just remove all elements (thats what we do anyway)
-  drawLine(drawing.get(i))
+      svg.selectAll('path').remove()
-}
+    }
-
+  })
-// clear canvas on request
+  // draw all existing content
-document.querySelector('#clearDrawingCanvas').onclick = function () {
+  for (var i = 0; i < drawing.length; i++) {
-  drawing.delete(0, drawing.length)
+    drawLine(drawing.get(i))
-}
-
-var sharedLine = null
-function dragstart () {
-  drawing.insert(drawing.length, [Y.Array])
-  sharedLine = drawing.get(drawing.length - 1)
-}
-
-// After one dragged event is recognized, we ignore them for 33ms.
-var ignoreDrag = null
-function drag () {
-  if (sharedLine != null && ignoreDrag == null) {
-    ignoreDrag = window.setTimeout(function () {
-      ignoreDrag = null
-    }, 10)
-    sharedLine.push([d3.mouse(this)])
   }
-}
 
-function dragend () {
+  // clear canvas on request
-  sharedLine = null
+  document.querySelector('#clearDrawingCanvas').onclick = function () {
-  window.clearTimeout(ignoreDrag)
+    drawing.delete(0, drawing.length)
-  ignoreDrag = null
+  }
-}
+
+  var sharedLine = null
+  function dragstart () {
+    drawing.insert(drawing.length, [Y.Array])
+    sharedLine = drawing.get(drawing.length - 1)
+  }
+
+  // After one dragged event is recognized, we ignore them for 33ms.
+  var ignoreDrag = null
+  function drag () {
+    if (sharedLine != null && ignoreDrag == null) {
+      ignoreDrag = window.setTimeout(function () {
+        ignoreDrag = null
+      }, 33)
+      sharedLine.push([d3.mouse(this)])
+    }
+  }
+
+  function dragend () {
+    sharedLine = null
+    window.clearTimeout(ignoreDrag)
+    ignoreDrag = null
+  }
+})

examples/html-editor-drawing-hook/index.html

@@ -1,35 +0,0 @@
-<!DOCTYPE html>
-<html>
-</head>
-  <script src="../yjs-dist.js"></script>
-  <script src="../bower_components/d3/d3.min.js"></script>
-  <script src="./index.js"></script>
-  <style>
-    magic-drawing .drawingCanvas path {
-      fill: none;
-      stroke: blue;
-      stroke-width: 2px;
-      stroke-linejoin: round;
-      stroke-linecap: round;
-    }
-    magic-drawing .drawingCanvas {
-      width: 500px;
-      height: 500px;
-      cursor: default;
-      padding:1px;
-      border:1px solid #021a40;
-    }
-    magic-drawing .clearDrawingButton {
-      position: absolute;
-      top: 0;
-      left: 0;
-    }
-    magic-drawing {
-      position: relative;
-      display: block;
-    }
-  </style>
-</head>
-<body contenteditable="true">
-</body>
-</html>

examples/html-editor-drawing-hook/index.js

@@ -1,134 +0,0 @@
-/* global Y, d3 */
-
-window.onload = function () {
-  window.yXmlType.bindToDom(document.body)
-}
-
-window.addMagicDrawing = function addMagicDrawing () {
-  let mt = document.createElement('magic-drawing')
-  mt.dataset.yjsHook = 'magic-drawing'
-  document.body.append(mt)
-}
-
-var renderPath = d3.svg.line()
-  .x(function (d) { return d[0] })
-  .y(function (d) { return d[1] })
-  .interpolate('basic')
-
-function initDrawingBindings (type, dom) {
-  dom.contentEditable = 'false'
-  dom.dataset.yjsHook = 'magic-drawing'
-  var drawing = type.get('drawing')
-  if (drawing === undefined) {
-    drawing = type.set('drawing', new Y.Array())
-  }
-  var canvas = dom.querySelector('.drawingCanvas')
-  if (canvas == null) {
-    canvas = document.createElementNS('http://www.w3.org/2000/svg', 'svg')
-    canvas.setAttribute('class', 'drawingCanvas')
-    canvas.setAttribute('viewbox', '0 0 100 100')
-    dom.insertBefore(canvas, null)
-  }
-  var clearDrawingButton = dom.querySelector('.clearDrawingButton')
-  if (clearDrawingButton == null) {
-    clearDrawingButton = document.createElement('button')
-    clearDrawingButton.setAttribute('type', 'button')
-    clearDrawingButton.setAttribute('class', 'clearDrawingButton')
-    clearDrawingButton.innerText = 'Clear Drawing'
-    dom.insertBefore(clearDrawingButton, null)
-  }
-  var svg = d3.select(canvas)
-    .call(d3.behavior.drag()
-      .on('dragstart', dragstart)
-      .on('drag', drag)
-      .on('dragend', dragend))
-  // create line from a shared array object and update the line when the array changes
-  function drawLine (yarray, svg) {
-    var line = svg.append('path').datum(yarray.toArray())
-    line.attr('d', renderPath)
-    yarray.observe(function (event) {
-      line.remove()
-      line = svg.append('path').datum(yarray.toArray())
-      line.attr('d', renderPath)
-    })
-  }
-  // call drawLine every time an array is appended
-  drawing.observe(function (event) {
-    event.removedElements.forEach(function () {
-      // if one is deleted, all will be deleted!!
-      svg.selectAll('path').remove()
-    })
-    event.addedElements.forEach(function (path) {
-      drawLine(path, svg)
-    })
-  })
-  // draw all existing content
-  for (var i = 0; i < drawing.length; i++) {
-    drawLine(drawing.get(i), svg)
-  }
-
-  // clear canvas on request
-  clearDrawingButton.onclick = function () {
-    drawing.delete(0, drawing.length)
-  }
-
-  var sharedLine = null
-  function dragstart () {
-    drawing.insert(drawing.length, [Y.Array])
-    sharedLine = drawing.get(drawing.length - 1)
-  }
-
-  // After one dragged event is recognized, we ignore them for 33ms.
-  var ignoreDrag = null
-  function drag () {
-    if (sharedLine != null && ignoreDrag == null) {
-      ignoreDrag = window.setTimeout(function () {
-        ignoreDrag = null
-      }, 10)
-      sharedLine.push([d3.mouse(this)])
-    }
-  }
-
-  function dragend () {
-    sharedLine = null
-    window.clearTimeout(ignoreDrag)
-    ignoreDrag = null
-  }
-}
-
-Y.XmlHook.addHook('magic-drawing', {
-  fillType: function (dom, type) {
-    initDrawingBindings(type, dom)
-  },
-  createDom: function (type) {
-    const dom = document.createElement('magic-drawing')
-    initDrawingBindings(type, dom)
-    return dom
-  }
-})
-
-// initialize a shared object. This function call returns a promise!
-let y = new Y({
-  connector: {
-    name: 'websockets-client',
-    url: 'http://127.0.0.1:1234',
-    room: 'html-editor-example6'
-    // maxBufferLength: 100
-  }
-})
-window.yXml = y
-window.yXmlType = y.define('xml', Y.XmlFragment)
-window.undoManager = new Y.utils.UndoManager(window.yXmlType, {
-  captureTimeout: 500
-})
-
-document.onkeydown = function interceptUndoRedo (e) {
-  if (e.keyCode === 90 && e.metaKey) {
-    if (!e.shiftKey) {
-      window.undoManager.undo()
-    } else {
-      window.undoManager.redo()
-    }
-    e.preventDefault()
-  }
-}

examples/html-editor/index.html

@@ -1,7 +1,10 @@
 <!DOCTYPE html>
 <html>
 </head>
+  <!-- jquery is not required for y-xml. It is just here for convenience, and to test batch operations. -->
+  <script src="https://code.jquery.com/jquery-3.2.1.min.js"></script>
   <script src="../yjs-dist.js"></script>
+  <script src="./canvasjs.min.js"></script>
   <script src="./index.js"></script>
 </head>
 <body contenteditable="true">

examples/html-editor/index.js

@@ -1,20 +1,77 @@
-/* global Y */
+/* global Y, HTMLElement, customElements, CanvasJS */
 
 window.onload = function () {
   window.yXmlType.bindToDom(document.body)
+  let mt = document.createElement('magic-table')
+  mt.innerHTML = '<table><tr><th>Amount</th></tr><tr><td>1</td></tr><tr><td>1</td></tr></table>'
+  document.body.append(mt)
 }
 
-let persistence = null //  new Y.IndexedDBPersistence()
+class MagicTable extends HTMLElement {
+  constructor () {
+    super()
+    this.createShadowRoot()
+  }
+  get _yjsHook () {
+    return 'magic-table'
+  }
+  showTable () {
+    this.shadowRoot.innerHTML = ''
+    this.shadowRoot.append(document.createElement('content'))
+  }
+  showDiagram () {
+    let dataPoints = []
+    this.querySelectorAll('td').forEach(td => {
+      let number = Number(td.textContent)
+      dataPoints.push({
+        x: (dataPoints.length + 1) * 10,
+        y: number,
+        label: '<magic-table> content'
+      })
+    })
+    this.shadowRoot.innerHTML = ''
+    var chart = new CanvasJS.Chart(this.shadowRoot,
+      {
+        title: {
+          text: 'Bar chart'
+        },
+        data: [
+          {
+            type: 'bar',
+
+            dataPoints: dataPoints
+          }
+        ]
+      })
+
+    chart.render()
+
+    // this.shadowRoot.innerHTML = '<p>dtrn</p>'
+  }
+}
+customElements.define('magic-table', MagicTable)
+
+Y.XmlHook.addHook('magic-table', {
+  fillType: function (dom, type) {
+    type.set('table', new Y.XmlElement(dom.querySelector('table')))
+  },
+  createDom: function (type) {
+    const table = type.get('table').getDom()
+    const dom = document.createElement('magic-table')
+    dom.insertBefore(table, null)
+    return dom
+  }
+})
 
 // initialize a shared object. This function call returns a promise!
 let y = new Y({
   connector: {
     name: 'websockets-client',
     url: 'http://127.0.0.1:1234',
-    room: 'x'
+    room: 'html-editor-example6'
     // maxBufferLength: 100
   }
-}, persistence)
+})
 window.yXml = y
 window.yXmlType = y.define('xml', Y.XmlFragment)
 window.undoManager = new Y.utils.UndoManager(window.yXmlType, {

examples/package.json

@@ -9,15 +9,12 @@
   "author": "Kevin Jahns",
   "license": "MIT",
   "dependencies": {
-    "monaco-editor": "^0.8.3",
+    "monaco-editor": "^0.8.3"
-    "rollup": "^0.52.3"
   },
   "devDependencies": {
     "standard": "^10.0.2"
   },
   "standard": {
-    "ignore": [
+    "ignore": ["bower_components"]
-      "bower_components"
-    ]
   }
 }

examples/rollup.config.js

@@ -4,7 +4,7 @@ import commonjs from 'rollup-plugin-commonjs'
 var pkg = require('./package.json')
 
 export default {
-  input: 'yjs-dist.mjs',
+  input: 'yjs-dist.esm',
   name: 'Y',
   output: {
     file: 'yjs-dist.js',

examples/yjs-dist.esm

@@ -1,9 +1,7 @@
 
 import Y from '../src/Y.js'
 import yWebsocketsClient from '../../y-websockets-client/src/y-websockets-client.js'
-import IndexedDBPersistence from '../../y-indexeddb/src/y-indexeddb.js'
 
 Y.extend(yWebsocketsClient)
-Y.IndexedDBPersistence = IndexedDBPersistence
 
 export default Y

package.json

@@ -1,6 +1,6 @@
 {
   "name": "yjs",
-  "version": "13.0.0-46",
+  "version": "13.0.0-37",
   "description": "A framework for real-time p2p shared editing on any data",
   "main": "./y.node.js",
   "browser": "./y.js",
@@ -65,6 +65,9 @@
     "tag-dist-files": "^0.1.6"
   },
   "dependencies": {
-    "debug": "^2.6.8"
+    "debug": "^2.6.8",
+    "fast-diff": "^1.1.2",
+    "utf-8": "^1.0.0",
+    "utf8": "^2.1.2"
   }
 }

rollup.test.js

@@ -3,7 +3,7 @@ import commonjs from 'rollup-plugin-commonjs'
 import multiEntry from 'rollup-plugin-multi-entry'
 
 export default {
-  input: 'test/index.js',
+  input: 'test/y-xml.tests.js',
   name: 'y-tests',
   sourcemap: true,
   output: {
@@ -11,12 +11,12 @@ export default {
     format: 'umd'
   },
   plugins: [
-    multiEntry(),
     nodeResolve({
       main: true,
       module: true,
       browser: true
     }),
-    commonjs()
+    commonjs(),
+    multiEntry()
   ]
 }

src/Binary/Decoder.js

@@ -1,3 +1,4 @@
+import utf8 from 'utf-8'
 import ID from '../Util/ID.js'
 import { default as RootID, RootFakeUserID } from '../Util/RootID.js'
 
@@ -90,8 +91,7 @@ export default class BinaryDecoder {
     for (let i = 0; i < len; i++) {
       bytes[i] = this.uint8arr[this.pos++]
     }
-    let encodedString = String.fromCodePoint(...bytes)
+    return utf8.getStringFromBytes(bytes)
-    return decodeURIComponent(escape(encodedString))
   }
   /**
    *  Look ahead and read varString without incrementing position

src/Binary/Encoder.js

@@ -1,3 +1,4 @@
+import utf8 from 'utf-8'
 import { RootFakeUserID } from '../Util/RootID.js'
 
 const bits7 = 0b1111111
@@ -61,8 +62,7 @@ export default class BinaryEncoder {
   }
 
   writeVarString (str) {
-    let encodedString = unescape(encodeURIComponent(str))
+    let bytes = utf8.setBytesFromString(str)
-    let bytes = encodedString.split('').map(c => c.codePointAt())
     let len = bytes.length
     this.writeVarUint(len)
     for (let i = 0; i < len; i++) {

src/Connector.js

@@ -132,7 +132,6 @@ export default class AbstractConnector {
         f()
       }
       this.whenSyncedListeners = []
-      this.y._setContentReady()
       this.y.emit('synced')
     }
   }
@@ -269,7 +268,7 @@ export default class AbstractConnector {
         if (messageType === 'sync step 2' && senderConn.auth === 'write') {
           readSyncStep2(decoder, encoder, y, senderConn, sender)
         } else if (messageType === 'update' && (skipAuth || senderConn.auth === 'write')) {
-          integrateRemoteStructs(y, decoder)
+          integrateRemoteStructs(decoder, encoder, y, senderConn, sender)
         } else {
           throw new Error('Unable to receive message')
         }

src/MessageHandler/binaryEncode.js

@@ -1,16 +0,0 @@
-import { writeStructs } from './syncStep1.js'
-import { integrateRemoteStructs } from './integrateRemoteStructs.js'
-import { readDeleteSet, writeDeleteSet } from './deleteSet.js'
-import BinaryEncoder from '../Binary/Encoder.js'
-
-export function fromBinary (y, decoder) {
-  integrateRemoteStructs(y, decoder)
-  readDeleteSet(y, decoder)
-}
-
-export function toBinary (y) {
-  let encoder = new BinaryEncoder()
-  writeStructs(y, encoder, new Map())
-  writeDeleteSet(y, encoder)
-  return encoder
-}

src/MessageHandler/integrateRemoteStructs.js

@@ -65,7 +65,7 @@ export function stringifyStructs (y, decoder, strBuilder) {
   }
 }
 
-export function integrateRemoteStructs (y, decoder) {
+export function integrateRemoteStructs (decoder, encoder, y) {
   const len = decoder.readUint32()
   for (let i = 0; i < len; i++) {
     let reference = decoder.readVarUint()

src/MessageHandler/syncStep1.js

@@ -30,7 +30,7 @@ export function sendSyncStep1 (connector, syncUser) {
   connector.send(syncUser, encoder.createBuffer())
 }
 
-export function writeStructs (y, encoder, ss) {
+export default function writeStructs (encoder, decoder, y, ss) {
   const lenPos = encoder.pos
   encoder.writeUint32(0)
   let len = 0
@@ -60,7 +60,7 @@ export function readSyncStep1 (decoder, encoder, y, senderConn, sender) {
   encoder.writeVarString('sync step 2')
   encoder.writeVarString(y.connector.authInfo || '')
   const ss = readStateSet(decoder)
-  writeStructs(y, encoder, ss)
+  writeStructs(encoder, decoder, y, ss)
   writeDeleteSet(y, encoder)
   y.connector.send(senderConn.uid, encoder.createBuffer())
   senderConn.receivedSyncStep2 = true

src/MessageHandler/syncStep2.js

@@ -22,7 +22,7 @@ export function stringifySyncStep2 (y, decoder, strBuilder) {
 }
 
 export function readSyncStep2 (decoder, encoder, y, senderConn, sender) {
-  integrateRemoteStructs(y, decoder)
+  integrateRemoteStructs(decoder, encoder, y)
   readDeleteSet(y, decoder)
   y.connector._setSyncedWith(sender)
 }

src/Persistence.js

@@ -1,93 +1,47 @@
-import BinaryEncoder from './Binary/Encoder.js'
+// import BinaryEncoder from './Binary/Encoder.js'
-import BinaryDecoder from './Binary/Decoder.js'
-import { toBinary, fromBinary } from './MessageHandler/binaryEncode.js'
-import { integrateRemoteStructs } from './MessageHandler/integrateRemoteStructs.js'
-import { createMutualExclude } from './Util/mutualExclude.js'
 
-function getFreshCnf () {
+export default function extendPersistence (Y) {
-  let buffer = new BinaryEncoder()
+  class AbstractPersistence {
-  buffer.writeUint32(0)
+    constructor (y, opts) {
-  return {
+      this.y = y
-    len: 0,
+      this.opts = opts
-    buffer
+      this.saveOperationsBuffer = []
-  }
+      this.log = Y.debug('y:persistence')
-}
-
-export default class AbstractPersistence {
-  constructor (opts) {
-    this.opts = opts
-    this.ys = new Map()
-    this.mutualExclude = createMutualExclude()
-  }
-
-  _init (y) {
-    let cnf = this.ys.get(y)
-    if (cnf === undefined) {
-      cnf = getFreshCnf()
-      this.ys.set(y, cnf)
-      this.init(y)
-      y.on('afterTransaction', (y, transaction) => {
-        let cnf = this.ys.get(y)
-        if (cnf.len > 0) {
-          cnf.buffer.setUint32(0, cnf.len)
-          this.saveUpdate(y, cnf.buffer.createBuffer(), transaction)
-          let _cnf = getFreshCnf()
-          for (let key in _cnf) {
-            cnf[key] = _cnf[key]
-          }
-        }
-      })
     }
-    return this.retrieve(y).then(function () {
-      return Promise.resolve(cnf)
-    })
-  }
 
-  deinit (y) {
+    saveToMessageQueue (binary) {
-    this.ys.delete(y)
+      this.log('Room %s: Save message to message queue', this.y.options.connector.room)
-  }
+    }
 
-  destroy () {
+    saveOperations (ops) {
-    this.ys = null
+      ops = ops.map(function (op) {
-  }
+        return Y.Struct[op.struct].encode(op)
-
-  /* overwrite */
-  saveUpdate (buffer) {
-  }
-
-  /**
-   * Save struct to update buffer.
-   * saveUpdate is called when transaction ends
-   */
-  saveStruct (y, struct) {
-    let cnf = this.ys.get(y)
-    if (cnf !== undefined) {
-      this.mutualExclude(function () {
-        struct._toBinary(cnf.buffer)
-        cnf.len++
       })
+      /*
+      const saveOperations = () => {
+        if (this.saveOperationsBuffer.length > 0) {
+          let encoder = new BinaryEncoder()
+          encoder.writeVarString(this.opts.room)
+          encoder.writeVarString('update')
+          let ops = this.saveOperationsBuffer
+          this.saveOperationsBuffer = []
+          let length = ops.length
+          encoder.writeUint32(length)
+          for (var i = 0; i < length; i++) {
+            let op = ops[i]
+            Y.Struct[op.struct].binaryEncode(encoder, op)
+          }
+          this.saveToMessageQueue(encoder.createBuffer())
+        }
+      }
+      */
+      if (this.saveOperationsBuffer.length === 0) {
+        this.saveOperationsBuffer = ops
+      } else {
+        this.saveOperationsBuffer = this.saveOperationsBuffer.concat(ops)
+      }
     }
   }
 
-  /* overwrite */
+  Y.AbstractPersistence = AbstractPersistence
-  retrieve (y, model, updates) {
-    this.mutualExclude(function () {
-      y.transact(function () {
-        if (model != null) {
-          fromBinary(y, new BinaryDecoder(new Uint8Array(model)))
-          y._setContentReady()
-        }
-        if (updates != null) {
-          for (let i = 0; i < updates.length; i++) {
-            integrateRemoteStructs(y, new BinaryDecoder(new Uint8Array(updates[i])))
-            y._setContentReady()
-          }
-        }
-      })
-    })
-  }
-  /* overwrite */
-  persist (y) {
-    return toBinary(y).createBuffer()
-  }
 }

src/Struct/Delete.js

@@ -7,7 +7,7 @@ import { logID } from '../MessageHandler/messageToString.js'
  * TODO: implement getItemCleanStartNode for better performance (only one lookup)
  */
 export function deleteItemRange (y, user, clock, range) {
-  const createDelete = y.connector !== null && y.connector._forwardAppliedStructs
+  const createDelete = y.connector._forwardAppliedStructs
   let item = y.os.getItemCleanStart(new ID(user, clock))
   if (item !== null) {
     if (!item._deleted) {
@@ -70,12 +70,12 @@ export default class Delete {
       // from remote
       const id = this._targetID
       deleteItemRange(y, id.user, id.clock, this._length)
-    } else if (y.connector !== null) {
+    } else {
       // from local
       y.connector.broadcastStruct(this)
     }
     if (y.persistence !== null) {
-      y.persistence.saveStruct(y, this)
+      y.persistence.saveOperations(this)
     }
   }
   _logString () {

src/Struct/Item.js

@@ -87,18 +87,16 @@ export default class Item {
     return this._right
   }
   _delete (y, createDelete = true) {
-    if (!this._deleted) {
+    this._deleted = true
-      this._deleted = true
+    y.ds.markDeleted(this._id, this._length)
-      y.ds.markDeleted(this._id, this._length)
+    if (createDelete) {
-      if (createDelete) {
+      let del = new Delete()
-        let del = new Delete()
+      del._targetID = this._id
-        del._targetID = this._id
+      del._length = this._length
-        del._length = this._length
+      del._integrate(y, true)
-        del._integrate(y, true)
-      }
-      transactionTypeChanged(y, this._parent, this._parentSub)
-      y._transaction.deletedStructs.add(this)
     }
+    transactionTypeChanged(y, this._parent, this._parentSub)
+    y._transaction.deletedStructs.add(this)
   }
   /**
    * This is called right before this struct receives any children.
@@ -218,11 +216,11 @@ export default class Item {
     y.os.put(this)
     transactionTypeChanged(y, parent, parentSub)
     if (this._id.user !== RootFakeUserID) {
-      if (y.connector !== null && (y.connector._forwardAppliedStructs || this._id.user === y.userID)) {
+      if (y.connector._forwardAppliedStructs || this._id.user === y.userID) {
         y.connector.broadcastStruct(this)
       }
       if (y.persistence !== null) {
-        y.persistence.saveStruct(y, this)
+        y.persistence.saveOperations(this)
       }
     }
   }

src/Type/YArray.js

@@ -5,38 +5,15 @@ import { logID } from '../MessageHandler/messageToString.js'
 import YEvent from '../Util/YEvent.js'
 
 class YArrayEvent extends YEvent {
-  constructor (yarray, remote, transaction) {
+  constructor (yarray, remote) {
     super(yarray)
     this.remote = remote
-    this._transaction = transaction
-  }
-  get addedElements () {
-    const target = this.target
-    const transaction = this._transaction
-    const addedElements = new Set()
-    transaction.newTypes.forEach(function (type) {
-      if (type._parent === target && !transaction.deletedStructs.has(type)) {
-        addedElements.add(type)
-      }
-    })
-    return addedElements
-  }
-  get removedElements () {
-    const target = this.target
-    const transaction = this._transaction
-    const removedElements = new Set()
-    transaction.deletedStructs.forEach(function (struct) {
-      if (struct._parent === target && !transaction.newTypes.has(struct)) {
-        removedElements.add(struct)
-      }
-    })
-    return removedElements
   }
 }
 
 export default class YArray extends Type {
   _callObserver (transaction, parentSubs, remote) {
-    this._callEventHandler(transaction, new YArrayEvent(this, remote, transaction))
+    this._callEventHandler(transaction, new YArrayEvent(this, remote))
   }
   get (pos) {
     let n = this._start
@@ -207,12 +184,8 @@ export default class YArray extends Type {
           prevJsonIns._content.push(c)
         }
       }
-      if (prevJsonIns !== null) {
+      if (prevJsonIns !== null && y !== null) {
-        if (y !== null) {
+        prevJsonIns._integrate(y)
-          prevJsonIns._integrate(y)
-        } else if (prevJsonIns._left === null) {
-          this._start = prevJsonIns
-        }
       }
     })
   }
@@ -241,17 +214,6 @@ export default class YArray extends Type {
     }
     this.insertAfter(left, content)
   }
-  push (content) {
-    let n = this._start
-    let lastUndeleted = null
-    while (n !== null) {
-      if (!n._deleted) {
-        lastUndeleted = n
-      }
-      n = n._right
-    }
-    this.insertAfter(lastUndeleted, content)
-  }
   _logString () {
     const left = this._left !== null ? this._left._lastId : null
     const origin = this._origin !== null ? this._origin._lastId : null

src/Type/YMap.js

@@ -56,7 +56,7 @@ export default class YMap extends Type {
     this._transact(y => {
       const old = this._map.get(key) || null
       if (old !== null) {
-        if (old.constructor === ItemJSON && !old._deleted && old._content[0] === value) {
+        if (old instanceof ItemJSON && old._content[0] === value) {
           // Trying to overwrite with same value
           // break here
           return value

src/Type/YText.js

@@ -24,9 +24,6 @@ export default class YText extends YArray {
     return strBuilder.join('')
   }
   insert (pos, text) {
-    if (text.length <= 0) {
-      return
-    }
     this._transact(y => {
       let left = null
       let right = this._start

src/Type/y-xml/YXmlElement.js

@@ -1,3 +1,4 @@
+// import diff from 'fast-diff'
 import { defaultDomFilter } from './utils.js'
 
 import YMap from '../YMap.js'
@@ -47,11 +48,6 @@ export default class YXmlElement extends YXmlFragment {
       return dom
     }
   }
-  _bindToDom (dom, _document) {
-    _document = _document || document
-    this._dom = dom
-    dom._yxml = this
-  }
   _fromBinary (y, decoder) {
     const missing = super._fromBinary(y, decoder)
     this.nodeName = decoder.readVarString()

src/Type/y-xml/YXmlFragment.js

@@ -7,7 +7,7 @@ import YArray from '../YArray.js'
 import YXmlEvent from './YXmlEvent.js'
 import { YXmlText, YXmlHook } from './y-xml'
 import { logID } from '../../MessageHandler/messageToString.js'
-import diff from '../../Util/simpleDiff.js'
+import diff from 'fast-diff'
 
 function domToYXml (parent, doms, _document) {
   const types = []
@@ -17,7 +17,7 @@ function domToYXml (parent, doms, _document) {
     }
     if (parent._domFilter(d.nodeName, new Map()) !== null) {
       let type
-      const hookName = d._yjsHook || (d.dataset != null ? d.dataset.yjsHook : undefined)
+      const hookName = d._yjsHook
       if (hookName !== undefined) {
         type = new YXmlHook(hookName, d)
       } else if (d.nodeType === d.TEXT_NODE) {
@@ -55,7 +55,7 @@ class YXmlTreeWalker {
       }
     }
     do {
-      if (!n._deleted && (n.constructor === YXmlFragment._YXmlElement || n.constructor === YXmlFragment) && n._start !== null) {
+      if (!n._deleted && n.constructor === YXmlFragment._YXmlElement && n._start !== null) {
         // walk down in the tree
         n = n._start
       } else {
@@ -101,11 +101,9 @@ export default class YXmlFragment extends YArray {
         } catch (e) {
           console.error(e)
         }
-        /*
         if (this._domObserver !== null) {
           this._domObserver.takeRecords()
         }
-        */
         token = true
       }
     }
@@ -145,23 +143,6 @@ export default class YXmlFragment extends YArray {
   }
   setDomFilter (f) {
     this._domFilter = f
-    let attributes = new Map()
-    if (this.getAttributes !== undefined) {
-      let attrs = this.getAttributes()
-      for (let key in attrs) {
-        attributes.set(key, attrs[key])
-      }
-    }
-    let result = this._domFilter(this.nodeName, new Map(attributes))
-    if (result === null) {
-      this._delete(this._y)
-    } else {
-      attributes.forEach((value, key) => {
-        if (!result.has(key)) {
-          this.removeAttribute(key)
-        }
-      })
-    }
     this.forEach(xml => {
       xml.setDomFilter(f)
     })
@@ -185,9 +166,6 @@ export default class YXmlFragment extends YArray {
       this._dom._yxml = null
       this._dom = null
     }
-    if (this._beforeTransactionHandler !== undefined) {
-      this._y.off('beforeTransaction', this._beforeTransactionHandler)
-    }
   }
   insertDomElementsAfter (prev, doms, _document) {
     const types = domToYXml(this, doms, _document)
@@ -221,7 +199,9 @@ export default class YXmlFragment extends YArray {
     _document = _document || document
     this._dom = dom
     dom._yxml = this
-    if (this._parent === null) {
+    // TODO: refine this..
+    if ((this.constructor !== YXmlFragment && this._parent !== this._y) || this._parent === null) {
+      // TODO: only top level YXmlFragment can bind. Also allow YXmlElements..
       return
     }
     this._y.on('beforeTransaction', beforeTransactionSelectionFixer)
@@ -278,10 +258,9 @@ export default class YXmlFragment extends YArray {
     })
     // Apply Dom changes on Y.Xml
     if (typeof MutationObserver !== 'undefined') {
-      this._beforeTransactionHandler = () => {
+      this._y.on('beforeTransaction', () => {
         this._domObserverListener(this._domObserver.takeRecords())
-      }
+      })
-      this._y.on('beforeTransaction', this._beforeTransactionHandler)
       this._domObserverListener = mutations => {
         this._mutualExclude(() => {
           this._y.transact(() => {
@@ -295,9 +274,19 @@ export default class YXmlFragment extends YArray {
               }
               switch (mutation.type) {
                 case 'characterData':
-                  var change = diff(yxml.toString(), dom.nodeValue)
+                  var diffs = diff(yxml.toString(), dom.nodeValue)
-                  yxml.delete(change.pos, change.remove)
+                  var pos = 0
-                  yxml.insert(change.pos, change.insert)
+                  for (var i = 0; i < diffs.length; i++) {
+                    var d = diffs[i]
+                    if (d[0] === 0) { // EQUAL
+                      pos += d[1].length
+                    } else if (d[0] === -1) { // DELETE
+                      yxml.delete(pos, d[1].length)
+                    } else { // INSERT
+                      yxml.insert(pos, d[1])
+                      pos += d[1].length
+                    }
+                  }
                   break
                 case 'attributes':
                   if (yxml.constructor === YXmlFragment) {
@@ -324,9 +313,6 @@ export default class YXmlFragment extends YArray {
               }
             })
             for (let dom of diffChildren) {
-              if (dom.yOnChildrenChanged !== undefined) {
-                dom.yOnChildrenChanged()
-              }
               if (dom._yxml != null && dom._yxml !== false) {
                 applyChangesFromDom(dom)
               }

src/Type/y-xml/YXmlHook.js

@@ -24,11 +24,6 @@ export default class YXmlHook extends YMap {
     }
     return this._dom
   }
-  _unbindFromDom () {
-    this._dom._yxml = null
-    this._yxml = null
-    // TODO: cleanup hook?
-  }
   _fromBinary (y, decoder) {
     const missing = super._fromBinary(y, decoder)
     this.hookName = decoder.readVarString()

src/Type/y-xml/selection.js

@@ -68,6 +68,7 @@ export function afterTransactionSelectionFixer (y, transaction, remote) {
     }
   }
   if (shouldUpdate) {
+    console.info('updating selection!!')
     browserSelection.setBaseAndExtent(
       anchorNode,
       anchorOffset,
@@ -75,4 +76,7 @@ export function afterTransactionSelectionFixer (y, transaction, remote) {
       focusOffset
     )
   }
+  // delete, so the objects can be gc'd
+  relativeSelection = null
+  browserSelection = null
 }

src/Type/y-xml/utils.js

@@ -174,7 +174,7 @@ export function reflectChangesOnDom (events, _document) {
         // let anchorViewPosition = getAnchorViewPosition(yxml._scrollElement)
         if (yxml.constructor === YXmlText) {
           yxml._dom.nodeValue = yxml.toString()
-        } else if (event.attributesChanged !== undefined) {
+        } else {
           // update attributes
           event.attributesChanged.forEach(attributeName => {
             const value = yxml.getAttribute(attributeName)
@@ -193,27 +193,19 @@ export function reflectChangesOnDom (events, _document) {
            *       only in the attributes (above)
            */
           if (event.childListChanged && yxml.constructor !== YXmlHook) {
-            let currentChild = dom.firstChild
+            // create fragment of undeleted nodes
+            const fragment = _document.createDocumentFragment()
             yxml.forEach(function (t) {
-              let expectedChild = t.getDom(_document)
+              fragment.appendChild(t.getDom(_document))
-              if (expectedChild.parentNode === dom) {
-                // is already attached to the dom. Look for it
-                while (currentChild !== expectedChild) {
-                  let del = currentChild
-                  currentChild = currentChild.nextSibling
-                  dom.removeChild(del)
-                }
-                currentChild = currentChild.nextSibling
-              } else {
-                // this dom is not yet attached to dom
-                dom.insertBefore(expectedChild, currentChild)
-              }
             })
-            while (currentChild !== null) {
+            // remove remainding nodes
-              let tmp = currentChild.nextSibling
+            let lastChild = dom.lastChild
-              dom.removeChild(currentChild)
+            while (lastChild !== null) {
-              currentChild = tmp
+              dom.removeChild(lastChild)
+              lastChild = dom.lastChild
             }
+            // insert fragment of undeleted nodes
+            dom.appendChild(fragment)
           }
         }
         /* TODO: smartscrolling

src/Util/ID.js

@@ -11,10 +11,6 @@ export default class ID {
     return id !== null && id.user === this.user && id.clock === this.clock
   }
   lessThan (id) {
-    if (id.constructor === ID) {
+    return this.user < id.user || (this.user === id.user && this.clock < id.clock)
-      return this.user < id.user || (this.user === id.user && this.clock < id.clock)
-    } else {
-      return false
-    }
   }
 }

src/Util/NamedEventHandler.js

@@ -27,8 +27,7 @@ export default class NamedEventHandler {
     }
     const listener = this._eventListener.get(name)
     if (listener !== undefined) {
-      listener.on.delete(f)
+      listener.remove(f)
-      listener.once.delete(f)
     }
   }
   emit (name, ...args) {

src/Util/RootID.js

@@ -12,10 +12,6 @@ export default class RootID {
     return id !== null && id.user === this.user && id.name === this.name && id.type === this.type
   }
   lessThan (id) {
-    if (id.constructor === RootID) {
+    return this.user < id.user || (this.user === id.user && (this.name < id.name || (this.name === id.name && this.type < id.type)))
-      return this.user < id.user || (this.user === id.user && (this.name < id.name || (this.name === id.name && this.type < id.type)))
-    } else {
-      return true
-    }
   }
 }

src/Util/mutualExclude.js

@@ -1,15 +0,0 @@
-
-export function createMutualExclude () {
-  var token = true
-  return function mutualExclude (f) {
-    if (token) {
-      token = false
-      try {
-        f()
-      } catch (e) {
-        console.error(e)
-      }
-      token = true
-    }
-  }
-}

src/Util/relativePosition.js

@@ -2,31 +2,37 @@ import ID from './ID.js'
 import RootID from './RootID.js'
 
 export function getRelativePosition (type, offset) {
-  let t = type._start
+  if (offset === 0) {
-  while (t !== null) {
+    return ['startof', type._id.user, type._id.clock || null, type._id.name || null, type._id.type || null]
-    if (t._deleted === false) {
+  } else {
-      if (t._length > offset) {
+    let t = type._start
-        return [t._id.user, t._id.clock + offset]
+    while (t !== null) {
+      if (t._deleted === false) {
+        if (t._length >= offset) {
+          return [t._id.user, t._id.clock + offset - 1]
+        }
+        if (t._right === null) {
+          return [t._id.user, t._id.clock + t._length - 1]
+        }
+        offset -= t._length
       }
-      offset -= t._length
+      t = t._right
     }
-    t = t._right
+    return null
   }
-  return ['endof', type._id.user, type._id.clock || null, type._id.name || null, type._id.type || null]
 }
 
 export function fromRelativePosition (y, rpos) {
-  if (rpos[0] === 'endof') {
+  if (rpos[0] === 'startof') {
     let id
     if (rpos[3] === null) {
       id = new ID(rpos[1], rpos[2])
     } else {
       id = new RootID(rpos[3], rpos[4])
     }
-    const type = y.os.get(id)
     return {
-      type,
+      type: y.os.get(id),
-      offset: type.length
+      offset: 0
     }
   } else {
     let offset = 0
@@ -36,7 +42,7 @@ export function fromRelativePosition (y, rpos) {
       return null
     }
     if (!struct._deleted) {
-      offset = rpos[1] - struct._id.clock
+      offset = rpos[1] - struct._id.clock + 1
     }
     struct = struct._left
     while (struct !== null) {

src/Util/simpleDiff.js

@@ -1,19 +0,0 @@
-
-export default function simpleDiff (a, b) {
-  let left = 0 // number of same characters counting from left
-  let right = 0 // number of same characters counting from right
-  while (left < a.length && left < b.length && a[left] === b[left]) {
-    left++
-  }
-  if (left !== a.length || left !== b.length) {
-    // Only check right if a !== b
-    while (right + left < a.length && right + left < b.length && a[a.length - right - 1] === b[b.length - right - 1]) {
-      right++
-    }
-  }
-  return {
-    pos: left,
-    remove: a.length - left - right,
-    insert: b.slice(left, b.length - right)
-  }
-}

src/Y.js

@@ -22,44 +22,25 @@ import debug from 'debug'
 import Transaction from './Transaction.js'
 
 export default class Y extends NamedEventHandler {
-  constructor (room, opts, persistence) {
+  constructor (opts) {
     super()
-    this.room = room
-    if (opts != null) {
-      opts.connector.room = room
-    }
-    this._contentReady = false
     this._opts = opts
-    this.userID = generateUserID()
+    this.userID = opts._userID != null ? opts._userID : generateUserID()
     this.share = {}
     this.ds = new DeleteStore(this)
     this.os = new OperationStore(this)
     this.ss = new StateStore(this)
+    this.connector = new Y[opts.connector.name](this, opts.connector)
+    if (opts.persistence != null) {
+      this.persistence = new Y[opts.persistence.name](this, opts.persistence)
+      this.persistence.retrieveContent()
+    } else {
+      this.persistence = null
+    }
+    this.connected = true
     this._missingStructs = new Map()
     this._readyToIntegrate = []
     this._transaction = null
-    this.connector = null
-    this.connected = false
-    let initConnection = () => {
-      if (opts != null) {
-        this.connector = new Y[opts.connector.name](this, opts.connector)
-        this.connected = true
-        this.emit('connectorReady')
-      }
-    }
-    if (persistence != null) {
-      this.persistence = persistence
-      persistence._init(this).then(initConnection)
-    } else {
-      this.persistence = null
-      initConnection()
-    }
-  }
-  _setContentReady () {
-    if (!this._contentReady) {
-      this._contentReady = true
-      this.emit('content')
-    }
   }
   _beforeChange () {}
   transact (f, remote = false) {
@@ -109,6 +90,9 @@ export default class Y extends NamedEventHandler {
   set _start (start) {
     return null
   }
+  get room () {
+    return this._opts.connector.room
+  }
   define (name, TypeConstructor) {
     let id = new RootID(name, TypeConstructor)
     let type = this.os.get(id)
@@ -139,18 +123,11 @@ export default class Y extends NamedEventHandler {
     }
   }
   destroy () {
-    super.destroy()
     this.share = null
-    if (this.connector != null) {
+    if (this.connector.destroy != null) {
-      if (this.connector.destroy != null) {
+      this.connector.destroy()
-        this.connector.destroy()
+    } else {
-      } else {
+      this.connector.disconnect()
-        this.connector.disconnect()
-      }
-    }
-    if (this.persistence !== null) {
-      this.persistence.deinit(this)
-      this.persistence = null
     }
     this.os = null
     this.ds = null
@@ -178,7 +155,7 @@ Y.extend = function extendYjs () {
 
 // TODO: The following assignments should be moved to yjs-dist
 Y.AbstractConnector = Connector
-Y.AbstractPersistence = Persistence
+Y.Persisence = Persistence
 Y.Array = YArray
 Y.Map = YMap
 Y.Text = YText

test/diff.tests.js

@@ -1,29 +0,0 @@
-import { test } from '../node_modules/cutest/cutest.mjs'
-import simpleDiff from '../src/Util/simpleDiff.js'
-import Chance from 'chance'
-
-function runDiffTest (t, a, b, expected) {
-  let result = simpleDiff(a, b)
-  t.compare(result, expected, `Compare "${a}" with "${b}"`)
-}
-
-test('diff tests', async function diff1 (t) {
-  runDiffTest(t, 'abc', 'axc', { pos: 1, remove: 1, insert: 'x' })
-  runDiffTest(t, 'bc', 'xc', { pos: 0, remove: 1, insert: 'x' })
-  runDiffTest(t, 'ab', 'ax', { pos: 1, remove: 1, insert: 'x' })
-  runDiffTest(t, 'b', 'x', { pos: 0, remove: 1, insert: 'x' })
-  runDiffTest(t, '', 'abc', { pos: 0, remove: 0, insert: 'abc' })
-  runDiffTest(t, 'abc', 'xyz', { pos: 0, remove: 3, insert: 'xyz' })
-  runDiffTest(t, 'axz', 'au', { pos: 1, remove: 2, insert: 'u' })
-  runDiffTest(t, 'ax', 'axy', { pos: 2, remove: 0, insert: 'y' })
-})
-
-test('random diff tests', async function randomDiff (t) {
-  const chance = new Chance(t.getSeed() * 1000000000)
-  let a = chance.word()
-  let b = chance.word()
-  let change = simpleDiff(a, b)
-  let arr = Array.from(a)
-  arr.splice(change.pos, change.remove, ...Array.from(change.insert))
-  t.assert(arr.join('') === b, 'Applying change information is correct')
-})

test/encode-decode.js

@@ -54,9 +54,6 @@ test('varString', async function varString (t) {
   testEncoding(t, writeVarString, readVarString, 'test!')
   testEncoding(t, writeVarString, readVarString, '☺☺☺')
   testEncoding(t, writeVarString, readVarString, '1234')
-  testEncoding(t, writeVarString, readVarString, '쾟')
-  testEncoding(t, writeVarString, readVarString, '龟') // surrogate length 3
-  testEncoding(t, writeVarString, readVarString, '😝') // surrogate length 4
 })
 
 test('varString random', async function varStringRandom (t) {

test/index.html

@@ -3,6 +3,6 @@
   <head>
   </head>
   <body>
-    <script type="module" src="./index.js"></script>
+    <script type="module" src="./encode-decode.js"></script>
   </body>
 </html>

test/index.js

@@ -1,6 +0,0 @@
-import './red-black-tree.js'
-import './y-array.tests.js'
-import './y-map.tests.js'
-import './y-xml.tests.js'
-import './encode-decode.tests.js'
-import './diff.tests.js'

test/y-xml.tests.js

@@ -280,6 +280,7 @@ test('deep element insert', async function xml16 (t) {
   deepElement.append(boldElement)
   deepElement.append(attrElement)
   dom0.append(deepElement)
+  console.log(dom0.outerHTML)
   let str0 = dom0.outerHTML
   await flushAll(t, users)
   let str1 = dom1.outerHTML
@@ -339,6 +340,7 @@ test('Filtering remote changes', async function xmlFilteringRemote (t) {
   // check dom
   paragraph.getDom().setAttribute('malicious', 'true')
   span.getDom().setAttribute('malicious', 'true')
+  console.log(xml0.toString())
   // check incoming attributes
   xml1.get(0).get(0).setAttribute('malicious', 'true')
   xml1.insert(0, [new Y.XmlElement('hideMe')])

tests-lib/helper.js

@@ -145,7 +145,7 @@ export async function initArrays (t, opts) {
     } else {
       connOpts = Object.assign({ role: 'slave' }, conn)
     }
-    let y = new Y(connOpts.room, {
+    let y = new Y({
       _userID: i, // evil hackery, don't try this at home
       connector: connOpts
     })