@@ -189,7 +189,7 @@ |
||
| 189 | 189 | $loop++; |
| 190 | 190 | if ($loop > 10 || in_array($instance, $knownInstance)) { |
| 191 | 191 | throw new CircleNotFoundException( |
| 192 | - 'circle not found after browsing ' . implode(', ', $knownInstance) |
|
| 192 | + 'circle not found after browsing '.implode(', ', $knownInstance) |
|
| 193 | 193 | ); |
| 194 | 194 | } |
| 195 | 195 | $knownInstance[] = $instance; |
@@ -261,7 +261,7 @@ discard block |
||
| 261 | 261 | |
| 262 | 262 | $request = new NC21Request('', $type); |
| 263 | 263 | if ($this->configService->isLocalInstance($instance)) { |
| 264 | - $this->configService->configureRequest($request, 'circles.Remote.' . $item, $params); |
|
| 264 | + $this->configService->configureRequest($request, 'circles.Remote.'.$item, $params); |
|
| 265 | 265 | } else { |
| 266 | 266 | $this->configService->configureRequest($request); |
| 267 | 267 | $link = $this->getRemoteInstanceEntry($instance, $item, $params); |
@@ -317,7 +317,7 @@ discard block |
||
| 317 | 317 | public function getCachedRemoteInstance(string $instance): RemoteInstance { |
| 318 | 318 | $remoteInstance = $this->remoteRequest->getFromInstance($instance); |
| 319 | 319 | if ($remoteInstance->getType() === RemoteInstance::TYPE_UNKNOWN) { |
| 320 | - throw new UnknownRemoteException($instance . ' is set as \'unknown\' in database'); |
|
| 320 | + throw new UnknownRemoteException($instance.' is set as \'unknown\' in database'); |
|
| 321 | 321 | } |
| 322 | 322 | |
| 323 | 323 | return $remoteInstance; |
@@ -162,19 +162,19 @@ discard block |
||
| 162 | 162 | private function requestInstance(string $host): void { |
| 163 | 163 | $webfinger = $this->getWebfinger($host, Application::APP_SUBJECT); |
| 164 | 164 | if ($this->input->getOption('all')) { |
| 165 | - $this->output->writeln('- Webfinger on <info>' . $host . '</info>'); |
|
| 165 | + $this->output->writeln('- Webfinger on <info>'.$host.'</info>'); |
|
| 166 | 166 | $this->output->writeln(json_encode($webfinger, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES)); |
| 167 | 167 | $this->output->writeln(''); |
| 168 | 168 | } |
| 169 | 169 | |
| 170 | 170 | if ($this->input->getOption('all')) { |
| 171 | 171 | $circleLink = $this->extractLink(Application::APP_REL, $webfinger); |
| 172 | - $this->output->writeln('- Information about Circles app on <info>' . $host . '</info>'); |
|
| 172 | + $this->output->writeln('- Information about Circles app on <info>'.$host.'</info>'); |
|
| 173 | 173 | $this->output->writeln(json_encode($circleLink, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES)); |
| 174 | 174 | $this->output->writeln(''); |
| 175 | 175 | } |
| 176 | 176 | |
| 177 | - $this->output->writeln('- Available services on <info>' . $host . '</info>'); |
|
| 177 | + $this->output->writeln('- Available services on <info>'.$host.'</info>'); |
|
| 178 | 178 | foreach ($webfinger->getLinks() as $link) { |
| 179 | 179 | $app = $link->getProperty('name'); |
| 180 | 180 | $ver = $link->getProperty('version'); |
@@ -182,14 +182,14 @@ discard block |
||
| 182 | 182 | $app .= ' '; |
| 183 | 183 | } |
| 184 | 184 | if ($ver !== '') { |
| 185 | - $ver = 'v' . $ver; |
|
| 185 | + $ver = 'v'.$ver; |
|
| 186 | 186 | } |
| 187 | 187 | |
| 188 | - $this->output->writeln(' * ' . $link->getRel() . ' ' . $app . $ver); |
|
| 188 | + $this->output->writeln(' * '.$link->getRel().' '.$app.$ver); |
|
| 189 | 189 | } |
| 190 | 190 | $this->output->writeln(''); |
| 191 | 191 | |
| 192 | - $this->output->writeln('- Resources related to Circles on <info>' . $host . '</info>'); |
|
| 192 | + $this->output->writeln('- Resources related to Circles on <info>'.$host.'</info>'); |
|
| 193 | 193 | $resource = $this->getResourceData($host, Application::APP_SUBJECT, Application::APP_REL); |
| 194 | 194 | $this->output->writeln(json_encode($resource, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES)); |
| 195 | 195 | $this->output->writeln(''); |
@@ -197,7 +197,7 @@ discard block |
||
| 197 | 197 | |
| 198 | 198 | $tempUid = $resource->g('uid'); |
| 199 | 199 | $this->output->writeln( |
| 200 | - '- Confirming UID=' . $tempUid . ' from parsed Signatory at <info>' . $host . '</info>' |
|
| 200 | + '- Confirming UID='.$tempUid.' from parsed Signatory at <info>'.$host.'</info>' |
|
| 201 | 201 | ); |
| 202 | 202 | |
| 203 | 203 | try { |
@@ -205,15 +205,15 @@ discard block |
||
| 205 | 205 | $this->output->writeln(' * No SignatureException: <info>Identity authed</info>'); |
| 206 | 206 | } catch (SignatureException $e) { |
| 207 | 207 | $this->output->writeln( |
| 208 | - '<error>' . $host . ' cannot auth its identity: ' . $e->getMessage() . '</error>' |
|
| 208 | + '<error>'.$host.' cannot auth its identity: '.$e->getMessage().'</error>' |
|
| 209 | 209 | ); |
| 210 | 210 | |
| 211 | 211 | return; |
| 212 | 212 | } |
| 213 | 213 | |
| 214 | - $this->output->writeln(' * Found <info>' . $remoteSignatory->getUid() . '</info>'); |
|
| 214 | + $this->output->writeln(' * Found <info>'.$remoteSignatory->getUid().'</info>'); |
|
| 215 | 215 | if ($remoteSignatory->getUid(true) !== $tempUid) { |
| 216 | - $this->output->writeln('<error>looks like ' . $host . ' is faking its identity'); |
|
| 216 | + $this->output->writeln('<error>looks like '.$host.' is faking its identity'); |
|
| 217 | 217 | |
| 218 | 218 | return; |
| 219 | 219 | } |
@@ -221,7 +221,7 @@ discard block |
||
| 221 | 221 | $this->output->writeln(''); |
| 222 | 222 | |
| 223 | 223 | $testUrl = $resource->g('test'); |
| 224 | - $this->output->writeln('- Testing signed payload on <info>' . $testUrl . '</info>'); |
|
| 224 | + $this->output->writeln('- Testing signed payload on <info>'.$testUrl.'</info>'); |
|
| 225 | 225 | |
| 226 | 226 | try { |
| 227 | 227 | $localSignatory = $this->remoteStreamService->getAppSignatory(); |
@@ -243,18 +243,18 @@ discard block |
||
| 243 | 243 | $this->output->writeln(''); |
| 244 | 244 | |
| 245 | 245 | $this->output->writeln(' * Clear Signature: '); |
| 246 | - $this->output->writeln('<comment>' . $signedRequest->getClearSignature() . '</comment>'); |
|
| 246 | + $this->output->writeln('<comment>'.$signedRequest->getClearSignature().'</comment>'); |
|
| 247 | 247 | $this->output->writeln(''); |
| 248 | 248 | |
| 249 | 249 | $this->output->writeln(' * Signed Signature (base64 encoded): '); |
| 250 | 250 | $this->output->writeln( |
| 251 | - '<comment>' . base64_encode($signedRequest->getSignedSignature()) . '</comment>' |
|
| 251 | + '<comment>'.base64_encode($signedRequest->getSignedSignature()).'</comment>' |
|
| 252 | 252 | ); |
| 253 | 253 | $this->output->writeln(''); |
| 254 | 254 | |
| 255 | 255 | $result = $signedRequest->getOutgoingRequest()->getResult(); |
| 256 | 256 | $code = $result->getStatusCode(); |
| 257 | - $this->output->writeln(' * Result: ' . (($code === 200) ? '<info>' . $code . '</info>' : $code)); |
|
| 257 | + $this->output->writeln(' * Result: '.(($code === 200) ? '<info>'.$code.'</info>' : $code)); |
|
| 258 | 258 | $this->output->writeln( |
| 259 | 259 | json_encode(json_decode($result->getContent(), true), JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES) |
| 260 | 260 | ); |
@@ -273,20 +273,20 @@ discard block |
||
| 273 | 273 | $stored = new RemoteInstance(); |
| 274 | 274 | $this->remoteStreamService->confirmValidRemote($remoteSignatory, $stored); |
| 275 | 275 | $this->output->writeln( |
| 276 | - '<info>The remote instance ' . $host |
|
| 276 | + '<info>The remote instance '.$host |
|
| 277 | 277 | . ' is already known with this current identity</info>' |
| 278 | 278 | ); |
| 279 | 279 | |
| 280 | 280 | if ($remoteSignatory->getInstance() !== $stored->getInstance()) { |
| 281 | 281 | $this->output->writeln( |
| 282 | - '- updating host from ' . $stored->getInstance() . ' to ' |
|
| 282 | + '- updating host from '.$stored->getInstance().' to ' |
|
| 283 | 283 | . $remoteSignatory->getInstance() |
| 284 | 284 | ); |
| 285 | 285 | $this->remoteStreamService->update($remoteSignatory, RemoteStreamService::UPDATE_INSTANCE); |
| 286 | 286 | } |
| 287 | 287 | if ($remoteSignatory->getId() !== $stored->getId()) { |
| 288 | 288 | $this->output->writeln( |
| 289 | - '- updating href/Id from ' . $stored->getId() . ' to ' |
|
| 289 | + '- updating href/Id from '.$stored->getId().' to ' |
|
| 290 | 290 | . $remoteSignatory->getId() |
| 291 | 291 | ); |
| 292 | 292 | $this->remoteStreamService->update($remoteSignatory, RemoteStreamService::UPDATE_HREF); |
@@ -312,7 +312,7 @@ discard block |
||
| 312 | 312 | $helper = $this->getHelper('question'); |
| 313 | 313 | |
| 314 | 314 | $this->output->writeln( |
| 315 | - 'The remote instance <info>' . $remoteSignatory->getInstance() . '</info> looks good.' |
|
| 315 | + 'The remote instance <info>'.$remoteSignatory->getInstance().'</info> looks good.' |
|
| 316 | 316 | ); |
| 317 | 317 | $question = new ConfirmationQuestion( |
| 318 | 318 | 'Would you like to allow the sharing of your circles with this remote instance ? (y/N) ', |
@@ -337,7 +337,7 @@ discard block |
||
| 337 | 337 | $helper = $this->getHelper('question'); |
| 338 | 338 | |
| 339 | 339 | $this->output->writeln( |
| 340 | - 'The remote instance <info>' . $remoteSignatory->getInstance() |
|
| 340 | + 'The remote instance <info>'.$remoteSignatory->getInstance() |
|
| 341 | 341 | . '</info> is known but <error>its identity has changed.</error>' |
| 342 | 342 | ); |
| 343 | 343 | $this->output->writeln( |
@@ -414,13 +414,13 @@ discard block |
||
| 414 | 414 | if ($this->configService->isLocalInstance($instance)) { |
| 415 | 415 | return; |
| 416 | 416 | } |
| 417 | - $this->output->write('Adding <comment>' . $instance . '</comment>: '); |
|
| 417 | + $this->output->write('Adding <comment>'.$instance.'</comment>: '); |
|
| 418 | 418 | try { |
| 419 | 419 | $this->remoteStreamService->addRemoteInstance($instance, RemoteInstance::TYPE_GLOBAL_SCALE, true); |
| 420 | 420 | $this->output->writeln('<info>ok</info>'); |
| 421 | 421 | } catch (Exception $e) { |
| 422 | - $msg = ($e->getMessage() === '') ? '' : ' (' . $e->getMessage() . ')'; |
|
| 423 | - $this->output->writeln('<error>' . get_class($e) . $msg . '</error>'); |
|
| 422 | + $msg = ($e->getMessage() === '') ? '' : ' ('.$e->getMessage().')'; |
|
| 423 | + $this->output->writeln('<error>'.get_class($e).$msg.'</error>'); |
|
| 424 | 424 | } |
| 425 | 425 | } |
| 426 | 426 | |
@@ -438,12 +438,12 @@ discard block |
||
| 438 | 438 | try { |
| 439 | 439 | $current = $this->remoteStreamService->retrieveRemoteInstance($instance->getInstance()); |
| 440 | 440 | if ($current->getUid(true) === $instance->getUid(true)) { |
| 441 | - $currentUid = '<info>' . $current->getUid(true) . '</info>'; |
|
| 441 | + $currentUid = '<info>'.$current->getUid(true).'</info>'; |
|
| 442 | 442 | } else { |
| 443 | - $currentUid = '<error>' . $current->getUid(true) . '</error>'; |
|
| 443 | + $currentUid = '<error>'.$current->getUid(true).'</error>'; |
|
| 444 | 444 | } |
| 445 | 445 | } catch (Exception $e) { |
| 446 | - $currentUid = '<error>' . $e->getMessage() . '</error>'; |
|
| 446 | + $currentUid = '<error>'.$e->getMessage().'</error>'; |
|
| 447 | 447 | } |
| 448 | 448 | |
| 449 | 449 | $table->appendRow( |
@@ -166,7 +166,7 @@ |
||
| 166 | 166 | } |
| 167 | 167 | |
| 168 | 168 | if ($input->getOption('json')) { |
| 169 | - echo json_encode($circles, JSON_PRETTY_PRINT) . "\n"; |
|
| 169 | + echo json_encode($circles, JSON_PRETTY_PRINT)."\n"; |
|
| 170 | 170 | |
| 171 | 171 | return 0; |
| 172 | 172 | } |
@@ -157,7 +157,7 @@ |
||
| 157 | 157 | } |
| 158 | 158 | } |
| 159 | 159 | |
| 160 | - echo json_encode($circle, JSON_PRETTY_PRINT) . "\n"; |
|
| 160 | + echo json_encode($circle, JSON_PRETTY_PRINT)."\n"; |
|
| 161 | 161 | |
| 162 | 162 | return 0; |
| 163 | 163 | } |
@@ -49,11 +49,11 @@ discard block |
||
| 49 | 49 | |
| 50 | 50 | use TArrayTools; |
| 51 | 51 | |
| 52 | - const TYPE_UNKNOWN = 'Unknown'; // not trusted |
|
| 53 | - const TYPE_PASSIVE = 'Passive'; // Minimum information about Federated Circles are broadcasted if a member belongs to the circle. |
|
| 54 | - const TYPE_EXTERNAL = 'External'; // info about Federated Circles and their members are broadcasted if a member belongs to the circle. |
|
| 55 | - const TYPE_TRUSTED = 'Trusted'; // everything about Federated Circles are broadcasted. |
|
| 56 | - const TYPE_GLOBAL_SCALE = 'GlobalScale'; // every Circle is broadcasted, |
|
| 52 | + const TYPE_UNKNOWN = 'Unknown'; // not trusted |
|
| 53 | + const TYPE_PASSIVE = 'Passive'; // Minimum information about Federated Circles are broadcasted if a member belongs to the circle. |
|
| 54 | + const TYPE_EXTERNAL = 'External'; // info about Federated Circles and their members are broadcasted if a member belongs to the circle. |
|
| 55 | + const TYPE_TRUSTED = 'Trusted'; // everything about Federated Circles are broadcasted. |
|
| 56 | + const TYPE_GLOBAL_SCALE = 'GlobalScale'; // every Circle is broadcasted, |
|
| 57 | 57 | |
| 58 | 58 | const TEST = 'test'; |
| 59 | 59 | const INCOMING = 'incoming'; |
@@ -399,7 +399,7 @@ discard block |
||
| 399 | 399 | ]; |
| 400 | 400 | |
| 401 | 401 | if ($this->getAuthSigned() !== '') { |
| 402 | - $data['auth-signed'] = $this->getAlgorithm() . ':' . $this->getAuthSigned(); |
|
| 402 | + $data['auth-signed'] = $this->getAlgorithm().':'.$this->getAuthSigned(); |
|
| 403 | 403 | } |
| 404 | 404 | |
| 405 | 405 | return array_filter(array_merge($data, parent::jsonSerialize())); |
@@ -161,16 +161,16 @@ discard block |
||
| 161 | 161 | $this->generateMemberSelectAlias($alias, self::PREFIX_MEMBER) |
| 162 | 162 | ->leftJoin( |
| 163 | 163 | $this->getDefaultSelectAlias(), CoreRequestBuilder::TABLE_MEMBER, $alias, |
| 164 | - $expr->eq($alias . '.circle_id', $this->getDefaultSelectAlias() . '.unique_id') |
|
| 164 | + $expr->eq($alias.'.circle_id', $this->getDefaultSelectAlias().'.unique_id') |
|
| 165 | 165 | ); |
| 166 | 166 | |
| 167 | 167 | // TODO: Check in big table if it is better to put condition in andWhere() or in LeftJoin() |
| 168 | 168 | $this->andWhere( |
| 169 | 169 | $expr->andX( |
| 170 | - $expr->eq($alias . '.user_id', $this->createNamedParameter($member->getUserId())), |
|
| 171 | - $expr->eq($alias . '.user_type', $this->createNamedParameter($member->getUserType())), |
|
| 172 | - $expr->eq($alias . '.instance', $this->createNamedParameter($this->getInstance($member))), |
|
| 173 | - $expr->gte($alias . '.level', $this->createNamedParameter($level)) |
|
| 170 | + $expr->eq($alias.'.user_id', $this->createNamedParameter($member->getUserId())), |
|
| 171 | + $expr->eq($alias.'.user_type', $this->createNamedParameter($member->getUserType())), |
|
| 172 | + $expr->eq($alias.'.instance', $this->createNamedParameter($this->getInstance($member))), |
|
| 173 | + $expr->gte($alias.'.level', $this->createNamedParameter($level)) |
|
| 174 | 174 | ) |
| 175 | 175 | ); |
| 176 | 176 | } |
@@ -191,7 +191,7 @@ discard block |
||
| 191 | 191 | ->leftJoin( |
| 192 | 192 | $this->getDefaultSelectAlias(), CoreRequestBuilder::TABLE_CIRCLE, $alias, |
| 193 | 193 | $expr->andX( |
| 194 | - $expr->eq($alias . '.unique_id', $this->getDefaultSelectAlias() . '.circle_id') |
|
| 194 | + $expr->eq($alias.'.unique_id', $this->getDefaultSelectAlias().'.circle_id') |
|
| 195 | 195 | ) |
| 196 | 196 | ); |
| 197 | 197 | |
@@ -221,8 +221,8 @@ discard block |
||
| 221 | 221 | ->leftJoin( |
| 222 | 222 | $circleTableAlias, CoreRequestBuilder::TABLE_MEMBER, $alias, |
| 223 | 223 | $expr->andX( |
| 224 | - $expr->eq($alias . '.circle_id', $circleTableAlias . '.unique_id'), |
|
| 225 | - $expr->eq($alias . '.level', $this->createNamedParameter(Member::LEVEL_OWNER)) |
|
| 224 | + $expr->eq($alias.'.circle_id', $circleTableAlias.'.unique_id'), |
|
| 225 | + $expr->eq($alias.'.level', $this->createNamedParameter(Member::LEVEL_OWNER)) |
|
| 226 | 226 | ) |
| 227 | 227 | ); |
| 228 | 228 | } |
@@ -248,11 +248,11 @@ discard block |
||
| 248 | 248 | ->leftJoin( |
| 249 | 249 | $aliasCircle, CoreRequestBuilder::TABLE_MEMBER, $alias, |
| 250 | 250 | $expr->andX( |
| 251 | - $expr->eq($alias . '.circle_id', $aliasCircle . '.unique_id'), |
|
| 252 | - $expr->eq($alias . '.user_id', $this->createNamedParameter($initiator->getUserId())), |
|
| 253 | - $expr->eq($alias . '.user_type', $this->createNamedParameter($initiator->getUserType())), |
|
| 251 | + $expr->eq($alias.'.circle_id', $aliasCircle.'.unique_id'), |
|
| 252 | + $expr->eq($alias.'.user_id', $this->createNamedParameter($initiator->getUserId())), |
|
| 253 | + $expr->eq($alias.'.user_type', $this->createNamedParameter($initiator->getUserType())), |
|
| 254 | 254 | $expr->eq( |
| 255 | - $alias . '.instance', $this->createNamedParameter($this->getInstance($initiator)) |
|
| 255 | + $alias.'.instance', $this->createNamedParameter($this->getInstance($initiator)) |
|
| 256 | 256 | ) |
| 257 | 257 | ) |
| 258 | 258 | ); |
@@ -278,9 +278,9 @@ discard block |
||
| 278 | 278 | $this->leftJoin( |
| 279 | 279 | $this->getDefaultSelectAlias(), CoreRequestBuilder::TABLE_MEMBER, $alias, |
| 280 | 280 | $expr->andX( |
| 281 | - $expr->eq($alias . '.circle_id', $aliasCircle . '.unique_id'), |
|
| 282 | - $expr->eq($alias . '.instance', $this->createNamedParameter($instance)), |
|
| 283 | - $expr->gte($alias . '.level', $this->createNamedParameter(Member::LEVEL_MEMBER)) |
|
| 281 | + $expr->eq($alias.'.circle_id', $aliasCircle.'.unique_id'), |
|
| 282 | + $expr->eq($alias.'.instance', $this->createNamedParameter($instance)), |
|
| 283 | + $expr->gte($alias.'.level', $this->createNamedParameter(Member::LEVEL_MEMBER)) |
|
| 284 | 284 | ) |
| 285 | 285 | ); |
| 286 | 286 | } |
@@ -300,7 +300,7 @@ discard block |
||
| 300 | 300 | $expr = $this->expr(); |
| 301 | 301 | $this->leftJoin( |
| 302 | 302 | $this->getDefaultSelectAlias(), CoreRequestBuilder::TABLE_REMOTE, $alias, |
| 303 | - $expr->eq($alias . '.instance', $this->createNamedParameter($instance)) |
|
| 303 | + $expr->eq($alias.'.instance', $this->createNamedParameter($instance)) |
|
| 304 | 304 | ); |
| 305 | 305 | } |
| 306 | 306 | |
@@ -319,15 +319,15 @@ discard block |
||
| 319 | 319 | // - 4 (Visible to everyone) |
| 320 | 320 | $orX = $expr->orX(); |
| 321 | 321 | $orX->add( |
| 322 | - $expr->andX($expr->gte($alias . '.level', $this->createNamedParameter(Member::LEVEL_MEMBER))) |
|
| 322 | + $expr->andX($expr->gte($alias.'.level', $this->createNamedParameter(Member::LEVEL_MEMBER))) |
|
| 323 | 323 | ); |
| 324 | 324 | $orX->add( |
| 325 | 325 | $expr->andX( |
| 326 | - $expr->bitwiseAnd($aliasCircle . '.config', Circle::CFG_PERSONAL), |
|
| 327 | - $expr->eq($alias . '.level', $this->createNamedParameter(Member::LEVEL_OWNER)) |
|
| 326 | + $expr->bitwiseAnd($aliasCircle.'.config', Circle::CFG_PERSONAL), |
|
| 327 | + $expr->eq($alias.'.level', $this->createNamedParameter(Member::LEVEL_OWNER)) |
|
| 328 | 328 | ) |
| 329 | 329 | ); |
| 330 | - $orX->add($expr->bitwiseAnd($aliasCircle . '.config', Circle::CFG_VISIBLE)); |
|
| 330 | + $orX->add($expr->bitwiseAnd($aliasCircle.'.config', Circle::CFG_VISIBLE)); |
|
| 331 | 331 | $this->andWhere($orX); |
| 332 | 332 | |
| 333 | 333 | |
@@ -362,10 +362,10 @@ discard block |
||
| 362 | 362 | $expr = $this->expr(); |
| 363 | 363 | |
| 364 | 364 | $orHidden = $expr->orX(); |
| 365 | - $orHidden->add($expr->bitwiseAnd($alias . '.config', Circle::CFG_SINGLE)); |
|
| 366 | - $orHidden->add($expr->bitwiseAnd($alias . '.config', Circle::CFG_HIDDEN)); |
|
| 367 | - $orHidden->add($expr->bitwiseAnd($alias . '.config', Circle::CFG_BACKEND)); |
|
| 368 | - $this->andWhere($this->createFunction('NOT') . $orHidden); |
|
| 365 | + $orHidden->add($expr->bitwiseAnd($alias.'.config', Circle::CFG_SINGLE)); |
|
| 366 | + $orHidden->add($expr->bitwiseAnd($alias.'.config', Circle::CFG_HIDDEN)); |
|
| 367 | + $orHidden->add($expr->bitwiseAnd($alias.'.config', Circle::CFG_BACKEND)); |
|
| 368 | + $this->andWhere($this->createFunction('NOT').$orHidden); |
|
| 369 | 369 | } |
| 370 | 370 | |
| 371 | 371 | |
@@ -394,30 +394,30 @@ discard block |
||
| 394 | 394 | |
| 395 | 395 | $orX = $expr->orX(); |
| 396 | 396 | $orX->add( |
| 397 | - $expr->eq($alias . '.type', $this->createNamedParameter(RemoteInstance::TYPE_GLOBAL_SCALE)) |
|
| 397 | + $expr->eq($alias.'.type', $this->createNamedParameter(RemoteInstance::TYPE_GLOBAL_SCALE)) |
|
| 398 | 398 | ); |
| 399 | 399 | |
| 400 | 400 | $orExtOrPassive = $expr->orX(); |
| 401 | 401 | $orExtOrPassive->add( |
| 402 | - $expr->eq($alias . '.type', $this->createNamedParameter(RemoteInstance::TYPE_EXTERNAL)) |
|
| 402 | + $expr->eq($alias.'.type', $this->createNamedParameter(RemoteInstance::TYPE_EXTERNAL)) |
|
| 403 | 403 | ); |
| 404 | 404 | if (!$sensitive) { |
| 405 | 405 | $orExtOrPassive->add( |
| 406 | - $expr->eq($alias . '.type', $this->createNamedParameter(RemoteInstance::TYPE_PASSIVE)) |
|
| 406 | + $expr->eq($alias.'.type', $this->createNamedParameter(RemoteInstance::TYPE_PASSIVE)) |
|
| 407 | 407 | ); |
| 408 | 408 | } else { |
| 409 | 409 | if ($this->getDefaultSelectAlias() === 'm') { |
| 410 | 410 | $andPassive = $expr->andX(); |
| 411 | 411 | $andPassive->add( |
| 412 | - $expr->eq($alias . '.type', $this->createNamedParameter(RemoteInstance::TYPE_PASSIVE)) |
|
| 412 | + $expr->eq($alias.'.type', $this->createNamedParameter(RemoteInstance::TYPE_PASSIVE)) |
|
| 413 | 413 | ); |
| 414 | 414 | $orMemberOrLevel = $expr->orX(); |
| 415 | 415 | $orMemberOrLevel->add( |
| 416 | - $expr->eq($this->getDefaultSelectAlias() . '.instance', $alias . '.instance') |
|
| 416 | + $expr->eq($this->getDefaultSelectAlias().'.instance', $alias.'.instance') |
|
| 417 | 417 | ); |
| 418 | 418 | $orMemberOrLevel->add( |
| 419 | 419 | $expr->eq( |
| 420 | - $this->getDefaultSelectAlias() . '.level', |
|
| 420 | + $this->getDefaultSelectAlias().'.level', |
|
| 421 | 421 | $this->createNamedParameter(Member::LEVEL_OWNER) |
| 422 | 422 | ) |
| 423 | 423 | ); |
@@ -428,18 +428,18 @@ discard block |
||
| 428 | 428 | |
| 429 | 429 | $andExternal = $expr->andX(); |
| 430 | 430 | $andExternal->add($orExtOrPassive); |
| 431 | - $andExternal->add($expr->isNotNull($aliasMembers . '.instance')); |
|
| 431 | + $andExternal->add($expr->isNotNull($aliasMembers.'.instance')); |
|
| 432 | 432 | |
| 433 | 433 | $orExtOrTrusted = $expr->orX(); |
| 434 | 434 | $orExtOrTrusted->add($andExternal); |
| 435 | 435 | $orExtOrTrusted->add( |
| 436 | - $expr->eq($alias . '.type', $this->createNamedParameter(RemoteInstance::TYPE_TRUSTED)) |
|
| 436 | + $expr->eq($alias.'.type', $this->createNamedParameter(RemoteInstance::TYPE_TRUSTED)) |
|
| 437 | 437 | ); |
| 438 | 438 | |
| 439 | 439 | $andTrusted = $expr->andX(); |
| 440 | 440 | $andTrusted->add($orExtOrTrusted); |
| 441 | - $andTrusted->add($expr->bitwiseAnd($aliasCircle . '.config', Circle::CFG_FEDERATED)); |
|
| 442 | - $andTrusted->add($expr->emptyString($aliasOwner . '.instance')); |
|
| 441 | + $andTrusted->add($expr->bitwiseAnd($aliasCircle.'.config', Circle::CFG_FEDERATED)); |
|
| 442 | + $andTrusted->add($expr->emptyString($aliasOwner.'.instance')); |
|
| 443 | 443 | $orX->add($andTrusted); |
| 444 | 444 | |
| 445 | 445 | $this->andWhere($orX); |
@@ -450,7 +450,7 @@ discard block |
||
| 450 | 450 | * @param int $flag |
| 451 | 451 | */ |
| 452 | 452 | public function filterConfig(int $flag): void { |
| 453 | - $this->andWhere($this->expr()->bitwiseAnd($this->getDefaultSelectAlias() . '.config', $flag)); |
|
| 453 | + $this->andWhere($this->expr()->bitwiseAnd($this->getDefaultSelectAlias().'.config', $flag)); |
|
| 454 | 454 | } |
| 455 | 455 | |
| 456 | 456 | |
@@ -461,15 +461,15 @@ discard block |
||
| 461 | 461 | * @return $this |
| 462 | 462 | */ |
| 463 | 463 | private function generateCircleSelectAlias(string $alias, string $prefix): self { |
| 464 | - $this->selectAlias($alias . '.unique_id', $prefix . 'unique_id') |
|
| 465 | - ->selectAlias($alias . '.name', $prefix . 'name') |
|
| 466 | - ->selectAlias($alias . '.alt_name', $prefix . 'alt_name') |
|
| 467 | - ->selectAlias($alias . '.description', $prefix . 'description') |
|
| 468 | - ->selectAlias($alias . '.settings', $prefix . 'settings') |
|
| 469 | - ->selectAlias($alias . '.config', $prefix . 'config') |
|
| 470 | - ->selectAlias($alias . '.contact_addressbook', $prefix . 'contact_addressbook') |
|
| 471 | - ->selectAlias($alias . '.contact_groupname', $prefix . 'contact_groupname') |
|
| 472 | - ->selectAlias($alias . '.creation', $prefix . 'creation'); |
|
| 464 | + $this->selectAlias($alias.'.unique_id', $prefix.'unique_id') |
|
| 465 | + ->selectAlias($alias.'.name', $prefix.'name') |
|
| 466 | + ->selectAlias($alias.'.alt_name', $prefix.'alt_name') |
|
| 467 | + ->selectAlias($alias.'.description', $prefix.'description') |
|
| 468 | + ->selectAlias($alias.'.settings', $prefix.'settings') |
|
| 469 | + ->selectAlias($alias.'.config', $prefix.'config') |
|
| 470 | + ->selectAlias($alias.'.contact_addressbook', $prefix.'contact_addressbook') |
|
| 471 | + ->selectAlias($alias.'.contact_groupname', $prefix.'contact_groupname') |
|
| 472 | + ->selectAlias($alias.'.creation', $prefix.'creation'); |
|
| 473 | 473 | |
| 474 | 474 | return $this; |
| 475 | 475 | } |
@@ -481,20 +481,20 @@ discard block |
||
| 481 | 481 | * @return $this |
| 482 | 482 | */ |
| 483 | 483 | private function generateMemberSelectAlias(string $alias, string $prefix): self { |
| 484 | - $this->selectAlias($alias . '.circle_id', $prefix . 'circle_id') |
|
| 485 | - ->selectAlias($alias . '.single_id', $prefix . 'single_id') |
|
| 486 | - ->selectAlias($alias . '.user_id', $prefix . 'user_id') |
|
| 487 | - ->selectAlias($alias . '.user_type', $prefix . 'user_type') |
|
| 488 | - ->selectAlias($alias . '.member_id', $prefix . 'member_id') |
|
| 489 | - ->selectAlias($alias . '.instance', $prefix . 'instance') |
|
| 490 | - ->selectAlias($alias . '.cached_name', $prefix . 'cached_name') |
|
| 491 | - ->selectAlias($alias . '.cached_update', $prefix . 'cached_update') |
|
| 492 | - ->selectAlias($alias . '.status', $prefix . 'status') |
|
| 493 | - ->selectAlias($alias . '.level', $prefix . 'level') |
|
| 494 | - ->selectAlias($alias . '.note', $prefix . 'note') |
|
| 495 | - ->selectAlias($alias . '.contact_id', $prefix . 'contact_id') |
|
| 496 | - ->selectAlias($alias . '.contact_meta', $prefix . 'contact_meta') |
|
| 497 | - ->selectAlias($alias . '.joined', $prefix . 'joined'); |
|
| 484 | + $this->selectAlias($alias.'.circle_id', $prefix.'circle_id') |
|
| 485 | + ->selectAlias($alias.'.single_id', $prefix.'single_id') |
|
| 486 | + ->selectAlias($alias.'.user_id', $prefix.'user_id') |
|
| 487 | + ->selectAlias($alias.'.user_type', $prefix.'user_type') |
|
| 488 | + ->selectAlias($alias.'.member_id', $prefix.'member_id') |
|
| 489 | + ->selectAlias($alias.'.instance', $prefix.'instance') |
|
| 490 | + ->selectAlias($alias.'.cached_name', $prefix.'cached_name') |
|
| 491 | + ->selectAlias($alias.'.cached_update', $prefix.'cached_update') |
|
| 492 | + ->selectAlias($alias.'.status', $prefix.'status') |
|
| 493 | + ->selectAlias($alias.'.level', $prefix.'level') |
|
| 494 | + ->selectAlias($alias.'.note', $prefix.'note') |
|
| 495 | + ->selectAlias($alias.'.contact_id', $prefix.'contact_id') |
|
| 496 | + ->selectAlias($alias.'.contact_meta', $prefix.'contact_meta') |
|
| 497 | + ->selectAlias($alias.'.joined', $prefix.'joined'); |
|
| 498 | 498 | |
| 499 | 499 | return $this; |
| 500 | 500 | } |
@@ -121,7 +121,7 @@ |
||
| 121 | 121 | * @param string $name |
| 122 | 122 | * @param FederatedUser|null $owner |
| 123 | 123 | * |
| 124 | - * @return Circle |
|
| 124 | + * @return SimpleDataStore |
|
| 125 | 125 | * @throws FederatedEventException |
| 126 | 126 | * @throws InitiatorNotConfirmedException |
| 127 | 127 | * @throws InitiatorNotFoundException |
@@ -549,29 +549,29 @@ discard block |
||
| 549 | 549 | * @throws MemberNotFoundException |
| 550 | 550 | */ |
| 551 | 551 | public function importFromDatabase(array $data, string $prefix = ''): INC21QueryRow { |
| 552 | - if (!array_key_exists($prefix . 'member_id', $data)) { |
|
| 552 | + if (!array_key_exists($prefix.'member_id', $data)) { |
|
| 553 | 553 | throw new MemberNotFoundException(); |
| 554 | 554 | } |
| 555 | 555 | |
| 556 | - $this->setId($this->get($prefix . 'member_id', $data)); |
|
| 557 | - $this->setCircleId($this->get($prefix . 'circle_id', $data)); |
|
| 558 | - $this->setSingleId($this->get($prefix . 'single_id', $data)); |
|
| 559 | - $this->setUserId($this->get($prefix . 'user_id', $data)); |
|
| 560 | - $this->setUserType($this->getInt($prefix . 'user_type', $data)); |
|
| 561 | - $this->setInstance($this->get($prefix . 'instance', $data)); |
|
| 562 | - $this->setLevel($this->getInt($prefix . 'level', $data)); |
|
| 563 | - $this->setStatus($this->get($prefix . 'status', $data)); |
|
| 564 | - $this->setCachedName($this->get($prefix . 'cached_name', $data)); |
|
| 565 | - $this->setNote($this->get($prefix . 'note', $data)); |
|
| 566 | - $this->setContactId($this->get($prefix . 'contact_id', $data)); |
|
| 567 | - $this->setContactMeta($this->get($prefix . 'contact_meta', $data)); |
|
| 568 | - |
|
| 569 | - $cachedUpdate = $this->get($prefix . 'cached_update', $data); |
|
| 556 | + $this->setId($this->get($prefix.'member_id', $data)); |
|
| 557 | + $this->setCircleId($this->get($prefix.'circle_id', $data)); |
|
| 558 | + $this->setSingleId($this->get($prefix.'single_id', $data)); |
|
| 559 | + $this->setUserId($this->get($prefix.'user_id', $data)); |
|
| 560 | + $this->setUserType($this->getInt($prefix.'user_type', $data)); |
|
| 561 | + $this->setInstance($this->get($prefix.'instance', $data)); |
|
| 562 | + $this->setLevel($this->getInt($prefix.'level', $data)); |
|
| 563 | + $this->setStatus($this->get($prefix.'status', $data)); |
|
| 564 | + $this->setCachedName($this->get($prefix.'cached_name', $data)); |
|
| 565 | + $this->setNote($this->get($prefix.'note', $data)); |
|
| 566 | + $this->setContactId($this->get($prefix.'contact_id', $data)); |
|
| 567 | + $this->setContactMeta($this->get($prefix.'contact_meta', $data)); |
|
| 568 | + |
|
| 569 | + $cachedUpdate = $this->get($prefix.'cached_update', $data); |
|
| 570 | 570 | if ($cachedUpdate !== '') { |
| 571 | 571 | $this->setCachedUpdate(DateTime::createFromFormat('Y-m-d H:i:s', $cachedUpdate)->getTimestamp()); |
| 572 | 572 | } |
| 573 | 573 | |
| 574 | - $joined = $this->get($prefix . 'joined', $data); |
|
| 574 | + $joined = $this->get($prefix.'joined', $data); |
|
| 575 | 575 | if ($joined !== '') { |
| 576 | 576 | $this->setJoined(DateTime::createFromFormat('Y-m-d H:i:s', $joined)->getTimestamp()); |
| 577 | 577 | } |
@@ -600,7 +600,7 @@ discard block |
||
| 600 | 600 | |
| 601 | 601 | if (!$level) { |
| 602 | 602 | $all = implode(', ', array_values(self::$DEF_LEVEL)); |
| 603 | - throw new MemberLevelException('Available levels: ' . $all); |
|
| 603 | + throw new MemberLevelException('Available levels: '.$all); |
|
| 604 | 604 | } |
| 605 | 605 | |
| 606 | 606 | return (int)$level; |
@@ -618,7 +618,7 @@ discard block |
||
| 618 | 618 | |
| 619 | 619 | if (!$type) { |
| 620 | 620 | $all = implode(', ', array_values(self::$DEF_TYPE)); |
| 621 | - throw new UserTypeNotFoundException('Available types: ' . $all); |
|
| 621 | + throw new UserTypeNotFoundException('Available types: '.$all); |
|
| 622 | 622 | } |
| 623 | 623 | |
| 624 | 624 | return (int)$type; |