psfs / nosql

src/NOSQL/autoload.php

Spacing +7 added lines, -7 removed lines

@@ -5,25 +5,25 @@ 
  * @version 1.0
  * Autogenerated autoloader [2019-01-03 15:23:58]
  */
-if(!defined("BASE_DIR"))
-define("BASE_DIR", dirname( dirname(__DIR__) ) );
+if (!defined("BASE_DIR"))
+define("BASE_DIR", dirname(dirname(__DIR__)));
 
 require_once __DIR__ . DIRECTORY_SEPARATOR . 'Config' . DIRECTORY_SEPARATOR . 'config.php';
 
-if(!function_exists("NOSQL_Autoloader")) {
+if (!function_exists("NOSQL_Autoloader")) {
     // autoloader
-    function NOSQL_Autoloader( $class ) {
+    function NOSQL_Autoloader($class) {
         // it only autoload class into the Rain scope
         if (false !== preg_match('/^\\\?NOSQL/', $class)) {
             // Change order src
             $class = preg_replace('/^\\\?NOSQL/', 'NOSQL', $class);
             // transform the namespace in path
-            $path = str_replace("\\", DIRECTORY_SEPARATOR, $class );
+            $path = str_replace("\\", DIRECTORY_SEPARATOR, $class);
             // filepath
             $abs_path = __DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . $path . ".php";
 
             // require the file
-            if(file_exists($abs_path)) {
+            if (file_exists($abs_path)) {
                 require_once $abs_path;
             }
         }
@@ -31,5 +31,5 @@ 
     }
 
     // register the autoloader
-    spl_autoload_register( "NOSQL_Autoloader" );
+    spl_autoload_register("NOSQL_Autoloader");
 }

src/NOSQL/Api/NOSQL.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
         $code = 200;
         try {
             $this->srv->setCollections($module, $this->getRequest()->getRawData());
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             $success = false;
             $code = 400;
             Logger::log($exception->getMessage(), LOG_WARNING);
@@ -75,7 +75,7 @@ 
         $code = 200;
         try {
             $success = $this->srv->syncCollections($module);
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             $success = false;
             $code = 400;
             Logger::log($exception->getMessage(), LOG_WARNING);

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);

src/NOSQL/Services/Helpers/NOSQLApiHelper.php

Spacing +2 added lines, -2 removed lines

@@ -33,7 +33,7 @@ 
     public static function parseForm(CollectionDto $collectionDto) {
         $form = new Form(false);
         $form->addField(self::generateId());
-        foreach($collectionDto->properties as $property) {
+        foreach ($collectionDto->properties as $property) {
             $values = null;
             $data = [];
             $url = null;
@@ -58,7 +58,7 @@ 
                 case NOSQLBase::NOSQL_TYPE_ENUM:
                     $type = Field::COMBO_TYPE;
                     $enumValues = explode('|', $property->enum);
-                    foreach($enumValues as $value) {
+                    foreach ($enumValues as $value) {
                         $data[] = [
                             $property->name => $value,
                             'Label' => t($value),

src/NOSQL/Models/base/NOSQLStatusTrait.php

Spacing +2 added lines, -2 removed lines

@@ -79,7 +79,7 @@ 
      * @param string $property
      */
     public function addChanges($property) {
-        if(!in_array($property, $this->changes)) {
+        if (!in_array($property, $this->changes)) {
             $this->changes[] = $property;
         }
     }
@@ -111,7 +111,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($model, $con);
             $model->feed($dto->toArray());
             $model->$hook($con);

src/NOSQL/Api/base/NOSQLBase.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
     public function getApi()
     {
         $class = explode('\\', get_called_class());
-        return $class[count($class)-1];
+        return $class[count($class) - 1];
     }
 
     /**

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 +22 added lines, -22 removed lines

@@ -44,7 +44,7 @@ 
      */
     public function getDtoCopy($cleanPk = false) {
         $copy = clone $this->dto;
-        if($cleanPk) {
+        if ($cleanPk) {
             $this->dto->resetPk();
         }
         return $copy;
@@ -60,7 +60,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);
@@ -68,7 +68,7 @@ 
             $isInsert = $isUpdate = false;
             $this->prepareData();
             $this->dto->setLastUpdate();
-            if($this->isNew()) {
+            if ($this->isNew()) {
                 $this->preInsert($con);
                 $isInsert = true;
             } elseif ($this->isModified()) {
@@ -76,19 +76,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());
@@ -103,7 +103,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);
@@ -117,8 +117,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());
@@ -134,7 +134,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);
@@ -144,7 +144,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;
@@ -158,7 +158,7 @@ 
      * @return int
      */
     public function bulkUpsert(array $data, $id, Database $con = null) {
-        if(null === $con) {
+        if (null === $con) {
             $con = ParserService::getInstance()->createConnection($this->getDomain());
         }
         $collection = $con->selectCollection($this->getSchema()->name);
@@ -168,7 +168,7 @@ 
         try {
             // Check index collation
             $indexes = $collection->listIndexes();
-            foreach($indexes as $index) {
+            foreach ($indexes as $index) {
                 $indexInfo = $index->__debugInfo();
                 $keys = array_keys($index["key"]);
                 if ((count($keys) === 1) && ($keys[0] === $id) && (array_key_exists("collation", $indexInfo))) {
@@ -178,7 +178,7 @@ 
                 }
             }
 
-            foreach($data as $item) {
+            foreach ($data as $item) {
                 $filter[$id] = ['$eq' => $item[$id]];
                 $update = [];
                 $update['$set'] = $item;
@@ -204,7 +204,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);
@@ -215,7 +215,7 @@ 
             $deleted = true;
             $this->dto = null;
             $this->countAction();
-        } catch(\Exception $exception) {
+        } catch (\Exception $exception) {
             Logger::log($exception->getMessage(), LOG_CRIT, $this->toArray());
         }
         return $deleted;
@@ -229,14 +229,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;
@@ -253,7 +253,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);
@@ -283,7 +283,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/Services/NOSQLService.php

Spacing +18 added lines, -18 removed lines

@@ -57,9 +57,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);
@@ -81,10 +81,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;
                 }
             }
@@ -100,7 +100,7 @@ 
         $collections = [];
         $path = GeneratorHelper::getDomainPaths($module);
         $schemaFilename = $path['base'] . 'Config' . DIRECTORY_SEPARATOR . 'schema.json';
-        if(file_exists($schemaFilename)) {
+        if (file_exists($schemaFilename)) {
             $collections = $this->cache->getDataFromFile($schemaFilename, Cache::JSON, TRUE);
         }
         return $collections;
@@ -123,10 +123,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,
@@ -134,7 +134,7 @@ 
                     'properties' => $collection->properties,
                 ]);
                 $force = false;
-                if(false !== strpos($template, 'dto') || false !== strpos(strtolower($template), 'base')) {
+                if (false !== strpos($template, 'dto') || false !== strpos(strtolower($template), 'base')) {
                     $force = true;
                 }
                 $this->writeTemplateToFile($templateDump, $path . DIRECTORY_SEPARATOR . $collection->name . '.php', $force);
@@ -172,12 +172,12 @@ 
         try {
             $collection = $db->selectCollection($collectionDto['name']);
             $textIndexes = [];
-            foreach($collectionDto['properties'] as $property) {
-                if(in_array($property['type'], [NOSQLBase::NOSQL_TYPE_STRING, NOSQLBase::NOSQL_TYPE_OBJECT])) {
+            foreach ($collectionDto['properties'] as $property) {
+                if (in_array($property['type'], [NOSQLBase::NOSQL_TYPE_STRING, NOSQLBase::NOSQL_TYPE_OBJECT])) {
                     $textIndexes[$property['name']] = 'text';
                 }
             }
-            if(count($textIndexes)) {
+            if (count($textIndexes)) {
                 $collection->createIndex($textIndexes, ['name' => 'idx_text_' . $collectionDto['name']]);
             }
         } catch (\Exception $exception) {
@@ -194,7 +194,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 */
@@ -205,8 +205,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;
                 }
             }
@@ -238,10 +238,10 @@ 
                     $property = new StringPropertyDto(false);
                     break;
             }
-            if(array_key_exists('type', $rawProperty)) {
+            if (array_key_exists('type', $rawProperty)) {
                 $property->bsonType = $rawProperty['type'];
             }
-            if(array_key_exists('description', $rawProperty)) {
+            if (array_key_exists('description', $rawProperty)) {
                 $property->description = $rawProperty['description'];
             }
             if (array_key_exists('required', $rawProperty) && $rawProperty['required']) {
@@ -259,7 +259,7 @@ 
     public function getValidations() {
         $fieldTypes = new \ReflectionClass(Field::class);
         $validations = [];
-        foreach($fieldTypes->getConstants() as $validation) {
+        foreach ($fieldTypes->getConstants() as $validation) {
             $validations[] = $validation;
         }
         return $validations;