From fe278ac62e1f14a7c1bd03da0355244f781af1c1 Mon Sep 17 00:00:00 2001
From: Pooya Parsa <pi0@users.noreply.github.com>
Date: Tue, 2 Aug 2016 15:03:00 +0430
Subject: [PATCH 1/5] Support laravel 5.3

New Laravel queries always return collection. this is a backward compatible enhancement as Collections can be used as Arrays!
---
 src/Jenssegers/Mongodb/Query/Builder.php | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/Jenssegers/Mongodb/Query/Builder.php b/src/Jenssegers/Mongodb/Query/Builder.php
index d7a60d4d1..f299b654d 100644
--- a/src/Jenssegers/Mongodb/Query/Builder.php
+++ b/src/Jenssegers/Mongodb/Query/Builder.php
@@ -146,7 +146,7 @@ public function find($id, $columns = [])
      * Execute the query as a "select" statement.
      *
      * @param  array  $columns
-     * @return array|static[]
+     * @return array|static[]|Collection
      */
     public function get($columns = [])
     {
@@ -157,7 +157,7 @@ public function get($columns = [])
      * Execute the query as a fresh "select" statement.
      *
      * @param  array  $columns
-     * @return array|static[]
+     * @return array|static[]|Collection
      */
     public function getFresh($columns = [])
     {
@@ -259,7 +259,7 @@ public function getFresh($columns = [])
             $results = iterator_to_array($this->collection->aggregate($pipeline, $options));
 
             // Return results
-            return $results;
+            return new Collection($results);
         }
 
         // Distinct query
@@ -274,7 +274,7 @@ public function getFresh($columns = [])
                 $result = $this->collection->distinct($column);
             }
 
-            return $result;
+            return new Collection($result);
         }
 
         // Normal query
@@ -317,7 +317,7 @@ public function getFresh($columns = [])
             $cursor = $this->collection->find($wheres, $options);
 
             // Return results as an array with numeric keys
-            return iterator_to_array($cursor, false);
+            return new Collection(iterator_to_array($cursor, false));
         }
     }
 

From 76b86559ffd78ce167474f95a2da1675d88921d2 Mon Sep 17 00:00:00 2001
From: pi0 <pyapar@gmail.com>
Date: Tue, 2 Aug 2016 17:39:08 +0430
Subject: [PATCH 2/5] Backward compability

---
 .../Mongodb/MongodbServiceProvider.php        |   3 +
 src/Jenssegers/Mongodb/Query/Builder.php      | 197 +++++++++---------
 2 files changed, 97 insertions(+), 103 deletions(-)

diff --git a/src/Jenssegers/Mongodb/MongodbServiceProvider.php b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
index bba2f6fd0..5fca7990e 100644
--- a/src/Jenssegers/Mongodb/MongodbServiceProvider.php
+++ b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
@@ -14,6 +14,9 @@ public function boot()
         Model::setConnectionResolver($this->app['db']);
 
         Model::setEventDispatcher($this->app['events']);
+
+        $s=explode('.',\Illuminate\Foundation\Application::VERSION);
+        define('SHOULD_RETURN_COLLECTION',(10*$s[0]+$s[1])>=53);
     }
 
     /**
diff --git a/src/Jenssegers/Mongodb/Query/Builder.php b/src/Jenssegers/Mongodb/Query/Builder.php
index f299b654d..8a4372b71 100644
--- a/src/Jenssegers/Mongodb/Query/Builder.php
+++ b/src/Jenssegers/Mongodb/Query/Builder.php
@@ -11,6 +11,7 @@
 use MongoDB\BSON\Regex;
 use MongoDB\BSON\UTCDateTime;
 
+
 class Builder extends BaseBuilder
 {
     /**
@@ -69,12 +70,12 @@ class Builder extends BaseBuilder
      * @var array
      */
     protected $conversion = [
-        '='  => '=',
+        '=' => '=',
         '!=' => '$ne',
         '<>' => '$ne',
-        '<'  => '$lt',
+        '<' => '$lt',
         '<=' => '$lte',
-        '>'  => '$gt',
+        '>' => '$gt',
         '>=' => '$gte',
     ];
 
@@ -82,7 +83,7 @@ class Builder extends BaseBuilder
      * Create a new query builder instance.
      *
      * @param Connection $connection
-     * @param Processor  $processor
+     * @param Processor $processor
      */
     public function __construct(Connection $connection, Processor $processor)
     {
@@ -94,7 +95,7 @@ public function __construct(Connection $connection, Processor $processor)
     /**
      * Set the projections.
      *
-     * @param  array  $columns
+     * @param  array $columns
      * @return $this
      */
     public function project($columns)
@@ -133,8 +134,8 @@ public function hint($index)
     /**
      * Execute a query for a single record by ID.
      *
-     * @param  mixed  $id
-     * @param  array  $columns
+     * @param  mixed $id
+     * @param  array $columns
      * @return mixed
      */
     public function find($id, $columns = [])
@@ -145,7 +146,7 @@ public function find($id, $columns = [])
     /**
      * Execute the query as a "select" statement.
      *
-     * @param  array  $columns
+     * @param  array $columns
      * @return array|static[]|Collection
      */
     public function get($columns = [])
@@ -156,7 +157,7 @@ public function get($columns = [])
     /**
      * Execute the query as a fresh "select" statement.
      *
-     * @param  array  $columns
+     * @param  array $columns
      * @return array|static[]|Collection
      */
     public function getFresh($columns = [])
@@ -207,8 +208,7 @@ public function getFresh($columns = [])
                     // Translate count into sum.
                     if ($function == 'count') {
                         $group['aggregate'] = ['$sum' => 1];
-                    }
-                    // Pass other functions directly.
+                    } // Pass other functions directly.
                     else {
                         $group['aggregate'] = ['$' . $function => '$' . $column];
                     }
