as3io / modlr-persister-mongodb

src/SchemaManager.php

Doc Comments -2 removed lines

@@ -16,7 +16,6 @@ 
      * Applies schemata
      *
      * @param   Collection  $collection     The MongoDB Collection
-     * @param   array       $index          Associative array containing index data
      */
     public function createSchemata(Collection $collection, array $schemata)
     {
@@ -31,7 +30,6 @@ 
      * @todo    Implement
      *
      * @param   Collection  $collection     The MongoDB Collection
-     * @param   array       $index              Associative array containing index data
      */
     public function syncSchemata(Collection $collection, array $schemata)
     {

Spacing +3 added lines, -3 removed lines

@@ -21,11 +21,11 @@
     public function createSchemata(Collection $collection, array $schemata)
     {
         foreach ($schemata as $schema) {
-            if (!isset($schema['keys']) || empty($schema['keys'])) {
+            if (!isset($schema[ 'keys' ]) || empty($schema[ 'keys' ])) {
                 throw new \InvalidArgumentException('Cannot create an index with no keys defined.');
             }
-            $schema['options']['background'] = true;
-            $collection->ensureIndex($schema['keys'], $schema['options']);
+            $schema[ 'options' ][ 'background' ] = true;
+            $collection->ensureIndex($schema[ 'keys' ], $schema[ 'options' ]);
         }
     }
 

src/StorageMetadata.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
      *
      * @var array
      */
-    public $schemata = [];
+    public $schemata = [ ];
 
     /**
      * {@inheritDoc}

src/Persister.php

Spacing +17 added lines, -17 removed lines

@@ -27,11 +27,11 @@ 
      * @var array
      */
     private $changeSetMethods = [
-        'attributes'    => ['getAttribute', 'getAttributeDbValue'],
-        'hasOne'        => ['getRelationship', 'getHasOneDbValue'],
-        'hasMany'       => ['getRelationship', 'getHasManyDbValue'],
-        'embedOne'      => ['getEmbed', 'getEmbedOneDbValue'],
-        'embedMany'     => ['getEmbed', 'getEmbedManyDbValue'],
+        'attributes'    => [ 'getAttribute', 'getAttributeDbValue' ],
+        'hasOne'        => [ 'getRelationship', 'getHasOneDbValue' ],
+        'hasMany'       => [ 'getRelationship', 'getHasManyDbValue' ],
+        'embedOne'      => [ 'getEmbed', 'getEmbedOneDbValue' ],
+        'embedMany'     => [ 'getEmbed', 'getEmbedManyDbValue' ],
     ];
 
     /**
@@ -76,7 +76,7 @@ 
     /**
      * {@inheritDoc}
      */
-    public function all(EntityMetadata $metadata, Store $store, array $identifiers = [], array $fields = [], array $sort = [], $offset = 0, $limit = 0)
+    public function all(EntityMetadata $metadata, Store $store, array $identifiers = [ ], array $fields = [ ], array $sort = [ ], $offset = 0, $limit = 0)
     {
         $criteria = $this->getQuery()->getRetrieveCritiera($metadata, $identifiers);
         $cursor = $this->getQuery()->executeFind($metadata, $store, $criteria, $fields, $sort, $offset, $limit);
@@ -109,7 +109,7 @@ 
     public function createSchemata(EntityMetadata $metadata)
     {
         $collection = $this->getQuery()->getModelCollection($metadata);
-        $schemata = $metadata->persistence->schemata ?: [];
+        $schemata = $metadata->persistence->schemata ?: [ ];
         return $this->schemaManager->createSchemata($collection, $schemata);
     }
 
@@ -119,7 +119,7 @@ 
     public function syncSchemata(EntityMetadata $metadata)
     {
         $collection = $this->getQuery()->getModelCollection($metadata);
-        $schemata = $metadata->persistence->schemata ?: [];
+        $schemata = $metadata->persistence->schemata ?: [ ];
         return $this->schemaManager->syncSchemata($collection);
     }
 
@@ -222,7 +222,7 @@ 
     /**
      * {@inheritDoc}
      */
-    public function query(EntityMetadata $metadata, Store $store, array $criteria, array $fields = [], array $sort = [], $offset = 0, $limit = 0)
+    public function query(EntityMetadata $metadata, Store $store, array $criteria, array $fields = [ ], array $sort = [ ], $offset = 0, $limit = 0)
     {
         $cursor = $this->getQuery()->executeFind($metadata, $store, $criteria, $fields, $sort, $offset, $limit);
         return $this->getHydrator()->createCursorRecordSet($metadata, $cursor, $store);
@@ -272,8 +272,8 @@ 
 
         foreach ($this->changeSetMethods as $setKey => $methods) {
             list($metaMethod, $formatMethod) = $methods;
-            foreach ($changeset[$setKey] as $key => $values) {
-                $value = $formatter->$formatMethod($metadata->$metaMethod($key), $values['new']);
+            foreach ($changeset[ $setKey ] as $key => $values) {
+                $value = $formatter->$formatMethod($metadata->$metaMethod($key), $values[ 'new' ]);
                 $obj = $handler($key, $value, $obj);
             }
         }
@@ -293,7 +293,7 @@ 
             $this->getIdentifierKey()   => $this->convertId($model->getId()),
         ];
         if (true === $metadata->isChildEntity()) {
-            $insert[$this->getPolymorphicKey()] = $metadata->type;
+            $insert[ $this->getPolymorphicKey() ] = $metadata->type;
         }
         return $this->appendChangeSet($model, $insert, $this->getCreateChangeSetHandler());
     }
@@ -306,7 +306,7 @@ 
      */
     private function createUpdateObj(Model $model)
     {
-        return $this->appendChangeSet($model, [], $this->getUpdateChangeSetHandler());
+        return $this->appendChangeSet($model, [ ], $this->getUpdateChangeSetHandler());
     }
 
     /**
@@ -316,9 +316,9 @@ 
      */
     private function getCreateChangeSetHandler()
     {
-        return function ($key, $value, $obj) {
+        return function($key, $value, $obj) {
             if (null !== $value) {
-                $obj[$key] = $value;
+                $obj[ $key ] = $value;
             }
             return $obj;
         };
@@ -331,13 +331,13 @@ 
      */
     private function getUpdateChangeSetHandler()
     {
-        return function ($key, $value, $obj) {
+        return function($key, $value, $obj) {
             $op = '$set';
             if (null === $value) {
                 $op = '$unset';
                 $value = 1;
             }
-            $obj[$op][$key] = $value;
+            $obj[ $op ][ $key ] = $value;
             return $obj;
         };
     }

tests/PersisterTest.php

Spacing +16 added lines, -16 removed lines

@@ -125,8 +125,8 @@ 
         $metadata = $this->getMetadata()->persistence;
 
         foreach ($metadata->schemata as $schema) {
-            $this->assertTrue(isset($schema['options']['name']) && !empty($schema['options']['name']), 'index name was not applied to schema');
-            $this->assertSame(stripos($schema['options']['name'], 'modlr_'), 0, '`modlr_` prefix missing from schema name');
+            $this->assertTrue(isset($schema[ 'options' ][ 'name' ]) && !empty($schema[ 'options' ][ 'name' ]), 'index name was not applied to schema');
+            $this->assertSame(stripos($schema[ 'options' ][ 'name' ], 'modlr_'), 0, '`modlr_` prefix missing from schema name');
         }
     }
 
@@ -136,7 +136,7 @@ 
      */
     public function testSchemaRequiresKeys()
     {
-        $schemata = [['options' => ['unique' => true]]];
+        $schemata = [ [ 'options' => [ 'unique' => true ] ] ];
         $metadata = $this->getMetadata($schemata);
     }
 
@@ -146,7 +146,7 @@ 
      */
     public function testSchemaRequiresAtLeastOneKey()
     {
-        $schemata = ['keys' => [], ['options' => ['unique' => true]]];
+        $schemata = [ 'keys' => [ ], [ 'options' => [ 'unique' => true ] ] ];
         $metadata = $this->getMetadata($schemata);
     }
 
@@ -160,7 +160,7 @@ 
         $manager = new Modlr\Persister\MongoDb\SchemaManager;
 
         $schemata = [
-            ['options' => ['unique' => true]]
+            [ 'options' => [ 'unique' => true ] ]
         ];
 
         $manager->createSchemata($collection, $schemata);
@@ -176,7 +176,7 @@ 
         $manager = new Modlr\Persister\MongoDb\SchemaManager;
 
         $schemata = [
-            ['keys' => [], 'options' => ['unique' => true]]
+            [ 'keys' => [ ], 'options' => [ 'unique' => true ] ]
         ];
 
         $manager->createSchemata($collection, $schemata);
@@ -193,36 +193,36 @@ 
         foreach ($metadata->persistence->schemata as $schema) {
             $found = false;
             foreach ($indices as $index) {
-                if ($index['name'] === $schema['options']['name']) {
+                if ($index[ 'name' ] === $schema[ 'options' ][ 'name' ]) {
                     $found = true;
                 }
             }
-            $this->assertTrue($found, sprintf('Index for "%s" was not created!', $schema['options']['name']));
+            $this->assertTrue($found, sprintf('Index for "%s" was not created!', $schema[ 'options' ][ 'name' ]));
         }
     }
 
-    private function getMetadata(array $schemata = [])
+    private function getMetadata(array $schemata = [ ])
     {
         $mapping = [
             'type'          => 'test-model',
             'attributes'    => [
-                'name'          => ['data_type' => 'string'],
-                'active'        => ['data_type' => 'boolean']
+                'name'          => [ 'data_type' => 'string' ],
+                'active'        => [ 'data_type' => 'boolean' ]
             ],
             'persistence'   => [
                 'db'            => self::$dbName,
                 'collection'    => 'test-model',
                 'schemata'      => [
-                    ['keys' => ['name' => 1]],
-                    ['keys' => ['active' => 1], ['options' => ['unique' => true]]]
+                    [ 'keys' => [ 'name' => 1 ] ],
+                    [ 'keys' => [ 'active' => 1 ], [ 'options' => [ 'unique' => true ] ] ]
                 ]
             ]
         ];
         if (!empty($schemata)) {
-            $mapping['persistence']['schemata'] = $schemata;
+            $mapping[ 'persistence' ][ 'schemata' ] = $schemata;
         }
-        $metadata = new Modlr\Metadata\EntityMetadata($mapping['type']);
-        $pmd = $this->smf->createInstance($mapping['persistence']);
+        $metadata = new Modlr\Metadata\EntityMetadata($mapping[ 'type' ]);
+        $pmd = $this->smf->createInstance($mapping[ 'persistence' ]);
         $metadata->setPersistence($pmd);
         $this->smf->handleValidate($metadata);
         return $metadata;

src/StorageMetadataFactory.php

Spacing +10 added lines, -10 removed lines

@@ -37,16 +37,16 @@ 
     {
         $persistence = new StorageMetadata();
 
-        if (isset($mapping['db'])) {
-            $persistence->db = $mapping['db'];
+        if (isset($mapping[ 'db' ])) {
+            $persistence->db = $mapping[ 'db' ];
         }
 
-        if (isset($mapping['collection'])) {
-            $persistence->collection = $mapping['collection'];
+        if (isset($mapping[ 'collection' ])) {
+            $persistence->collection = $mapping[ 'collection' ];
         }
 
-        if (isset($mapping['schemata'])) {
-            $persistence->schemata = $this->rksort($mapping['schemata']);
+        if (isset($mapping[ 'schemata' ])) {
+            $persistence->schemata = $this->rksort($mapping[ 'schemata' ]);
         }
         return $persistence;
     }
@@ -82,7 +82,7 @@ 
         ksort($array);
         foreach ($array as $k => $v) {
             if (is_array($v)) {
-                $array[$k] = $this->rksort($v);
+                $array[ $k ] = $this->rksort($v);
             }
         }
         return $array;
@@ -131,7 +131,7 @@ 
     private function validateIdStrategy(EntityMetadata $metadata)
     {
         $persistence = $metadata->persistence;
-        $validIdStrategies = ['object'];
+        $validIdStrategies = [ 'object' ];
         if (!in_array($persistence->idStrategy, $validIdStrategies)) {
             throw MetadataException::invalidMetadata($metadata->type, sprintf('The persistence id strategy "%s" is invalid. Valid types are "%s"', $persistence->idStrategy, implode('", "', $validIdStrategies)));
         }
@@ -147,10 +147,10 @@ 
     {
         $persistence = $metadata->persistence;
         foreach ($persistence->schemata as $k => $schema) {
-            if (!isset($schema['keys']) || empty($schema['keys'])) {
+            if (!isset($schema[ 'keys' ]) || empty($schema[ 'keys' ])) {
                 throw MetadataException::invalidMetadata($metadata->type, 'At least one key must be specified to define an index.');
             }
-            $persistence->schemata[$k]['options']['name'] = sprintf('modlr_%s', md5(json_encode($schema)));
+            $persistence->schemata[ $k ][ 'options' ][ 'name' ] = sprintf('modlr_%s', md5(json_encode($schema)));
         }
     }
 }