psfs / nosql

src/NOSQL/Models/base/NOSQLModelTrait.php

Spacing +9 added lines, -9 removed lines

@@ -24,7 +24,7 @@ 
     public function __get($name)
     {
         $value = null;
-        if(null !== $this->dto && property_exists($this->dto, $name)) {
+        if (null !== $this->dto && property_exists($this->dto, $name)) {
             $value = $this->dto->$name;
         }
         return $value;
@@ -36,7 +36,7 @@ 
      */
     public function __set($name, $value)
     {
-        if(null !== $this->dto && property_exists($this->dto, $name)) {
+        if (null !== $this->dto && property_exists($this->dto, $name)) {
             $this->dto->$name = $value;
             $this->addChanges($name);
         }
@@ -45,9 +45,9 @@ 
 
     public function __call($name, $arguments)
     {
-        if(preg_match('/^(set|get)/', $name)) {
+        if (preg_match('/^(set|get)/', $name)) {
             $property = str_replace(['set', 'Set', 'get', 'Get'], '', $name);
-            if(false !== stripos($name, 'set')) {
+            if (false !== stripos($name, 'set')) {
                 $this->$property = $arguments[0];
             } else {
                 return $this->$property;
@@ -64,10 +64,10 @@ 
     public function feed(array $data, $withName = false) {
         $name = '';
         $sep = '';
-        foreach($data as $key => $value) {
-            if($value instanceof ObjectId) {
+        foreach ($data as $key => $value) {
+            if ($value instanceof ObjectId) {
                 $this->dto->setPk($value->jsonSerialize()['$oid']);
-            } elseif($key === '_last_update') {
+            } elseif ($key === '_last_update') {
                 $this->dto->setLastUpdate($value instanceof UTCDateTime ? $value : null);
             } else {
                 if (is_object($value)) {
@@ -78,13 +78,13 @@ 
                     }
                 }
                 $this->$key = $value;
-                if(in_array(strtolower($key), ['name', 'label', 'title', 'method'])) {
+                if (in_array(strtolower($key), ['name', 'label', 'title', 'method'])) {
                     $name .= $sep . $value;
                     $sep = ' ';
                 }
             }
         }
-        if($withName) {
+        if ($withName) {
             $this->dto->setName($name);
         }
     }

src/NOSQL/Dto/Model/NOSQLModelDto.php

Spacing +13 added lines, -13 removed lines

@@ -51,7 +51,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;
@@ -64,7 +64,7 @@ 
     public function getLastUpdate($format = null)
     {
         $value = $this->_last_update;
-        if(null !== $format) {
+        if (null !== $format) {
 
         }
         return $value;
@@ -104,11 +104,11 @@ 
     public function validate($throwException = false) {
         $errors = [];
         $reflection = new \ReflectionClass(get_called_class());
-        foreach($reflection->getProperties(\ReflectionProperty::IS_PUBLIC) as $property) {
+        foreach ($reflection->getProperties(\ReflectionProperty::IS_PUBLIC) 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();
@@ -123,10 +123,10 @@ 
     public function toArray()
     {
         $array = parent::toArray();
-        if(null !== $this->getPk()) {
+        if (null !== $this->getPk()) {
             $array['_id'] = $this->getPk();
         }
-        if(null !== $this->getName()) {
+        if (null !== $this->getName()) {
             $array[Api::API_LIST_NAME_FIELD] = $this->getName();
         }
         $array['_last_update'] = $this->getLastUpdate(\DateTime::ATOM);
@@ -150,10 +150,10 @@ 
                 if (!is_numeric($value)) {
                     $errors[] = $property->getName();
                 } else {
-                    if(NOSQLBase::NOSQL_TYPE_INTEGER === strtolower($type)) {
-                        $property->setValue($this, (integer)$value);
+                    if (NOSQLBase::NOSQL_TYPE_INTEGER === strtolower($type)) {
+                        $property->setValue($this, (integer) $value);
                     } else {
-                        $property->setValue($this, (float)$value);
+                        $property->setValue($this, (float) $value);
                     }
                 }
                 break;
@@ -175,16 +175,16 @@ 
                 if (!in_array($value, [true, false, 0, 1])) {
                     $errors[] = $property->getName();
                 }
-                $property->setValue($this, (bool)$value);
+                $property->setValue($this, (bool) $value);
                 break;
             case NOSQLBase::NOSQL_TYPE_DATE:
             case NOSQLBase::NOSQL_TYPE_TIMESTAMP:
                 $dateTime = new \DateTime($value, new \DateTimeZone('UTC'));
-                if(!$dateTime) {
+                if (!$dateTime) {
                     $errors[] = $property->getName();
                 } else {
                     $dateTime->setTimezone(new \DateTimeZone(date_default_timezone_get()));
-                    $property->setValue($this, new UTCDateTime($dateTime->getTimestamp()*1000));
+                    $property->setValue($this, new UTCDateTime($dateTime->getTimestamp() * 1000));
                 }
                 break;
         }

src/NOSQL/Models/NOSQLActiveRecord.php

Spacing +21 added lines, -21 removed lines

@@ -43,7 +43,7 @@ 
      */
     public function getDtoCopy($cleanPk = false) {
         $copy = clone $this->dto;
-        if($cleanPk) {
+        if ($cleanPk) {
             $this->dto->resetPk();
         }
         return $copy;
@@ -59,7 +59,7 @@ 
      */
     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);
@@ -67,7 +67,7 @@ 
             $isInsert = $isUpdate = false;
             $this->prepareData();
             $this->dto->setLastUpdate();
-            if($this->isNew()) {
+            if ($this->isNew()) {
                 $this->preInsert($con);
                 $isInsert = true;
             } elseif ($this->isModified()) {
@@ -75,19 +75,19 @@ 
                 $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;
                 $this->countAction();
             }
-        } catch(\Exception $exception) {
-            if($exception instanceof NOSQLValidationException) {
+        } catch (\Exception $exception) {
+            if ($exception instanceof NOSQLValidationException) {
                 throw $exception;
             } else {
                 Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
@@ -102,7 +102,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);
@@ -116,8 +116,8 @@ 
             $this->postUpdate($con);
             $updated = true;
             $this->countAction();
-        } catch(\Exception $exception) {
-            if($exception instanceof NOSQLValidationException) {
+        } catch (\Exception $exception) {
+            if ($exception instanceof NOSQLValidationException) {
                 throw $exception;
             } else {
                 Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
@@ -133,7 +133,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);
@@ -143,7 +143,7 @@ 
             $ids = $result->getInsertedIds();
             $inserts = $this->parseInsertedDtos($con, $ids, $dtos);
             $this->setActionCount($inserts);
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
         }
         return $inserts;
@@ -160,12 +160,12 @@ 
         $upserts = 0;
         $filters = $options = [];
 
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
 
-        foreach($data as $item) {
+        foreach ($data as $item) {
             try {
                 $filters[$id] = ['$eq' => $item[$id]];
                 $updateSet = [];
@@ -191,7 +191,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);
@@ -202,7 +202,7 @@ 
             $deleted = true;
             $this->dto = null;
             $this->countAction();
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
         }
         return $deleted;
@@ -216,14 +216,14 @@ 
      */
     public function bulkDelete(array $filters, Database $con = null) {
         $deletedCount = 0;
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
         try {
             $result = $collection->deleteMany($filters);
             $deletedCount = $result->getDeletedCount();
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
         }
         return $deletedCount;
@@ -240,7 +240,7 @@ 
         $dtos = [];
         /** @var NOSQLModelDto $dto */
         foreach ($data as &$insertData) {
-            if(is_object($insertData) && $insertData instanceof NOSQLModelDto) {
+            if (is_object($insertData) && $insertData instanceof NOSQLModelDto) {
                 $dto = clone $insertData;
             } else {
                 $dto = $this->getDtoCopy(true);
@@ -270,7 +270,7 @@ 
         foreach ($ids as $index => $insertedId) {
             $id = $insertedId->jsonSerialize();
             $dto = $dtos[$index];
-            if($dto instanceof  NOSQLModelDto) {
+            if ($dto instanceof  NOSQLModelDto) {
                 $dto->setPk($id['$oid']);
             } else {
 

src/NOSQL/Models/base/NOSQLParserTrait.php

Spacing +5 added lines, -5 removed lines

@@ -73,20 +73,20 @@
      * @throws \PSFS\base\exception\GeneratorException
      */
     protected function hydrate() {
-        if(empty($this->domain)) {
+        if (empty($this->domain)) {
             throw new NOSQLParserException(t('Domain not defined'), NOSQLParserException::NOSQL_PARSER_DOMAIN_NOT_DEFINED);
         }
         //$schemaFilename = CORE_DIR . DIRECTORY_SEPARATOR . $this->domain . DIRECTORY_SEPARATOR . 'Config' . DIRECTORY_SEPARATOR . 'schema.json';
         $schemaFilename = Config::getParam("nosql.schema.path", VENDOR_DIR . DIRECTORY_SEPARATOR . "tks" . DIRECTORY_SEPARATOR .
                     strtolower($this->domain) . DIRECTORY_SEPARATOR . "src" . DIRECTORY_SEPARATOR . $this->domain .
-                    DIRECTORY_SEPARATOR . "Config". DIRECTORY_SEPARATOR . "schema.json");
-        if(file_exists($schemaFilename)) {
+                    DIRECTORY_SEPARATOR . "Config" . DIRECTORY_SEPARATOR . "schema.json");
+        if (file_exists($schemaFilename)) {
             $schema = Cache::getInstance()->getDataFromFile($schemaFilename, Cache::JSON, true);
             $class = get_called_class();
             $this->schema = new CollectionDto(false);
-            foreach($schema as $collection) {
+            foreach ($schema as $collection) {
                 $collectionName = $collection['name'];
-                if(false !== strpos($class, $collectionName)) {
+                if (false !== strpos($class, $collectionName)) {
                     $this->schema->fromArray($collection);
                     break;
                 }