psfs / nosql

src/NOSQL/Dto/Model/NOSQLModelDto.php

Spacing +5 added lines, -5 removed lines

@@ -36,7 +36,7 @@ 
      */
     public function setPk(string $id)
     {
-        if(!empty($this->_id)) {
+        if (!empty($this->_id)) {
             throw new NOSQLValidationException(t('Primary key already defined'), NOSQLValidationException::NOSQL_VALIDATION_ID_ALREADY_DEFINED);
         }
         $this->_id = $id;
@@ -74,11 +74,11 @@ 
     public function validate($throwException = false) {
         $errors = [];
         $reflection = new \ReflectionClass(get_called_class());
-        foreach($reflection->getProperties() as $property) {
+        foreach ($reflection->getProperties() as $property) {
             $required = InjectorHelper::checkIsRequired($property->getDocComment());
             $value = $property->getValue($this);
-            if($required && empty($value)) {
-                if($throwException) {
+            if ($required && empty($value)) {
+                if ($throwException) {
                     throw new NOSQLValidationException(t('Empty value for property ') . $property->getName(), NOSQLValidationException::NOSQL_VALIDATION_REQUIRED);
                 } else {
                     $errors[] = $property->getName();
@@ -93,7 +93,7 @@ 
     public function toArray()
     {
         $array = parent::toArray();
-        if(null !== $this->getPk()) {
+        if (null !== $this->getPk()) {
             $array['_id'] = $this->getPk();
         }
         $array['_last_update'] = $this->getLastUpdate(\DateTime::ATOM);

src/NOSQL/Models/base/NOSQLStatusTrait.php

Spacing +2 added lines, -2 removed lines

@@ -75,7 +75,7 @@ 
      * @param string $property
      */
     public function addChanges($property) {
-        if(!in_array($property, $this->changes)) {
+        if (!in_array($property, $this->changes)) {
             $this->changes[] = $property;
         }
     }
@@ -88,7 +88,7 @@ 
      * @throws \NOSQL\Exceptions\NOSQLValidationException
      */
     public static function invokeHook(NOSQLActiveRecord $model, NOSQLModelDto $dto, $hook, Database $con = null) {
-        if(method_exists($model, $hook)) {
+        if (method_exists($model, $hook)) {
             $con = self::initConnection($con, $model);
             $model->feed($dto->toArray());
             $model->$hook($con);

src/NOSQL/Models/NOSQLQuery.php

Spacing +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
         $con = NOSQLParserTrait::initConnection($con, $model);
         $collection = $con->selectCollection($model->getSchema()->name);
         $result = $collection->findOne(['_id' => new ObjectId($pk)]);
-        if(null !== $result) {
+        if (null !== $result) {
             $model->feed($result->getArrayCopy());
         } else {
             throw new ApiException(t('Document not found'), 404);
@@ -47,7 +47,7 @@ 
         $resultSet->count = $collection->countDocuments($criteria, $nosqlOptions);
         $results = $collection->find($criteria, $nosqlOptions);
         /** @var  $result */
-        foreach($results->toArray() as $result) {
+        foreach ($results->toArray() as $result) {
             $model->feed($result->getArrayCopy());
             $resultSet->items[] = $model->getDtoCopy(true);
         }

src/NOSQL/Models/NOSQLActiveRecord.php

Spacing +13 added lines, -13 removed lines

@@ -42,7 +42,7 @@ 
      */
     public function getDtoCopy($cleanPk = false) {
         $copy = clone $this->dto;
-        if($cleanPk) {
+        if ($cleanPk) {
             $this->dto->resetPk();
         }
         return $copy;
@@ -54,14 +54,14 @@ 
      */
     public function save(Database $con = null) {
         $saved = false;
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
         try {
             $isInsert = $isUpdate = false;
             $this->dto->setLastUpdate(new \DateTime());
-            if($this->isNew()) {
+            if ($this->isNew()) {
                 $this->preInsert($con);
                 $isInsert = true;
             } elseif ($this->isModified()) {
@@ -69,17 +69,17 @@ 
                 $isUpdate = true;
             }
             $result = $collection->insertOne($this->toArray());
-            if($result->getInsertedCount() > 0) {
+            if ($result->getInsertedCount() > 0) {
                 $id = $result->getInsertedId();
                 $this->dto->setPk($id->jsonSerialize()['$oid']);
-                if($isInsert) {
+                if ($isInsert) {
                     $this->postInsert($con);
-                } elseif($isUpdate) {
+                } elseif ($isUpdate) {
                     $this->postUpdate($con);
                 }
                 $saved = true;
             }
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception, LOG_CRIT, $this->toArray());
         }
         return $saved;
@@ -91,7 +91,7 @@ 
      */
     public function update(Database $con = null) {
         $updated = false;
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
@@ -103,7 +103,7 @@ 
             $collection->findOneAndReplace(['_id' => new ObjectId($this->dto->getPk())], $data);
             $this->postUpdate($con);
             $updated = true;
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception, LOG_CRIT, $this->toArray());
         }
         return $updated;
@@ -116,7 +116,7 @@ 
      */
     public function bulkInsert(array $data, Database $con = null) {
         $inserts = 0;
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
@@ -125,7 +125,7 @@ 
             $result = $collection->insertMany($data);
             $ids = $result->getInsertedIds();
             $inserts = $this->parseInsertedDtos($con, $ids, $dtos);
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception, LOG_CRIT, $this->toArray());
         }
         return $inserts;
@@ -137,7 +137,7 @@ 
      */
     public function delete(Database $con = null) {
         $deleted = false;
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
@@ -147,7 +147,7 @@ 
             $this->postDelete($con);
             $deleted = true;
             $this->dto = null;
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception, LOG_CRIT, $this->toArray());
         }
         return $deleted;

src/NOSQL/Services/NOSQLService.php

Spacing +12 added lines, -12 removed lines

@@ -55,9 +55,9 @@ 
      */
     private function extractTypes() {
         $baseClass = new \ReflectionClass(NOSQLBase::class);
-        if(null !== $baseClass) {
+        if (null !== $baseClass) {
             $types = [];
-            foreach($baseClass->getConstants() as $constant) {
+            foreach ($baseClass->getConstants() as $constant) {
                 $types[] = $constant;
             }
             $this->setTypes($types);
@@ -79,10 +79,10 @@ 
     public function getDomains() {
         $domains = [];
         $storedDomains = $this->cache->getDataFromFile(CONFIG_DIR . DIRECTORY_SEPARATOR . 'domains.json', Cache::JSON, TRUE);
-        if(!empty($storedDomains)) {
-            foreach($storedDomains as $domain => $data) {
+        if (!empty($storedDomains)) {
+            foreach ($storedDomains as $domain => $data) {
                 $domainLabel = str_replace(['@', '/'], '', $domain);
-                if('ROOT' !== $domainLabel) {
+                if ('ROOT' !== $domainLabel) {
                     $domains[] = $domainLabel;
                 }
             }
@@ -97,7 +97,7 @@ 
     public function getCollections($module) {
         $collections = [];
         $schemaFilename = CORE_DIR . DIRECTORY_SEPARATOR . $module . DIRECTORY_SEPARATOR . 'Config' . DIRECTORY_SEPARATOR . 'schema.json';
-        if(file_exists($schemaFilename)) {
+        if (file_exists($schemaFilename)) {
             $collections = $this->cache->getDataFromFile($schemaFilename, Cache::JSON, TRUE);
         }
         return $collections;
@@ -120,10 +120,10 @@ 
             '@NOSQL/generator/api.base.php.twig' => CORE_DIR . DIRECTORY_SEPARATOR . $module . DIRECTORY_SEPARATOR . 'Api' . DIRECTORY_SEPARATOR . 'base',
             '@NOSQL/generator/dto.php.twig' => CORE_DIR . DIRECTORY_SEPARATOR . $module . DIRECTORY_SEPARATOR . 'Dto' . DIRECTORY_SEPARATOR . 'Models',
         ];
-        foreach($collections as $raw) {
+        foreach ($collections as $raw) {
             $collection = new CollectionDto(false);
             $collection->fromArray($raw);
-            foreach($files as $template => $path) {
+            foreach ($files as $template => $path) {
                 GeneratorHelper::createDir($path);
                 $templateDump = $tpl->dump($template, [
                     'domain' => $module,
@@ -131,7 +131,7 @@ 
                     'properties' => $collection->properties,
                 ]);
                 $force = false;
-                if(false !== strpos($template, 'dto') || false !== strpos($template, 'base')) {
+                if (false !== strpos($template, 'dto') || false !== strpos($template, 'base')) {
                     $force = true;
                 }
                 $this->writeTemplateToFile($templateDump, $path . DIRECTORY_SEPARATOR . $collection->name . '.php', $force);
@@ -170,7 +170,7 @@ 
         $db = ParserService::getInstance()->createConnection($module);
         $collections = $this->getCollections($module);
         $success = true;
-        foreach($collections as $raw) {
+        foreach ($collections as $raw) {
             $jsonSchema = $this->parseCollection($raw);
             try {
                 /** @var BSONDocument $result */
@@ -181,8 +181,8 @@ 
                 ]);
                 $response = $result->getArrayCopy();
                 $success = array_key_exists('ok', $response) && $response['ok'] > 0;
-            } catch(\Exception $exception) {
-                if($exception->getCode() !== 48) {
+            } catch (\Exception $exception) {
+                if ($exception->getCode() !== 48) {
                     $success = false;
                 }
             }

src/NOSQL/Services/ParserService.php

Spacing +3 added lines, -3 removed lines

@@ -27,7 +27,7 @@ 
         $dns .= '@' . Config::getParam('nosql.host', 'localhost', $lowerDomain);
 
         $database = Config::getParam('nosql.database', 'nosql', $lowerDomain);
-        if(null !== Config::getParam('nosql.replicaset')) {
+        if (null !== Config::getParam('nosql.replicaset')) {
             $dns .= '/' . $database . '?ssl=true&replicaSet=' . Config::getParam('nosql.replicaset', null, $lowerDomain);
             $dns .= '&authSource=admin&serverSelectionTryOnce=false&serverSelectionTimeoutMS=15000&retryWrites=true';
         } else {
@@ -48,7 +48,7 @@ 
      */
     public function checkAndSave($domain, $collection, NOSQLModelDto $dto) {
         $errors = $dto->validate();
-        if(empty($errors)) {
+        if (empty($errors)) {
 
         } else {
             throw new ApiException(t('Dto not valid'), 400);
@@ -64,7 +64,7 @@ 
     public function hydrateModelFromRequest(array $data, $className) {
         $model = null;
         $reflectionClass = new \ReflectionClass($className);
-        if($reflectionClass->isSubclassOf(NOSQLBase::class)) {
+        if ($reflectionClass->isSubclassOf(NOSQLBase::class)) {
             /** @var NOSQLActiveRecord $modelName */
             $modelName = $className::MODEL_CLASS;
             $model = $modelName::fromArray($data);