Deploy v11.2.6 (hot fix for #54 )

2016-09-28 13:33:50 +02:00
11 changed files with 342 additions and 505 deletions
--- a/Examples/Drawing/index.js
+++ b/Examples/Drawing/index.js
@@ -43,7 +43,9 @@ Y({
  // call drawLine every time an array is appended
  y.share.drawing.observe(function (event) {
    if (event.type === 'insert') {
-      event.values.forEach(drawLine)
+      event.values().then(function (values) {
        values.forEach(drawLine)
      })
    } else {
      // just remove all elements (thats what we do anyway)
      svg.selectAll('path').remove()
@@ -51,7 +53,7 @@ Y({
  })
  // draw all existing content
  for (var i = 0; i < drawing.length; i++) {
-    drawLine(drawing.get(i))
+    drawing.get(i).then(drawLine)
  }
  // clear canvas on request
@@ -62,7 +64,9 @@ Y({
  var sharedLine = null
  function dragstart () {
    drawing.insert(drawing.length, [Y.Array])
-    sharedLine = drawing.get(drawing.length - 1)
+    drawing.get(drawing.length - 1).then(function (array) {
      sharedLine = array
    })
  }
  // After one dragged event is recognized, we ignore them for 33ms.
--- a/Examples/Quill/index.html
+++ b/Examples/Quill/index.html
@@ -1,9 +1,7 @@
 <!DOCTYPE html>
 <html>
 <head>
-  <!-- quill does not include dist files! We are using the hosted version instead -->
+  <link rel="stylesheet" href="../bower_components/quill/dist/quill.snow.css" />
  <!--link rel="stylesheet" href="../bower_components/quill/dist/quill.snow.css" /-->
  <link href="https://cdn.quilljs.com/1.0.4/quill.snow.css" rel="stylesheet">
  <link href="//cdnjs.cloudflare.com/ajax/libs/KaTeX/0.5.1/katex.min.css" rel="stylesheet"> 
  <link href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.2.0/styles/monokai-sublime.min.css" rel="stylesheet">
  <style>
@@ -19,12 +17,10 @@
    </div>
  </div>
  <!-- Include the Quill library -->
  <script src="//cdnjs.cloudflare.com/ajax/libs/KaTeX/0.5.1/katex.min.js" type="text/javascript"></script>
  <script src="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.2.0/highlight.min.js" type="text/javascript"></script>
  <script src="https://cdn.quilljs.com/1.0.4/quill.js"></script>
  <!-- quill does not include dist files! We are using the hosted version instead (see above)
  <script src="../bower_components/quill/dist/quill.js"></script>
  -->
  <script src="../bower_components/yjs/y.es6"></script>
  <script src="./index.js"></script>
 </body>
--- a/Examples/Quill/index.js
+++ b/Examples/Quill/index.js
@@ -7,8 +7,8 @@ Y({
    name: 'memory'
  },
  connector: {
-    name: 'websockets-client',
+    name: 'webrtc',
-    room: 'richtext-example-quill-1.0-test'
+    room: 'richtext-example-quill-beta'
  },
  sourceDir: '/bower_components',
  share: {
@@ -36,4 +36,5 @@ Y({
  });
  // bind quill to richtext type
  y.share.richtext.bind(window.quill)
-})
+})
--- a/Examples/Xml/index.js
+++ b/Examples/Xml/index.js
@@ -16,6 +16,8 @@ Y({
 }).then(function (y) {
  window.yXml = y
  // bind xml type to a dom, and put it in body
-  window.sharedDom = y.share.xml.getDom()
+  y.share.xml.getDom().then(function (dom) {
-  document.body.appendChild(window.sharedDom)
+    window.sharedDom = dom
    document.body.appendChild(dom)
  })
 })
--- a/Examples/bower.json
+++ b/Examples/bower.json
@@ -19,7 +19,7 @@
    "y-text": "latest",
    "y-indexeddb": "latest",
    "y-xml": "latest",
-    "quill": "^1.0.0-rc.2",
+    "quill": "~0.20.1",
    "ace": "~1.2.3",
    "ace-builds": "~1.2.3",
    "jquery": "~2.2.2",
--- a/README.md
+++ b/README.md
@@ -1,142 +1,100 @@
 # ![Yjs](http://y-js.org/images/yjs.png)
-Yjs is a framework for offline-first p2p shared editing on structured data like text, richtext, json, or XML.
+Yjs is a framework for optimistic concurrency control and automatic conflict resolution on shared data.
-It is fairly easy to get started, as Yjs hides most of the complexity of concurrent editing.
+The framework provides similar functionality as [ShareJs] and [OpenCoweb], but supports peer-to-peer
-For additional information, demos, and tutorials visit [y-js.org](http://y-js.org/).
+communication protocols by default. Yjs was designed to handle concurrent actions on arbitrary data
 like Text, Json, and XML. We also provide support for storing and manipulating your shared data offline.
 For more information and demo applications visit our [homepage](http://y-js.org/).
-### Extensions
+You can create you own shared types easily.
-Yjs only knows how to resolve conflicts on shared data. You have to choose a ..
+Therefore, you can design the structure of your custom type,
-* *Connector* - a communication protocol that propagates changes to the clients 
+and ensure data validity, while Yjs ensures data consistency (everyone will eventually end up with the same data).
-* *Database* - a database to store your changes
+We already provide abstract data types for
 * one or more *Types* - that represent the shared data
 Connectors, Databases, and Types are available as modules that extend Yjs. Here is a list of the modules we know of:
 ##### Connectors
 |Name            | Description               |
 |----------------|-----------------------------------|
 |[webrtc](https://github.com/y-js/y-webrtc) | Propagate updates Browser2Browser via WebRTC|
 |[websockets](https://github.com/y-js/y-websockets-client) | Set up [a central server](https://github.com/y-js/y-websockets-client), and connect to it via websockets |
 |[xmpp](https://github.com/y-js/y-xmpp) | Propagate updates in a XMPP multi-user-chat room ([XEP-0045](http://xmpp.org/extensions/xep-0045.html))|
 |[test](https://github.com/y-js/y-test) | A Connector for testing purposes. It is designed to simulate delays that happen in worst case scenarios|
 ##### Database adapters
 |Name            | Description               |
 |----------------|-----------------------------------|
 |[memory](https://github.com/y-js/y-memory) | In-memory storage. |
 |[indexeddb](https://github.com/y-js/y-indexeddb) | Offline storage for the browser |
 |[leveldb](https://github.com/y-js/y-leveldb) | Persistent storage for node apps |
 ##### Types
 | Name     | Description       |
 |----------|-------------------|
 |[map](https://github.com/y-js/y-map) | A shared Map implementation. Maps from text to any stringify-able object |
 |[array](https://github.com/y-js/y-array) | A shared Array implementation |
 |[xml](https://github.com/y-js/y-xml) | An implementation of the DOM. You can create a two way binding to Browser DOM objects |
-|[text](https://github.com/y-js/y-text) | Collaborate on text. Supports two way binding to the [Ace Editor](https://ace.c9.io), textareas, input elements, and HTML elements (e.g. <*h1*>, or <*p*>) |
+|[text](https://github.com/y-js/y-text) | Collaborate on text. Supports two way binding to textareas, input elements, or HTML elements (e.g. <*h1*>, or <*p*>). Also supports the [Ace Editor](https://ace.c9.io) |
 |[richtext](https://github.com/y-js/y-richtext) | Collaborate on rich text. Supports two way binding to the [Quill Rich Text Editor](http://quilljs.com/)|
-## Use it! 
+Yjs supports P2P message propagation, and is not bound to a specific communication protocol. Therefore, Yjs is extremely scalable and can be used in a wide range of application scenarios.
-Install Yjs, and its modules with [bower](http://bower.io/), or [npm](https://www.npmjs.org/package/yjs).
+
 We support several communication protocols as so called *Connectors*.
 You can create your own connector too - read [this wiki page](https://github.com/y-js/yjs/wiki/Custom-Connectors).
 Currently, we support the following communication protocols:
 |Name            | Description               |
 |----------------|-----------------------------------|
 |[xmpp](https://github.com/y-js/y-xmpp) | Propagate updates in a XMPP multi-user-chat room ([XEP-0045](http://xmpp.org/extensions/xep-0045.html))|
 |[webrtc](https://github.com/y-js/y-webrtc) | Propagate updates Browser2Browser via WebRTC|
 |[websockets](https://github.com/y-js/y-websockets-client) | Exchange updates efficiently in the classical client-server model |
 |[test](https://github.com/y-js/y-test) | A Connector for testing purposes. It is designed to simulate delays that happen in worst case scenarios|
 You are not limited to use a specific database to store the shared data. We provide the following database adapters:
 |Name            | Description               |
 |----------------|-----------------------------------|
 |[memory](https://github.com/y-js/y-memory) | In-memory storage. |
 |[indexeddb](https://github.com/y-js/y-indexeddb) | Offline storage for the browser |
 The advantages over similar frameworks are support for
 * .. P2P message propagation and arbitrary communication protocols
 * .. share any type of data. The types provide a convenient interface
 * .. offline support: Changes are stored persistently and only relevant changes are propagated on rejoin
 * .. Intention Preservation: When working on Text, the intention of your changes are preserved. This is particularily important when working offline. Every type has a notion on how we define Intention Preservation on it.
 ## Use it!
 Install yjs and its modules with [bower](http://bower.io/), or with [npm](https://www.npmjs.org/package/yjs).
 ### Bower
 ```
-bower install --save yjs y-array % add all y-* modules you want to use
+bower install yjs --save
 ```
-You only need to include the `y.js` file. Yjs is able to automatically require missing modules.  
+Then you include the libraries directly from the installation folder.
 ```
 <script src="./bower_components/yjs/y.js"></script>
 ```
 ### Npm
 ```
-npm install --save yjs % add all y-* modules you want to use
+npm install yjs --save
 ```
-If you don't include via script tag, you have to explicitly include all modules! (Same goes for other module systems)
+And use it like this with *npm*:
 ```
-var Y = require('yjs')
+Y = require("yjs");
 require('y-array')(Y) // add the y-array type to Yjs
 require('y-websockets-client')(Y)
 require('y-memory')(Y)
 require('y-array')(Y)
 require('y-map')(Y)
 require('y-text')(Y)
 // ..
 // do the same for all modules you want to use
 ```
 ### ES6 Syntax
 ```
 import Y from 'yjs'
 import yArray from 'y-array'
 import yWebsocketsClient from 'y-webrtc'
 import yMemory from 'y-memory'
 import yArray from 'y-array'
 import yMap from 'y-map'
 import yText from 'y-text'
 // ..
 Y.extend(yArray, yWebsocketsClient, yMemory, yArray, yMap, yText /*, .. */)
 ```
 # Text editing example
 Install dependencies
 ```
-bower i yjs y-memory y-webrtc y-array y-text
+Y({
  db: {
    name: 'memory' // store in memory.
    // name: 'indexeddb'
  },
  connector: {
    name: 'websockets-client', // choose the websockets connector
    // name: 'webrtc'
    // name: 'xmpp'
    room: 'Textarea-example-dev'
  },
  sourceDir: '/bower_components', // location of the y-* modules
  share: {
    textarea: 'Text' // y.share.textarea is of type Y.Text
  }
  // types: ['Richtext', 'Array'] // optional list of types you want to import
 }).then(function (y) {
  // bind the textarea to a shared text element
  y.share.textarea.bind(document.getElementById('textfield'))
 }
 ```
-Here is a simple example of a shared textarea
+# Api
 ```HTML
  <!DOCTYPE html>
  <html>
    <body>
      <script src="./bower_components/yjs/y.js"></script>
      <!-- Yjs automatically includes all missing dependencies (browser only) -->
      <script>
        Y({
          db: {
            name: 'memory' // use memory database adapter.
            // name: 'indexeddb' // use indexeddb database adapter instead for offline apps
          },
          connector: {
            name: 'webrtc', // use webrtc connector
            // name: 'websockets-client'
            // name: 'xmpp'
            room: 'my-room' // clients connecting to the same room share data 
          },
          sourceDir: '/bower_components', // location of the y-* modules (browser only)
          share: {
            textarea: 'Text' // y.share.textarea is of type y-text
          }
        }).then(function (y) {
          // The Yjs instance `y` is available
          // y.share.* contains the shared types
          // Bind `y.share.textarea` to `<textarea/>`
          y.share.textarea.bind(document.querySelector('textarea'))
        })
      </script>
      <textarea></textarea>
    </body>
  </html>
 ```
 ## Get Help & Give Help
 There are some friendly people on [![Gitter](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/y-js/yjs?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge) who are eager to help, and answer questions. Please join!
 Report _any_ issues to the [Github issue page](https://github.com/y-js/yjs/issues)! I try to fix them very soon, if possible.
 # API
 ### Y(options)
 * Y.extend(module1, module2, ..)
  * Add extensions to Y
  * `Y.extend(require('y-webrtc'))` has the same semantics as `require('y-webrtc')(Y)` 
 * options.db
  * Will be forwarded to the database adapter. Specify the database adaper on `options.db.name`.
  * Have a look at the used database adapter repository to see all available options.
@@ -146,14 +104,14 @@ Report _any_ issues to the [Github issue page](https://github.com/y-js/yjs/issue
  * All of our connectors specify an `url` property that defines the connection endpoint of the used connector.
    * All of our connectors also have a default connection endpoint that you can use for development. 
  * Have a look at the used connector repository to see all available options.
-* options.sourceDir (browser only)
+* options.sourceDir
-  * Path where all y-* modules are stored
+  * Path where all y-* modules are stored.
  * Defaults to `/bower_components`
  * Not required when running on `nodejs` / `iojs`
-  * When using nodejs you need to manually extend Yjs:
+  * When using browserify you can specify all used modules like this:
 ```
 var Y = require('yjs')
-// you have to require a db, connector, and *all* types you use! 
+// you need to require the db, connector, and *all* types you use! 
 require('y-memory')(Y)
 require('y-webrtc')(Y)
 require('y-map')(Y)
@@ -161,13 +119,13 @@ require('y-map')(Y)
 ``` 
 * options.share
  * Specify on `options.share[arbitraryName]` types that are shared among all users.
-  * E.g. Specify `options.share[arbitraryName] = 'Array'` to require y-array and create an y-array type on `y.share[arbitraryName]`.
+  * E.g. Specify `options.share[arbitraryName] = 'Array'` to require y-array and create an Y.Array type on `y.share[arbitraryName]`.
  * If userA doesn't specify `options.share[arbitraryName]`, it won't be available for userA.
  * If userB specifies `options.share[arbitraryName]`, it still won't be available for userA. But all the updates are send from userB to userA.
-  * In contrast to y-map, types on `y.share.*` cannot be overwritten or deleted. Instead, they are merged among all users. This feature is only available on `y.share.*`
+  * In contrast to Y.Map, types on `y.share.*` cannot be overwritten or deleted. Instead, they are merged among all users. This feature is only available on `y.share.*`
  * Weird behavior: It is supported that two users specify different types with the same property name.
-     E.g. userA specifies `options.share.x = 'Array'`, and userB specifies `options.share.x = 'Text'`. But they only share data if they specified the same type with the same property name
+     E.g. userA specifies `options.share.x = 'Array'`, and userB specifies `options.share.x = 'Text'`. But they'll only share data if they specified the same type with the same property name
-* options.type (browser only)
+* options.type
  * Array of modules that Yjs needs to require, before instantiating a shared type.
  * By default Yjs requires the specified database adapter, the specified connector, and all modules that are used in `options.share.*`
  * Put all types here that you intend to use, but are not used in y.share.*
@@ -198,39 +156,32 @@ The promise returns an instance of Y. We denote it with a lower case `y`.
  * Force to disconnect this instance from the other instances
 * y.connector.reconnect()
  * Try to reconnect to the other instances (needs to be supported by the connector)
-  * Not supported by y-xmpp
+  * Not supported by y-xmpp 
-* y.close()
+* y.destroy()
  * Destroy this object.
  * Destroys all types (they will throw weird errors if you still use them)
  * Disconnects from the other instances (via connector)
  * Returns a promise
 * y.destroy()
  * calls y.close()
  * Removes all data from the database
  * Returns a promise
 * y.db.stopGarbageCollector()
  * Stop the garbage collector. Call y.db.garbageCollect() to continue garbage collection
 * y.db.gc :: Boolean
  * Whether gc is turned on
 * y.db.gcTimeout :: Number (defaults to 50000 ms)
  * Time interval between two garbage collect cycles
  * It is required that all instances exchanged all messages after two garbage collect cycles (after 100000 ms per default)
 * y.db.userId :: String
  * The used user id for this client. **Never overwrite this**
-## Changelog
+## Get help
 There are some friendly people on [![Gitter](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/y-js/yjs?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge) who may help you with your problem, and answer your questions.
-### 12.0.0
+Please report _any_ issues to the [Github issue page](https://github.com/y-js/yjs/issues)! I try to fix them very soon, if possible.
-* **Types are synchronous and never return a promise (except explicitly stated)**
+If you want to see an issue fixed, please subscribe to the thread (or remind me via gitter).
-  * `y.share.map.get('map type') // => returns a y-map instead of a promise`
+
-  * The event property `oldValues`, and `values` contain a list of values (without wrapper)
+
-* Support for the [y-leveldb](https://github.com/y-js/y-leveldb) database adapter
+## Changelog
 * [y-richtext](https://github.com/y-js/y-richtext) supports Quill@1.0.0-rc.2
 * Only the types are affected by this release. You have to upgrade y-array@10.0.0, y-map@10.0.0, y-richtext@9.0.0, and y-xml@10.0.0
 ### 11.0.0
-* **All types return a single event instead of list of events**
+* **All types now return a single event instead of list of events**
  * Insert events contain a list of values
 * Improved performance for large insertions & deletions
 * Several bugfixes (offline editing related)
@@ -244,7 +195,7 @@ The promise returns an instance of Y. We denote it with a lower case `y`.
 ### 9.0.0
 There were several rolling updates from 0.6 to 0.8. We consider Yjs stable since a long time, 
 and intend to continue stable releases. From this release forward y-* modules will implement peer-dependencies for npm, and dependencies for bower.
-Furthermore, incompatible yjs instances throw errors now when syncing - this feature was influenced by #48. The versioning jump was influenced by react (see [here](https://facebook.github.io/react/blog/2016/02/19/new-versioning-scheme.html))
+Furthermore, incompatible yjs instances will now throw errors when syncing - this feature was influenced by #48. The versioning jump was influenced by react (see [here](https://facebook.github.io/react/blog/2016/02/19/new-versioning-scheme.html))
 ### 0.6.0
@@ -264,7 +215,10 @@ This is a complete rewrite of the 0.5 version of Yjs. Since Yjs 0.6.0 it is poss
 I created this framework during my bachelor thesis at the chair of computer science 5 [(i5)](http://dbis.rwth-aachen.de/cms), RWTH University. Since December 2014 I'm working on Yjs as a part of my student worker job at the i5.
 ## License
-Yjs is licensed under the [MIT License](./LICENSE).
+Yjs is licensed under the [MIT License](./LICENSE.txt).
 <yjs@dbis.rwth-aachen.de>
 [ShareJs]: https://github.com/share/ShareJS
 [OpenCoweb]: https://github.com/opencoweb/coweb/wiki
--- a/bower.json
+++ b/bower.json
@@ -1,6 +1,6 @@
 {
  "name": "yjs",
-  "version": "12.1.2",
+  "version": "11.2.6",
  "homepage": "y-js.org",
  "authors": [
    "Kevin Jahns <kevin.jahns@rwth-aachen.de>"
--- a/y.es6
+++ b/y.es6
@@ -2,9 +2,6 @@
 /* @flow */
 'use strict'
 function canRead (auth) { return auth === 'read' || auth === 'write' }
 function canWrite (auth) { return auth === 'write' }
 module.exports = function (Y/* :any */) {
  class AbstractConnector {
    /* ::
@@ -58,8 +55,6 @@ module.exports = function (Y/* :any */) {
      this.syncStep2 = Promise.resolve()
      this.broadcastOpBuffer = []
      this.protocolVersion = 11
      this.authInfo = opts.auth || null
      this.checkAuth = opts.checkAuth || function () { return Promise.resolve('write') } // default is everyone has write access
    }
    reconnect () {
    }
@@ -93,9 +88,6 @@ module.exports = function (Y/* :any */) {
    onUserEvent (f) {
      this.userEventListeners.push(f)
    }
    removeUserEventListener (f) {
      this.userEventListeners = this.userEventListeners.filter(g => { f !== g })
    }
    userLeft (user) {
      if (this.connections[user] != null) {
        delete this.connections[user]
@@ -145,8 +137,13 @@ module.exports = function (Y/* :any */) {
        this.whenSyncedListeners.push(f)
      }
    }
    /*
     returns false, if there is no sync target
     true otherwise
    */
    findNextSyncTarget () {
-      if (this.currentSyncTarget != null) {
+      if (this.currentSyncTarget != null || this.isSynced) {
        return // "The current sync has not finished!"
      }
@@ -167,25 +164,20 @@ module.exports = function (Y/* :any */) {
            type: 'sync step 1',
            stateSet: stateSet,
            deleteSet: deleteSet,
-            protocolVersion: conn.protocolVersion,
+            protocolVersion: conn.protocolVersion
            auth: conn.authInfo
          })
        })
      } else {
-        if (!conn.isSynced) {
+        this.y.db.requestTransaction(function *() {
-          this.y.db.requestTransaction(function *() {
+          // it is crucial that isSynced is set at the time garbageCollectAfterSync is called
-            if (!conn.isSynced) {
+          conn.isSynced = true
-              // it is crucial that isSynced is set at the time garbageCollectAfterSync is called
+          yield* this.garbageCollectAfterSync()
-              conn.isSynced = true
+          // call whensynced listeners
-              yield* this.garbageCollectAfterSync()
+          for (var f of conn.whenSyncedListeners) {
-              // call whensynced listeners
+            f()
-              for (var f of conn.whenSyncedListeners) {
+          }
-                f()
+          conn.whenSyncedListeners = []
-              }
+        })
              conn.whenSyncedListeners = []
            }
          })
        }
      }
    }
    send (uid, message) {
@@ -226,7 +218,7 @@ module.exports = function (Y/* :any */) {
    */
    receiveMessage (sender/* :UserId */, message/* :Message */) {
      if (sender === this.userId) {
-        return Promise.resolve()
+        return
      }
      if (this.debug) {
        console.log(`receive ${sender} -> ${this.userId}: ${message.type}`, JSON.parse(JSON.stringify(message))) // eslint-disable-line
@@ -241,118 +233,91 @@ module.exports = function (Y/* :any */) {
          type: 'sync stop',
          protocolVersion: this.protocolVersion
        })
-        return Promise.reject('Incompatible protocol version')
+        return
      }
-      if (message.auth != null && this.connections[sender] != null) {
+      if (message.type === 'sync step 1') {
-        // authenticate using auth in message
+        let conn = this
-        var auth = this.checkAuth(message.auth, this.y)
+        let m = message
-        this.connections[sender].auth = auth
+        this.y.db.requestTransaction(function *() {
-        auth.then(auth => {
+          var currentStateSet = yield* this.getStateSet()
-          for (var f of this.userEventListeners) {
+          yield* this.applyDeleteSet(m.deleteSet)
            f({
              action: 'userAuthenticated',
              user: sender,
              auth: auth
            })
          }
        })
      } else if (this.connections[sender] != null && this.connections[sender].auth == null) {
        // authenticate without otherwise
        this.connections[sender].auth = this.checkAuth(null, this.y)
      }
      if (this.connections[sender] != null && this.connections[sender].auth != null) {
        return this.connections[sender].auth.then((auth) => {
          if (message.type === 'sync step 1' && canRead(auth)) {
            let conn = this
            let m = message
-            this.y.db.requestTransaction(function *() {
+          var ds = yield* this.getDeleteSet()
-              var currentStateSet = yield* this.getStateSet()
+          var ops = yield* this.getOperations(m.stateSet)
-              if (canWrite(auth)) {
+          conn.send(sender, {
-                yield* this.applyDeleteSet(m.deleteSet)
+            type: 'sync step 2',
-              }
+            os: ops,
-
+            stateSet: currentStateSet,
-              var ds = yield* this.getDeleteSet()
+            deleteSet: ds,
-              var ops = yield* this.getOperations(m.stateSet)
+            protocolVersion: this.protocolVersion
          })
          if (this.forwardToSyncingClients) {
            conn.syncingClients.push(sender)
            setTimeout(function () {
              conn.syncingClients = conn.syncingClients.filter(function (cli) {
                return cli !== sender
              })
              conn.send(sender, {
-                type: 'sync step 2',
+                type: 'sync done'
                os: ops,
                stateSet: currentStateSet,
                deleteSet: ds,
                protocolVersion: this.protocolVersion,
                auth: this.authInfo
              })
-              if (this.forwardToSyncingClients) {
+            }, 5000) // TODO: conn.syncingClientDuration)
-                conn.syncingClients.push(sender)
+          } else {
-                setTimeout(function () {
+            conn.send(sender, {
-                  conn.syncingClients = conn.syncingClients.filter(function (cli) {
+              type: 'sync done'
                    return cli !== sender
                  })
                  conn.send(sender, {
                    type: 'sync done'
                  })
                }, 5000) // TODO: conn.syncingClientDuration)
              } else {
                conn.send(sender, {
                  type: 'sync done'
                })
              }
              conn._setSyncedWith(sender)
            })
          } else if (message.type === 'sync step 2' && canWrite(auth)) {
            let conn = this
            var broadcastHB = !this.broadcastedHB
            this.broadcastedHB = true
            var db = this.y.db
            var defer = {}
            defer.promise = new Promise(function (resolve) {
              defer.resolve = resolve
            })
            this.syncStep2 = defer.promise
            let m /* :MessageSyncStep2 */ = message
            db.requestTransaction(function * () {
              yield* this.applyDeleteSet(m.deleteSet)
              this.store.apply(m.os)
              db.requestTransaction(function * () {
                var ops = yield* this.getOperations(m.stateSet)
                if (ops.length > 0) {
                  if (!broadcastHB) { // TODO: consider to broadcast here..
                    conn.send(sender, {
                      type: 'update',
                      ops: ops
                    })
                  } else {
                    // broadcast only once!
                    conn.broadcastOps(ops)
                  }
                }
                defer.resolve()
              })
            })
          } else if (message.type === 'sync done') {
            var self = this
            this.syncStep2.then(function () {
              self._setSyncedWith(sender)
            })
          } else if (message.type === 'update' && canWrite(auth)) {
            if (this.forwardToSyncingClients) {
              for (var client of this.syncingClients) {
                this.send(client, message)
              }
            }
            if (this.y.db.forwardAppliedOperations) {
              var delops = message.ops.filter(function (o) {
                return o.struct === 'Delete'
              })
              if (delops.length > 0) {
                this.broadcastOps(delops)
              }
            }
            this.y.db.apply(message.ops)
          }
          conn._setSyncedWith(sender)
        })
-      } else {
+      } else if (message.type === 'sync step 2') {
-        return Promise.reject('Unable to deliver message')
+        let conn = this
        var broadcastHB = !this.broadcastedHB
        this.broadcastedHB = true
        var db = this.y.db
        var defer = {}
        defer.promise = new Promise(function (resolve) {
          defer.resolve = resolve
        })
        this.syncStep2 = defer.promise
        let m /* :MessageSyncStep2 */ = message
        db.requestTransaction(function * () {
          yield* this.applyDeleteSet(m.deleteSet)
          this.store.apply(m.os)
          db.requestTransaction(function * () {
            var ops = yield* this.getOperations(m.stateSet)
            if (ops.length > 0) {
              if (!broadcastHB) { // TODO: consider to broadcast here..
                conn.send(sender, {
                  type: 'update',
                  ops: ops
                })
              } else {
                // broadcast only once!
                conn.broadcastOps(ops)
              }
            }
            defer.resolve()
          })
        })
      } else if (message.type === 'sync done') {
        var self = this
        this.syncStep2.then(function () {
          self._setSyncedWith(sender)
        })
      } else if (message.type === 'update') {
        if (this.forwardToSyncingClients) {
          for (var client of this.syncingClients) {
            this.send(client, message)
          }
        }
        if (this.y.db.forwardAppliedOperations) {
          var delops = message.ops.filter(function (o) {
            return o.struct === 'Delete'
          })
          if (delops.length > 0) {
            this.broadcastOps(delops)
          }
        }
        this.y.db.apply(message.ops)
      }
    }
    _setSyncedWith (user) {
@@ -486,21 +451,11 @@ module.exports = function (Y) {
      }
    },
    whenTransactionsFinished: function () {
-      var self = this
+      var ps = []
-      return new Promise(function (resolve, reject) {
+      for (var name in this.users) {
-        // The connector first has to send the messages to the db.
+        ps.push(this.users[name].y.db.whenTransactionsFinished())
-        // Wait for the checkAuth-function to resolve
+      }
-        // The test lib only has a simple checkAuth function: `() => Promise.resolve()`
+      return Promise.all(ps)
        // Just add a function to the event-queue, in order to wait for the event.
        // TODO: this may be buggy in test applications (but it isn't be for real-life apps)
        setTimeout(function () {
          var ps = []
          for (var name in self.users) {
            ps.push(self.users[name].y.db.whenTransactionsFinished())
          }
          Promise.all(ps).then(resolve, reject)
        }, 0)
      })
    },
    flushOne: function flushOne () {
      var bufs = []
@@ -526,9 +481,8 @@ module.exports = function (Y) {
          delete buff[sender]
        }
        var user = globalRoom.users[userId]
-        return user.receiveMessage(m[0], m[1]).then(function () {
+        user.receiveMessage(m[0], m[1])
-          return user.y.db.whenTransactionsFinished()
+        return user.y.db.whenTransactionsFinished()
        }, function () {})
      } else {
        return false
      }
@@ -545,14 +499,16 @@ module.exports = function (Y) {
            }
            globalRoom.whenTransactionsFinished().then(nextFlush)
          } else {
-            c = globalRoom.flushOne()
+            setTimeout(function () {
-            if (c) {
+              var c = globalRoom.flushOne()
-              c.then(function () {
+              if (c) {
-                globalRoom.whenTransactionsFinished().then(nextFlush)
+                c.then(function () {
-              })
+                  globalRoom.whenTransactionsFinished().then(nextFlush)
-            } else {
+                })
-              resolve()
+              } else {
-            }
+                resolve()
              }
            }, 0)
          }
        }
        globalRoom.whenTransactionsFinished().then(nextFlush)
@@ -578,7 +534,7 @@ module.exports = function (Y) {
      this.syncingClientDuration = 0
    }
    receiveMessage (sender, m) {
-      return super.receiveMessage(sender, JSON.parse(JSON.stringify(m)))
+      super.receiveMessage(sender, JSON.parse(JSON.stringify(m)))
    }
    send (userId, message) {
      var buffer = globalRoom.buffers[userId]
@@ -625,7 +581,7 @@ module.exports = function (Y) {
          if (buff[sender].length === 0) {
            delete buff[sender]
          }
-          yield this.receiveMessage(m[0], m[1])
+          this.receiveMessage(m[0], m[1])
        }
        yield self.whenTransactionsFinished()
      })
@@ -713,18 +669,12 @@ module.exports = function (Y /* :any */) {
      }
      this.gc1 = [] // first stage
      this.gc2 = [] // second stage -> after that, remove the op
-      this.gc = opts.gc == null || opts.gc
+      this.gcTimeout = !opts.gcTimeout ? 50000 : opts.gcTimeouts
      if (this.gc) {
        this.gcTimeout = !opts.gcTimeout ? 50000 : opts.gcTimeout
      } else {
        this.gcTimeout = -1
      }
      function garbageCollect () {
        return os.whenTransactionsFinished().then(function () {
          if (os.gc1.length > 0 || os.gc2.length > 0) {
-            if (!os.y.connector.isSynced) {
+            if (!os.y.isConnected()) {
-              console.warn('gc should be empty when not synced!')
+              console.warn('gc should be empty when disconnected!')
            }
            return new Promise((resolve) => {
              os.requestTransaction(function * () {
@@ -793,7 +743,7 @@ module.exports = function (Y /* :any */) {
      clearInterval(this.repairCheckIntervalHandler)
    }
    queueGarbageCollector (id) {
-      if (this.y.connector.isSynced && this.gc) {
+      if (this.y.isConnected()) {
        this.gc1.push(id)
      }
    }
@@ -848,7 +798,7 @@ module.exports = function (Y /* :any */) {
      TODO: rename this function
      Rulez:
-      * Only gc if this user is online & gc turned on
+      * Only gc if this user is online
      * The most left element in a list must not be gc'd.
        => There is at least one element in the list
@@ -857,9 +807,7 @@ module.exports = function (Y /* :any */) {
    * addToGarbageCollector (op, left) {
      if (
        op.gc == null &&
-        op.deleted === true &&
+        op.deleted === true
        this.store.gc &&
        this.store.y.connector.isSynced
      ) {
        var gc = false
        if (left != null && left.deleted === true) {
@@ -885,7 +833,10 @@ module.exports = function (Y /* :any */) {
      this.gc2 = this.gc2.filter(filter)
      delete op.gc
    }
-    destroyTypes () {
+    * destroy () {
      clearInterval(this.gcInterval)
      this.gcInterval = null
      this.stopRepairCheck()
      for (var key in this.initializedTypes) {
        var type = this.initializedTypes[key]
        if (type._destroy != null) {
@@ -895,11 +846,6 @@ module.exports = function (Y /* :any */) {
        }
      }
    }
    * destroy () {
      clearInterval(this.gcInterval)
      this.gcInterval = null
      this.stopRepairCheck()
    }
    setUserId (userId) {
      if (!this.userIdPromise.inProgress) {
        this.userIdPromise.inProgress = true
@@ -1082,7 +1028,8 @@ module.exports = function (Y /* :any */) {
     */
    * operationAdded (transaction, op) {
      if (op.struct === 'Delete') {
-        var type = this.initializedTypes[JSON.stringify(op.targetParent)]
+        var target = yield* transaction.getInsertion(op.target)
        var type = this.initializedTypes[JSON.stringify(target.parent)]
        if (type != null) {
          yield* type._changed(transaction, op)
        }
@@ -1150,8 +1097,10 @@ module.exports = function (Y /* :any */) {
            resolve: resolve,
            promise: promise
          }
          return promise
        } else {
          return this.transactionsFinished.promise
        }
        return this.transactionsFinished.promise
      } else {
        return Promise.resolve()
      }
@@ -1188,48 +1137,6 @@ module.exports = function (Y /* :any */) {
        }, 0)
      }
    }
    /*
      Get a created/initialized type.
    */
    getType (id) {
      return this.initializedTypes[JSON.stringify(id)]
    }
    /*
      Init type. This is called when a remote operation is retrieved, and transformed to a type
      TODO: delete type from store.initializedTypes[id] when corresponding id was deleted!
    */
    * initType (id, args) {
      var sid = JSON.stringify(id)
      var t = this.store.initializedTypes[sid]
      if (t == null) {
        var op/* :MapStruct | ListStruct */ = yield* this.getOperation(id)
        if (op != null) {
          t = yield* Y[op.type].typeDefinition.initType.call(this, this.store, op, args)
          this.store.initializedTypes[sid] = t
        }
      }
      return t
    }
    /*
     Create type. This is called when the local user creates a type (which is a synchronous action)
    */
    createType (typedefinition, id) {
      var structname = typedefinition[0].struct
      id = id || this.getNextOpId(1)
      var op = Y.Struct[structname].create(id)
      op.type = typedefinition[0].name
      this.requestTransaction(function * () {
        if (op.id[0] === '_') {
          yield* this.setOperation(op)
        } else {
          yield* this.applyCreatedOperations([op])
        }
      })
      var t = Y[op.type].typeDefinition.createType(this, op, typedefinition[1])
      this.initializedTypes[JSON.stringify(op.id)] = t
      return t
    }
  }
  Y.AbstractDatabase = AbstractDatabase
 }
@@ -1267,11 +1174,7 @@ module.exports = function (Y/* :any */) {
    */
    Delete: {
      encode: function (op) {
-        return {
+        return op
          target: op.target,
          length: op.length || 0,
          struct: 'Delete'
        }
      },
      requiredOps: function (op) {
        return [] // [op.target]
@@ -1735,6 +1638,57 @@ module.exports = function (Y/* :any */) {
    os: Store;
    ss: Store;
    */
    /*
      Get a type based on the id of its model.
      If it does not exist yes, create it.
      TODO: delete type from store.initializedTypes[id] when corresponding id was deleted!
    */
    * getType (id, args) {
      var sid = JSON.stringify(id)
      var t = this.store.initializedTypes[sid]
      if (t == null) {
        var op/* :MapStruct | ListStruct */ = yield* this.getOperation(id)
        if (op != null) {
          t = yield* Y[op.type].typeDefinition.initType.call(this, this.store, op, args)
          this.store.initializedTypes[sid] = t
        }
      }
      return t
    }
    * createType (typedefinition, id) {
      var structname = typedefinition[0].struct
      id = id || this.store.getNextOpId(1)
      var op
      if (id[0] === '_') {
        op = yield* this.getOperation(id)
      } else {
        op = Y.Struct[structname].create(id)
        op.type = typedefinition[0].name
      }
      if (typedefinition[0].appendAdditionalInfo != null) {
        yield* typedefinition[0].appendAdditionalInfo.call(this, op, typedefinition[1])
      }
      if (op[0] === '_') {
        yield* this.setOperation(op)
      } else {
        yield* this.applyCreatedOperations([op])
      }
      return yield* this.getType(id, typedefinition[1])
    }
    /* createType (typedefinition, id) {
      var structname = typedefinition[0].struct
      id = id || this.store.getNextOpId(1)
      var op = Y.Struct[structname].create(id)
      op.type = typedefinition[0].name
      if (typedefinition[0].appendAdditionalInfo != null) {
        yield* typedefinition[0].appendAdditionalInfo.call(this, op, typedefinition[1])
      }
      // yield* this.applyCreatedOperations([op])
      yield* Y.Struct[op.struct].execute.call(this, op)
      yield* this.addOperation(op)
      yield* this.store.operationAdded(this, op)
      return yield* this.getType(id, typedefinition[1])
    }*/
    /*
      Apply operations that this user created (no remote ones!)
        * does not check for Struct.*.requiredOps()
@@ -1749,7 +1703,7 @@ module.exports = function (Y/* :any */) {
          send.push(Y.Struct[op.struct].encode(op))
        }
      }
-      if (this.store.y.connector.isSynced && send.length > 0) { // TODO: && !this.store.forwardAppliedOperations (but then i don't send delete ops)
+      if (!this.store.y.connector.isDisconnected() && send.length > 0) { // TODO: && !this.store.forwardAppliedOperations (but then i don't send delete ops)
        // is connected, and this is not going to be send in addOperation
        this.store.y.connector.broadcastOps(send)
      }
@@ -1859,8 +1813,7 @@ module.exports = function (Y/* :any */) {
            yield* this.store.operationAdded(this, {
              struct: 'Delete',
              target: target.id,
-              length: targetLength,
+              length: targetLength
              targetParent: target.parent
            })
          }
          // need to gc in the end!
@@ -2329,7 +2282,7 @@ module.exports = function (Y/* :any */) {
        }
        if (this.store.forwardAppliedOperations) {
          var ops = []
-          ops.push({struct: 'Delete', target: [del[0], del[1]], length: del[2]})
+          ops.push({struct: 'Delete', target: [d[0], d[1]], length: del[2]})
          this.store.y.connector.broadcastOps(ops)
        }
      }
@@ -2367,7 +2320,7 @@ module.exports = function (Y/* :any */) {
    }
    * addOperation (op) {
      yield* this.os.put(op)
-      if (this.store.y.connector.isSynced && this.store.forwardAppliedOperations && typeof op.id[1] !== 'string') {
+      if (!this.store.y.connector.isDisconnected() && this.store.forwardAppliedOperations && typeof op.id[1] !== 'string') {
        // is connected, and this is not going to be send in addOperation
        this.store.y.connector.broadcastOps([op])
      }
@@ -2752,7 +2705,7 @@ module.exports = function (Y /* : any*/) {
        try {
          this.eventListeners[i](event)
        } catch (e) {
-          console.error('Your observer threw an error. This error was caught so that Yjs still can ensure data consistency! In order to debug this error you have to check "Pause On Caught Exceptions"', e)
+          console.error('User events must not throw Errors!')
        }
      }
    }
@@ -2782,6 +2735,7 @@ module.exports = function (Y /* : any*/) {
    destroy () {
      super.destroy()
      this.waiting = null
      this.awaiting = null
      this.onevent = null
    }
    /*
@@ -2937,13 +2891,7 @@ module.exports = function (Y /* : any*/) {
          // finished with remaining operations
          self.waiting.push(d)
        }
-        if (op.key == null) {
+        checkDelete(op)
          // deletes in list
          checkDelete(op)
        } else {
          // deletes in map
          this.waiting.push(op)
        }
      } else {
        this.waiting.push(op)
      }
@@ -2992,11 +2940,7 @@ module.exports = function (Y /* : any*/) {
          var o = this.waiting[i]
          if (o.struct === 'Insert') {
            var _o = yield* transaction.getInsertion(o.id)
-            if (_o.parentSub != null && _o.left != null) {
+            if (!Y.utils.compareIds(_o.id, o.id)) {
              // if o is an insertion of a map struc (parentSub is defined), then it shouldn't be necessary to compute left
              this.waiting.splice(i, 1)
              i-- // update index
            } else if (!Y.utils.compareIds(_o.id, o.id)) {
              // o got extended
              o.left = [o.id[0], o.id[1] - 1]
            } else if (_o.left == null) {
@@ -3156,14 +3100,6 @@ module.exports = function (Y /* : any*/) {
  }
  Y.utils.EventHandler = EventHandler
  /*
    Default class of custom types!
  */
  class CustomType {
  }
  Y.utils.CustomType = CustomType
  /*
    A wrapper for the definition of a custom type.
    Every custom type must have three properties:
@@ -3175,7 +3111,7 @@ module.exports = function (Y /* : any*/) {
    * class
      - the constructor of the custom type (e.g. in order to inherit from a type)
  */
-  class CustomTypeDefinition { // eslint-disable-line
+  class CustomType { // eslint-disable-line
    /* ::
    struct: any;
    initType: any;
@@ -3186,14 +3122,12 @@ module.exports = function (Y /* : any*/) {
      if (def.struct == null ||
        def.initType == null ||
        def.class == null ||
-        def.name == null ||
+        def.name == null
        def.createType == null
      ) {
        throw new Error('Custom type was not initialized correctly!')
      }
      this.struct = def.struct
      this.initType = def.initType
      this.createType = def.createType
      this.class = def.class
      this.name = def.name
      if (def.appendAdditionalInfo != null) {
@@ -3205,13 +3139,13 @@ module.exports = function (Y /* : any*/) {
      this.parseArguments.typeDefinition = this
    }
  }
-  Y.utils.CustomTypeDefinition = CustomTypeDefinition
+  Y.utils.CustomType = CustomType
  Y.utils.isTypeDefinition = function isTypeDefinition (v) {
    if (v != null) {
-      if (v instanceof Y.utils.CustomTypeDefinition) return [v]
+      if (v instanceof Y.utils.CustomType) return [v]
-      else if (v.constructor === Array && v[0] instanceof Y.utils.CustomTypeDefinition) return v
+      else if (v.constructor === Array && v[0] instanceof Y.utils.CustomType) return v
-      else if (v instanceof Function && v.typeDefinition instanceof Y.utils.CustomTypeDefinition) return [v.typeDefinition]
+      else if (v instanceof Function && v.typeDefinition instanceof Y.utils.CustomType) return [v.typeDefinition]
    }
    return false
  }
@@ -3471,36 +3405,19 @@ module.exports = Y
 Y.requiringModules = requiringModules
 Y.extend = function (name, value) {
-  if (arguments.length === 2 && typeof name === 'string') {
+  if (value instanceof Y.utils.CustomType) {
-    if (value instanceof Y.utils.CustomTypeDefinition) {
+    Y[name] = value.parseArguments
      Y[name] = value.parseArguments
    } else {
      Y[name] = value
    }
    if (requiringModules[name] != null) {
      requiringModules[name].resolve()
      delete requiringModules[name]
    }
  } else {
-    for (var i = 0; i < arguments.length; i++) {
+    Y[name] = value
-      var f = arguments[i]
+  }
-      if (typeof f === 'function') {
+  if (requiringModules[name] != null) {
-        f(Y)
+    requiringModules[name].resolve()
-      } else {
+    delete requiringModules[name]
        throw new Error('Expected function!')
      }
    }
  }
 }
 Y.requestModules = requestModules
 function requestModules (modules) {
  var sourceDir
  if (Y.sourceDir === null) {
    sourceDir = null
  } else {
    sourceDir = Y.sourceDir || '/bower_components'
  }
  // determine if this module was compiled for es5 or es6 (y.js vs. y.es6)
  // if Insert.execute is a Function, then it isnt a generator..
  // then load the es5(.js) files..
@@ -3513,11 +3430,10 @@ function requestModules (modules) {
      if (requiringModules[module] == null) {
        // module does not exist
        if (typeof window !== 'undefined' && window.Y !== 'undefined') {
-          if (sourceDir != null) {
+          var imported = document.createElement('script')
-            var imported = document.createElement('script')
+          imported.src = Y.sourceDir + '/' + modulename + '/' + modulename + extention
-            imported.src = sourceDir + '/' + modulename + '/' + modulename + extention
+          document.head.appendChild(imported)
-            document.head.appendChild(imported)
+
          }
          let requireModule = {}
          requiringModules[module] = requireModule
          requireModule.promise = new Promise(function (resolve) {
@@ -3566,37 +3482,31 @@ type YOptions = {
 */
 function Y (opts/* :YOptions */) /* :Promise<YConfig> */ {
  if (opts.hasOwnProperty('sourceDir')) {
    Y.sourceDir = opts.sourceDir
  }
  opts.types = opts.types != null ? opts.types : []
  var modules = [opts.db.name, opts.connector.name].concat(opts.types)
  for (var name in opts.share) {
    modules.push(opts.share[name])
  }
  Y.sourceDir = opts.sourceDir
  return new Promise(function (resolve, reject) {
-    if (opts == null) reject('An options object is expected! ')
+    setTimeout(function () {
-    else if (opts.connector == null) reject('You must specify a connector! (missing connector property)')
+      Y.requestModules(modules).then(function () {
-    else if (opts.connector.name == null) reject('You must specify connector name! (missing connector.name property)')
+        if (opts == null) reject('An options object is expected! ')
-    else if (opts.db == null) reject('You must specify a database! (missing db property)')
+        else if (opts.connector == null) reject('You must specify a connector! (missing connector property)')
-    else if (opts.connector.name == null) reject('You must specify db name! (missing db.name property)')
+        else if (opts.connector.name == null) reject('You must specify connector name! (missing connector.name property)')
-    else if (opts.share == null) reject('You must specify a set of shared types!')
+        else if (opts.db == null) reject('You must specify a database! (missing db property)')
-    else {
+        else if (opts.connector.name == null) reject('You must specify db name! (missing db.name property)')
-      opts = Y.utils.copyObject(opts)
+        else if (opts.share == null) reject('You must specify a set of shared types!')
-      opts.connector = Y.utils.copyObject(opts.connector)
+        else {
      opts.db = Y.utils.copyObject(opts.db)
      opts.share = Y.utils.copyObject(opts.share)
      setTimeout(function () {
        Y.requestModules(modules).then(function () {
          var yconfig = new YConfig(opts)
          yconfig.db.whenUserIdSet(function () {
            yconfig.init(function () {
              resolve(yconfig)
            })
          })
-        }).catch(reject)
+        }
-      }, 0)
+      }).catch(reject)
-    }
+    }, 0)
  })
 }
@@ -3611,7 +3521,6 @@ class YConfig {
    this.options = opts
    this.db = new Y[opts.db.name](this, opts.db)
    this.connector = new Y[opts.connector.name](this, opts.connector)
    this.connected = true
  }
  init (callback) {
    var opts = this.options
@@ -3622,9 +3531,6 @@ class YConfig {
      for (var propertyname in opts.share) {
        var typeConstructor = opts.share[propertyname].split('(')
        var typeName = typeConstructor.splice(0, 1)
        var type = Y[typeName]
        var typedef = type.typeDefinition
        var id = ['_', typedef.struct + '_' + typeName + '_' + propertyname + '_' + typeConstructor]
        var args = []
        if (typeConstructor.length === 1) {
          try {
@@ -3632,13 +3538,11 @@ class YConfig {
          } catch (e) {
            throw new Error('Was not able to parse type definition! (share.' + propertyname + ')')
          }
          if (type.typeDefinition.parseArguments == null) {
            throw new Error(typeName + ' does not expect arguments!')
          } else {
            args = typedef.parseArguments(args[0])[1]
          }
        }
-        share[propertyname] = yield* this.store.initType.call(this, id, args)
+        var type = Y[typeName]
        var typedef = type.typeDefinition
        var id = ['_', typedef.struct + '_' + typeName + '_' + propertyname + '_' + typeConstructor]
        share[propertyname] = yield* this.createType(type.apply(typedef, args), id)
      }
      this.store.whenTransactionsFinished()
        .then(callback)
@@ -3648,46 +3552,22 @@ class YConfig {
    return this.connector.isSynced
  }
  disconnect () {
-    if (this.connected) {
+    return this.connector.disconnect()
      this.connected = false
      return this.connector.disconnect()
    } else {
      return Promise.resolve()
    }
  }
  reconnect () {
-    if (!this.connected) {
+    return this.connector.reconnect()
      this.connected = true
      return this.connector.reconnect()
    } else {
      return Promise.resolve()
    }
  }
  destroy () {
    var self = this
    return this.close().then(function () {
      if (self.db.deleteDB != null) {
        return self.db.deleteDB()
      } else {
        return Promise.resolve()
      }
    })
  }
  close () {
    var self = this
    this.share = null
    if (this.connector.destroy != null) {
      this.connector.destroy()
    } else {
      this.connector.disconnect()
    }
-    return this.db.whenTransactionsFinished(function () {
+    var self = this
-      this.db.destroyTypes()
+    this.db.requestTransaction(function * () {
-      // make sure to wait for all transactions before destroying the db
+      yield* self.db.destroy()
-      this.db.requestTransaction(function * () {
+      self.connector = null
-        yield* self.db.destroy()
+      self.db = null
      })
      return this.db.whenTransactionsFinished()
    })
  }
 }
--- a/y.es6.map
+++ b/y.es6.map
--- a/y.js
+++ b/y.js
--- a/y.js.map
+++ b/y.js.map