Fixes #244

Author: jenssegers

src/Jenssegers/Mongodb/Eloquent/Builder.php

@@ -96,6 +96,64 @@ public function delete()
         return parent::delete();
     }
 
+    /**
+     * Increment a column's value by a given amount.
+     *
+     * @param  string  $column
+     * @param  int     $amount
+     * @param  array   $extra
+     * @return int
+     */
+    public function increment($column, $amount = 1, array $extra = array())
+    {
+        // Intercept operations on embedded models and delegate logic
+        // to the parent relation instance.
+        if ($relation = $this->model->getParent())
+        {
+            $value = $this->model->{$column};
+
+            // When doing increment and decrements, Eloquent will automatically
+            // sync the original attributes. We need to change the attribute
+            // temporary in order to trigger an update query.
+            $this->model->{$column} = null;
+            $this->model->syncOriginalAttribute($column);
+
+            $result = $this->model->update(array($column => $value));
+
+            return $result;
+        }
+
+        return parent::increment($column, $amount, $extra);
+    }
+
+    /**
+     * Decrement a column's value by a given amount.
+     *
+     * @param  string  $column
+     * @param  int     $amount
+     * @param  array   $extra
+     * @return int
+     */
+    public function decrement($column, $amount = 1, array $extra = array())
+    {
+        // Intercept operations on embedded models and delegate logic
+        // to the parent relation instance.
+        if ($relation = $this->model->getParent())
+        {
+            $value = $this->model->{$column};
+
+            // When doing increment and decrements, Eloquent will automatically
+            // sync the original attributes. We need to change the attribute
+            // temporary in order to trigger an update query.
+            $this->model->{$column} = null;
+            $this->model->syncOriginalAttribute($column);
+
+            return $this->model->update(array($column => $value));
+        }
+
+        return parent::decrement($column, $amount, $extra);
+    }
+
     /**
      * Add the "has" condition where clause to the query.
      *

src/Jenssegers/Mongodb/Relations/EmbedsMany.php

@@ -89,6 +89,14 @@ public function performUpdate(Model $model, array $values)
      */
     public function performDelete(Model $model)
     {
+        // For deeply nested documents, let the parent handle the changes.
+        if ($this->isNested())
+        {
+            $this->dissociate($model);
+
+            return $this->parent->save();
+        }
+
         // Get the correct foreign key value.
         $foreignKey = $this->getForeignKeyValue($model);
 

src/Jenssegers/Mongodb/Relations/EmbedsOne.php

@@ -82,6 +82,14 @@ public function performUpdate(Model $model, array $values)
      */
     public function performDelete(Model $model)
     {
+        // For deeply nested documents, let the parent handle the changes.
+        if ($this->isNested())
+        {
+            $this->dissociate($model);
+
+            return $this->parent->save();
+        }
+
         // Overwrite the local key with an empty array.
         $result = $this->query->update(array($this->localKey => null));
 

tests/EmbeddedRelationsTest.php

@@ -651,4 +651,17 @@ public function testSaveEmptyModel()
         $this->assertEquals(1, $user->addresses()->count());
     }
 
+    public function testIncrementEmbedded()
+    {
+        $user = User::create(array('name' => 'John Doe'));
+        $address = $user->addresses()->create(array('city' => 'New York', 'visited' => 5));
+
+        $address->increment('visited');
+        $this->assertEquals(6, $address->visited);
+        $this->assertEquals(6, $user->addresses()->first()->visited);
+
+        $user = User::where('name', 'John Doe')->first();
+        $this->assertEquals(6, $user->addresses()->first()->visited);
+    }
+
 }