@@ -27,7 +27,7 @@ discard block |
||
| 27 | 27 | $dns .= '@' . Config::getParam('nosql.host', 'localhost', $lowerDomain); |
| 28 | 28 | |
| 29 | 29 | $database = Config::getParam('nosql.database', 'nosql', $lowerDomain); |
| 30 | - if(null !== Config::getParam('nosql.replicaset')) { |
|
| 30 | + if (null !== Config::getParam('nosql.replicaset')) { |
|
| 31 | 31 | $dns .= '/' . $database . '?ssl=true&replicaSet=' . Config::getParam('nosql.replicaset', null, $lowerDomain); |
| 32 | 32 | $dns .= '&authSource=admin&serverSelectionTryOnce=false&serverSelectionTimeoutMS=15000'; |
| 33 | 33 | } else { |
@@ -49,7 +49,7 @@ discard block |
||
| 49 | 49 | */ |
| 50 | 50 | public function checkAndSave($domain, $collection, NOSQLModelDto $dto) { |
| 51 | 51 | $errors = $dto->validate(); |
| 52 | - if(empty($errors)) { |
|
| 52 | + if (empty($errors)) { |
|
| 53 | 53 | |
| 54 | 54 | } else { |
| 55 | 55 | throw new ApiException(t('Dto not valid'), 400); |
@@ -66,7 +66,7 @@ discard block |
||
| 66 | 66 | public function hydrateModelFromRequest(array $data, $className) { |
| 67 | 67 | $model = null; |
| 68 | 68 | $reflectionClass = new \ReflectionClass($className); |
| 69 | - if($reflectionClass->isSubclassOf(NOSQLBase::class)) { |
|
| 69 | + if ($reflectionClass->isSubclassOf(NOSQLBase::class)) { |
|
| 70 | 70 | /** @var NOSQLActiveRecord $modelName */ |
| 71 | 71 | $modelName = $className::MODEL_CLASS; |
| 72 | 72 | $model = $modelName::fromArray($data); |
@@ -61,9 +61,9 @@ discard block |
||
| 61 | 61 | */ |
| 62 | 62 | private function extractTypes() { |
| 63 | 63 | $baseClass = new \ReflectionClass(NOSQLBase::class); |
| 64 | - if(null !== $baseClass) { |
|
| 64 | + if (null !== $baseClass) { |
|
| 65 | 65 | $types = []; |
| 66 | - foreach($baseClass->getConstants() as $constant) { |
|
| 66 | + foreach ($baseClass->getConstants() as $constant) { |
|
| 67 | 67 | $types[] = $constant; |
| 68 | 68 | } |
| 69 | 69 | $this->setTypes($types); |
@@ -85,10 +85,10 @@ discard block |
||
| 85 | 85 | public function getDomains() { |
| 86 | 86 | $domains = []; |
| 87 | 87 | $storedDomains = $this->cache->getDataFromFile(CONFIG_DIR . DIRECTORY_SEPARATOR . 'domains.json', Cache::JSON, TRUE); |
| 88 | - if(!empty($storedDomains)) { |
|
| 89 | - foreach($storedDomains as $domain => $data) { |
|
| 88 | + if (!empty($storedDomains)) { |
|
| 89 | + foreach ($storedDomains as $domain => $data) { |
|
| 90 | 90 | $domainLabel = str_replace(['@', '/'], '', $domain); |
| 91 | - if('ROOT' !== $domainLabel) { |
|
| 91 | + if ('ROOT' !== $domainLabel) { |
|
| 92 | 92 | $domains[] = $domainLabel; |
| 93 | 93 | } |
| 94 | 94 | } |
@@ -99,8 +99,8 @@ discard block |
||
| 99 | 99 | public static function getDomainPaths($module) { |
| 100 | 100 | $domains = Router::getInstance()->getDomains(); |
| 101 | 101 | $path = null; |
| 102 | - foreach($domains as $domain => $paths) { |
|
| 103 | - if(preg_match("/^@" . $module . "\//i", $domain)) { |
|
| 102 | + foreach ($domains as $domain => $paths) { |
|
| 103 | + if (preg_match("/^@" . $module . "\//i", $domain)) { |
|
| 104 | 104 | $path = $paths; |
| 105 | 105 | break; |
| 106 | 106 | } |
@@ -115,11 +115,11 @@ discard block |
||
| 115 | 115 | public function getCollections($module) { |
| 116 | 116 | $collections = []; |
| 117 | 117 | $path = self::getDomainPaths($module); |
| 118 | - if(null === $path) { |
|
| 118 | + if (null === $path) { |
|
| 119 | 119 | throw new ApiException(t("Module not found"), 404); |
| 120 | 120 | } |
| 121 | 121 | $schemaFilename = $path['base'] . 'Config' . DIRECTORY_SEPARATOR . 'schema.json'; |
| 122 | - if(file_exists($schemaFilename)) { |
|
| 122 | + if (file_exists($schemaFilename)) { |
|
| 123 | 123 | $collections = $this->cache->getDataFromFile($schemaFilename, Cache::JSON, TRUE); |
| 124 | 124 | } |
| 125 | 125 | return $collections; |
@@ -142,10 +142,10 @@ discard block |
||
| 142 | 142 | '@NOSQL/generator/api.base.php.twig' => CORE_DIR . DIRECTORY_SEPARATOR . $module . DIRECTORY_SEPARATOR . 'Api' . DIRECTORY_SEPARATOR . 'Base', |
| 143 | 143 | '@NOSQL/generator/dto.php.twig' => CORE_DIR . DIRECTORY_SEPARATOR . $module . DIRECTORY_SEPARATOR . 'Dto' . DIRECTORY_SEPARATOR . 'Models', |
| 144 | 144 | ]; |
| 145 | - foreach($collections as $raw) { |
|
| 145 | + foreach ($collections as $raw) { |
|
| 146 | 146 | $collection = new CollectionDto(false); |
| 147 | 147 | $collection->fromArray($raw); |
| 148 | - foreach($files as $template => $path) { |
|
| 148 | + foreach ($files as $template => $path) { |
|
| 149 | 149 | GeneratorHelper::createDir($path); |
| 150 | 150 | $templateDump = $tpl->dump($template, [ |
| 151 | 151 | 'domain' => $module, |
@@ -154,7 +154,7 @@ discard block |
||
| 154 | 154 | 'indexes' => $collection->indexes, |
| 155 | 155 | ]); |
| 156 | 156 | $force = false; |
| 157 | - if(false !== strpos($template, 'dto') || false !== strpos(strtolower($template), 'base')) { |
|
| 157 | + if (false !== strpos($template, 'dto') || false !== strpos(strtolower($template), 'base')) { |
|
| 158 | 158 | $force = true; |
| 159 | 159 | } |
| 160 | 160 | $this->writeTemplateToFile($templateDump, $path . DIRECTORY_SEPARATOR . $collection->name . '.php', $force); |
@@ -191,12 +191,12 @@ discard block |
||
| 191 | 191 | private function createTextIndex(Database $db, $collectionDto) { |
| 192 | 192 | try { |
| 193 | 193 | $textIndexes = []; |
| 194 | - foreach($collectionDto['properties'] as $property) { |
|
| 195 | - if(in_array($property['type'], [NOSQLBase::NOSQL_TYPE_STRING, NOSQLBase::NOSQL_TYPE_OBJECT])) { |
|
| 194 | + foreach ($collectionDto['properties'] as $property) { |
|
| 195 | + if (in_array($property['type'], [NOSQLBase::NOSQL_TYPE_STRING, NOSQLBase::NOSQL_TYPE_OBJECT])) { |
|
| 196 | 196 | $textIndexes[$property['name']] = 'text'; |
| 197 | 197 | } |
| 198 | 198 | } |
| 199 | - if(count($textIndexes)) { |
|
| 199 | + if (count($textIndexes)) { |
|
| 200 | 200 | $collection = $db->selectCollection($collectionDto['name']); |
| 201 | 201 | $collection->createIndex($textIndexes, ['name' => 'idx_text_' . $collectionDto['name']]); |
| 202 | 202 | } |
@@ -214,7 +214,7 @@ discard block |
||
| 214 | 214 | private function createIndexes(Database $db, $collectionDto, array $indexes = []) { |
| 215 | 215 | try { |
| 216 | 216 | $collection = $db->selectCollection($collectionDto['name']); |
| 217 | - if(count($indexes)) { |
|
| 217 | + if (count($indexes)) { |
|
| 218 | 218 | $collection->createIndexes($indexes); |
| 219 | 219 | } |
| 220 | 220 | } catch (\Exception $exception) { |
@@ -231,7 +231,7 @@ discard block |
||
| 231 | 231 | $db = ParserService::getInstance()->createConnection($module); |
| 232 | 232 | $collections = $this->getCollections($module); |
| 233 | 233 | $success = true; |
| 234 | - foreach($collections as $raw) { |
|
| 234 | + foreach ($collections as $raw) { |
|
| 235 | 235 | $jsonSchema = $this->parseCollection($raw); |
| 236 | 236 | try { |
| 237 | 237 | /** @var BSONDocument $result */ |
@@ -242,21 +242,21 @@ discard block |
||
| 242 | 242 | ]); |
| 243 | 243 | $response = $result->getArrayCopy(); |
| 244 | 244 | $success = array_key_exists('ok', $response) && $response['ok'] > 0; |
| 245 | - } catch(\Exception $exception) { |
|
| 246 | - if($exception->getCode() !== 48) { |
|
| 245 | + } catch (\Exception $exception) { |
|
| 246 | + if ($exception->getCode() !== 48) { |
|
| 247 | 247 | $success = false; |
| 248 | 248 | } |
| 249 | 249 | } |
| 250 | - if($success) { |
|
| 250 | + if ($success) { |
|
| 251 | 251 | if (Config::getParam("nosql.sync.defaultIndex", false, $module)) { |
| 252 | 252 | $this->createTextIndex($db, $raw); |
| 253 | 253 | } |
| 254 | 254 | $indexToCreate = []; |
| 255 | - foreach($raw['indexes'] as $index) { |
|
| 255 | + foreach ($raw['indexes'] as $index) { |
|
| 256 | 256 | $dbIndex = []; |
| 257 | - foreach($index['properties'] as $idx) { |
|
| 257 | + foreach ($index['properties'] as $idx) { |
|
| 258 | 258 | list($property, $direction) = explode('.', $idx); |
| 259 | - switch(strtoupper($direction)) { |
|
| 259 | + switch (strtoupper($direction)) { |
|
| 260 | 260 | case 'ASC': $dbIndex[$property] = 1; break; |
| 261 | 261 | case 'DESC': $dbIndex[$property] = -1; break; |
| 262 | 262 | } |
@@ -297,10 +297,10 @@ discard block |
||
| 297 | 297 | $property = new StringPropertyDto(false); |
| 298 | 298 | break; |
| 299 | 299 | } |
| 300 | - if(array_key_exists('type', $rawProperty)) { |
|
| 300 | + if (array_key_exists('type', $rawProperty)) { |
|
| 301 | 301 | $property->bsonType = $rawProperty['type']; |
| 302 | 302 | } |
| 303 | - if(array_key_exists('description', $rawProperty)) { |
|
| 303 | + if (array_key_exists('description', $rawProperty)) { |
|
| 304 | 304 | $property->description = $rawProperty['description']; |
| 305 | 305 | } |
| 306 | 306 | if (array_key_exists('required', $rawProperty) && $rawProperty['required']) { |
@@ -318,7 +318,7 @@ discard block |
||
| 318 | 318 | public function getValidations() { |
| 319 | 319 | $fieldTypes = new \ReflectionClass(Field::class); |
| 320 | 320 | $validations = []; |
| 321 | - foreach($fieldTypes->getConstants() as $validation) { |
|
| 321 | + foreach ($fieldTypes->getConstants() as $validation) { |
|
| 322 | 322 | $validations[] = $validation; |
| 323 | 323 | } |
| 324 | 324 | return $validations; |