22
33namespace Xima \XimaOauth2Extended \UserFactory ;
44
5- use Doctrine \DBAL \DBALException ;
65use Doctrine \DBAL \Driver \Exception ;
76use JetBrains \PhpStorm \ArrayShape ;
87use TYPO3 \CMS \Core \Crypto \PasswordHashing \InvalidPasswordHashException ;
98use TYPO3 \CMS \Core \Crypto \PasswordHashing \PasswordHashFactory ;
9+ use TYPO3 \CMS \Core \Database \Connection ;
1010use TYPO3 \CMS \Core \Database \ConnectionPool ;
1111use TYPO3 \CMS \Core \Database \Query \QueryBuilder ;
1212use TYPO3 \CMS \Core \Database \Query \Restriction \DeletedRestriction ;
@@ -39,19 +39,20 @@ private function updateProfileImage(array &$userRecord): void
3939 $ result = $ qb ->select ('* ' )
4040 ->from ('sys_file_reference ' )
4141 ->where (
42- $ qb ->expr ()->eq ('uid_foreign ' , $ qb ->createNamedParameter ($ userRecord ['uid ' ], \ PDO ::PARAM_INT )),
42+ $ qb ->expr ()->eq ('uid_foreign ' , $ qb ->createNamedParameter ($ userRecord ['uid ' ], Connection ::PARAM_INT )),
4343 $ qb ->expr ()->eq ('tablenames ' , $ qb ->createNamedParameter ('be_users ' )),
4444 $ qb ->expr ()->eq ('fieldname ' , $ qb ->createNamedParameter ('avatar ' ))
4545 )
46- ->execute ()
46+ ->executeQuery ()
4747 ->fetchOne ();
4848 if ($ result ) {
4949 return ;
5050 }
5151
5252 $ imageUtility = new ImageUserFactory (
5353 $ this ->resolver ,
54- $ this ->resolver ->getOptions ()->imageStorageBackendIdentifier
54+ $ this ->resolver ->getOptions ()->imageStorageBackendIdentifier ,
55+ $ this ->logger
5556 );
5657 $ success = $ imageUtility ->addProfileImageForBackendUser ($ userRecord ['uid ' ]);
5758 if ($ success ) {
@@ -82,15 +83,15 @@ private function createUserGroups(): void
8283 $ existingGroupsResult = $ qb ->select ('oauth2_id ' )
8384 ->from ('be_groups ' )
8485 ->where ($ qb ->expr ()->in ('oauth2_id ' , $ qb ->quoteArrayBasedValueListToStringList ($ groupIds )))
85- ->execute ()
86+ ->executeQuery ()
8687 ->fetchAllAssociative ();
8788
8889 $ groupIdsToCreate = array_diff ($ groupIds , array_column ($ existingGroupsResult , 'oauth2_id ' ));
8990 if (!count ($ groupIdsToCreate )) {
9091 return ;
9192 }
9293
93- $ insertValues = array_map (function ($ oauthId ) {
94+ $ insertValues = array_map (static function ($ oauthId ) {
9495 return [time (), time (), $ oauthId , $ oauthId ];
9596 }, $ groupIdsToCreate );
9697
@@ -99,7 +100,7 @@ private function createUserGroups(): void
99100 'be_groups ' ,
100101 $ insertValues ,
101102 ['crdate ' , 'tstamp ' , 'title ' , 'oauth2_id ' ],
102- [\ PDO ::PARAM_INT , \ PDO ::PARAM_INT , \ PDO ::PARAM_STR , \ PDO ::PARAM_STR ]
103+ [Connection ::PARAM_INT , Connection ::PARAM_INT , Connection ::PARAM_STR , Connection ::PARAM_STR ]
103104 );
104105 }
105106
@@ -121,11 +122,11 @@ private function updateUserGroups(array &$typo3User): void
121122 $ qb ->expr ()->in ('g.oauth2_id ' , $ qb ->quoteArrayBasedValueListToStringList ($ groupIds )),
122123 $ qb ->expr ()->and (
123124 $ qb ->expr ()->eq ('g.oauth2_id ' , $ qb ->createNamedParameter ('' )),
124- $ qb ->expr ()->eq ('u.uid ' , $ qb ->createNamedParameter ($ typo3User ['uid ' ], \ PDO ::PARAM_INT ))
125+ $ qb ->expr ()->eq ('u.uid ' , $ qb ->createNamedParameter ($ typo3User ['uid ' ], Connection ::PARAM_INT ))
125126 )
126127 )
127128 )
128- ->execute ()
129+ ->executeQuery ()
129130 ->fetchAllAssociative ();
130131
131132 $ groupIds = array_map (function ($ groupResult ) {
@@ -166,7 +167,7 @@ private function saveUpdatedTypo3User(array $typo3User): void
166167 }
167168 $ qb ->update ('be_users ' )
168169 ->where (
169- $ qb ->expr ()->eq ('uid ' , $ qb ->createNamedParameter ($ typo3User ['uid ' ], \ PDO ::PARAM_INT ))
170+ $ qb ->expr ()->eq ('uid ' , $ qb ->createNamedParameter ($ typo3User ['uid ' ], Connection ::PARAM_INT ))
170171 )
171172 ->executeStatement ();
172173 }
@@ -254,8 +255,8 @@ protected function findUserByUsernameOrEmail(): ?array
254255 $ user = $ qb
255256 ->select ('* ' )
256257 ->from ('be_users ' )
257- ->where ($ qb ->expr ()->orX (...$ constraints ))
258- ->execute ()
258+ ->where ($ qb ->expr ()->or (...$ constraints ))
259+ ->executeQuery ()
259260 ->fetchAssociative ();
260261
261262 return $ user ?: null ;
@@ -273,7 +274,7 @@ protected function checkBackendGroupRestriction(): bool
273274 $ existingGroups = $ qb ->count ('uid ' )
274275 ->from ('be_groups ' )
275276 ->where ($ qb ->expr ()->in ('oauth2_id ' , $ qb ->quoteArrayBasedValueListToStringList ($ groupIds )))
276- ->execute ()
277+ ->executeQuery ()
277278 ->fetchOne ();
278279
279280 return (bool )$ existingGroups ;
@@ -316,33 +317,27 @@ protected function checkBackendGroupRestriction(): bool
316317 }
317318
318319 /**
319- * @throws DBALException
320320 * @throws Exception
321321 */
322322 public function persistAndRetrieveUser ($ userRecord ): ?array
323323 {
324324 $ password = $ userRecord ['password ' ];
325325
326- $ user = $ this ->getQueryBuilder ('be_users ' )->insert ('be_users ' )
326+ $ this ->getQueryBuilder ('be_users ' )->insert ('be_users ' )
327327 ->values ($ userRecord )
328- ->execute ();
329-
330- if (!$ user ) {
331- return null ;
332- }
328+ ->executeStatement ();
333329
334330 $ qb = $ this ->getQueryBuilder ('be_users ' );
335331 return $ qb ->select ('* ' )
336332 ->from ('be_users ' )
337333 ->where (
338334 $ qb ->expr ()->eq ('password ' , $ qb ->createNamedParameter ($ password ))
339335 )
340- ->execute ()
336+ ->executeQuery ()
341337 ->fetchAssociative ();
342338 }
343339
344340 /**
345- * @throws DBALException
346341 * @throws Exception
347342 */
348343 public function persistIdentityForUser (array $ userRecord ): bool
@@ -358,7 +353,7 @@ public function persistIdentityForUser(array $userRecord): bool
358353 'cruser_id ' => (int )$ userRecord ['uid ' ],
359354 'parentid ' => (int )$ userRecord ['uid ' ],
360355 ])
361- ->execute ();
356+ ->executeStatement ();
362357
363358 // get newly created identity
364359 $ qb = $ this ->getQueryBuilder ('tx_oauth2_beuser_provider_configuration ' );
0 commit comments