alcaeus / mongo-php-adapter

lib/Mongo/MongoAnalytics.php

Doc Comments +3 added lines

@@ -11,6 +11,9 @@
         return $redis;
     }
 
+    /**
+     * @param Closure $fnc
+     */
     public function eavesdrop($opts = ['criteria' => 0, 'options' => 1], $fnc, $args = [])
     {
         if (isset($opts['readArgs']) && !$opts['readArgs']) {

Spacing +5 added lines, -5 removed lines

@@ -5,7 +5,7 @@ 
     public function analyticalStore()
     {
         static $redis;
-        if (!$redis) {
+        if ( ! $redis) {
             $redis = new Predis\Client();
         }
         return $redis;
@@ -13,7 +13,7 @@ 
 
     public function eavesdrop($opts = ['criteria' => 0, 'options' => 1], $fnc, $args = [])
     {
-        if (isset($opts['readArgs']) && !$opts['readArgs']) {
+        if (isset($opts['readArgs']) && ! $opts['readArgs']) {
             $criteria = $opts['criteria'] ?? [];
             $options = $opts['options'] ?? [];
             $op = $opts['operation'] ?: null;
@@ -21,7 +21,7 @@ 
         } else {
             $criteria = isset($opts['criteria']) ? $args[$opts['criteria']] ?? [] : [];
             $options = isset($opts['options']) ? ($args[$opts['options']] ?? []) : [];
-            $op = is_array($fnc) && !isset($opts['operation']) ?
+            $op = is_array($fnc) && ! isset($opts['operation']) ?
             ($fnc[1] ?? null) : (isset($opts['operation']) ? ($opts['operation'] ?? null) : null);
             $name = $opts['name'] ?? $this->name;
         }
@@ -32,7 +32,7 @@ 
     private function analyticalNormalization(&$criteria)
     {
         if (is_array($criteria)) {
-            array_walk($criteria, function (&$ref) {
+            array_walk($criteria, function(&$ref) {
                 if (is_array($ref)) {
                     $this->analyticalNormalization($ref);
                     return;
@@ -53,7 +53,7 @@ 
         $serialized = json_encode($payload);
         $redisKey = sprintf("mongodb/%s/%s/%s", $name ?: $this->name, $op, md5($serialized));
 
-        $onEnd = function () use ($serialized, $redisKey, $init) {
+        $onEnd = function() use ($serialized, $redisKey, $init) {
             $diff = ceil((microtime(true) - $init) * 1000);
             if ($diff < 10) return;
 

Braces +3 added lines, -1 removed lines

@@ -55,7 +55,9 @@
 
         $onEnd = function () use ($serialized, $redisKey, $init) {
             $diff = ceil((microtime(true) - $init) * 1000);
-            if ($diff < 10) return;
+            if ($diff < 10) {
+             return;
+            }
 
             $time = strtotime("+1 hour 00:00");
             $redis = $this->analyticalStore();

lib/Mongo/MongoCursor.php

Doc Comments +2 added lines, -2 removed lines

@@ -490,7 +490,7 @@ 
     }
 
     /**
-     * @return Cursor
+     * @return Traversable
      */
     protected function ensureCursor()
     {
@@ -534,7 +534,7 @@ 
     }
 
     /**
-     * @return array
+     * @return string[]
      */
     public function __sleep()
     {

Spacing +5 added lines, -5 removed lines

@@ -143,7 +143,7 @@ 
         'options' => array_merge(['foundOnly'=> $foundOnly], $this->options),
         'operation' => 'count',
         'name' => $this->collection->getCollectionName()
-      ], function () use ($foundOnly) {
+      ], function() use ($foundOnly) {
           $optionNames = ['hint', 'maxTimeMS'];
           if ($foundOnly) {
               $optionNames = array_merge($optionNames, ['limit', 'skip']);
@@ -173,7 +173,7 @@ 
             'options' => $this->options,
             'operation' => 'count',
             'name' => $this->collection->getCollectionName()
-        ], function () {
+        ], function() {
             // MongoDB\Driver\Cursor needs to be wrapped into a \Generator so that a valid \Iterator with working implementations of
             // next, current, valid, key and rewind is returned. These methods don't work if we wrap the Cursor inside an \IteratorIterator
             if ($this->iterator === null) {
@@ -271,7 +271,7 @@ 
      */
     public function hasNext()
     {
-        if (! $this->startedIterating) {
+        if ( ! $this->startedIterating) {
             $this->ensureIterator();
             $this->startedIterating = true;
             $this->storeIteratorState();
@@ -456,7 +456,7 @@ 
      */
     protected function convertCursorType()
     {
-        if (! $this->tailable) {
+        if ( ! $this->tailable) {
             return null;
         }
 
@@ -510,7 +510,7 @@ 
     protected function wrapTraversable(\Traversable $traversable)
     {
         foreach ($traversable as $key => $value) {
-            if (isset($value->_id) && ($value->_id instanceof \MongoDB\BSON\ObjectID || !is_object($value->_id))) {
+            if (isset($value->_id) && ($value->_id instanceof \MongoDB\BSON\ObjectID || ! is_object($value->_id))) {
                 $key = (string) $value->_id;
             }
             yield $key => $value;

lib/Mongo/MongoCollection.php

Spacing +37 added lines, -37 removed lines

@@ -142,8 +142,8 @@ 
           'criteria' => 0,
           'options' => 1,
           'operation' => 'aggregate'
-        ], function () use ($pipeline, $op) {
-            if (! TypeConverter::isNumericArray($pipeline)) {
+        ], function() use ($pipeline, $op) {
+            if ( ! TypeConverter::isNumericArray($pipeline)) {
                 $operators = func_get_args();
                 $pipeline = [];
                 $options = [];
@@ -151,7 +151,7 @@ 
                 $i = 0;
                 foreach ($operators as $operator) {
                     $i++;
-                    if (! is_array($operator)) {
+                    if ( ! is_array($operator)) {
                         trigger_error("Argument $i is not an array", E_USER_WARNING);
                         return;
                     }
@@ -205,7 +205,7 @@ 
         ];
 
         // Convert cursor option
-        if (! isset($options['cursor'])) {
+        if ( ! isset($options['cursor'])) {
             $options['cursor'] = new \stdClass();
         }
 
@@ -291,7 +291,7 @@ 
      */
     public function insert(&$a, array $options = [])
     {
-        if (! $this->ensureDocumentHasMongoId($a)) {
+        if ( ! $this->ensureDocumentHasMongoId($a)) {
             trigger_error(sprintf('%s(): expects parameter %d to be an array or object, %s given', __METHOD__, 1, gettype($a)), E_USER_WARNING);
             return;
         }
@@ -307,7 +307,7 @@ 
             throw ExceptionConverter::toLegacy($e);
         }
 
-        if (! $result->isAcknowledged()) {
+        if ( ! $result->isAcknowledged()) {
             return true;
         }
 
@@ -338,7 +338,7 @@ 
 
         foreach ($a as $key => $item) {
             try {
-                if (! $this->ensureDocumentHasMongoId($a[$key])) {
+                if ( ! $this->ensureDocumentHasMongoId($a[$key])) {
                     if ($continueOnError) {
                         unset($a[$key]);
                     } else {
@@ -347,7 +347,7 @@ 
                     }
                 }
             } catch (MongoException $e) {
-                if (! $continueOnError) {
+                if ( ! $continueOnError) {
                     throw $e;
                 }
             }
@@ -362,7 +362,7 @@ 
             throw ExceptionConverter::toLegacy($e, 'MongoResultException');
         }
 
-        if (! $result->isAcknowledged()) {
+        if ( ! $result->isAcknowledged()) {
             return true;
         }
 
@@ -393,7 +393,7 @@ 
           'criteria' => 0,
           'options' => 2,
           'operation' => 'update'
-      ], function () use ($criteria, $newobj, $options) {
+      ], function() use ($criteria, $newobj, $options) {
           $this->mustBeArrayOrObject($criteria);
           $this->mustBeArrayOrObject($newobj);
 
@@ -421,7 +421,7 @@ 
               throw ExceptionConverter::toLegacy($e);
           }
 
-          if (! $result->isAcknowledged()) {
+          if ( ! $result->isAcknowledged()) {
               return true;
           }
 
@@ -453,8 +453,8 @@ 
              'criteria' => 0,
              'options' => 1,
              'operation' => 'remove'
-         ], function () use ($criteria, $options) {
-             $multiple = isset($options['justOne']) ? !$options['justOne'] : true;
+         ], function() use ($criteria, $options) {
+             $multiple = isset($options['justOne']) ? ! $options['justOne'] : true;
              $method = $multiple ? 'deleteMany' : 'deleteOne';
 
              try {
@@ -467,7 +467,7 @@ 
                  throw ExceptionConverter::toLegacy($e);
              }
 
-             if (! $result->isAcknowledged()) {
+             if ( ! $result->isAcknowledged()) {
                  return true;
              }
 
@@ -510,7 +510,7 @@ 
           'criteria' => 1,
           'options' => 0,
           'operation' => 'distinct'
-        ], function () use ($key, $query) {
+        ], function() use ($key, $query) {
             try {
                 return array_map([TypeConverter::class, 'toLegacy'], $this->collection->distinct($key, TypeConverter::fromLegacy($query)));
             } catch (\MongoDB\Driver\Exception\Exception $e) {
@@ -535,7 +535,7 @@ 
           'criteria' => 0,
           'options' => 3,
           'operation' => 'findAndModify'
-      ], function () use ($query, $update, $fields, $options) {
+      ], function() use ($query, $update, $fields, $options) {
           $query = TypeConverter::fromLegacy($query);
           try {
               if (isset($options['remove'])) {
@@ -557,7 +557,7 @@ 
 
                   $options['projection'] = TypeConverter::convertProjection($fields);
 
-                  if (! \MongoDB\is_first_key_operator($update)) {
+                  if ( ! \MongoDB\is_first_key_operator($update)) {
                       $document = $this->collection->findOneAndReplace($query, $update, $options);
                   } else {
                       $document = $this->collection->findOneAndUpdate($query, $update, $options);
@@ -592,9 +592,9 @@ 
           'criteria' => 0,
           'options' => 2,
           'operation' => 'findOne'
-      ], function () use ($query, $fields, $options) {
+      ], function() use ($query, $fields, $options) {
           // Can't typehint for array since MongoGridFS extends and accepts strings
-        if (! is_array($query)) {
+        if ( ! is_array($query)) {
             trigger_error(sprintf('MongoCollection::findOne(): expects parameter 1 to be an array or object, %s given', gettype($query)), E_USER_WARNING);
             return;
         }
@@ -635,11 +635,11 @@ 
             $keys = (array) $keys;
         }
 
-        if (! is_array($keys) || ! count($keys)) {
+        if ( ! is_array($keys) || ! count($keys)) {
             throw new MongoException('index specification has no elements');
         }
 
-        if (! isset($options['name'])) {
+        if ( ! isset($options['name'])) {
             $options['name'] = \MongoDB\generate_index_name($keys);
         }
 
@@ -674,14 +674,14 @@ 
         }
 
         $result = [
-            'createdCollectionAutomatically' => !$collectionExists,
+            'createdCollectionAutomatically' => ! $collectionExists,
             'numIndexesBefore' => $indexCount,
             'numIndexesAfter' => $indexCount,
             'note' => 'all indexes already exist',
             'ok' => 1.0,
         ];
 
-        if (! $indexExists) {
+        if ( ! $indexExists) {
             $result['numIndexesAfter']++;
             unset($result['note']);
         }
@@ -714,7 +714,7 @@ 
     {
         if (is_string($keys)) {
             $indexName = $keys;
-            if (! preg_match('#_-?1$#', $indexName)) {
+            if ( ! preg_match('#_-?1$#', $indexName)) {
                 $indexName .= '_1';
             }
         } elseif (is_array($keys)) {
@@ -753,7 +753,7 @@ 
      */
     public function getIndexInfo()
     {
-        $convertIndex = function (\MongoDB\Model\IndexInfo $indexInfo) {
+        $convertIndex = function(\MongoDB\Model\IndexInfo $indexInfo) {
             $infos = [
                 'v' => $indexInfo->getVersion(),
                 'key' => $indexInfo->getKey(),
@@ -777,7 +777,7 @@ 
             ];
 
             foreach ($additionalKeys as $key) {
-                if (! isset($indexInfo[$key])) {
+                if ( ! isset($indexInfo[$key])) {
                     continue;
                 }
 
@@ -804,10 +804,10 @@ 
           'criteria' => 0,
           'options' => 1,
           'operation' => 'count'
-        ], function () use ($query, $options) {
+        ], function() use ($query, $options) {
             try {
                 // Handle legacy mode - limit and skip as second and third parameters, respectively
-            if (! is_array($options)) {
+            if ( ! is_array($options)) {
                 $limit = $options;
                 $options = [];
 
@@ -855,7 +855,7 @@ 
                 $this->convertWriteConcernOptions($options)
             );
 
-            if (! $result->isAcknowledged()) {
+            if ( ! $result->isAcknowledged()) {
                 return true;
             }
 
@@ -889,13 +889,13 @@ 
         if ($document_or_id instanceof \MongoId) {
             $id = $document_or_id;
         } elseif (is_object($document_or_id)) {
-            if (! isset($document_or_id->_id)) {
+            if ( ! isset($document_or_id->_id)) {
                 return null;
             }
 
             $id = $document_or_id->_id;
         } elseif (is_array($document_or_id)) {
-            if (! isset($document_or_id['_id'])) {
+            if ( ! isset($document_or_id['_id'])) {
                 return null;
             }
 
@@ -1008,11 +1008,11 @@ 
             $options['w'] = ($options['safe']) ? 1 : 0;
         }
 
-        if (isset($options['wtimeout']) && !isset($options['wTimeoutMS'])) {
+        if (isset($options['wtimeout']) && ! isset($options['wTimeoutMS'])) {
             $options['wTimeoutMS'] = $options['wtimeout'];
         }
 
-        if (isset($options['w']) || !isset($options['wTimeoutMS'])) {
+        if (isset($options['w']) || ! isset($options['wTimeoutMS'])) {
             $collectionWriteConcern = $this->getWriteConcern();
             $writeConcern = $this->createWriteConcernFromParameters(
                 isset($options['w']) ? $options['w'] : $collectionWriteConcern['w'],
@@ -1050,7 +1050,7 @@ 
     private function ensureDocumentHasMongoId(&$document)
     {
         if (is_array($document)) {
-            if (! isset($document['_id'])) {
+            if ( ! isset($document['_id'])) {
                 $document['_id'] = new \MongoId();
             }
 
@@ -1060,12 +1060,12 @@ 
         } elseif (is_object($document)) {
             $reflectionObject = new \ReflectionObject($document);
             foreach ($reflectionObject->getProperties() as $property) {
-                if (! $property->isPublic()) {
+                if ( ! $property->isPublic()) {
                     throw new \MongoException('zero-length keys are not allowed, did you use $ with double quotes?');
                 }
             }
 
-            if (! isset($document->_id)) {
+            if ( ! isset($document->_id)) {
                 $document->_id = new \MongoId();
             }
 
@@ -1096,7 +1096,7 @@ 
 
     private function mustBeArrayOrObject($a)
     {
-        if (!is_array($a) && !is_object($a)) {
+        if ( ! is_array($a) && ! is_object($a)) {
             throw new \MongoException('document must be an array or object');
         }
     }

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -152,7 +152,7 @@
                 foreach ($operators as $operator) {
                     $i++;
                     if (! is_array($operator)) {
-                        trigger_error("Argument $i is not an array", E_USER_WARNING);
+                        trigger_error("argument $i is not an array", E_USER_WARNING);
                         return;
                     }