late join should work now. Need to test more. root is passed to transaction generator

.eslintrc

@@ -11,6 +11,7 @@
   },
   "parser": "babel-eslint",
   "globals": {
+    "copyObject": true,
     "Struct": true,
     "OperationStore": true,
     "AbstractOperationStore": true,

src/OperationStores/Memory.js

@@ -4,6 +4,15 @@ type State = {
   clock: number
 };
 
+
+function copyObject (o) {
+  var c = {};
+  for (var key in o) {
+    c[key] = o[key];
+  }
+  return c;
+}
+
 type StateVector = Array<State>;
 type OperationSet = Object; // os[Id] = op
 type StateSet = Object;
@@ -75,12 +84,30 @@ Y.Memory = (function(){ //eslint-disable-line no-unused-vars
         for (var clock = startPos; clock <= endPos; clock++) {
           var op = yield* this.getOperation([user, clock]);
           if (op != null) {
-            ops.push(op);
+            ops.push(yield* this.makeOperationReady.call(this, startSS, op));
           }
         }
       }
       return ops;
     }
+    *makeOperationReady (ss, op) {
+      var clock;
+      var o = op;
+      while (true){
+        // while unknown, go to the right
+        o = yield* this.getOperation(o.right);
+        if (o == null) {
+          break;
+        }
+        clock = ss[o.id[0]];
+        if (clock != null && o.id[1] < clock ) {
+          break;
+        }
+      }
+      op = copyObject(op);
+      op.right = (o == null) ? null : o.id;
+      return op;
+    }
   }
   class OperationStore extends AbstractOperationStore { //eslint-disable-line no-undef
     constructor (y) {
@@ -90,7 +117,7 @@ Y.Memory = (function(){ //eslint-disable-line no-unused-vars
     }
     requestTransaction (makeGen : Function) {
       var t = new Transaction(this);
-      var gen = makeGen.call(t);
+      var gen = makeGen.call(t, new Y.Map.Create(["_", 0]));
       var res = gen.next();
       while(!res.done){
         if (res.value === "transaction") {

src/y.js

@@ -6,14 +6,13 @@ class Y { //eslint-disable-line no-unused-vars
   constructor (opts) {
     this.db = new Y[opts.db.name](this, opts.db);
     this.connector = new Y[opts.connector.name](this, opts.connector);
-    var y = this;
     this.db.requestTransaction(function*(){
+      // create initial Map type
       yield* this.addOperation({
         id: ["_", 0],
         struct: "Map",
         map: {}
       });
-      y.root = new Y.Map.Create(["_", 0]);
     });
   }
   transact (generator) {

src/y.spec.js

@@ -23,52 +23,45 @@ describe("Yjs (basic)", function(){
     }
     this.users = [];
   });
-  it("There is an initial Map type", function(done){
+  it("There is an initial Map type", function(){
     var y = this.users[0];
-    y.transact(function*(){
+    y.transact(function*(root){
-      expect(y.root).not.toBeUndefined();
+      expect(root).not.toBeUndefined();
-      done();
     });
   });
-  it("Basic get&set of Map property (converge via sync)", function(done){
+  it("Basic get&set of Map property (converge via sync)", function(){
     var y = this.users[0];
-    y.transact(function*(){
+    y.transact(function*(root){
-      yield* y.root.val("stuff", "stuffy");
+      yield* root.val("stuff", "stuffy");
-      expect(yield* y.root.val("stuff")).toEqual("stuffy");
+      expect(yield* root.val("stuff")).toEqual("stuffy");
     });
 
     y.connector.flushAll();
 
-    function getTransaction(yy){
+    var transaction = function*(root){
-      return function*(){
+      expect(yield* root.val("stuff")).toEqual("stuffy");
-        expect(yield* yy.root.val("stuff")).toEqual("stuffy");
     };
-    }
     for (var key in this.users) {
       var u = this.users[key];
-      u.transact(getTransaction(u));
+      u.transact(transaction);
     }
-    done();
   });
-  it("Basic get&set of Map property (converge via update)", function(done){
+  it("Basic get&set of Map property (converge via update)", function(){
     var y = this.users[0];
     y.connector.flushAll();
-    y.transact(function*(){
+    y.transact(function*(root){
-      yield* y.root.val("stuff", "stuffy");
+      yield* root.val("stuff", "stuffy");
-      expect(yield* y.root.val("stuff")).toEqual("stuffy");
+      expect(yield* root.val("stuff")).toEqual("stuffy");
     });
 
-    function getTransaction(yy){
+    var transaction = function*(root){
-      return function*(){
+      expect(yield* root.val("stuff")).toEqual("stuffy");
-        expect(yield* yy.root.val("stuff")).toEqual("stuffy");
     };
-    }
     y.connector.flushAll();
 
     for (var key in this.users) {
       var u = this.users[key];
-      u.transact(getTransaction(u));
+      u.transact(transaction);
     }
-    done();
   });
 });