@@ -571,17 +571,17 @@ discard block |
||
571 | 571 | } |
572 | 572 | |
573 | 573 | $metadata = array("service"=> |
574 | - array("displayName" => $this->_name, |
|
575 | - "identifier" => $this->_identifier, |
|
576 | - "logoUrl" => $this->_logoUrl, |
|
577 | - "infoUrl" => $this->_infoUrl, |
|
578 | - "authenticationUrl" => $authenticationUrl, |
|
579 | - "ocraSuite" => $this->_ocraSuite, |
|
580 | - "enrollmentUrl" => $enrollmentUrl |
|
581 | - ), |
|
582 | - "identity"=> |
|
583 | - array("identifier" =>$data["userId"], |
|
584 | - "displayName"=>$data["displayName"])); |
|
574 | + array("displayName" => $this->_name, |
|
575 | + "identifier" => $this->_identifier, |
|
576 | + "logoUrl" => $this->_logoUrl, |
|
577 | + "infoUrl" => $this->_infoUrl, |
|
578 | + "authenticationUrl" => $authenticationUrl, |
|
579 | + "ocraSuite" => $this->_ocraSuite, |
|
580 | + "enrollmentUrl" => $enrollmentUrl |
|
581 | + ), |
|
582 | + "identity"=> |
|
583 | + array("identifier" =>$data["userId"], |
|
584 | + "displayName"=>$data["displayName"])); |
|
585 | 585 | |
586 | 586 | $this->_unsetStateValue(self::PREFIX_ENROLLMENT, $enrollmentKey); |
587 | 587 | |
@@ -611,28 +611,28 @@ discard block |
||
611 | 611 | */ |
612 | 612 | public function getEnrollmentSecret(string $enrollmentKey): string |
613 | 613 | { |
614 | - $data = $this->_getStateValue(self::PREFIX_ENROLLMENT, $enrollmentKey); |
|
615 | - if (!is_array($data)) { |
|
616 | - $this->logger->error('getEnrollmentSecret: enrollment key not found'); |
|
617 | - throw new RuntimeException('enrollment key not found'); |
|
618 | - } |
|
619 | - $userId = $data["userId"] ?? NULL; |
|
620 | - $sessionId = $data["sessionId"] ?? NULL; |
|
621 | - if (!is_string($userId) || !(is_string($sessionId))) { |
|
622 | - throw new RuntimeException('getEnrollmentSecret: invalid enrollment data'); |
|
623 | - } |
|
624 | - $enrollmentData = [ |
|
625 | - "userId" => $userId, |
|
626 | - "sessionId" => $sessionId |
|
627 | - ]; |
|
628 | - $enrollmentSecret = $this->_uniqueSessionKey(); |
|
629 | - $this->_setStateValue( |
|
630 | - self::PREFIX_ENROLLMENT_SECRET, |
|
631 | - $enrollmentSecret, |
|
632 | - $enrollmentData, |
|
633 | - self::ENROLLMENT_EXPIRE |
|
634 | - ); |
|
635 | - return $enrollmentSecret; |
|
614 | + $data = $this->_getStateValue(self::PREFIX_ENROLLMENT, $enrollmentKey); |
|
615 | + if (!is_array($data)) { |
|
616 | + $this->logger->error('getEnrollmentSecret: enrollment key not found'); |
|
617 | + throw new RuntimeException('enrollment key not found'); |
|
618 | + } |
|
619 | + $userId = $data["userId"] ?? NULL; |
|
620 | + $sessionId = $data["sessionId"] ?? NULL; |
|
621 | + if (!is_string($userId) || !(is_string($sessionId))) { |
|
622 | + throw new RuntimeException('getEnrollmentSecret: invalid enrollment data'); |
|
623 | + } |
|
624 | + $enrollmentData = [ |
|
625 | + "userId" => $userId, |
|
626 | + "sessionId" => $sessionId |
|
627 | + ]; |
|
628 | + $enrollmentSecret = $this->_uniqueSessionKey(); |
|
629 | + $this->_setStateValue( |
|
630 | + self::PREFIX_ENROLLMENT_SECRET, |
|
631 | + $enrollmentSecret, |
|
632 | + $enrollmentData, |
|
633 | + self::ENROLLMENT_EXPIRE |
|
634 | + ); |
|
635 | + return $enrollmentSecret; |
|
636 | 636 | } |
637 | 637 | |
638 | 638 | /** |
@@ -118,7 +118,7 @@ discard block |
||
118 | 118 | // INVALID_USERID: The client authenticated a different user than the server expected. This error is returned when |
119 | 119 | // the application stated an authentication session specifying the userId and later during the authentication |
120 | 120 | // provides a different userId |
121 | - const AUTH_RESULT_INVALID_USERID = 5; |
|
121 | + const AUTH_RESULT_INVALID_USERID = 5; |
|
122 | 122 | |
123 | 123 | /** |
124 | 124 | * The default OCRA Suite (RFC 6287) to use for authentication in Tiqr |
@@ -244,7 +244,7 @@ discard block |
||
244 | 244 | * @param int $version The tiqr protocol version to use (defaults to the latest) |
245 | 245 | * @throws Exception |
246 | 246 | */ |
247 | - public function __construct(LoggerInterface $logger, array $options=array(), int $version = 2) |
|
247 | + public function __construct(LoggerInterface $logger, array $options = array(), int $version = 2) |
|
248 | 248 | { |
249 | 249 | $this->_options = $options; // Used to later get settings for Tiqr_Message_* |
250 | 250 | $this->logger = $logger; |
@@ -361,7 +361,7 @@ discard block |
||
361 | 361 | |
362 | 362 | $this->logger->info(sprintf('Creating and sending a %s push notification', $notificationType)); |
363 | 363 | $message->setId(time()); |
364 | - $message->setText("Please authenticate for " . $this->_name); |
|
364 | + $message->setText("Please authenticate for ".$this->_name); |
|
365 | 365 | $message->setAddress($notificationAddress); |
366 | 366 | $message->setCustomProperty('challenge', $this->_getChallengeUrl($sessionKey)); |
367 | 367 | $message->send(); |
@@ -407,13 +407,13 @@ discard block |
||
407 | 407 | * @return string The authentication sessionKey |
408 | 408 | * @throws Exception when starting the authentication session failed |
409 | 409 | */ |
410 | - public function startAuthenticationSession(string $userId="", string $sessionId="", string $spIdentifier=""): string |
|
410 | + public function startAuthenticationSession(string $userId = "", string $sessionId = "", string $spIdentifier = ""): string |
|
411 | 411 | { |
412 | - if ($sessionId=="") { |
|
412 | + if ($sessionId == "") { |
|
413 | 413 | $sessionId = session_id(); |
414 | 414 | } |
415 | 415 | |
416 | - if ($spIdentifier=="") { |
|
416 | + if ($spIdentifier == "") { |
|
417 | 417 | $spIdentifier = $this->_identifier; |
418 | 418 | } |
419 | 419 | |
@@ -422,7 +422,7 @@ discard block |
||
422 | 422 | |
423 | 423 | $data = array("sessionId"=>$sessionId, "challenge"=>$challenge, "spIdentifier" => $spIdentifier); |
424 | 424 | |
425 | - if ($userId!="") { |
|
425 | + if ($userId != "") { |
|
426 | 426 | $data["userId"] = $userId; |
427 | 427 | } |
428 | 428 | |
@@ -446,9 +446,9 @@ discard block |
||
446 | 446 | * @return String The enrollment key |
447 | 447 | * @throws Exception when start the enrollement session failed |
448 | 448 | */ |
449 | - public function startEnrollmentSession(string $userId, string $displayName, string $sessionId=""): string |
|
449 | + public function startEnrollmentSession(string $userId, string $displayName, string $sessionId = ""): string |
|
450 | 450 | { |
451 | - if ($sessionId=="") { |
|
451 | + if ($sessionId == "") { |
|
452 | 452 | $sessionId = session_id(); |
453 | 453 | } |
454 | 454 | $enrollmentKey = $this->_uniqueSessionKey(); |
@@ -468,9 +468,9 @@ discard block |
||
468 | 468 | * @param string $sessionId The application's session identifier (defaults to php session) |
469 | 469 | * @throws Exception when resetting the session failed |
470 | 470 | */ |
471 | - public function resetEnrollmentSession(string $sessionId=""): void |
|
471 | + public function resetEnrollmentSession(string $sessionId = ""): void |
|
472 | 472 | { |
473 | - if ($sessionId=="") { |
|
473 | + if ($sessionId == "") { |
|
474 | 474 | $sessionId = session_id(); |
475 | 475 | } |
476 | 476 | |
@@ -505,9 +505,9 @@ discard block |
||
505 | 505 | * |
506 | 506 | * @throws Exception when an error communicating with the state storage backend was detected |
507 | 507 | */ |
508 | - public function getEnrollmentStatus(string $sessionId=""): int |
|
508 | + public function getEnrollmentStatus(string $sessionId = ""): int |
|
509 | 509 | { |
510 | - if ($sessionId=="") { |
|
510 | + if ($sessionId == "") { |
|
511 | 511 | $sessionId = session_id(); |
512 | 512 | } |
513 | 513 | $status = $this->_getStateValue(self::PREFIX_ENROLLMENT_STATUS, $sessionId); |
@@ -660,7 +660,7 @@ discard block |
||
660 | 660 | if (NULL === $data) { |
661 | 661 | throw new RuntimeException('Enrollment secret not found'); |
662 | 662 | } |
663 | - if ( !is_array($data) || !is_string($data["userId"] ?? NULL)) { |
|
663 | + if (!is_array($data) || !is_string($data["userId"] ?? NULL)) { |
|
664 | 664 | throw new RuntimeException('Invalid enrollment data'); |
665 | 665 | } |
666 | 666 | |
@@ -700,7 +700,7 @@ discard block |
||
700 | 700 | $this->_setEnrollmentStatus($data["sessionId"], self::ENROLLMENT_STATUS_FINALIZED); |
701 | 701 | } else { |
702 | 702 | $this->logger->error( |
703 | - 'Enrollment status is not finalized, enrollmentsecret was not found in state storage. ' . |
|
703 | + 'Enrollment status is not finalized, enrollmentsecret was not found in state storage. '. |
|
704 | 704 | 'Warning! the method will still return "true" as a result.' |
705 | 705 | ); |
706 | 706 | } |
@@ -758,9 +758,9 @@ discard block |
||
758 | 758 | throw $e; |
759 | 759 | } |
760 | 760 | |
761 | - $sessionId = $state["sessionId"] ?? NULL; // Application's sessionId |
|
762 | - $challenge = $state["challenge"] ?? NULL; // The challenge we sent to the Tiqr client |
|
763 | - if (!is_string($sessionId) || (!is_string($challenge)) ) { |
|
761 | + $sessionId = $state["sessionId"] ?? NULL; // Application's sessionId |
|
762 | + $challenge = $state["challenge"] ?? NULL; // The challenge we sent to the Tiqr client |
|
763 | + if (!is_string($sessionId) || (!is_string($challenge))) { |
|
764 | 764 | throw new RuntimeException('Invalid state for state storage'); |
765 | 765 | } |
766 | 766 | |
@@ -769,7 +769,7 @@ discard block |
||
769 | 769 | $challengeUserId = $state["userId"] ?? NULL; |
770 | 770 | |
771 | 771 | // If the application requested a specific userId, verify that that is that userId that we're now authenticating |
772 | - if ($challengeUserId!==NULL && ($userId !== $challengeUserId)) { |
|
772 | + if ($challengeUserId !== NULL && ($userId !== $challengeUserId)) { |
|
773 | 773 | $this->logger->error( |
774 | 774 | sprintf('Authentication failed: the requested userId "%s" does not match userId "%s" that is being authenticated', |
775 | 775 | $challengeUserId, $userId) |
@@ -817,9 +817,9 @@ discard block |
||
817 | 817 | * |
818 | 818 | * @throws Exception when there was an error communicating with the storage backed |
819 | 819 | */ |
820 | - public function logout(string $sessionId=""): void |
|
820 | + public function logout(string $sessionId = ""): void |
|
821 | 821 | { |
822 | - if ($sessionId=="") { |
|
822 | + if ($sessionId == "") { |
|
823 | 823 | $sessionId = session_id(); |
824 | 824 | } |
825 | 825 | |
@@ -859,9 +859,9 @@ discard block |
||
859 | 859 | * |
860 | 860 | * Does not throw |
861 | 861 | */ |
862 | - public function getAuthenticatedUser(string $sessionId=""): ?string |
|
862 | + public function getAuthenticatedUser(string $sessionId = ""): ?string |
|
863 | 863 | { |
864 | - if ($sessionId=="") { |
|
864 | + if ($sessionId == "") { |
|
865 | 865 | $this->logger->debug('Using the PHP session id, as no session id was provided'); |
866 | 866 | $sessionId = session_id(); |
867 | 867 | } |
@@ -905,22 +905,22 @@ discard block |
||
905 | 905 | $challenge = $state["challenge"] ?? ''; |
906 | 906 | $spIdentifier = $state["spIdentifier"] ?? ''; |
907 | 907 | |
908 | - if ( (strpos($this->_protocolAuth, 'https://') === 0) || (strpos($this->_protocolAuth, 'http://') === 0) ) { |
|
908 | + if ((strpos($this->_protocolAuth, 'https://') === 0) || (strpos($this->_protocolAuth, 'http://') === 0)) { |
|
909 | 909 | // Create universal Link |
910 | - $parameters=array(); |
|
910 | + $parameters = array(); |
|
911 | 911 | if (!is_null($userId)) { |
912 | - $parameters[]='u='.urlencode($userId); |
|
912 | + $parameters[] = 'u='.urlencode($userId); |
|
913 | 913 | } |
914 | - $parameters[]='s='.urlencode($sessionKey); |
|
915 | - $parameters[]='q='.urlencode($challenge); |
|
916 | - $parameters[]='i='.urlencode($this->getIdentifier()); |
|
917 | - $parameters[]='v='.urlencode($this->_protocolVersion); |
|
914 | + $parameters[] = 's='.urlencode($sessionKey); |
|
915 | + $parameters[] = 'q='.urlencode($challenge); |
|
916 | + $parameters[] = 'i='.urlencode($this->getIdentifier()); |
|
917 | + $parameters[] = 'v='.urlencode($this->_protocolVersion); |
|
918 | 918 | return $this->_protocolAuth.'?'.implode('&', $parameters); |
919 | 919 | } |
920 | 920 | |
921 | 921 | // Create custom URL scheme |
922 | 922 | // Last bit is the spIdentifier |
923 | - return $this->_protocolAuth."://".(!is_null($userId)?urlencode($userId).'@':'').$this->getIdentifier()."/".$sessionKey."/".$challenge."/".urlencode($spIdentifier)."/".$this->_protocolVersion; |
|
923 | + return $this->_protocolAuth."://".(!is_null($userId) ?urlencode($userId).'@' : '').$this->getIdentifier()."/".$sessionKey."/".$challenge."/".urlencode($spIdentifier)."/".$this->_protocolVersion; |
|
924 | 924 | } |
925 | 925 | |
926 | 926 | /** |
@@ -931,7 +931,7 @@ discard block |
||
931 | 931 | { |
932 | 932 | // The are two formats see: https://tiqr.org/technical/protocol/ |
933 | 933 | |
934 | - if ( (strpos($this->_protocolEnroll, 'https://') === 0) || (strpos($this->_protocolEnroll, 'http://') === 0) ) { |
|
934 | + if ((strpos($this->_protocolEnroll, 'https://') === 0) || (strpos($this->_protocolEnroll, 'http://') === 0)) { |
|
935 | 935 | // Create universal Link |
936 | 936 | return $this->_protocolEnroll.'?metadata='.urlencode($metadataUrl); |
937 | 937 | } |
@@ -950,7 +950,7 @@ discard block |
||
950 | 950 | protected function _uniqueSessionKey(): string |
951 | 951 | { |
952 | 952 | |
953 | - return bin2hex( Tiqr_Random::randomBytes(self::SESSION_KEY_LENGTH_BYTES) ); |
|
953 | + return bin2hex(Tiqr_Random::randomBytes(self::SESSION_KEY_LENGTH_BYTES)); |
|
954 | 954 | } |
955 | 955 | |
956 | 956 | /** |
@@ -981,7 +981,7 @@ discard block |
||
981 | 981 | */ |
982 | 982 | protected function _setStateValue(string $key_prefix, string $key, $value, int $expire): void { |
983 | 983 | $this->_stateStorage->setValue( |
984 | - $key_prefix . $this->_hashKey($key), |
|
984 | + $key_prefix.$this->_hashKey($key), |
|
985 | 985 | $value, |
986 | 986 | $expire |
987 | 987 | ); |
@@ -998,7 +998,7 @@ discard block |
||
998 | 998 | |
999 | 999 | protected function _getStateValue(string $key_prefix, string $key) { |
1000 | 1000 | return $this->_stateStorage->getValue( |
1001 | - $key_prefix . $this->_hashKey($key) |
|
1001 | + $key_prefix.$this->_hashKey($key) |
|
1002 | 1002 | ); |
1003 | 1003 | } |
1004 | 1004 | |
@@ -1012,7 +1012,7 @@ discard block |
||
1012 | 1012 | */ |
1013 | 1013 | protected function _unsetStateValue(string $key_prefix, string $key): void { |
1014 | 1014 | $this->_stateStorage->unsetValue( |
1015 | - $key_prefix . $this->_hashKey($key) |
|
1015 | + $key_prefix.$this->_hashKey($key) |
|
1016 | 1016 | ); |
1017 | 1017 | } |
1018 | 1018 |
@@ -287,8 +287,7 @@ discard block |
||
287 | 287 | if (isset($options['ocraservice']) && $options['ocraservice']['type'] != 'tiqr') { |
288 | 288 | $options['ocraservice']['ocra.suite'] = $this->_ocraSuite; |
289 | 289 | $this->_ocraService = Tiqr_OcraService::getOcraService($options['ocraservice']['type'], $options['ocraservice'], $logger); |
290 | - } |
|
291 | - else { // Create default ocraservice |
|
290 | + } else { // Create default ocraservice |
|
292 | 291 | $this->_ocraService = Tiqr_OcraService::getOcraService('tiqr', array('ocra.suite' => $this->_ocraSuite), $logger); |
293 | 292 | } |
294 | 293 | } |
@@ -511,7 +510,9 @@ discard block |
||
511 | 510 | $sessionId = session_id(); |
512 | 511 | } |
513 | 512 | $status = $this->_getStateValue(self::PREFIX_ENROLLMENT_STATUS, $sessionId); |
514 | - if (is_null($status)) return self::ENROLLMENT_STATUS_IDLE; |
|
513 | + if (is_null($status)) { |
|
514 | + return self::ENROLLMENT_STATUS_IDLE; |
|
515 | + } |
|
515 | 516 | return $status; |
516 | 517 | } |
517 | 518 | |
@@ -868,8 +869,7 @@ discard block |
||
868 | 869 | |
869 | 870 | try { |
870 | 871 | return $this->_getStateValue("authenticated_", $sessionId); |
871 | - } |
|
872 | - catch (Exception $e) { |
|
872 | + } catch (Exception $e) { |
|
873 | 873 | $this->logger->error('getAuthenticatedUser failed', array('exception'=>$e)); |
874 | 874 | return NULL; |
875 | 875 | } |
@@ -1,6 +1,6 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -require_once __DIR__ . '/../OATH/OCRA.php'; |
|
3 | +require_once __DIR__.'/../OATH/OCRA.php'; |
|
4 | 4 | |
5 | 5 | /** |
6 | 6 | * This file is part of the tiqr project. |
@@ -30,13 +30,11 @@ |
||
30 | 30 | notificationtype varchar(10), |
31 | 31 | notificationaddress varchar(64) |
32 | 32 | ); |
33 | - |
|
34 | 33 | * |
35 | 34 | * In version 3.0 the format of the tmpblocktimestamp was changed from a datetime format to an integer. |
36 | 35 | * Because it holds a unix timestamp a 64-bit (8-byte) integer. To upgrade the user table to the new format use: |
37 | 36 | |
38 | 37 | ALTER TABLE user MODIFY tmpblocktimestamp BIGINT; |
39 | - |
|
40 | 38 | */ |
41 | 39 | |
42 | 40 | use Psr\Log\LoggerInterface; |
@@ -89,21 +89,21 @@ discard block |
||
89 | 89 | */ |
90 | 90 | private function _getStringValue(string $columnName, string $userId): string |
91 | 91 | { |
92 | - if ( !in_array($columnName, $this->_allowedStringColumns) ) { |
|
92 | + if (!in_array($columnName, $this->_allowedStringColumns)) { |
|
93 | 93 | throw new InvalidArgumentException('Unsupported column name'); |
94 | 94 | } |
95 | 95 | |
96 | 96 | try { |
97 | - $sth = $this->handle->prepare('SELECT ' . $columnName . ' FROM ' . $this->tablename . ' WHERE userid = ?'); |
|
97 | + $sth = $this->handle->prepare('SELECT '.$columnName.' FROM '.$this->tablename.' WHERE userid = ?'); |
|
98 | 98 | $sth->execute(array($userId)); |
99 | - $res=$sth->fetchColumn(); |
|
99 | + $res = $sth->fetchColumn(); |
|
100 | 100 | if ($res === false) { |
101 | 101 | // No result |
102 | 102 | $this->logger->error(sprintf('No result getting "%s" for user "%s"', $columnName, $userId)); |
103 | 103 | throw new RuntimeException('User not found'); |
104 | 104 | } |
105 | 105 | if ($res === NULL) { |
106 | - return ''; // Value unset |
|
106 | + return ''; // Value unset |
|
107 | 107 | } |
108 | 108 | if (!is_string($res)) { |
109 | 109 | $this->logger->error(sprintf('Expected string type while getting "%s" for user "%s"', $columnName, $userId)); |
@@ -127,28 +127,28 @@ discard block |
||
127 | 127 | */ |
128 | 128 | private function _getIntValue(string $columnName, string $userId): int |
129 | 129 | { |
130 | - if ( !in_array($columnName, $this->_allowedIntColumns) ) { |
|
130 | + if (!in_array($columnName, $this->_allowedIntColumns)) { |
|
131 | 131 | throw new InvalidArgumentException('Unsupported column name'); |
132 | 132 | } |
133 | 133 | |
134 | 134 | try { |
135 | - $sth = $this->handle->prepare('SELECT ' . $columnName . ' FROM ' . $this->tablename . ' WHERE userid = ?'); |
|
135 | + $sth = $this->handle->prepare('SELECT '.$columnName.' FROM '.$this->tablename.' WHERE userid = ?'); |
|
136 | 136 | $sth->execute(array($userId)); |
137 | - $res=$sth->fetchColumn(); |
|
137 | + $res = $sth->fetchColumn(); |
|
138 | 138 | if ($res === false) { |
139 | 139 | // No result |
140 | 140 | $this->logger->error(sprintf('No result getting "%s" for user "%s"', $columnName, $userId)); |
141 | 141 | throw new RuntimeException('User not found'); |
142 | 142 | } |
143 | 143 | if ($res === NULL) { |
144 | - return 0; // Value unset |
|
144 | + return 0; // Value unset |
|
145 | 145 | } |
146 | 146 | // Return type for integers depends on the PDO driver, can be string |
147 | 147 | if (!is_numeric($res)) { |
148 | 148 | $this->logger->error(sprintf('Expected int type while getting "%s" for user "%s"', $columnName, $userId)); |
149 | 149 | throw new RuntimeException('Unexpected return type'); |
150 | 150 | } |
151 | - return (int)$res; |
|
151 | + return (int) $res; |
|
152 | 152 | } |
153 | 153 | catch (Exception $e) { |
154 | 154 | $this->logger->error('PDO error getting user', array('exception' => $e, 'userId' => $userId, 'columnName'=>$columnName)); |
@@ -165,11 +165,11 @@ discard block |
||
165 | 165 | */ |
166 | 166 | private function _setStringValue(string $columnName, string $userId, string $value): void |
167 | 167 | { |
168 | - if ( !in_array($columnName, $this->_allowedStringColumns) ) { |
|
168 | + if (!in_array($columnName, $this->_allowedStringColumns)) { |
|
169 | 169 | throw new InvalidArgumentException('Unsupported column name'); |
170 | 170 | } |
171 | 171 | try { |
172 | - $sth = $this->handle->prepare('UPDATE ' . $this->tablename . ' SET ' . $columnName . ' = ? WHERE userid = ?'); |
|
172 | + $sth = $this->handle->prepare('UPDATE '.$this->tablename.' SET '.$columnName.' = ? WHERE userid = ?'); |
|
173 | 173 | $sth->execute(array($value, $userId)); |
174 | 174 | if ($sth->rowCount() == 0) { |
175 | 175 | // Required for mysql which only returns the number of rows that were actually updated |
@@ -193,11 +193,11 @@ discard block |
||
193 | 193 | */ |
194 | 194 | private function _setIntValue(string $columnName, string $userId, int $value): void |
195 | 195 | { |
196 | - if ( !in_array($columnName, $this->_allowedIntColumns) ) { |
|
196 | + if (!in_array($columnName, $this->_allowedIntColumns)) { |
|
197 | 197 | throw new InvalidArgumentException('Unsupported column name'); |
198 | 198 | } |
199 | 199 | try { |
200 | - $sth = $this->handle->prepare('UPDATE ' . $this->tablename . ' SET ' . $columnName . ' = ? WHERE userid = ?'); |
|
200 | + $sth = $this->handle->prepare('UPDATE '.$this->tablename.' SET '.$columnName.' = ? WHERE userid = ?'); |
|
201 | 201 | $sth->execute(array($value, $userId)); |
202 | 202 | if ($sth->rowCount() == 0) { |
203 | 203 | // Required for mysql which only returns the number of rows that were actually updated |
@@ -309,17 +309,17 @@ discard block |
||
309 | 309 | { |
310 | 310 | // Check for blocked |
311 | 311 | if ($this->_getIntValue('blocked', $userId) != 0) { |
312 | - return true; // Blocked |
|
312 | + return true; // Blocked |
|
313 | 313 | } |
314 | 314 | |
315 | 315 | if (0 == $tempBlockDuration) { |
316 | - return false; // No check for temporary block |
|
316 | + return false; // No check for temporary block |
|
317 | 317 | } |
318 | 318 | |
319 | 319 | // Check for temporary block |
320 | 320 | $timestamp = $this->getTemporaryBlockTimestamp($userId); |
321 | 321 | // if no temporary block timestamp is set or if the temporary block is expired, return false |
322 | - if ( 0 == $timestamp || ($timestamp + $tempBlockDuration * 60) < time()) { |
|
322 | + if (0 == $timestamp || ($timestamp + $tempBlockDuration * 60) < time()) { |
|
323 | 323 | return false; |
324 | 324 | } |
325 | 325 | return true; |
@@ -110,8 +110,7 @@ discard block |
||
110 | 110 | throw new RuntimeException('Unexpected return type'); |
111 | 111 | } |
112 | 112 | return $res; |
113 | - } |
|
114 | - catch (Exception $e) { |
|
113 | + } catch (Exception $e) { |
|
115 | 114 | $this->logger->error('PDO error getting user', array('exception' => $e, 'userId' => $userId, 'columnName'=>$columnName)); |
116 | 115 | throw ReadWriteException::fromOriginalException($e); |
117 | 116 | } |
@@ -149,8 +148,7 @@ discard block |
||
149 | 148 | throw new RuntimeException('Unexpected return type'); |
150 | 149 | } |
151 | 150 | return (int)$res; |
152 | - } |
|
153 | - catch (Exception $e) { |
|
151 | + } catch (Exception $e) { |
|
154 | 152 | $this->logger->error('PDO error getting user', array('exception' => $e, 'userId' => $userId, 'columnName'=>$columnName)); |
155 | 153 | throw ReadWriteException::fromOriginalException($e); |
156 | 154 | } |
@@ -177,8 +175,7 @@ discard block |
||
177 | 175 | throw new RuntimeException('User not found'); |
178 | 176 | } |
179 | 177 | } |
180 | - } |
|
181 | - catch (Exception $e) { |
|
178 | + } catch (Exception $e) { |
|
182 | 179 | $this->logger->error('PDO error updating user', array('exception' => $e, 'userId' => $userId, 'columnName'=>$columnName)); |
183 | 180 | throw ReadWriteException::fromOriginalException($e); |
184 | 181 | } |
@@ -205,8 +202,7 @@ discard block |
||
205 | 202 | throw new RuntimeException('User not found'); |
206 | 203 | } |
207 | 204 | } |
208 | - } |
|
209 | - catch (Exception $e) { |
|
205 | + } catch (Exception $e) { |
|
210 | 206 | $this->logger->error('PDO error updating user', array('exception' => $e, 'userId' => $userId, 'columnName'=>$columnName)); |
211 | 207 | throw ReadWriteException::fromOriginalException($e); |
212 | 208 | } |
@@ -223,8 +219,7 @@ discard block |
||
223 | 219 | try { |
224 | 220 | $sth = $this->handle->prepare("INSERT INTO ".$this->tablename." (displayname,userid) VALUES (?,?)"); |
225 | 221 | $sth->execute(array($displayName, $userId)); |
226 | - } |
|
227 | - catch (Exception $e) { |
|
222 | + } catch (Exception $e) { |
|
228 | 223 | $this->logger->error(sprintf('Error creating user "%s"', $userId), array('exception'=>$e)); |
229 | 224 | throw new ReadWriteException('The user could not be saved in the user storage (PDO)'); |
230 | 225 | } |
@@ -239,8 +234,7 @@ discard block |
||
239 | 234 | $sth = $this->handle->prepare("SELECT userid FROM ".$this->tablename." WHERE userid = ?"); |
240 | 235 | $sth->execute(array($userId)); |
241 | 236 | return (false !== $sth->fetchColumn()); |
242 | - } |
|
243 | - catch (Exception $e) { |
|
237 | + } catch (Exception $e) { |
|
244 | 238 | $this->logger->error('PDO error checking user exists', array('exception'=>$e, 'userId'=>$userId)); |
245 | 239 | throw ReadWriteException::fromOriginalException($e); |
246 | 240 | } |