@@ -259,10 +259,8 @@ public function getFresh($columns = [])
             $results = iterator_to_array($this->collection->aggregate($pipeline, $options));
 
             // Return results
-            return new Collection($results);
-        }
-
-        // Distinct query
+            return SHOULD_RETURN_COLLECTION ? new Collection($results) : $results;
+        } // Distinct query
         elseif ($this->distinct) {
             // Return distinct results directly
             $column = isset($this->columns[0]) ? $this->columns[0] : '_id';
@@ -274,10 +272,8 @@ public function getFresh($columns = [])
                 $result = $this->collection->distinct($column);
             }
 
-            return new Collection($result);
-        }
-
-        // Normal query
+            return SHOULD_RETURN_COLLECTION ? new Collection($result) : $result;
+        } // Normal query
         else {
             $columns = [];
 
@@ -317,7 +313,8 @@ public function getFresh($columns = [])
             $cursor = $this->collection->find($wheres, $options);
 
             // Return results as an array with numeric keys
-            return new Collection(iterator_to_array($cursor, false));
+            $results = iterator_to_array($cursor, false);
+            return SHOULD_RETURN_COLLECTION ? new Collection($results) : $results;
         }
     }
 
@@ -331,13 +328,13 @@ public function generateCacheKey()
         $key = [
             'connection' => $this->collection->getDatabaseName(),
             'collection' => $this->collection->getCollectionName(),
-            'wheres'     => $this->wheres,
-            'columns'    => $this->columns,
-            'groups'     => $this->groups,
-            'orders'     => $this->orders,
-            'offset'     => $this->offset,
-            'limit'      => $this->limit,
-            'aggregate'  => $this->aggregate,
+            'wheres' => $this->wheres,
+            'columns' => $this->columns,
+            'groups' => $this->groups,
+            'orders' => $this->orders,
+            'offset' => $this->offset,
+            'limit' => $this->limit,
+            'aggregate' => $this->aggregate,
         ];
 
         return md5(serialize(array_values($key)));
@@ -346,8 +343,8 @@ public function generateCacheKey()
     /**
      * Execute an aggregate function on the database.
      *
-     * @param  string  $function
-     * @param  array   $columns
+     * @param  string $function
+     * @param  array $columns
      * @return mixed
      */
     public function aggregate($function, $columns = [])
@@ -363,7 +360,7 @@ public function aggregate($function, $columns = [])
         $this->aggregate = null;
 
         if (isset($results[0])) {
-            $result = (array) $results[0];
+            $result = (array)$results[0];
 
             return $result['aggregate'];
         }
@@ -376,7 +373,7 @@ public function aggregate($function, $columns = [])
      */
     public function exists()
     {
-        return ! is_null($this->first());
+        return !is_null($this->first());
     }
 
     /**
@@ -398,8 +395,8 @@ public function distinct($column = false)
     /**
      * Add an "order by" clause to the query.
      *
-     * @param  string  $column
-     * @param  string  $direction
+     * @param  string $column
+     * @param  string $direction
      * @return Builder
      */
     public function orderBy($column, $direction = 'asc')
@@ -420,10 +417,10 @@ public function orderBy($column, $direction = 'asc')
     /**
      * Add a where between statement to the query.
      *
-     * @param  string  $column
-     * @param  array   $values
-     * @param  string  $boolean
-     * @param  bool  $not
+     * @param  string $column
+     * @param  array $values
+     * @param  string $boolean
+     * @param  bool $not
      * @return Builder
      */
     public function whereBetween($column, array $values, $boolean = 'and', $not = false)
