Pouzor / mongoDBBundle

DocumentManager/DocumentManager.php

Doc Comments +2 added lines, -2 removed lines

@@ -136,7 +136,7 @@ 
     }
 
     /**
-     * @param $collection
+     * @param string $collection
      * @param $id
      * @param array $options
      * @return null|object
@@ -147,7 +147,7 @@ 
     }
 
     /**
-     * @param $collectionName
+     * @param string $collectionName
      * @param array $filter
      * @return \MongoDB\DeleteResult
      */

Repository/Repository.php

Doc Comments +4 added lines, -4 removed lines

@@ -52,7 +52,7 @@ 
     /**
      * Repository constructor.
      * @param $name
-     * @param $manager
+     * @param \Pouzor\MongoDBBundle\DocumentManager\DocumentManager $manager
      */
     public function __construct($name, $manager)
     {
@@ -143,7 +143,7 @@ 
      * Persist a document
      *
      * @param $document
-     * @return null | BulkWriteResult
+     * @return BulkWriteResult|null | BulkWriteResult
      */
     public function persist($document, $andFlush = false)
     {
@@ -545,7 +545,7 @@ 
     /**
      * Return the max value for a field in a collection
      *
-     * @param $field
+     * @param string $field
      * @param array $query
      * @param array $options
      * @return mixed
@@ -582,7 +582,7 @@ 
     /**
      * Return the min value for a field in a collection
      *
-     * @param $field
+     * @param string $field
      * @param array $query
      * @param array $options
      * @return \Traversable

Unused Use Statements -2 removed lines

@@ -5,8 +5,6 @@
 
 use MongoDB\BulkWriteResult;
 use MongoDB\Collection;
-use MongoDB\Operation\InsertOne;
-use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 use Pouzor\MongoDBBundle\Constants\DriverClasses;
 use Pouzor\MongoDBBundle\Constants\Query;

Spacing +10 added lines, -10 removed lines

@@ -92,10 +92,10 @@ 
             if (preg_match($regex, $re->getMessage(), $output)) {
                 $name = $output['name'];
 
-                $this->logger->info('Dropping index ' . $name);
+                $this->logger->info('Dropping index '.$name);
                 $result = $this->collection->dropIndex($name);
 
-                $this->logger->info('Result from dropping index ' . $name, $result);
+                $this->logger->info('Result from dropping index '.$name, $result);
 
                 $this->ensureIndex($fields, $options, $callback);
             }
@@ -519,7 +519,7 @@ 
         $query = [$field => ['$gt' => $min, '$lte' => $max]];
 
         $this->logger->info(
-            'Counting  ' . $field,
+            'Counting  '.$field,
             [
                 'filter' => [
                     $field => ['$gt' => $min, '$lte' => $max]
@@ -575,7 +575,7 @@ 
             ]
         )->toArray();
 
-        return ArrayAccessor::dget($result, '0.' . $field);
+        return ArrayAccessor::dget($result, '0.'.$field);
 
     }
 
@@ -612,7 +612,7 @@ 
             ]
         )->toArray();
 
-        return ArrayAccessor::dget($result, '0.' . $field);
+        return ArrayAccessor::dget($result, '0.'.$field);
     }
 
     /**
@@ -625,7 +625,7 @@ 
     {
 
         $this->logger->info(
-            'Distinct over ' . $field,
+            'Distinct over '.$field,
             [
                 'filter' => $filter,
                 'options' => $options,
@@ -667,28 +667,28 @@ 
          * limit
          */
         if (isset($options[Query::SORT]) and !is_array($options[Query::SORT])) {
-            throw new \InvalidArgumentException(Query::SORT . ' option must be an array');
+            throw new \InvalidArgumentException(Query::SORT.' option must be an array');
         }
 
         /**
          * limit
          */
         if (isset($options[Query::PROJECTION]) and !is_array($options[Query::PROJECTION])) {
-            throw new \InvalidArgumentException(Query::PROJECTION . ' option must be an array');
+            throw new \InvalidArgumentException(Query::PROJECTION.' option must be an array');
         }
 
         /**
          *  limit
          */
         if (isset($options[Query::LIMIT]) and !is_integer($options[Query::LIMIT])) {
-            throw new \InvalidArgumentException(Query::LIMIT . " option must be an integer");
+            throw new \InvalidArgumentException(Query::LIMIT." option must be an integer");
         }
 
         /**
          *  limit
          */
         if (isset($options[Query::OFFSET]) and !is_integer($options[Query::OFFSET])) {
-            throw new \InvalidArgumentException(Query::OFFSET . ' option must be an array');
+            throw new \InvalidArgumentException(Query::OFFSET.' option must be an array');
         }
 
         // TODO validate other options

Services/ArrayAccessor.php

Doc Comments +10 added lines, -10 removed lines

@@ -10,8 +10,8 @@ 
      * Replace an array key with another while keeping value
      *
      * @param array $array
-     * @param $key1
-     * @param $key2
+     * @param string $key1
+     * @param string $key2
      * @return array
      */
     static function replaceKey(&$array, $key1, $key2)
@@ -47,8 +47,8 @@ 
      * person.childs.0.name = victor
      *
      * @param array $data
-     * @param $path
-     * @param $default
+     * @param string $path
+     * @param string $default
      * @return array|null
      */
     static function dget(array &$data, $path, $default = null)
@@ -85,8 +85,8 @@ 
      *
      *
      * @param array $data
-     * @param $path
-     * @param $value
+     * @param string $path
+     * @param string $value
      */
     static function dset(array &$data, $path, $value)
     {
@@ -123,7 +123,7 @@ 
      * person.childs = 2
      *
      * @param array $data
-     * @param $path
+     * @param string $path
      * @return int|null
      */
     static function dcount(array &$data, $path)
@@ -171,7 +171,7 @@ 
      * )
      *
      * @param array $data
-     * @param $path
+     * @param string $path
      */
     static function ddel(array &$data, $path)
     {
@@ -189,8 +189,8 @@ 
 
     /**
      * @param $array
-     * @param $key
-     * @param null $default
+     * @param string $key
+     * @param string $default
      * @return null
      */
     static function get_key_exist($array, $key, $default = null) {

Spacing +5 added lines, -5 removed lines

@@ -56,7 +56,7 @@ 
         $keys = explode('.', $path);
         foreach ($keys as $k) {
             if (isset($data[$k])) {
-                $data =& $data[$k];
+                $data = & $data[$k];
             } else {
                 return $default;
             }
@@ -94,10 +94,10 @@ 
         $last = array_pop($keys);
         foreach ($keys as $k) {
             if (isset($data[$k]) && is_array($data[$k])) {
-                $data =& $data[$k];
+                $data = & $data[$k];
             } else {
                 $data[$k] = array();
-                $data =& $data[$k];
+                $data = & $data[$k];
             }
         }
         $data[$last] = $value;
@@ -132,7 +132,7 @@ 
         $last = array_pop($keys);
         foreach ($keys as $k) {
             if (isset($data[$k]) && is_array($data[$k])) {
-                $data =& $data[$k];
+                $data = & $data[$k];
             } else {
                 return null;
             }
@@ -179,7 +179,7 @@ 
         $last = array_pop($keys);
         foreach ($keys as $k) {
             if (isset($data[$k]) && is_array($data[$k])) {
-                $data =& $data[$k];
+                $data = & $data[$k];
             } else {
                 return;
             }

Braces +3 added lines, -2 removed lines

@@ -195,8 +195,9 @@
      */
     static function get_key_exist($array, $key, $default = null) {
 
-        if (isset($array[$key]))
-            return $array[$key];
+        if (isset($array[$key])) {
+                    return $array[$key];
+        }
 
         return $default;
 

Command/BuildIndexesCommand.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
 
         $manager = $this->getContainer()->get('document.manager');
 
-        $callback = function ($name) use ($style) {
+        $callback = function($name) use ($style) {
             $style->comment(sprintf('%s : Ok', $name));
         };
 

DependencyInjection/Compiler/MongoTypeTransformer.php

Spacing +5 added lines, -5 removed lines

@@ -17,9 +17,9 @@ 
 
         $references = [];
 
-        foreach($ids as $id => $tags)
+        foreach ($ids as $id => $tags)
         {
-            foreach($tags as $tag => $attributes)
+            foreach ($tags as $tag => $attributes)
             {
                 $references[] = new Reference($id);
             }
@@ -27,12 +27,12 @@ 
 
         $managers = $container->findTaggedServiceIds('document.manager');
 
-        foreach($managers as $id => $tags)
+        foreach ($managers as $id => $tags)
         {
             $def = $container->getDefinition($id);
 
-            foreach($references as $ref){
-                $def->addMethodCall('addTransformer', [ $ref]);
+            foreach ($references as $ref) {
+                $def->addMethodCall('addTransformer', [$ref]);
             }
         }
     }

DependencyInjection/MongoDBExtension.php

Spacing +3 added lines, -3 removed lines

@@ -31,12 +31,12 @@
             );
 
             $def = $container->register('document.manager.'.$name, DocumentManager::class);
-            $def->addTag('document.manager',[ 'name' => $name]);
+            $def->addTag('document.manager', ['name' => $name]);
             $def->setArguments([$con, new Reference('logger')]);
-            $def->addTag('monolog.logger', [ 'channel' => 'odm.mongo']);
+            $def->addTag('monolog.logger', ['channel' => 'odm.mongo']);
         }
 
-        if(isset($mergedConfig['default_connection']) and $container->hasDefinition('document.manager.'.$mergedConfig['default_connection'])){
+        if (isset($mergedConfig['default_connection']) and $container->hasDefinition('document.manager.'.$mergedConfig['default_connection'])) {
             $container->setAlias('document.manager', 'document.manager.'.$mergedConfig['default_connection']);
         }
     }

DependencyInjection/Configuration.php

Spacing +4 added lines, -4 removed lines

@@ -70,12 +70,12 @@ 
                                     ->beforeNormalization()
                                     // Handle readPreferenceTag XML nodes
                                     ->ifTrue(
-                                        function ($v) {
+                                        function($v) {
                                             return isset($v['readPreferenceTag']);
                                         }
                                     )
                                     ->then(
-                                        function ($v) {
+                                        function($v) {
                                             // Equivalent of fixXmlConfig() for inner node
                                             if (isset($v['readPreferenceTag']['name'])) {
                                                 $v['readPreferenceTag'] = array($v['readPreferenceTag']);
@@ -97,12 +97,12 @@ 
                     ->end()
                     ->validate()
                     ->ifTrue(
-                        function ($v) {
+                        function($v) {
                             return count($v['readPreferenceTags']) === 0;
                         }
                     )
                     ->then(
-                        function ($v) {
+                        function($v) {
                             unset($v['readPreferenceTags']);
 
                             return $v;