Store object original data in the object. Do not track _id changes.

docker-compose.yml

@@ -2,12 +2,13 @@ version: '2'
 services:
   yadm:
     image: formapro/nginx-php-fpm:latest-all-exts
+    working_dir: /yadm
     volumes:
       - ./:/yadm
     environment:
       - MONGODB_URI=mongodb://mongo/
 
   mongo:
     image: mongo:3
-    ports:
-      - "27017:27017"
+#    ports:
+#      - "27017:27017"

src/ChangesCollector.php

@@ -1,39 +1,31 @@
 <?php
 namespace Makasim\Yadm;
 
-use function Makasim\Values\get_values;
 use mikemccabe\JsonPatch\JsonPatch;
 
 class ChangesCollector
 {
-    private $originalValues;
-
     public function register($object)
     {
-        if ($id = get_object_id($object)) {
-            $this->originalValues[$id] = get_values($object);
-        }
-    }
-
-    public function unregister($object)
-    {
-        if ($id = get_object_id($object)) {
-            unset($this->originalValues[$id]);
-        }
+        (function() {
+            $this->originalValues = $this->values;
+        })->call($object);
     }
 
     public function changes($object)
     {
-        if (false == $id = get_object_id($object)) {
-            throw new \LogicException(sprintf('Object does not have an id set.'));
-        }
+        return (function() {
+            $values = $this->values;
+
+            if (property_exists($this, 'originalValues')) {
+                $originalValues = $this->originalValues;
 
-        if (false == array_key_exists($id, $this->originalValues)) {
-            throw new \LogicException(sprintf('Changes has not been collected. The object with id "%s" original data is missing.'));
-        }
+                $diff = JsonPatch::diff($originalValues, $values);
 
-        $diff = JsonPatch::diff($this->originalValues[$id], get_values($object));
+                return Converter::convertJsonPatchToMongoUpdate($diff);
+            }
 
-        return Converter::convertJsonPatchToMongoUpdate($diff);
+            return ['$set' => $values];
+        })->call($object);
     }
 }

src/Converter.php

@@ -12,6 +12,10 @@ public static function convertJsonPatchToMongoUpdate(array $diff)
     {
         $update = ['$set' => [], '$unset' => []];
         foreach ($diff as $op) {
+            if (isset($op['path']) && '/_id' == $op['path']) {
+                continue;
+            }
+
             switch ($op['op']) {
                 case 'add':
                     if (is_array($op['value'])) {

src/Storage.php

@@ -141,10 +141,6 @@ public function delete($model, array $options = [])
             throw new \LogicException('Operation is not acknowledged');
         }
 
-        // TODO remove id???
-
-        $this->changesCollector->unregister($model);
-
         return $result;
     }
 

tests/ChangesCollectorTest.php

@@ -12,9 +12,6 @@
 
 class ChangesCollectorTest extends TestCase
 {
-    /**
-     * @group d
-     */
     public function testShouldTrackSetValue()
     {
         $obj = $this->createPersistedObject();
@@ -23,15 +20,15 @@ public function testShouldTrackSetValue()
         $collector->register($obj);
 
         set_value($obj, 'aKey', 'aVal');
-var_dump($collector->changes($obj));
+
         self::assertEquals([
             '$set' => [
                 'aKey' => 'aVal',
             ],
         ], $collector->changes($obj));
     }
 
-    public function testShouldTrackAddedValue()
+    public function testShouldTrackAddedValueToEmptyCollection()
     {
         $obj = $this->createPersistedObject();
 
@@ -47,6 +44,52 @@ public function testShouldTrackAddedValue()
         ], $collector->changes($obj));
     }
 
+    public function testShouldSkipMongoIdField()
+    {
+        $obj = $this->createPersistedObject();
+        set_value($obj, '_id',123);
+
+        $collector = new ChangesCollector();
+        $collector->register($obj);
+
+        set_value($obj, '_id',321);
+
+        self::assertEquals([], $collector->changes($obj));
+    }
+
+    public function testShouldUseWholeValuesIfNotRegistered()
+    {
+        $collector = new ChangesCollector();
+
+        $obj = new Object();
+        set_value($obj, 'foo','fooVal');
+        set_value($obj, 'bar.baz','barVal');
+
+        self::assertEquals([
+            '$set' => [
+                'foo' => 'fooVal',
+                'bar' => ['baz' => 'barVal'],
+            ],
+        ], $collector->changes($obj));
+    }
+
+    public function testShouldTrackAddedValue()
+    {
+        $obj = $this->createPersistedObject();
+        add_value($obj, 'aKey', 'anOldVal');
+
+        $collector = new ChangesCollector();
+        $collector->register($obj);
+
+        add_value($obj, 'aKey', 'aVal');
+
+        self::assertEquals([
+            '$set' => [
+                'aKey.1' => 'aVal',
+            ],
+        ], $collector->changes($obj));
+    }
+
     public function testShouldNotTrackSetValueAndUnsetLater()
     {
         $obj = $this->createPersistedObject();
@@ -155,7 +198,7 @@ public function testShouldFoo()
     }
 
     /**
-     * @return Object
+     * @return object
      */
     private function createPersistedObject(array $values = [])
     {