@@ -438,8 +435,8 @@ public function whereBetween($column, array $values, $boolean = 'and', $not = fa
     /**
      * Set the limit and offset for a given page.
      *
-     * @param  int  $page
-     * @param  int  $perPage
+     * @param  int $page
+     * @param  int $perPage
      * @return \Illuminate\Database\Query\Builder|static
      */
     public function forPage($page, $perPage = 15)
@@ -452,7 +449,7 @@ public function forPage($page, $perPage = 15)
     /**
      * Insert a new record into the database.
      *
-     * @param  array  $values
+     * @param  array $values
      * @return bool
      */
     public function insert(array $values)
@@ -464,34 +461,34 @@ public function insert(array $values)
         foreach ($values as $value) {
             // As soon as we find a value that is not an array we assume the user is
             // inserting a single document.
-            if (! is_array($value)) {
+            if (!is_array($value)) {
                 $batch = false;
                 break;
             }
         }
 
-        if (! $batch) {
+        if (!$batch) {
             $values = [$values];
         }
 
         // Batch insert
         $result = $this->collection->insertMany($values);
 
-        return (1 == (int) $result->isAcknowledged());
+        return (1 == (int)$result->isAcknowledged());
     }
 
     /**
      * Insert a new record and get the value of the primary key.
      *
-     * @param  array   $values
-     * @param  string  $sequence
+     * @param  array $values
+     * @param  string $sequence
      * @return int
      */
     public function insertGetId(array $values, $sequence = null)
     {
         $result = $this->collection->insertOne($values);
 
-        if (1 == (int) $result->isAcknowledged()) {
+        if (1 == (int)$result->isAcknowledged()) {
             if (is_null($sequence)) {
                 $sequence = '_id';
             }
@@ -504,14 +501,14 @@ public function insertGetId(array $values, $sequence = null)
     /**
      * Update a record in the database.
      *
-     * @param  array  $values
-     * @param  array  $options
+     * @param  array $values
+     * @param  array $options
      * @return int
      */
     public function update(array $values, array $options = [])
     {
         // Use $set as default operator.
-        if (! starts_with(key($values), '$')) {
+        if (!starts_with(key($values), '$')) {
             $values = ['$set' => $values];
         }
 
@@ -521,16 +518,16 @@ public function update(array $values, array $options = [])
     /**
      * Increment a column's value by a given amount.
      *
-     * @param  string  $column
-     * @param  int     $amount
-     * @param  array   $extra
+     * @param  string $column
+     * @param  int $amount
+     * @param  array $extra
      * @return int
      */
     public function increment($column, $amount = 1, array $extra = [], array $options = [])
     {
         $query = ['$inc' => [$column => $amount]];
 
-        if (! empty($extra)) {
+        if (!empty($extra)) {
             $query['$set'] = $extra;
         }
 
@@ -547,9 +544,9 @@ public function increment($column, $amount = 1, array $extra = [], array $option
     /**
      * Decrement a column's value by a given amount.
      *
-     * @param  string  $column
-     * @param  int     $amount
-     * @param  array   $extra
+     * @param  string $column
+     * @param  int $amount
+     * @param  array $extra
      * @return int
      */
     public function decrement($column, $amount = 1, array $extra = [], array $options = [])
@@ -560,8 +557,8 @@ public function decrement($column, $amount = 1, array $extra = [], array $option
     /**
      * Get an array with the values of a given column.
      *
-     * @param  string  $column
-     * @param  string|null  $key
+     * @param  string $column
+     * @param  string|null $key
      * @return array
      */
     public function pluck($column, $key = null)
@@ -581,14 +578,14 @@ public function pluck($column, $key = null)
     /**
      * Delete a record from the database.
      *
-     * @param  mixed  $id
+     * @param  mixed $id
      * @return int
      */
     public function delete($id = null)
     {
         $wheres = $this->compileWheres();
         $result = $this->collection->DeleteMany($wheres);
-        if (1 == (int) $result->isAcknowledged()) {
+        if (1 == (int)$result->isAcknowledged()) {
             return $result->getDeletedCount();
         }
 
@@ -598,7 +595,7 @@ public function delete($id = null)
     /**
      * Set the collection which the query is targeting.
      *
-     * @param  string  $collection
+     * @param  string $collection
      * @return Builder
      */
     public function from($collection)
@@ -617,14 +614,14 @@ public function truncate()
     {
         $result = $this->collection->drop();
 
-        return (1 == (int) $result->ok);
+        return (1 == (int)$result->ok);
     }
 
     /**
      * Get an array with the values of a given column.
      *
-     * @param  string  $column
-     * @param  string  $key
+     * @param  string $column
+     * @param  string $key
      * @return array
      */
     public function lists($column, $key = null)
@@ -634,7 +631,7 @@ public function lists($column, $key = null)
 
             // Convert ObjectID's to strings so that lists can do its work.
             $results = $results->map(function ($item) {
-                $item['_id'] = (string) $item['_id'];
+                $item['_id'] = (string)$item['_id'];
 
                 return $item;
             });
@@ -648,7 +645,7 @@ public function lists($column, $key = null)
     /**
      * Create a raw database expression.
      *
-     * @param  closure  $expression
+     * @param  closure $expression
      * @return mixed
      */
     public function raw($expression = null)
@@ -656,10 +653,8 @@ public function raw($expression = null)
         // Execute the closure on the mongodb collection
         if ($expression instanceof Closure) {
             return call_user_func($expression, $this->collection);
-        }
-
-        // Create an expression for the given value
-        elseif (! is_null($expression)) {
+        } // Create an expression for the given value
+        elseif (!is_null($expression)) {
             return new Expression($expression);
         }
 
@@ -670,8 +665,8 @@ public function raw($expression = null)
     /**
      * Append one or more values to an array.
      *
-     * @param  mixed   $column
-     * @param  mixed   $value
+     * @param  mixed $column
+     * @param  mixed $value
      * @return int
      */
     public function push($column, $value = null, $unique = false)
@@ -696,8 +691,8 @@ public function push($column, $value = null, $unique = false)
     /**
      * Remove one or more values from an array.
      *
-     * @param  mixed   $column
-     * @param  mixed   $value
+     * @param  mixed $column
+     * @param  mixed $value
      * @return int
      */
     public function pull($column, $value = null)
@@ -725,7 +720,7 @@ public function pull($column, $value = null)
      */
     public function drop($columns)
     {
-        if (! is_array($columns)) {
+        if (!is_array($columns)) {
             $columns = [$columns];
         }
 
@@ -753,20 +748,20 @@ public function newQuery()
     /**
      * Perform an update query.
      *
-     * @param  array  $query
-     * @param  array  $options
+     * @param  array $query
+     * @param  array $options
      * @return int
      */
     protected function performUpdate($query, array $options = [])
     {
         // Update multiple items by default.
-        if (! array_key_exists('multiple', $options)) {
+        if (!array_key_exists('multiple', $options)) {
             $options['multiple'] = true;
         }
 
         $wheres = $this->compileWheres();
         $result = $this->collection->UpdateMany($wheres, $query, $options);
-        if (1 == (int) $result->isAcknowledged()) {
+        if (1 == (int)$result->isAcknowledged()) {
             return $result->getModifiedCount() ? $result->getModifiedCount() : $result->getUpsertedCount();
         }
 
@@ -791,10 +786,10 @@ public function convertKey($id)
     /**
      * Add a basic where clause to the query.
      *
-     * @param  string  $column
-     * @param  string  $operator
-     * @param  mixed   $value
-     * @param  string  $boolean
+     * @param  string $column
+     * @param  string $operator
+     * @param  mixed $value
+     * @param  string $boolean
      * @return \Illuminate\Database\Query\Builder|static
      *
      * @throws \InvalidArgumentException
@@ -835,14 +830,14 @@ protected function compileWheres()
 
                 // Operator conversions
                 $convert = [
-                    'regexp'        => 'regex',
-                    'elemmatch'     => 'elemMatch',
+                    'regexp' => 'regex',
+                    'elemmatch' => 'elemMatch',
                     'geointersects' => 'geoIntersects',
-                    'geowithin'     => 'geoWithin',
-                    'nearsphere'    => 'nearSphere',
-                    'maxdistance'   => 'maxDistance',
-                    'centersphere'  => 'centerSphere',
-                    'uniquedocs'    => 'uniqueDocs',
+                    'geowithin' => 'geoWithin',
+                    'nearsphere' => 'nearSphere',
+                    'maxdistance' => 'maxDistance',
+                    'centersphere' => 'centerSphere',
+                    'uniquedocs' => 'uniqueDocs',
                 ];
 
                 if (array_key_exists($where['operator'], $convert)) {
@@ -857,9 +852,7 @@ protected function compileWheres()
                     foreach ($where['values'] as &$value) {
                         $value = $this->convertKey($value);
                     }
-                }
-
-                // Single value.
+                } // Single value.
                 elseif (isset($where['value'])) {
                     $where['value'] = $this->convertKey($where['value']);
                 }
@@ -911,20 +904,18 @@ protected function compileWhereBasic($where)
             $regex = preg_replace('#(^|[^\\\])%#', '$1.*', preg_quote($value));
 
             // Convert like to regular expression.
-            if (! starts_with($value, '%')) {
+            if (!starts_with($value, '%')) {
                 $regex = '^' . $regex;
             }
-            if (! ends_with($value, '%')) {
+            if (!ends_with($value, '%')) {
                 $regex = $regex . '$';
             }
 
             $value = new Regex($regex, 'i');
-        }
-
-        // Manipulate regexp operations.
+        } // Manipulate regexp operations.
         elseif (in_array($operator, ['regexp', 'not regexp', 'regex', 'not regex'])) {
             // Automatically convert regular expression strings to Regex objects.
-            if (! $value instanceof Regex) {
+            if (!$value instanceof Regex) {
                 $e = explode('/', $value);
                 $flag = end($e);
                 $regstr = substr($value, 1, -(strlen($flag) + 1));
@@ -938,7 +929,7 @@ protected function compileWhereBasic($where)
             }
         }
 
-        if (! isset($operator) or $operator == '=') {
+        if (!isset($operator) or $operator == '=') {
             $query = [$column => $value];
         } elseif (array_key_exists($operator, $this->conversion)) {
             $query = [$column => [$this->conversion[$operator] => $value]];
@@ -1023,8 +1014,8 @@ protected function compileWhereRaw($where)
     /**
      * Handle dynamic method calls into the method.
      *
-     * @param  string  $method
-     * @param  array   $parameters
+     * @param  string $method
+     * @param  array $parameters
      * @return mixed
      */
     public function __call($method, $parameters)
@@ -1035,4 +1026,4 @@ public function __call($method, $parameters)
 
         return parent::__call($method, $parameters);
     }
-}
+}
\ No newline at end of file

From 5706ed380bbf301ceffb9a5eee205b841677ff0c Mon Sep 17 00:00:00 2001
From: pi0 <pyapar@gmail.com>
Date: Tue, 2 Aug 2016 17:56:15 +0430
Subject: [PATCH 3/5] Style CI

---
 .../Mongodb/MongodbServiceProvider.php        |   4 +-
 src/Jenssegers/Mongodb/Query/Builder.php      | 188 +++++++++---------
 2 files changed, 101 insertions(+), 91 deletions(-)

diff --git a/src/Jenssegers/Mongodb/MongodbServiceProvider.php b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
index 5fca7990e..ee72bf034 100644
--- a/src/Jenssegers/Mongodb/MongodbServiceProvider.php
+++ b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
@@ -15,8 +15,8 @@ public function boot()
 
         Model::setEventDispatcher($this->app['events']);
 
-        $s=explode('.',\Illuminate\Foundation\Application::VERSION);
-        define('SHOULD_RETURN_COLLECTION',(10*$s[0]+$s[1])>=53);
+        $s = explode('.', \Illuminate\Foundation\Application::VERSION);
+        define('SHOULD_RETURN_COLLECTION', (10 * $s[0] + $s[1]) >= 53);
     }
 
     /**
diff --git a/src/Jenssegers/Mongodb/Query/Builder.php b/src/Jenssegers/Mongodb/Query/Builder.php
index 8a4372b71..dabca2a2b 100644
--- a/src/Jenssegers/Mongodb/Query/Builder.php
+++ b/src/Jenssegers/Mongodb/Query/Builder.php
@@ -11,7 +11,6 @@
 use MongoDB\BSON\Regex;
 use MongoDB\BSON\UTCDateTime;
 
-
 class Builder extends BaseBuilder
 {
     /**
@@ -70,12 +69,12 @@ class Builder extends BaseBuilder
      * @var array
      */
     protected $conversion = [
-        '=' => '=',
+        '='  => '=',
         '!=' => '$ne',
         '<>' => '$ne',
-        '<' => '$lt',
+        '<'  => '$lt',
         '<=' => '$lte',
-        '>' => '$gt',
+        '>'  => '$gt',
         '>=' => '$gte',
     ];
 
@@ -83,7 +82,7 @@ class Builder extends BaseBuilder
      * Create a new query builder instance.
      *
      * @param Connection $connection
-     * @param Processor $processor
+     * @param Processor  $processor
      */
     public function __construct(Connection $connection, Processor $processor)
     {
@@ -95,7 +94,7 @@ public function __construct(Connection $connection, Processor $processor)
     /**
      * Set the projections.
      *
-     * @param  array $columns
+     * @param  array  $columns
      * @return $this
      */
     public function project($columns)
@@ -134,8 +133,8 @@ public function hint($index)
     /**
      * Execute a query for a single record by ID.
      *
-     * @param  mixed $id
-     * @param  array $columns
+     * @param  mixed  $id
+     * @param  array  $columns
      * @return mixed
      */
     public function find($id, $columns = [])
@@ -146,7 +145,7 @@ public function find($id, $columns = [])
     /**
      * Execute the query as a "select" statement.
      *
-     * @param  array $columns
+     * @param  array  $columns
      * @return array|static[]|Collection
      */
     public function get($columns = [])
@@ -157,7 +156,7 @@ public function get($columns = [])
     /**
      * Execute the query as a fresh "select" statement.
      *
-     * @param  array $columns
+     * @param  array  $columns
      * @return array|static[]|Collection
      */
     public function getFresh($columns = [])
@@ -208,7 +207,8 @@ public function getFresh($columns = [])
                     // Translate count into sum.
                     if ($function == 'count') {
                         $group['aggregate'] = ['$sum' => 1];
-                    } // Pass other functions directly.
+                    }
+                    // Pass other functions directly.
                     else {
                         $group['aggregate'] = ['$' . $function => '$' . $column];
                     }
@@ -260,7 +260,9 @@ public function getFresh($columns = [])
 
             // Return results
             return SHOULD_RETURN_COLLECTION ? new Collection($results) : $results;
-        } // Distinct query
+        }
+
+        // Distinct query
         elseif ($this->distinct) {
             // Return distinct results directly
             $column = isset($this->columns[0]) ? $this->columns[0] : '_id';
@@ -273,7 +275,9 @@ public function getFresh($columns = [])
             }
 
             return SHOULD_RETURN_COLLECTION ? new Collection($result) : $result;
-        } // Normal query
+        }
+
+        // Normal query
         else {
             $columns = [];
 
@@ -328,13 +332,13 @@ public function generateCacheKey()
         $key = [
             'connection' => $this->collection->getDatabaseName(),
             'collection' => $this->collection->getCollectionName(),
-            'wheres' => $this->wheres,
-            'columns' => $this->columns,
-            'groups' => $this->groups,
-            'orders' => $this->orders,
-            'offset' => $this->offset,
-            'limit' => $this->limit,
-            'aggregate' => $this->aggregate,
+            'wheres'     => $this->wheres,
+            'columns'    => $this->columns,
+            'groups'     => $this->groups,
+            'orders'     => $this->orders,
+            'offset'     => $this->offset,
+            'limit'      => $this->limit,
+            'aggregate'  => $this->aggregate,
         ];
 
         return md5(serialize(array_values($key)));
@@ -343,8 +347,8 @@ public function generateCacheKey()
     /**
      * Execute an aggregate function on the database.
      *
-     * @param  string $function
-     * @param  array $columns
+     * @param  string  $function
+     * @param  array   $columns
      * @return mixed
      */
     public function aggregate($function, $columns = [])
@@ -360,7 +364,7 @@ public function aggregate($function, $columns = [])
         $this->aggregate = null;
 
         if (isset($results[0])) {
-            $result = (array)$results[0];
+            $result = (array) $results[0];
 
             return $result['aggregate'];
         }
@@ -373,7 +377,7 @@ public function aggregate($function, $columns = [])
      */
     public function exists()
     {
-        return !is_null($this->first());
+        return ! is_null($this->first());
     }
 
     /**
@@ -395,8 +399,8 @@ public function distinct($column = false)
     /**
      * Add an "order by" clause to the query.
      *
-     * @param  string $column
-     * @param  string $direction
+     * @param  string  $column
+     * @param  string  $direction
      * @return Builder
      */
     public function orderBy($column, $direction = 'asc')
@@ -417,10 +421,10 @@ public function orderBy($column, $direction = 'asc')
     /**
      * Add a where between statement to the query.
      *
-     * @param  string $column
-     * @param  array $values
-     * @param  string $boolean
-     * @param  bool $not
+     * @param  string  $column
+     * @param  array   $values
+     * @param  string  $boolean
+     * @param  bool  $not
      * @return Builder
      */
     public function whereBetween($column, array $values, $boolean = 'and', $not = false)
@@ -435,8 +439,8 @@ public function whereBetween($column, array $values, $boolean = 'and', $not = fa
     /**
      * Set the limit and offset for a given page.
      *
-     * @param  int $page
-     * @param  int $perPage
+     * @param  int  $page
+     * @param  int  $perPage
      * @return \Illuminate\Database\Query\Builder|static
      */
     public function forPage($page, $perPage = 15)
@@ -449,7 +453,7 @@ public function forPage($page, $perPage = 15)
     /**
      * Insert a new record into the database.
      *
-     * @param  array $values
+     * @param  array  $values
      * @return bool
      */
     public function insert(array $values)
@@ -461,34 +465,34 @@ public function insert(array $values)
         foreach ($values as $value) {
             // As soon as we find a value that is not an array we assume the user is
             // inserting a single document.
-            if (!is_array($value)) {
+            if (! is_array($value)) {
                 $batch = false;
                 break;
             }
         }
 
-        if (!$batch) {
+        if (! $batch) {
             $values = [$values];
         }
 
         // Batch insert
         $result = $this->collection->insertMany($values);
 
-        return (1 == (int)$result->isAcknowledged());
+        return (1 == (int) $result->isAcknowledged());
     }
 
     /**
      * Insert a new record and get the value of the primary key.
      *
-     * @param  array $values
-     * @param  string $sequence
+     * @param  array   $values
+     * @param  string  $sequence
      * @return int
      */
     public function insertGetId(array $values, $sequence = null)
     {
         $result = $this->collection->insertOne($values);
 
-        if (1 == (int)$result->isAcknowledged()) {
+        if (1 == (int) $result->isAcknowledged()) {
             if (is_null($sequence)) {
                 $sequence = '_id';
             }
@@ -501,14 +505,14 @@ public function insertGetId(array $values, $sequence = null)
     /**
      * Update a record in the database.
      *
-     * @param  array $values
-     * @param  array $options
+     * @param  array  $values
+     * @param  array  $options
      * @return int
      */
     public function update(array $values, array $options = [])
     {
         // Use $set as default operator.
-        if (!starts_with(key($values), '$')) {
+        if (! starts_with(key($values), '$')) {
             $values = ['$set' => $values];
         }
 
@@ -518,16 +522,16 @@ public function update(array $values, array $options = [])
     /**
      * Increment a column's value by a given amount.
      *
-     * @param  string $column
-     * @param  int $amount
-     * @param  array $extra
+     * @param  string  $column
+     * @param  int     $amount
+     * @param  array   $extra
      * @return int
      */
     public function increment($column, $amount = 1, array $extra = [], array $options = [])
     {
         $query = ['$inc' => [$column => $amount]];
 
-        if (!empty($extra)) {
+        if (! empty($extra)) {
             $query['$set'] = $extra;
         }
 
@@ -544,9 +548,9 @@ public function increment($column, $amount = 1, array $extra = [], array $option
     /**
      * Decrement a column's value by a given amount.
      *
-     * @param  string $column
-     * @param  int $amount
-     * @param  array $extra
+     * @param  string  $column
+     * @param  int     $amount
+     * @param  array   $extra
      * @return int
      */
     public function decrement($column, $amount = 1, array $extra = [], array $options = [])
@@ -557,8 +561,8 @@ public function decrement($column, $amount = 1, array $extra = [], array $option
     /**
      * Get an array with the values of a given column.
      *
-     * @param  string $column
-     * @param  string|null $key
+     * @param  string  $column
+     * @param  string|null  $key
      * @return array
      */
     public function pluck($column, $key = null)
@@ -578,14 +582,14 @@ public function pluck($column, $key = null)
     /**
      * Delete a record from the database.
      *
-     * @param  mixed $id
+     * @param  mixed  $id
      * @return int
      */
     public function delete($id = null)
     {
         $wheres = $this->compileWheres();
         $result = $this->collection->DeleteMany($wheres);
-        if (1 == (int)$result->isAcknowledged()) {
+        if (1 == (int) $result->isAcknowledged()) {
             return $result->getDeletedCount();
         }
 
@@ -595,7 +599,7 @@ public function delete($id = null)
     /**
      * Set the collection which the query is targeting.
      *
-     * @param  string $collection
+     * @param  string  $collection
      * @return Builder
      */
     public function from($collection)
@@ -614,14 +618,14 @@ public function truncate()
     {
         $result = $this->collection->drop();
 
-        return (1 == (int)$result->ok);
+        return (1 == (int) $result->ok);
     }
 
     /**
      * Get an array with the values of a given column.
      *
-     * @param  string $column
-     * @param  string $key
+     * @param  string  $column
+     * @param  string  $key
      * @return array
      */
     public function lists($column, $key = null)
@@ -631,7 +635,7 @@ public function lists($column, $key = null)
 
             // Convert ObjectID's to strings so that lists can do its work.
             $results = $results->map(function ($item) {
-                $item['_id'] = (string)$item['_id'];
+                $item['_id'] = (string) $item['_id'];
 
                 return $item;
             });
@@ -645,7 +649,7 @@ public function lists($column, $key = null)
     /**
      * Create a raw database expression.
      *
-     * @param  closure $expression
+     * @param  closure  $expression
      * @return mixed
      */
     public function raw($expression = null)
@@ -653,8 +657,10 @@ public function raw($expression = null)
         // Execute the closure on the mongodb collection
         if ($expression instanceof Closure) {
             return call_user_func($expression, $this->collection);
-        } // Create an expression for the given value
-        elseif (!is_null($expression)) {
+        }
+
+        // Create an expression for the given value
+        elseif (! is_null($expression)) {
             return new Expression($expression);
         }
 
@@ -665,8 +671,8 @@ public function raw($expression = null)
     /**
      * Append one or more values to an array.
      *
-     * @param  mixed $column
-     * @param  mixed $value
+     * @param  mixed   $column
+     * @param  mixed   $value
      * @return int
      */
     public function push($column, $value = null, $unique = false)
@@ -691,8 +697,8 @@ public function push($column, $value = null, $unique = false)
     /**
      * Remove one or more values from an array.
      *
-     * @param  mixed $column
-     * @param  mixed $value
+     * @param  mixed   $column
+     * @param  mixed   $value
      * @return int
      */
     public function pull($column, $value = null)
@@ -720,7 +726,7 @@ public function pull($column, $value = null)
      */
     public function drop($columns)
     {
-        if (!is_array($columns)) {
+        if (! is_array($columns)) {
             $columns = [$columns];
         }
 
@@ -748,20 +754,20 @@ public function newQuery()
     /**
      * Perform an update query.
      *
-     * @param  array $query
-     * @param  array $options
+     * @param  array  $query
+     * @param  array  $options
      * @return int
      */
     protected function performUpdate($query, array $options = [])
     {
         // Update multiple items by default.
-        if (!array_key_exists('multiple', $options)) {
+        if (! array_key_exists('multiple', $options)) {
             $options['multiple'] = true;
         }
 
         $wheres = $this->compileWheres();
         $result = $this->collection->UpdateMany($wheres, $query, $options);
-        if (1 == (int)$result->isAcknowledged()) {
+        if (1 == (int) $result->isAcknowledged()) {
             return $result->getModifiedCount() ? $result->getModifiedCount() : $result->getUpsertedCount();
         }
 
@@ -786,10 +792,10 @@ public function convertKey($id)
     /**
      * Add a basic where clause to the query.
      *
-     * @param  string $column
-     * @param  string $operator
-     * @param  mixed $value
-     * @param  string $boolean
+     * @param  string  $column
+     * @param  string  $operator
+     * @param  mixed   $value
+     * @param  string  $boolean
      * @return \Illuminate\Database\Query\Builder|static
      *
      * @throws \InvalidArgumentException
@@ -830,14 +836,14 @@ protected function compileWheres()
 
                 // Operator conversions
                 $convert = [
-                    'regexp' => 'regex',
-                    'elemmatch' => 'elemMatch',
+                    'regexp'        => 'regex',
+                    'elemmatch'     => 'elemMatch',
                     'geointersects' => 'geoIntersects',
-                    'geowithin' => 'geoWithin',
-                    'nearsphere' => 'nearSphere',
-                    'maxdistance' => 'maxDistance',
-                    'centersphere' => 'centerSphere',
-                    'uniquedocs' => 'uniqueDocs',
+                    'geowithin'     => 'geoWithin',
+                    'nearsphere'    => 'nearSphere',
+                    'maxdistance'   => 'maxDistance',
+                    'centersphere'  => 'centerSphere',
+                    'uniquedocs'    => 'uniqueDocs',
                 ];
 
                 if (array_key_exists($where['operator'], $convert)) {
@@ -852,7 +858,9 @@ protected function compileWheres()
                     foreach ($where['values'] as &$value) {
                         $value = $this->convertKey($value);
                     }
-                } // Single value.
+                }
+
+                // Single value.
                 elseif (isset($where['value'])) {
                     $where['value'] = $this->convertKey($where['value']);
                 }
@@ -904,18 +912,20 @@ protected function compileWhereBasic($where)
             $regex = preg_replace('#(^|[^\\\])%#', '$1.*', preg_quote($value));
 
             // Convert like to regular expression.
-            if (!starts_with($value, '%')) {
+            if (! starts_with($value, '%')) {
                 $regex = '^' . $regex;
             }
-            if (!ends_with($value, '%')) {
+            if (! ends_with($value, '%')) {
                 $regex = $regex . '$';
             }
 
             $value = new Regex($regex, 'i');
-        } // Manipulate regexp operations.
+        }
+
+        // Manipulate regexp operations.
         elseif (in_array($operator, ['regexp', 'not regexp', 'regex', 'not regex'])) {
             // Automatically convert regular expression strings to Regex objects.
-            if (!$value instanceof Regex) {
+            if (! $value instanceof Regex) {
                 $e = explode('/', $value);
                 $flag = end($e);
                 $regstr = substr($value, 1, -(strlen($flag) + 1));
@@ -929,7 +939,7 @@ protected function compileWhereBasic($where)
             }
         }
 
-        if (!isset($operator) or $operator == '=') {
+        if (! isset($operator) or $operator == '=') {
             $query = [$column => $value];
         } elseif (array_key_exists($operator, $this->conversion)) {
             $query = [$column => [$this->conversion[$operator] => $value]];
@@ -1014,8 +1024,8 @@ protected function compileWhereRaw($where)
     /**
      * Handle dynamic method calls into the method.
      *
-     * @param  string $method
-     * @param  array $parameters
+     * @param  string  $method
+     * @param  array   $parameters
      * @return mixed
      */
     public function __call($method, $parameters)

From 49eb85cb1775d18112c8c831ab6110d1244fad5c Mon Sep 17 00:00:00 2001
From: pi0 <pyapar@gmail.com>
Date: Tue, 2 Aug 2016 17:58:54 +0430
Subject: [PATCH 4/5] Check SHOULD_RETURN_COLLECTION is not defined

---
 src/Jenssegers/Mongodb/MongodbServiceProvider.php | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/Jenssegers/Mongodb/MongodbServiceProvider.php b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
index ee72bf034..6c0376e9a 100644
--- a/src/Jenssegers/Mongodb/MongodbServiceProvider.php
+++ b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
@@ -15,8 +15,10 @@ public function boot()
 
         Model::setEventDispatcher($this->app['events']);
 
-        $s = explode('.', \Illuminate\Foundation\Application::VERSION);
-        define('SHOULD_RETURN_COLLECTION', (10 * $s[0] + $s[1]) >= 53);
+        if(!defined('SHOULD_RETURN_COLLECTION')) {
+            $s = explode('.', \Illuminate\Foundation\Application::VERSION);
+            define('SHOULD_RETURN_COLLECTION', (10 * $s[0] + $s[1]) >= 53);
+        }
     }
 
     /**

From c0e80b4bd698e238dfab6cf2dfbb51ae4eb843f7 Mon Sep 17 00:00:00 2001
From: pi0 <pyapar@gmail.com>
Date: Tue, 2 Aug 2016 18:02:00 +0430
Subject: [PATCH 5/5] Style CI

---
 src/Jenssegers/Mongodb/MongodbServiceProvider.php | 2 +-
 src/Jenssegers/Mongodb/Query/Builder.php          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Jenssegers/Mongodb/MongodbServiceProvider.php b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
index 6c0376e9a..dee5ac076 100644
--- a/src/Jenssegers/Mongodb/MongodbServiceProvider.php
+++ b/src/Jenssegers/Mongodb/MongodbServiceProvider.php
@@ -15,7 +15,7 @@ public function boot()
 
         Model::setEventDispatcher($this->app['events']);
 
-        if(!defined('SHOULD_RETURN_COLLECTION')) {
+        if (!defined('SHOULD_RETURN_COLLECTION')) {
             $s = explode('.', \Illuminate\Foundation\Application::VERSION);
             define('SHOULD_RETURN_COLLECTION', (10 * $s[0] + $s[1]) >= 53);
         }
diff --git a/src/Jenssegers/Mongodb/Query/Builder.php b/src/Jenssegers/Mongodb/Query/Builder.php
index dabca2a2b..076b42719 100644
--- a/src/Jenssegers/Mongodb/Query/Builder.php
+++ b/src/Jenssegers/Mongodb/Query/Builder.php
@@ -1036,4 +1036,4 @@ public function __call($method, $parameters)
 
         return parent::__call($method, $parameters);
     }
-}
\ No newline at end of file
+}