@@ -91,215 +91,215 @@ |
||
| 91 | 91 | switch ($post_type) { |
| 92 | 92 | //########################################################## |
| 93 | 93 | //CASE for creating a DB backup |
| 94 | -case 'perform_fix_pf_items-step1': |
|
| 95 | - // Check KEY |
|
| 96 | - if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 97 | - echo prepareExchangedData( |
|
| 98 | - array( |
|
| 99 | - 'error' => true, |
|
| 100 | - 'message' => $lang->get('key_is_not_correct'), |
|
| 101 | - ), |
|
| 102 | - 'encode' |
|
| 103 | - ); |
|
| 104 | - break; |
|
| 105 | - } |
|
| 106 | - // Is admin? |
|
| 107 | - if ((int) $session->get('user-admin') !== 1) { |
|
| 108 | - echo prepareExchangedData( |
|
| 109 | - array( |
|
| 110 | - 'error' => true, |
|
| 111 | - 'message' => $lang->get('error_not_allowed_to'), |
|
| 112 | - ), |
|
| 113 | - 'encode' |
|
| 114 | - ); |
|
| 115 | - break; |
|
| 116 | - } |
|
| 94 | + case 'perform_fix_pf_items-step1': |
|
| 95 | + // Check KEY |
|
| 96 | + if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 97 | + echo prepareExchangedData( |
|
| 98 | + array( |
|
| 99 | + 'error' => true, |
|
| 100 | + 'message' => $lang->get('key_is_not_correct'), |
|
| 101 | + ), |
|
| 102 | + 'encode' |
|
| 103 | + ); |
|
| 104 | + break; |
|
| 105 | + } |
|
| 106 | + // Is admin? |
|
| 107 | + if ((int) $session->get('user-admin') !== 1) { |
|
| 108 | + echo prepareExchangedData( |
|
| 109 | + array( |
|
| 110 | + 'error' => true, |
|
| 111 | + 'message' => $lang->get('error_not_allowed_to'), |
|
| 112 | + ), |
|
| 113 | + 'encode' |
|
| 114 | + ); |
|
| 115 | + break; |
|
| 116 | + } |
|
| 117 | 117 | |
| 118 | - // decrypt and retrieve data in JSON format |
|
| 119 | - $dataReceived = prepareExchangedData( |
|
| 120 | - $post_data, |
|
| 121 | - 'decode' |
|
| 122 | - ); |
|
| 118 | + // decrypt and retrieve data in JSON format |
|
| 119 | + $dataReceived = prepareExchangedData( |
|
| 120 | + $post_data, |
|
| 121 | + 'decode' |
|
| 122 | + ); |
|
| 123 | 123 | |
| 124 | - $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 124 | + $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 125 | 125 | |
| 126 | - // Get user info |
|
| 127 | - $userInfo = DB::queryFirstRow( |
|
| 128 | - 'SELECT private_key, public_key, psk, encrypted_psk |
|
| 126 | + // Get user info |
|
| 127 | + $userInfo = DB::queryFirstRow( |
|
| 128 | + 'SELECT private_key, public_key, psk, encrypted_psk |
|
| 129 | 129 | FROM teampass_users |
| 130 | 130 | WHERE id = %i', |
| 131 | - $userId |
|
| 132 | - ); |
|
| 131 | + $userId |
|
| 132 | + ); |
|
| 133 | 133 | |
| 134 | - // Get user's private folders |
|
| 135 | - $userPFRoot = DB::queryFirstRow( |
|
| 136 | - 'SELECT id |
|
| 134 | + // Get user's private folders |
|
| 135 | + $userPFRoot = DB::queryFirstRow( |
|
| 136 | + 'SELECT id |
|
| 137 | 137 | FROM teampass_nested_tree |
| 138 | 138 | WHERE title = %i', |
| 139 | - $userId |
|
| 140 | - ); |
|
| 141 | - if (DB::count() === 0) { |
|
| 142 | - echo prepareExchangedData( |
|
| 143 | - array( |
|
| 144 | - 'error' => true, |
|
| 145 | - 'message' => 'User has no personal folders', |
|
| 146 | - ), |
|
| 147 | - 'encode' |
|
| 148 | - ); |
|
| 149 | - break; |
|
| 150 | - } |
|
| 151 | - $personalFolders = []; |
|
| 152 | - $tree = new NestedTree(prefixTable('nested_tree'), 'id', 'parent_id', 'title'); |
|
| 153 | - $tree->rebuild(); |
|
| 154 | - $folders = $tree->getDescendants($userPFRoot['id'], true); |
|
| 155 | - foreach ($folders as $folder) { |
|
| 156 | - array_push($personalFolders, $folder->id); |
|
| 157 | - } |
|
| 158 | - |
|
| 159 | - //Show done |
|
| 160 | - echo prepareExchangedData( |
|
| 161 | - array( |
|
| 162 | - 'error' => false, |
|
| 163 | - 'message' => 'Personal Folders found: ', |
|
| 164 | - 'personalFolders' => json_encode($personalFolders), |
|
| 165 | - ), |
|
| 166 | - 'encode' |
|
| 167 | - ); |
|
| 168 | - break; |
|
| 169 | - |
|
| 170 | -case 'perform_fix_pf_items-step2': |
|
| 171 | - // Check KEY |
|
| 172 | - if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 173 | - echo prepareExchangedData( |
|
| 174 | - array( |
|
| 175 | - 'error' => true, |
|
| 176 | - 'message' => $lang->get('key_is_not_correct'), |
|
| 177 | - ), |
|
| 178 | - 'encode' |
|
| 139 | + $userId |
|
| 179 | 140 | ); |
| 180 | - break; |
|
| 181 | - } |
|
| 182 | - // Is admin? |
|
| 183 | - if ((int) $session->get('user-admin') !== 1) { |
|
| 141 | + if (DB::count() === 0) { |
|
| 142 | + echo prepareExchangedData( |
|
| 143 | + array( |
|
| 144 | + 'error' => true, |
|
| 145 | + 'message' => 'User has no personal folders', |
|
| 146 | + ), |
|
| 147 | + 'encode' |
|
| 148 | + ); |
|
| 149 | + break; |
|
| 150 | + } |
|
| 151 | + $personalFolders = []; |
|
| 152 | + $tree = new NestedTree(prefixTable('nested_tree'), 'id', 'parent_id', 'title'); |
|
| 153 | + $tree->rebuild(); |
|
| 154 | + $folders = $tree->getDescendants($userPFRoot['id'], true); |
|
| 155 | + foreach ($folders as $folder) { |
|
| 156 | + array_push($personalFolders, $folder->id); |
|
| 157 | + } |
|
| 158 | + |
|
| 159 | + //Show done |
|
| 184 | 160 | echo prepareExchangedData( |
| 185 | 161 | array( |
| 186 | - 'error' => true, |
|
| 187 | - 'message' => $lang->get('error_not_allowed_to'), |
|
| 162 | + 'error' => false, |
|
| 163 | + 'message' => 'Personal Folders found: ', |
|
| 164 | + 'personalFolders' => json_encode($personalFolders), |
|
| 188 | 165 | ), |
| 189 | 166 | 'encode' |
| 190 | 167 | ); |
| 191 | 168 | break; |
| 192 | - } |
|
| 193 | 169 | |
| 194 | - // decrypt and retrieve data in JSON format |
|
| 195 | - $dataReceived = prepareExchangedData( |
|
| 196 | - $post_data, |
|
| 197 | - 'decode' |
|
| 198 | - ); |
|
| 170 | + case 'perform_fix_pf_items-step2': |
|
| 171 | + // Check KEY |
|
| 172 | + if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 173 | + echo prepareExchangedData( |
|
| 174 | + array( |
|
| 175 | + 'error' => true, |
|
| 176 | + 'message' => $lang->get('key_is_not_correct'), |
|
| 177 | + ), |
|
| 178 | + 'encode' |
|
| 179 | + ); |
|
| 180 | + break; |
|
| 181 | + } |
|
| 182 | + // Is admin? |
|
| 183 | + if ((int) $session->get('user-admin') !== 1) { |
|
| 184 | + echo prepareExchangedData( |
|
| 185 | + array( |
|
| 186 | + 'error' => true, |
|
| 187 | + 'message' => $lang->get('error_not_allowed_to'), |
|
| 188 | + ), |
|
| 189 | + 'encode' |
|
| 190 | + ); |
|
| 191 | + break; |
|
| 192 | + } |
|
| 199 | 193 | |
| 200 | - $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 201 | - $personalFolders = filter_var($dataReceived['personalFolders'], FILTER_SANITIZE_FULL_SPECIAL_CHARS); |
|
| 194 | + // decrypt and retrieve data in JSON format |
|
| 195 | + $dataReceived = prepareExchangedData( |
|
| 196 | + $post_data, |
|
| 197 | + 'decode' |
|
| 198 | + ); |
|
| 199 | + |
|
| 200 | + $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 201 | + $personalFolders = filter_var($dataReceived['personalFolders'], FILTER_SANITIZE_FULL_SPECIAL_CHARS); |
|
| 202 | 202 | |
| 203 | - // Delete all private items with sharekeys |
|
| 204 | - $pfiSharekeys = DB::queryFirstColumn( |
|
| 205 | - 'select s.increment_id |
|
| 203 | + // Delete all private items with sharekeys |
|
| 204 | + $pfiSharekeys = DB::queryFirstColumn( |
|
| 205 | + 'select s.increment_id |
|
| 206 | 206 | from teampass_sharekeys_items as s |
| 207 | 207 | INNER JOIN teampass_items AS i ON (i.id = s.object_id) |
| 208 | 208 | WHERE s.user_id = %i AND i.perso = 1 AND i.id_tree IN %ls', |
| 209 | - $userId, |
|
| 210 | - $personalFolders |
|
| 211 | - ); |
|
| 212 | - $pfiSharekeysCount = DB::count(); |
|
| 213 | - if ($pfiSharekeysCount > 0) { |
|
| 214 | - DB::delete( |
|
| 215 | - "teampass_sharekeys_items", |
|
| 216 | - "increment_id IN %ls", |
|
| 217 | - $pfiSharekeys |
|
| 209 | + $userId, |
|
| 210 | + $personalFolders |
|
| 218 | 211 | ); |
| 219 | - } |
|
| 212 | + $pfiSharekeysCount = DB::count(); |
|
| 213 | + if ($pfiSharekeysCount > 0) { |
|
| 214 | + DB::delete( |
|
| 215 | + "teampass_sharekeys_items", |
|
| 216 | + "increment_id IN %ls", |
|
| 217 | + $pfiSharekeys |
|
| 218 | + ); |
|
| 219 | + } |
|
| 220 | 220 | |
| 221 | 221 | |
| 222 | - //Show done |
|
| 223 | - echo prepareExchangedData( |
|
| 224 | - array( |
|
| 225 | - 'error' => false, |
|
| 226 | - 'message' => '<br>Number of Sharekeys for private items DELETED: ', |
|
| 227 | - 'nbDeleted' => $pfiSharekeysCount, |
|
| 228 | - 'personalFolders' => json_encode($personalFolders), |
|
| 229 | - ), |
|
| 230 | - 'encode' |
|
| 231 | - ); |
|
| 232 | - break; |
|
| 233 | - |
|
| 234 | -case 'perform_fix_pf_items-step3': |
|
| 235 | - // Check KEY |
|
| 236 | - if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 237 | - echo prepareExchangedData( |
|
| 238 | - array( |
|
| 239 | - 'error' => true, |
|
| 240 | - 'message' => $lang->get('key_is_not_correct'), |
|
| 241 | - ), |
|
| 242 | - 'encode' |
|
| 243 | - ); |
|
| 244 | - break; |
|
| 245 | - } |
|
| 246 | - // Is admin? |
|
| 247 | - if ((int) $session->get('user-admin') !== 1) { |
|
| 222 | + //Show done |
|
| 248 | 223 | echo prepareExchangedData( |
| 249 | 224 | array( |
| 250 | - 'error' => true, |
|
| 251 | - 'message' => $lang->get('error_not_allowed_to'), |
|
| 225 | + 'error' => false, |
|
| 226 | + 'message' => '<br>Number of Sharekeys for private items DELETED: ', |
|
| 227 | + 'nbDeleted' => $pfiSharekeysCount, |
|
| 228 | + 'personalFolders' => json_encode($personalFolders), |
|
| 252 | 229 | ), |
| 253 | 230 | 'encode' |
| 254 | 231 | ); |
| 255 | 232 | break; |
| 256 | - } |
|
| 257 | 233 | |
| 258 | - // decrypt and retrieve data in JSON format |
|
| 259 | - $dataReceived = prepareExchangedData( |
|
| 260 | - $post_data, |
|
| 261 | - 'decode' |
|
| 262 | - ); |
|
| 234 | + case 'perform_fix_pf_items-step3': |
|
| 235 | + // Check KEY |
|
| 236 | + if (!hash_equals((string) $session->get('key'), (string) $post_key)) { |
|
| 237 | + echo prepareExchangedData( |
|
| 238 | + array( |
|
| 239 | + 'error' => true, |
|
| 240 | + 'message' => $lang->get('key_is_not_correct'), |
|
| 241 | + ), |
|
| 242 | + 'encode' |
|
| 243 | + ); |
|
| 244 | + break; |
|
| 245 | + } |
|
| 246 | + // Is admin? |
|
| 247 | + if ((int) $session->get('user-admin') !== 1) { |
|
| 248 | + echo prepareExchangedData( |
|
| 249 | + array( |
|
| 250 | + 'error' => true, |
|
| 251 | + 'message' => $lang->get('error_not_allowed_to'), |
|
| 252 | + ), |
|
| 253 | + 'encode' |
|
| 254 | + ); |
|
| 255 | + break; |
|
| 256 | + } |
|
| 257 | + |
|
| 258 | + // decrypt and retrieve data in JSON format |
|
| 259 | + $dataReceived = prepareExchangedData( |
|
| 260 | + $post_data, |
|
| 261 | + 'decode' |
|
| 262 | + ); |
|
| 263 | 263 | |
| 264 | - $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 265 | - $personalFolders = filter_var($dataReceived['personalFolders'], FILTER_SANITIZE_FULL_SPECIAL_CHARS); |
|
| 264 | + $userId = filter_var($dataReceived['userId'], FILTER_SANITIZE_NUMBER_INT); |
|
| 265 | + $personalFolders = filter_var($dataReceived['personalFolders'], FILTER_SANITIZE_FULL_SPECIAL_CHARS); |
|
| 266 | 266 | |
| 267 | - // Update from items_old to items all the private itemsitems that have been converted to teampass_aes |
|
| 268 | - // Get all key back |
|
| 269 | - $items = DB::query( |
|
| 270 | - "SELECT id |
|
| 267 | + // Update from items_old to items all the private itemsitems that have been converted to teampass_aes |
|
| 268 | + // Get all key back |
|
| 269 | + $items = DB::query( |
|
| 270 | + "SELECT id |
|
| 271 | 271 | FROM teampass_items |
| 272 | 272 | WHERE id_tree IN %ls AND encryption_type = %s", |
| 273 | - $personalFolders, |
|
| 274 | - "teampass_aes" |
|
| 275 | - ); |
|
| 276 | - //DB::debugMode(false); |
|
| 277 | - $nbItems = DB::count(); |
|
| 278 | - foreach ($items as $item) { |
|
| 279 | - $defusePwd = DB::queryFirstField("SELECT pw FROM teampass_items_old WHERE id = %i", $item['id']); |
|
| 280 | - DB::update( |
|
| 281 | - "teampass_items", |
|
| 282 | - ['pw' => $defusePwd, "encryption_type" => "defuse"], |
|
| 283 | - "id = %i", |
|
| 284 | - $item['id'] |
|
| 273 | + $personalFolders, |
|
| 274 | + "teampass_aes" |
|
| 285 | 275 | ); |
| 286 | - } |
|
| 276 | + //DB::debugMode(false); |
|
| 277 | + $nbItems = DB::count(); |
|
| 278 | + foreach ($items as $item) { |
|
| 279 | + $defusePwd = DB::queryFirstField("SELECT pw FROM teampass_items_old WHERE id = %i", $item['id']); |
|
| 280 | + DB::update( |
|
| 281 | + "teampass_items", |
|
| 282 | + ['pw' => $defusePwd, "encryption_type" => "defuse"], |
|
| 283 | + "id = %i", |
|
| 284 | + $item['id'] |
|
| 285 | + ); |
|
| 286 | + } |
|
| 287 | 287 | |
| 288 | 288 | |
| 289 | - //Show done |
|
| 290 | - echo prepareExchangedData( |
|
| 291 | - array( |
|
| 292 | - 'error' => false, |
|
| 293 | - 'message' => '<br>Number of items reseted to Defuse: ', |
|
| 294 | - 'nbItems' => $nbItems, |
|
| 295 | - 'personalFolders' => json_encode($personalFolders), |
|
| 296 | - ), |
|
| 297 | - 'encode' |
|
| 298 | - ); |
|
| 299 | - break; |
|
| 300 | - |
|
| 301 | - /* TOOL #2 - Fixing items master keys */ |
|
| 302 | - /* |
|
| 289 | + //Show done |
|
| 290 | + echo prepareExchangedData( |
|
| 291 | + array( |
|
| 292 | + 'error' => false, |
|
| 293 | + 'message' => '<br>Number of items reseted to Defuse: ', |
|
| 294 | + 'nbItems' => $nbItems, |
|
| 295 | + 'personalFolders' => json_encode($personalFolders), |
|
| 296 | + ), |
|
| 297 | + 'encode' |
|
| 298 | + ); |
|
| 299 | + break; |
|
| 300 | + |
|
| 301 | + /* TOOL #2 - Fixing items master keys */ |
|
| 302 | + /* |
|
| 303 | 303 | * STEP 1 - Check if we have the correct pwd for TP_USER |
| 304 | 304 | */ |
| 305 | 305 | case 'perform_fix_items_master_keys-step1': |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | if ($checkUserAccess->checkSession() === false || $checkUserAccess->userAccessPage('tools') === false) { |
| 71 | 71 | // Not allowed page |
| 72 | 72 | $session->set('system-error_code', ERR_NOT_ALLOWED); |
| 73 | - include $SETTINGS['cpassman_dir'] . '/error.php'; |
|
| 73 | + include $SETTINGS['cpassman_dir'].'/error.php'; |
|
| 74 | 74 | exit; |
| 75 | 75 | } |
| 76 | 76 | |
@@ -335,7 +335,7 @@ discard block |
||
| 335 | 335 | // Get PT_USER info |
| 336 | 336 | $userInfo = DB::queryFirstRow( |
| 337 | 337 | 'SELECT pw, public_key, private_key, login, name |
| 338 | - FROM ' . prefixTable('users') . ' |
|
| 338 | + FROM ' . prefixTable('users').' |
|
| 339 | 339 | WHERE id = %i', |
| 340 | 340 | TP_USER_ID |
| 341 | 341 | ); |
@@ -372,8 +372,8 @@ discard block |
||
| 372 | 372 | // Get one itemKey from current user |
| 373 | 373 | $currentUserKey = DB::queryFirstRow( |
| 374 | 374 | 'SELECT ski.share_key, ski.increment_id AS increment_id, l.id_user |
| 375 | - FROM ' . prefixTable('sharekeys_items') . ' AS ski |
|
| 376 | - INNER JOIN ' . prefixTable('log_items') . ' AS l ON ski.object_id = l.id_item |
|
| 375 | + FROM ' . prefixTable('sharekeys_items').' AS ski |
|
| 376 | + INNER JOIN ' . prefixTable('log_items').' AS l ON ski.object_id = l.id_item |
|
| 377 | 377 | WHERE ski.user_id = %i |
| 378 | 378 | ORDER BY RAND() |
| 379 | 379 | LIMIT 1', |
@@ -392,7 +392,7 @@ discard block |
||
| 392 | 392 | echo prepareExchangedData( |
| 393 | 393 | array( |
| 394 | 394 | 'error' => true, |
| 395 | - 'message' => 'No issue found, normal process should work. This process is now finished. (item id : ' . $currentUserKey['increment_id'] . ')', |
|
| 395 | + 'message' => 'No issue found, normal process should work. This process is now finished. (item id : '.$currentUserKey['increment_id'].')', |
|
| 396 | 396 | ), |
| 397 | 397 | 'encode' |
| 398 | 398 | ); |
@@ -452,7 +452,7 @@ discard block |
||
| 452 | 452 | // Get user info |
| 453 | 453 | $userInfo = DB::queryFirstRow( |
| 454 | 454 | 'SELECT public_key, private_key |
| 455 | - FROM ' . prefixTable('users') . ' |
|
| 455 | + FROM ' . prefixTable('users').' |
|
| 456 | 456 | WHERE id = %i', |
| 457 | 457 | $userId |
| 458 | 458 | ); |
@@ -475,8 +475,8 @@ discard block |
||
| 475 | 475 | // Get one itemKey from current user |
| 476 | 476 | $currentUserKey = DB::queryFirstRow( |
| 477 | 477 | 'SELECT ski.share_key, ski.increment_id AS increment_id, l.id_user |
| 478 | - FROM ' . prefixTable('sharekeys_items') . ' AS ski |
|
| 479 | - INNER JOIN ' . prefixTable('log_items') . ' AS l ON ski.object_id = l.id_item |
|
| 478 | + FROM ' . prefixTable('sharekeys_items').' AS ski |
|
| 479 | + INNER JOIN ' . prefixTable('log_items').' AS l ON ski.object_id = l.id_item |
|
| 480 | 480 | WHERE ski.user_id = %i |
| 481 | 481 | ORDER BY RAND() |
| 482 | 482 | LIMIT 1', |
@@ -514,8 +514,8 @@ discard block |
||
| 514 | 514 | // Get number of users to treat |
| 515 | 515 | DB::query( |
| 516 | 516 | 'SELECT i.id |
| 517 | - FROM ' . prefixTable('items') . ' AS i |
|
| 518 | - INNER JOIN ' . prefixTable('sharekeys_items') . ' AS si ON i.id = si.object_id |
|
| 517 | + FROM ' . prefixTable('items').' AS i |
|
| 518 | + INNER JOIN ' . prefixTable('sharekeys_items').' AS si ON i.id = si.object_id |
|
| 519 | 519 | WHERE i.perso = %i AND si.user_id = %i;', |
| 520 | 520 | 0, |
| 521 | 521 | $userId |
@@ -597,11 +597,11 @@ discard block |
||
| 597 | 597 | // Loop on items |
| 598 | 598 | $rows = DB::query( |
| 599 | 599 | 'SELECT si.object_id AS object_id, si.share_key AS share_key, i.pw AS pw, si.increment_id as increment_id |
| 600 | - FROM ' . prefixTable('sharekeys_items') . ' AS si |
|
| 601 | - INNER JOIN ' . prefixTable('items') . ' AS i ON (i.id = si.object_id) |
|
| 600 | + FROM ' . prefixTable('sharekeys_items').' AS si |
|
| 601 | + INNER JOIN ' . prefixTable('items').' AS i ON (i.id = si.object_id) |
|
| 602 | 602 | WHERE si.user_id = %i |
| 603 | 603 | ORDER BY si.increment_id ASC |
| 604 | - LIMIT ' . $startIndex . ', ' . $limit, |
|
| 604 | + LIMIT ' . $startIndex.', '.$limit, |
|
| 605 | 605 | $userId |
| 606 | 606 | ); |
| 607 | 607 | |
@@ -625,7 +625,7 @@ discard block |
||
| 625 | 625 | // It will be updated if already exists |
| 626 | 626 | $currentTPUserKey = DB::queryFirstRow( |
| 627 | 627 | 'SELECT increment_id, user_id, share_key |
| 628 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 628 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 629 | 629 | WHERE object_id = %i AND user_id = %i', |
| 630 | 630 | $record['object_id'], |
| 631 | 631 | TP_USER_ID |
@@ -661,7 +661,7 @@ discard block |
||
| 661 | 661 | DB::commit(); |
| 662 | 662 | } catch (Exception $e) { |
| 663 | 663 | DB::rollback(); |
| 664 | - error_log("Teampass - Error: Keys treatment: " . $e->getMessage()); |
|
| 664 | + error_log("Teampass - Error: Keys treatment: ".$e->getMessage()); |
|
| 665 | 665 | } |
| 666 | 666 | |
| 667 | 667 | $nextIndex = (int) $startIndex + (int) $limit; |
@@ -717,7 +717,7 @@ discard block |
||
| 717 | 717 | // Get PT_USER info |
| 718 | 718 | DB::queryFirstRow( |
| 719 | 719 | 'SELECT operation_code |
| 720 | - FROM ' . prefixTable('sharekeys_backup') . ' |
|
| 720 | + FROM ' . prefixTable('sharekeys_backup').' |
|
| 721 | 721 | WHERE operation_code = %s', |
| 722 | 722 | $operationCode |
| 723 | 723 | ); |
@@ -727,7 +727,7 @@ discard block |
||
| 727 | 727 | // using increment_id_value in order to update the correct record |
| 728 | 728 | $rows = DB::query( |
| 729 | 729 | 'SELECT * |
| 730 | - FROM ' . prefixTable('sharekeys_backup') . ' |
|
| 730 | + FROM ' . prefixTable('sharekeys_backup').' |
|
| 731 | 731 | WHERE operation_code = %s', |
| 732 | 732 | $operationCode |
| 733 | 733 | ); |
@@ -746,7 +746,7 @@ discard block |
||
| 746 | 746 | |
| 747 | 747 | // Delete all sharekeys for this operation |
| 748 | 748 | DB::query( |
| 749 | - 'DELETE FROM ' . prefixTable('sharekeys_backup') . ' |
|
| 749 | + 'DELETE FROM '.prefixTable('sharekeys_backup').' |
|
| 750 | 750 | WHERE operation_code = %i', |
| 751 | 751 | $operationCode |
| 752 | 752 | ); |
@@ -809,7 +809,7 @@ discard block |
||
| 809 | 809 | // Get operation info |
| 810 | 810 | DB::query( |
| 811 | 811 | 'SELECT operation_code |
| 812 | - FROM ' . prefixTable('sharekeys_backup') . ' |
|
| 812 | + FROM ' . prefixTable('sharekeys_backup').' |
|
| 813 | 813 | WHERE operation_code = %s', |
| 814 | 814 | $operationCode |
| 815 | 815 | ); |
@@ -818,7 +818,7 @@ discard block |
||
| 818 | 818 | if ($nbKeys > 0) { |
| 819 | 819 | // Delete all sharekeys for this operation |
| 820 | 820 | DB::query( |
| 821 | - 'DELETE FROM ' . prefixTable('sharekeys_backup') . ' |
|
| 821 | + 'DELETE FROM '.prefixTable('sharekeys_backup').' |
|
| 822 | 822 | WHERE operation_code = %s', |
| 823 | 823 | $operationCode |
| 824 | 824 | ); |
@@ -75,7 +75,7 @@ discard block |
||
| 75 | 75 | ) { |
| 76 | 76 | // Not allowed page |
| 77 | 77 | $session->set('system-error_code', ERR_NOT_ALLOWED); |
| 78 | - include $SETTINGS['cpassman_dir'] . '/error.php'; |
|
| 78 | + include $SETTINGS['cpassman_dir'].'/error.php'; |
|
| 79 | 79 | exit; |
| 80 | 80 | } |
| 81 | 81 | |
@@ -145,7 +145,7 @@ discard block |
||
| 145 | 145 | if (isset($order['column']) && preg_match('#^(asc|desc)$#i', $order['dir'])) { |
| 146 | 146 | $columnIndex = $order['column']; |
| 147 | 147 | $dir = $inputData['dir']; |
| 148 | - $sOrder .= $aColumns[$columnIndex] . ' ' . $dir . ', '; |
|
| 148 | + $sOrder .= $aColumns[$columnIndex].' '.$dir.', '; |
|
| 149 | 149 | } |
| 150 | 150 | |
| 151 | 151 | $sOrder = substr_replace($sOrder, '', -2); |
@@ -113,7 +113,7 @@ |
||
| 113 | 113 | private function isParentFolderAllowed($parent_id, $user_accessible_folders, $user_is_admin, $user_can_create_root_folder) |
| 114 | 114 | { |
| 115 | 115 | if ($parent_id == 0 && $user_can_create_root_folder == true) |
| 116 | - return true; |
|
| 116 | + return true; |
|
| 117 | 117 | |
| 118 | 118 | if (in_array($parent_id, $user_accessible_folders) === false |
| 119 | 119 | && (int) $user_is_admin !== 1 |
@@ -112,8 +112,9 @@ discard block |
||
| 112 | 112 | */ |
| 113 | 113 | private function isParentFolderAllowed($parent_id, $user_accessible_folders, $user_is_admin, $user_can_create_root_folder) |
| 114 | 114 | { |
| 115 | - if ($parent_id == 0 && $user_can_create_root_folder == true) |
|
| 116 | - return true; |
|
| 115 | + if ($parent_id == 0 && $user_can_create_root_folder == true) { |
|
| 116 | + return true; |
|
| 117 | + } |
|
| 117 | 118 | |
| 118 | 119 | if (in_array($parent_id, $user_accessible_folders) === false |
| 119 | 120 | && (int) $user_is_admin !== 1 |
@@ -438,8 +439,9 @@ discard block |
||
| 438 | 439 | )['count']; |
| 439 | 440 | |
| 440 | 441 | // Don't insert duplicates |
| 441 | - if ($count > 0) |
|
| 442 | - continue; |
|
| 442 | + if ($count > 0) { |
|
| 443 | + continue; |
|
| 444 | + } |
|
| 443 | 445 | |
| 444 | 446 | // Insert new background task |
| 445 | 447 | DB::insert( |
@@ -91,7 +91,7 @@ discard block |
||
| 91 | 91 | |
| 92 | 92 | $parentComplexity = $this->checkComplexityLevel($parentFolderData, $complexity, $parent_id); |
| 93 | 93 | if (isset($parentComplexity['error']) && $parentComplexity['error'] === true) { |
| 94 | - return $this->errorResponse($this->lang->get('error_folder_complexity_lower_than_top_folder') . " [<b>{$this->settings['TP_PW_COMPLEXITY'][$parentComplexity['valeur']][1]}</b>]"); |
|
| 94 | + return $this->errorResponse($this->lang->get('error_folder_complexity_lower_than_top_folder')." [<b>{$this->settings['TP_PW_COMPLEXITY'][$parentComplexity['valeur']][1]}</b>]"); |
|
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | return $this->createFolder($params, array_merge($parentFolderData, $parentComplexity), $options); |
@@ -144,7 +144,7 @@ discard block |
||
| 144 | 144 | ) { |
| 145 | 145 | DB::query( |
| 146 | 146 | 'SELECT * |
| 147 | - FROM ' . prefixTable('nested_tree') . ' |
|
| 147 | + FROM ' . prefixTable('nested_tree').' |
|
| 148 | 148 | WHERE title = %s AND personal_folder = 0', |
| 149 | 149 | $title |
| 150 | 150 | ); |
@@ -168,7 +168,7 @@ discard block |
||
| 168 | 168 | //check if parent folder is personal |
| 169 | 169 | $data = DB::queryFirstRow( |
| 170 | 170 | 'SELECT personal_folder, bloquer_creation, bloquer_modification |
| 171 | - FROM ' . prefixTable('nested_tree') . ' |
|
| 171 | + FROM ' . prefixTable('nested_tree').' |
|
| 172 | 172 | WHERE id = %i', |
| 173 | 173 | $parent_id |
| 174 | 174 | ); |
@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | // get complexity level for this folder |
| 208 | 208 | $data = DB::queryFirstRow( |
| 209 | 209 | 'SELECT valeur |
| 210 | - FROM ' . prefixTable('misc') . ' |
|
| 210 | + FROM ' . prefixTable('misc').' |
|
| 211 | 211 | WHERE intitule = %i AND type = %s', |
| 212 | 212 | $parent_id, |
| 213 | 213 | 'complex' |
@@ -278,11 +278,11 @@ discard block |
||
| 278 | 278 | */ |
| 279 | 279 | private function canCreateFolder($isPersonal, $user_is_admin, $user_is_manager, $user_can_manage_all_users, $user_can_create_root_folder) |
| 280 | 280 | { |
| 281 | - return (int)$isPersonal === 1 || |
|
| 282 | - (int)$user_is_admin === 1 || |
|
| 283 | - ((int)$user_is_manager === 1 || (int)$user_can_manage_all_users === 1) || |
|
| 281 | + return (int) $isPersonal === 1 || |
|
| 282 | + (int) $user_is_admin === 1 || |
|
| 283 | + ((int) $user_is_manager === 1 || (int) $user_can_manage_all_users === 1) || |
|
| 284 | 284 | ($this->settings['enable_user_can_create_folders'] ?? false) || |
| 285 | - ((int)$user_can_create_root_folder === 1); |
|
| 285 | + ((int) $user_can_create_root_folder === 1); |
|
| 286 | 286 | } |
| 287 | 287 | |
| 288 | 288 | /** |
@@ -362,7 +362,7 @@ discard block |
||
| 362 | 362 | $path = ''; |
| 363 | 363 | $tree_path = $tree->getPath(0, false); |
| 364 | 364 | foreach ($tree_path as $fld) { |
| 365 | - $path .= empty($path) ? $fld->title : '/' . $fld->title; |
|
| 365 | + $path .= empty($path) ? $fld->title : '/'.$fld->title; |
|
| 366 | 366 | } |
| 367 | 367 | |
| 368 | 368 | $new_json = [ |
@@ -376,7 +376,7 @@ discard block |
||
| 376 | 376 | "is_visible_active" => 0, |
| 377 | 377 | ]; |
| 378 | 378 | |
| 379 | - $cache_tree = DB::queryFirstRow('SELECT increment_id, folders, visible_folders FROM ' . prefixTable('cache_tree') . ' WHERE user_id = %i', (int)$user_id); |
|
| 379 | + $cache_tree = DB::queryFirstRow('SELECT increment_id, folders, visible_folders FROM '.prefixTable('cache_tree').' WHERE user_id = %i', (int) $user_id); |
|
| 380 | 380 | |
| 381 | 381 | if (empty($cache_tree)) { |
| 382 | 382 | DB::insert(prefixTable('cache_tree'), [ |
@@ -396,7 +396,7 @@ discard block |
||
| 396 | 396 | 'folders' => json_encode($folders), |
| 397 | 397 | 'visible_folders' => json_encode($visible_folders), |
| 398 | 398 | 'timestamp' => time(), |
| 399 | - ], 'increment_id = %i', (int)$cache_tree['increment_id']); |
|
| 399 | + ], 'increment_id = %i', (int) $cache_tree['increment_id']); |
|
| 400 | 400 | } |
| 401 | 401 | } |
| 402 | 402 | |
@@ -406,7 +406,7 @@ discard block |
||
| 406 | 406 | private function manageFolderPermissions($parent_id, $newId, $user_roles, $access_rights, $user_is_admin) |
| 407 | 407 | { |
| 408 | 408 | if ($parent_id !== 0 && $this->settings['subfolder_rights_as_parent'] ?? false) { |
| 409 | - $rows = DB::query('SELECT role_id, type FROM ' . prefixTable('roles_values') . ' WHERE folder_id = %i', $parent_id); |
|
| 409 | + $rows = DB::query('SELECT role_id, type FROM '.prefixTable('roles_values').' WHERE folder_id = %i', $parent_id); |
|
| 410 | 410 | foreach ($rows as $record) { |
| 411 | 411 | DB::insert(prefixTable('roles_values'), [ |
| 412 | 412 | 'role_id' => $record['role_id'], |
@@ -414,7 +414,7 @@ discard block |
||
| 414 | 414 | 'type' => $record['type'], |
| 415 | 415 | ]); |
| 416 | 416 | } |
| 417 | - } elseif ((int)$user_is_admin !== 1) { |
|
| 417 | + } elseif ((int) $user_is_admin !== 1) { |
|
| 418 | 418 | foreach (array_unique(explode(';', $user_roles)) as $role) { |
| 419 | 419 | if (!empty($role)) { |
| 420 | 420 | DB::insert(prefixTable('roles_values'), [ |
@@ -432,7 +432,7 @@ discard block |
||
| 432 | 432 | */ |
| 433 | 433 | private function copyCustomFieldsCategories($parent_id, $newId) |
| 434 | 434 | { |
| 435 | - $rows = DB::query('SELECT id_category FROM ' . prefixTable('categories_folders') . ' WHERE id_folder = %i', $parent_id); |
|
| 435 | + $rows = DB::query('SELECT id_category FROM '.prefixTable('categories_folders').' WHERE id_folder = %i', $parent_id); |
|
| 436 | 436 | foreach ($rows as $record) { |
| 437 | 437 | DB::insert(prefixTable('categories_folders'), [ |
| 438 | 438 | 'id_category' => $record['id_category'], |
@@ -457,7 +457,7 @@ discard block |
||
| 457 | 457 | // Search for existing job |
| 458 | 458 | $count = DB::queryFirstRow( |
| 459 | 459 | 'SELECT COUNT(*) AS count |
| 460 | - FROM ' . prefixTable('background_tasks') . ' |
|
| 460 | + FROM ' . prefixTable('background_tasks').' |
|
| 461 | 461 | WHERE is_in_progress = %i AND process_type = %s AND arguments = %s', |
| 462 | 462 | 0, |
| 463 | 463 | 'user_build_cache_tree', |
@@ -491,7 +491,7 @@ discard block |
||
| 491 | 491 | return [ |
| 492 | 492 | 'error' => true, |
| 493 | 493 | 'message' => $message, |
| 494 | - 'newId' => '' . $newIdSuffix, |
|
| 494 | + 'newId' => ''.$newIdSuffix, |
|
| 495 | 495 | ]; |
| 496 | 496 | } |
| 497 | 497 | } |
@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | || isset($SETTINGS['allow_import']) === false || (int) $SETTINGS['allow_import'] !== 1) { |
| 72 | 72 | // Not allowed page |
| 73 | 73 | $session->set('system-error_code', ERR_NOT_ALLOWED); |
| 74 | - include $SETTINGS['cpassman_dir'] . '/error.php'; |
|
| 74 | + include $SETTINGS['cpassman_dir'].'/error.php'; |
|
| 75 | 75 | exit; |
| 76 | 76 | } |
| 77 | 77 | |
@@ -183,7 +183,7 @@ discard block |
||
| 183 | 183 | <?php |
| 184 | 184 | $complexitySelect = ''; |
| 185 | 185 | foreach (TP_PW_COMPLEXITY as $level) { |
| 186 | - $complexitySelect .= '<option value="' . $level[0] . '">' . $level[1] . '</option>'; |
|
| 186 | + $complexitySelect .= '<option value="'.$level[0].'">'.$level[1].'</option>'; |
|
| 187 | 187 | } |
| 188 | 188 | echo $complexitySelect; |
| 189 | 189 | ?> |
@@ -72,7 +72,7 @@ discard block |
||
| 72 | 72 | if ($checkUserAccess->checkSession() === false || $checkUserAccess->userAccessPage('import') === false) { |
| 73 | 73 | // Not allowed page |
| 74 | 74 | $session->set('system-error_code', ERR_NOT_ALLOWED); |
| 75 | - include $SETTINGS['cpassman_dir'] . '/error.php'; |
|
| 75 | + include $SETTINGS['cpassman_dir'].'/error.php'; |
|
| 76 | 76 | exit; |
| 77 | 77 | } |
| 78 | 78 | ?> |
@@ -1043,7 +1043,7 @@ discard block |
||
| 1043 | 1043 | // Isolate first item |
| 1044 | 1044 | if (itemsList.length > 0) { |
| 1045 | 1045 | $('#import-feedback-progress-text') |
| 1046 | - .html('<i class="fa-solid fa-cog fa-spin ml-4 mr-2"></i><?php echo $lang->get('operation_progress');?> ('+((counter*100)/itemsNumber).toFixed(2)+'%) - <i id="item-title"></i>'); |
|
| 1046 | + .html('<i class="fa-solid fa-cog fa-spin ml-4 mr-2"></i><?php echo $lang->get('operation_progress'); ?> ('+((counter*100)/itemsNumber).toFixed(2)+'%) - <i id="item-title"></i>'); |
|
| 1047 | 1047 | |
| 1048 | 1048 | // XSS Filtering : |
| 1049 | 1049 | $('#import-feedback-progress-text').text(itemsList[0].Title); |
@@ -1364,4 +1364,4 @@ |
||
| 1364 | 1364 | $string = str_replace("{%}", "?", $string); |
| 1365 | 1365 | // Trim and return. |
| 1366 | 1366 | return trim($string); |
| 1367 | - } |
|
| 1367 | + } |
|
@@ -79,7 +79,7 @@ discard block |
||
| 79 | 79 | ) { |
| 80 | 80 | // Not allowed page |
| 81 | 81 | $session->set('system-error_code', ERR_NOT_ALLOWED); |
| 82 | - include $SETTINGS['cpassman_dir'] . '/error.php'; |
|
| 82 | + include $SETTINGS['cpassman_dir'].'/error.php'; |
|
| 83 | 83 | exit; |
| 84 | 84 | } |
| 85 | 85 | |
@@ -167,7 +167,7 @@ discard block |
||
| 167 | 167 | ); |
| 168 | 168 | |
| 169 | 169 | // Initialisation |
| 170 | - $file = $SETTINGS['path_to_files_folder'] . '/' . $data['valeur']; |
|
| 170 | + $file = $SETTINGS['path_to_files_folder'].'/'.$data['valeur']; |
|
| 171 | 171 | $importation_possible = true; |
| 172 | 172 | $valuesToImport = []; |
| 173 | 173 | $items_number = 0; |
@@ -210,7 +210,7 @@ discard block |
||
| 210 | 210 | |
| 211 | 211 | // Observer pour récupérer les données et respecter l'ordre des colonnes |
| 212 | 212 | $interpreter = new Interpreter(); |
| 213 | - $interpreter->addObserver(function (array $row) use (&$valuesToImport, $header) { |
|
| 213 | + $interpreter->addObserver(function(array $row) use (&$valuesToImport, $header) { |
|
| 214 | 214 | $rowData = array_combine($header, $row); |
| 215 | 215 | |
| 216 | 216 | if ($rowData !== false) { |
@@ -261,7 +261,7 @@ discard block |
||
| 261 | 261 | // Handle multiple lignes description |
| 262 | 262 | if (strpos($comments, '<br>') !== false || strpos($label, '<br>') !== false) { |
| 263 | 263 | $continue_on_next_line = true; |
| 264 | - $comment .= " " . $label; |
|
| 264 | + $comment .= " ".$label; |
|
| 265 | 265 | } else { |
| 266 | 266 | // Insert previous line if changing line |
| 267 | 267 | if (!empty($label)) { |
@@ -325,10 +325,10 @@ discard block |
||
| 325 | 325 | $values = []; |
| 326 | 326 | |
| 327 | 327 | foreach ($batchInsert as $data) { |
| 328 | - $values[] = "('" . implode("','", array_map('addslashes', $data)) . "')"; |
|
| 328 | + $values[] = "('".implode("','", array_map('addslashes', $data))."')"; |
|
| 329 | 329 | } |
| 330 | 330 | |
| 331 | - $sql = "INSERT INTO `$tableName` (`label`, `description`, `pwd`, `url`, `folder`, `login`, `operation_id`) VALUES " . implode(',', $values); |
|
| 331 | + $sql = "INSERT INTO `$tableName` (`label`, `description`, `pwd`, `url`, `folder`, `login`, `operation_id`) VALUES ".implode(',', $values); |
|
| 332 | 332 | |
| 333 | 333 | DB::query($sql); |
| 334 | 334 | } |
@@ -411,7 +411,7 @@ discard block |
||
| 411 | 411 | $parentId = $dataReceived['folderId']; // Strating with provided folder |
| 412 | 412 | |
| 413 | 413 | foreach ($parts as $part) { |
| 414 | - $currentPath = trim($currentPath . "/" . $part, "/"); |
|
| 414 | + $currentPath = trim($currentPath."/".$part, "/"); |
|
| 415 | 415 | $currentFolder = $part; |
| 416 | 416 | |
| 417 | 417 | // Check if this folder has already been created |
@@ -472,7 +472,7 @@ discard block |
||
| 472 | 472 | // Get ID of existing folder |
| 473 | 473 | $ret = DB::queryFirstRow( |
| 474 | 474 | 'SELECT * |
| 475 | - FROM ' . prefixTable('nested_tree') . ' |
|
| 475 | + FROM ' . prefixTable('nested_tree').' |
|
| 476 | 476 | WHERE title = %s', |
| 477 | 477 | $currentFolder |
| 478 | 478 | ); |
@@ -994,7 +994,7 @@ discard block |
||
| 994 | 994 | ]; |
| 995 | 995 | $startPathLevel = 1; |
| 996 | 996 | |
| 997 | - foreach($post_folders as $folder) { |
|
| 997 | + foreach ($post_folders as $folder) { |
|
| 998 | 998 | // get parent id |
| 999 | 999 | $parentId = $arrFolders[$folder['parentFolderId']]; |
| 1000 | 1000 | |
@@ -1065,7 +1065,7 @@ discard block |
||
| 1065 | 1065 | DB::startTransaction(); |
| 1066 | 1066 | |
| 1067 | 1067 | // Import all items |
| 1068 | - foreach($post_items as $item) { |
|
| 1068 | + foreach ($post_items as $item) { |
|
| 1069 | 1069 | // get info about this folder |
| 1070 | 1070 | $destinationFolderMore = DB::queryFirstRow( |
| 1071 | 1071 | 'SELECT title FROM '.prefixTable('nested_tree').' WHERE id = %i', |
@@ -1290,7 +1290,7 @@ discard block |
||
| 1290 | 1290 | ]; |
| 1291 | 1291 | } |
| 1292 | 1292 | |
| 1293 | -spl_autoload_register(function ($class) { |
|
| 1293 | +spl_autoload_register(function($class) { |
|
| 1294 | 1294 | $prefix = 'League\\Csv\\'; |
| 1295 | 1295 | $base_dir = __DIR__.'/src/'; |
| 1296 | 1296 | $len = strlen($prefix); |
@@ -54,13 +54,17 @@ discard block |
||
| 54 | 54 | ); |
| 55 | 55 | |
| 56 | 56 | if (empty($subtasks)) { |
| 57 | - if (LOG_TASKS=== true) $this->logger->log("No subtask was found for task {$this->taskId}"); |
|
| 57 | + if (LOG_TASKS=== true) { |
|
| 58 | + $this->logger->log("No subtask was found for task {$this->taskId}"); |
|
| 59 | + } |
|
| 58 | 60 | return; |
| 59 | 61 | } |
| 60 | 62 | |
| 61 | 63 | // Process each subtask |
| 62 | 64 | foreach ($subtasks as $subtask) { |
| 63 | - if (LOG_TASKS=== true) $this->logger->log("Processing subtask {$subtask['increment_id']} for task {$this->taskId}"); |
|
| 65 | + if (LOG_TASKS=== true) { |
|
| 66 | + $this->logger->log("Processing subtask {$subtask['increment_id']} for task {$this->taskId}"); |
|
| 67 | + } |
|
| 64 | 68 | $this->processGenerateUserKeysSubtask($subtask, $arguments); |
| 65 | 69 | } |
| 66 | 70 | |
@@ -97,7 +101,9 @@ discard block |
||
| 97 | 101 | $subtask['increment_id'] |
| 98 | 102 | ); |
| 99 | 103 | |
| 100 | - if (LOG_TASKS=== true) $this->logger->log("Subtask is in progress: ".$taskData['step'], 'INFO'); |
|
| 104 | + if (LOG_TASKS=== true) { |
|
| 105 | + $this->logger->log("Subtask is in progress: ".$taskData['step'], 'INFO'); |
|
| 106 | + } |
|
| 101 | 107 | switch ($taskData['step'] ?? '') { |
| 102 | 108 | case 'step0': |
| 103 | 109 | $this->generateNewUserStep0($arguments); |
@@ -50,24 +50,24 @@ discard block |
||
| 50 | 50 | private function generateUserKeys($arguments) { |
| 51 | 51 | // Get all subtasks related to this task |
| 52 | 52 | $subtasks = DB::query( |
| 53 | - 'SELECT * FROM ' . prefixTable('background_subtasks') . ' WHERE task_id = %i AND is_in_progress = 0 ORDER BY `task` ASC', |
|
| 53 | + 'SELECT * FROM '.prefixTable('background_subtasks').' WHERE task_id = %i AND is_in_progress = 0 ORDER BY `task` ASC', |
|
| 54 | 54 | $this->taskId |
| 55 | 55 | ); |
| 56 | 56 | |
| 57 | 57 | if (empty($subtasks)) { |
| 58 | - if (LOG_TASKS=== true) $this->logger->log("No subtask was found for task {$this->taskId}"); |
|
| 58 | + if (LOG_TASKS === true) $this->logger->log("No subtask was found for task {$this->taskId}"); |
|
| 59 | 59 | return; |
| 60 | 60 | } |
| 61 | 61 | |
| 62 | 62 | // Process each subtask |
| 63 | 63 | foreach ($subtasks as $subtask) { |
| 64 | - if (LOG_TASKS=== true) $this->logger->log("Processing subtask {$subtask['increment_id']} for task {$this->taskId}"); |
|
| 64 | + if (LOG_TASKS === true) $this->logger->log("Processing subtask {$subtask['increment_id']} for task {$this->taskId}"); |
|
| 65 | 65 | $this->processGenerateUserKeysSubtask($subtask, $arguments); |
| 66 | 66 | } |
| 67 | 67 | |
| 68 | 68 | // Are all subtasks completed? |
| 69 | 69 | $remainingSubtasks = DB::queryFirstField( |
| 70 | - 'SELECT COUNT(*) FROM ' . prefixTable('background_subtasks') . ' WHERE task_id = %i AND is_in_progress = 0', |
|
| 70 | + 'SELECT COUNT(*) FROM '.prefixTable('background_subtasks').' WHERE task_id = %i AND is_in_progress = 0', |
|
| 71 | 71 | $this->taskId |
| 72 | 72 | ); |
| 73 | 73 | if ($remainingSubtasks == 0) { |
@@ -98,7 +98,7 @@ discard block |
||
| 98 | 98 | $subtask['increment_id'] |
| 99 | 99 | ); |
| 100 | 100 | |
| 101 | - if (LOG_TASKS=== true) $this->logger->log("Subtask is in progress: ".$taskData['step'], 'INFO'); |
|
| 101 | + if (LOG_TASKS === true) $this->logger->log("Subtask is in progress: ".$taskData['step'], 'INFO'); |
|
| 102 | 102 | switch ($taskData['step'] ?? '') { |
| 103 | 103 | case 'step0': |
| 104 | 104 | $this->generateNewUserStep0($arguments); |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | $subtask['increment_id'] |
| 153 | 153 | ); |
| 154 | 154 | |
| 155 | - $this->logger->log("Subtask {$subtask['increment_id']} failure: " . $e->getMessage(), 'ERROR'); |
|
| 155 | + $this->logger->log("Subtask {$subtask['increment_id']} failure: ".$e->getMessage(), 'ERROR'); |
|
| 156 | 156 | } |
| 157 | 157 | } |
| 158 | 158 | |
@@ -186,7 +186,7 @@ discard block |
||
| 186 | 186 | // Loop on items |
| 187 | 187 | $rows = DB::query( |
| 188 | 188 | 'SELECT id, pw, perso |
| 189 | - FROM ' . prefixTable('items') . ' |
|
| 189 | + FROM ' . prefixTable('items').' |
|
| 190 | 190 | WHERE perso = %i |
| 191 | 191 | ORDER BY id ASC |
| 192 | 192 | LIMIT %i, %i', |
@@ -199,7 +199,7 @@ discard block |
||
| 199 | 199 | // Get itemKey from current user |
| 200 | 200 | $currentUserKey = DB::queryFirstRow( |
| 201 | 201 | 'SELECT share_key, increment_id |
| 202 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 202 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 203 | 203 | WHERE object_id = %i AND user_id = %i', |
| 204 | 204 | $record['id'], |
| 205 | 205 | (int) $record['perso'] === 0 ? $arguments['owner_id'] : $arguments['new_user_id'] |
@@ -226,7 +226,7 @@ discard block |
||
| 226 | 226 | |
| 227 | 227 | $currentUserKey = DB::queryFirstRow( |
| 228 | 228 | 'SELECT increment_id |
| 229 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 229 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 230 | 230 | WHERE object_id = %i AND user_id = %i', |
| 231 | 231 | $record['id'], |
| 232 | 232 | $arguments['new_user_id'] |
@@ -276,16 +276,16 @@ discard block |
||
| 276 | 276 | // Loop on logs |
| 277 | 277 | $rows = DB::query( |
| 278 | 278 | 'SELECT increment_id |
| 279 | - FROM ' . prefixTable('log_items') . ' |
|
| 279 | + FROM ' . prefixTable('log_items').' |
|
| 280 | 280 | WHERE raison LIKE "at_pw :%" AND encryption_type = "teampass_aes" |
| 281 | 281 | ORDER BY increment_id ASC |
| 282 | - LIMIT ' . $taskData['index'] . ', ' . $taskData['nb'] |
|
| 282 | + LIMIT ' . $taskData['index'].', '.$taskData['nb'] |
|
| 283 | 283 | ); |
| 284 | 284 | foreach ($rows as $record) { |
| 285 | 285 | // Get itemKey from current user |
| 286 | 286 | $currentUserKey = DB::queryFirstRow( |
| 287 | 287 | 'SELECT share_key |
| 288 | - FROM ' . prefixTable('sharekeys_logs') . ' |
|
| 288 | + FROM ' . prefixTable('sharekeys_logs').' |
|
| 289 | 289 | WHERE object_id = %i AND user_id = %i', |
| 290 | 290 | $record['increment_id'], |
| 291 | 291 | $arguments['owner_id'] |
@@ -317,7 +317,7 @@ discard block |
||
| 317 | 317 | if ((int) $arguments['new_user_id'] !== (int) $arguments['owner_id']) { |
| 318 | 318 | $currentUserKey = DB::queryFirstRow( |
| 319 | 319 | 'SELECT increment_id |
| 320 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 320 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 321 | 321 | WHERE object_id = %i AND user_id = %i', |
| 322 | 322 | $record['id'], |
| 323 | 323 | $arguments['new_user_id'] |
@@ -358,7 +358,7 @@ discard block |
||
| 358 | 358 | // Loop on fields |
| 359 | 359 | $rows = DB::query( |
| 360 | 360 | 'SELECT id |
| 361 | - FROM ' . prefixTable('categories_items') . ' |
|
| 361 | + FROM ' . prefixTable('categories_items').' |
|
| 362 | 362 | WHERE encryption_type = "teampass_aes" |
| 363 | 363 | ORDER BY id ASC |
| 364 | 364 | LIMIT %i, %i', |
@@ -369,7 +369,7 @@ discard block |
||
| 369 | 369 | // Get itemKey from current user |
| 370 | 370 | $currentUserKey = DB::queryFirstRow( |
| 371 | 371 | 'SELECT share_key |
| 372 | - FROM ' . prefixTable('sharekeys_fields') . ' |
|
| 372 | + FROM ' . prefixTable('sharekeys_fields').' |
|
| 373 | 373 | WHERE object_id = %i AND user_id = %i', |
| 374 | 374 | $record['id'], |
| 375 | 375 | $arguments['owner_id'] |
@@ -397,7 +397,7 @@ discard block |
||
| 397 | 397 | if ((int) $arguments['new_user_id'] !== (int) $arguments['owner_id']) { |
| 398 | 398 | $currentUserKey = DB::queryFirstRow( |
| 399 | 399 | 'SELECT increment_id |
| 400 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 400 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 401 | 401 | WHERE object_id = %i AND user_id = %i', |
| 402 | 402 | $record['id'], |
| 403 | 403 | $arguments['new_user_id'] |
@@ -439,7 +439,7 @@ discard block |
||
| 439 | 439 | // Loop on suggestions |
| 440 | 440 | $rows = DB::query( |
| 441 | 441 | 'SELECT id |
| 442 | - FROM ' . prefixTable('suggestion') . ' |
|
| 442 | + FROM ' . prefixTable('suggestion').' |
|
| 443 | 443 | ORDER BY id ASC |
| 444 | 444 | LIMIT %i, %i', |
| 445 | 445 | $taskData['index'], |
@@ -449,7 +449,7 @@ discard block |
||
| 449 | 449 | // Get itemKey from current user |
| 450 | 450 | $currentUserKey = DB::queryFirstRow( |
| 451 | 451 | 'SELECT share_key |
| 452 | - FROM ' . prefixTable('sharekeys_suggestions') . ' |
|
| 452 | + FROM ' . prefixTable('sharekeys_suggestions').' |
|
| 453 | 453 | WHERE object_id = %i AND user_id = %i', |
| 454 | 454 | $record['id'], |
| 455 | 455 | $arguments['owner_id'] |
@@ -481,7 +481,7 @@ discard block |
||
| 481 | 481 | if ((int) $arguments['new_user_id'] !== (int) $arguments['owner_id']) { |
| 482 | 482 | $currentUserKey = DB::queryFirstRow( |
| 483 | 483 | 'SELECT increment_id |
| 484 | - FROM ' . prefixTable('sharekeys_items') . ' |
|
| 484 | + FROM ' . prefixTable('sharekeys_items').' |
|
| 485 | 485 | WHERE object_id = %i AND user_id = %i', |
| 486 | 486 | $record['id'], |
| 487 | 487 | $arguments['new_user_id'] |
@@ -522,9 +522,9 @@ discard block |
||
| 522 | 522 | // Loop on files |
| 523 | 523 | $rows = DB::query( |
| 524 | 524 | 'SELECT f.id AS id, i.perso AS perso |
| 525 | - FROM ' . prefixTable('files') . ' AS f |
|
| 526 | - INNER JOIN ' . prefixTable('items') . ' AS i ON i.id = f.id_item |
|
| 527 | - WHERE f.status = "' . TP_ENCRYPTION_NAME . '" |
|
| 525 | + FROM ' . prefixTable('files').' AS f |
|
| 526 | + INNER JOIN ' . prefixTable('items').' AS i ON i.id = f.id_item |
|
| 527 | + WHERE f.status = "' . TP_ENCRYPTION_NAME.'" |
|
| 528 | 528 | LIMIT %i, %i', |
| 529 | 529 | $taskData['index'], |
| 530 | 530 | $taskData['nb'] |
@@ -533,7 +533,7 @@ discard block |
||
| 533 | 533 | // Get itemKey from current user |
| 534 | 534 | $currentUserKey = DB::queryFirstRow( |
| 535 | 535 | 'SELECT share_key, increment_id |
| 536 | - FROM ' . prefixTable('sharekeys_files') . ' |
|
| 536 | + FROM ' . prefixTable('sharekeys_files').' |
|
| 537 | 537 | WHERE object_id = %i AND user_id = %i', |
| 538 | 538 | $record['id'], |
| 539 | 539 | (int) $record['perso'] === 0 ? $arguments['owner_id'] : $arguments['new_user_id'] |
@@ -561,7 +561,7 @@ discard block |
||
| 561 | 561 | |
| 562 | 562 | $currentUserKey = DB::queryFirstRow( |
| 563 | 563 | 'SELECT increment_id |
| 564 | - FROM ' . prefixTable('sharekeys_files') . ' |
|
| 564 | + FROM ' . prefixTable('sharekeys_files').' |
|
| 565 | 565 | WHERE object_id = %i AND user_id = %i', |
| 566 | 566 | $record['id'], |
| 567 | 567 | $arguments['new_user_id'] |
@@ -623,7 +623,7 @@ discard block |
||
| 623 | 623 | // get user info |
| 624 | 624 | $userInfo = DB::queryFirstRow( |
| 625 | 625 | 'SELECT email, login, auth_type, special, lastname, name |
| 626 | - FROM ' . prefixTable('users') . ' |
|
| 626 | + FROM ' . prefixTable('users').' |
|
| 627 | 627 | WHERE id = %i', |
| 628 | 628 | $arguments['new_user_id'] |
| 629 | 629 | ); |
@@ -638,10 +638,10 @@ discard block |
||
| 638 | 638 | filter_var($userInfo['email'], FILTER_SANITIZE_EMAIL), |
| 639 | 639 | // @scrutinizer ignore-type |
| 640 | 640 | empty($arguments['email_body']) === false ? $arguments['email_body'] : $lang->get('email_body_user_config_1'), |
| 641 | - 'TEAMPASS - ' . $lang->get('login_credentials'), |
|
| 641 | + 'TEAMPASS - '.$lang->get('login_credentials'), |
|
| 642 | 642 | (array) filter_var_array( |
| 643 | 643 | [ |
| 644 | - '#code#' => cryption($arguments['new_user_code'], '','decrypt', $this->settings)['string'], |
|
| 644 | + '#code#' => cryption($arguments['new_user_code'], '', 'decrypt', $this->settings)['string'], |
|
| 645 | 645 | '#lastname#' => isset($userInfo['name']) === true ? $userInfo['name'] : '', |
| 646 | 646 | '#login#' => isset($userInfo['login']) === true ? $userInfo['login'] : '', |
| 647 | 647 | ], |
@@ -677,13 +677,13 @@ discard block |
||
| 677 | 677 | private function getOwnerInfos(int $owner_id, string $owner_pwd) { |
| 678 | 678 | $userInfo = DB::queryFirstRow( |
| 679 | 679 | 'SELECT pw, public_key, private_key, login, name |
| 680 | - FROM ' . prefixTable('users') . ' |
|
| 680 | + FROM ' . prefixTable('users').' |
|
| 681 | 681 | WHERE id = %i', |
| 682 | 682 | $owner_id |
| 683 | 683 | ); |
| 684 | 684 | |
| 685 | 685 | // decrypt owner password |
| 686 | - $pwd = cryption($owner_pwd, '','decrypt', $this->settings)['string']; |
|
| 686 | + $pwd = cryption($owner_pwd, '', 'decrypt', $this->settings)['string']; |
|
| 687 | 687 | // decrypt private key and send back |
| 688 | 688 | return [ |
| 689 | 689 | 'private_key' => decryptPrivateKey($pwd, $userInfo['private_key']), |
@@ -29,7 +29,7 @@ discard block |
||
| 29 | 29 | trait ItemHandlerTrait { |
| 30 | 30 | |
| 31 | 31 | private function generateUserPasswordKeys($arguments) { |
| 32 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserPasswordKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 32 | + if (LOG_TASKS === true) $this->logger->log('Processing generateUserPasswordKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 33 | 33 | // Generate keys for user passwords |
| 34 | 34 | storeUsersShareKey( |
| 35 | 35 | prefixTable('sharekeys_items'), |
@@ -49,8 +49,8 @@ discard block |
||
| 49 | 49 | * @param array $taskData |
| 50 | 50 | */ |
| 51 | 51 | private function generateUserFileKeys($taskData) { |
| 52 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserFileKeys : '.print_r($taskData, true), 'DEBUG'); |
|
| 53 | - foreach($taskData['files_keys'] as $file) { |
|
| 52 | + if (LOG_TASKS === true) $this->logger->log('Processing generateUserFileKeys : '.print_r($taskData, true), 'DEBUG'); |
|
| 53 | + foreach ($taskData['files_keys'] as $file) { |
|
| 54 | 54 | storeUsersShareKey( |
| 55 | 55 | prefixTable('sharekeys_files'), |
| 56 | 56 | 0, |
@@ -70,9 +70,9 @@ discard block |
||
| 70 | 70 | * @param array $arguments |
| 71 | 71 | */ |
| 72 | 72 | private function generateUserFieldKeys($arguments) { |
| 73 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserFieldKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 74 | - foreach($arguments['fields_keys'] as $field) { |
|
| 75 | - $this->logger->log('Processing generateUserFieldKeys for: ' . $field['object_id'], 'DEBUG'); |
|
| 73 | + if (LOG_TASKS === true) $this->logger->log('Processing generateUserFieldKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 74 | + foreach ($arguments['fields_keys'] as $field) { |
|
| 75 | + $this->logger->log('Processing generateUserFieldKeys for: '.$field['object_id'], 'DEBUG'); |
|
| 76 | 76 | storeUsersShareKey( |
| 77 | 77 | prefixTable('sharekeys_fields'), |
| 78 | 78 | 0, |
@@ -29,7 +29,9 @@ discard block |
||
| 29 | 29 | trait ItemHandlerTrait { |
| 30 | 30 | |
| 31 | 31 | private function generateUserPasswordKeys($arguments) { |
| 32 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserPasswordKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 32 | + if (LOG_TASKS=== true) { |
|
| 33 | + $this->logger->log('Processing generateUserPasswordKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 34 | + } |
|
| 33 | 35 | // Generate keys for user passwords |
| 34 | 36 | storeUsersShareKey( |
| 35 | 37 | prefixTable('sharekeys_items'), |
@@ -49,7 +51,9 @@ discard block |
||
| 49 | 51 | * @param array $taskData |
| 50 | 52 | */ |
| 51 | 53 | private function generateUserFileKeys($taskData) { |
| 52 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserFileKeys : '.print_r($taskData, true), 'DEBUG'); |
|
| 54 | + if (LOG_TASKS=== true) { |
|
| 55 | + $this->logger->log('Processing generateUserFileKeys : '.print_r($taskData, true), 'DEBUG'); |
|
| 56 | + } |
|
| 53 | 57 | foreach($taskData['files_keys'] as $file) { |
| 54 | 58 | storeUsersShareKey( |
| 55 | 59 | prefixTable('sharekeys_files'), |
@@ -70,7 +74,9 @@ discard block |
||
| 70 | 74 | * @param array $arguments |
| 71 | 75 | */ |
| 72 | 76 | private function generateUserFieldKeys($arguments) { |
| 73 | - if (LOG_TASKS=== true) $this->logger->log('Processing generateUserFieldKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 77 | + if (LOG_TASKS=== true) { |
|
| 78 | + $this->logger->log('Processing generateUserFieldKeys : '.print_r($arguments, true), 'DEBUG'); |
|
| 79 | + } |
|
| 74 | 80 | foreach($arguments['fields_keys'] as $field) { |
| 75 | 81 | $this->logger->log('Processing generateUserFieldKeys for: ' . $field['object_id'], 'DEBUG'); |
| 76 | 82 | storeUsersShareKey( |
@@ -80,7 +80,7 @@ discard block |
||
| 80 | 80 | //get through all users with enabled personnal folder. |
| 81 | 81 | $users = DB::query( |
| 82 | 82 | 'SELECT id, login, email |
| 83 | - FROM ' . prefixTable('users') . ' |
|
| 83 | + FROM ' . prefixTable('users').' |
|
| 84 | 84 | WHERE id NOT IN ('.OTV_USER_ID.', '.TP_USER_ID.', '.SSH_USER_ID.', '.API_USER_ID.') |
| 85 | 85 | AND personal_folder = 1 |
| 86 | 86 | ORDER BY login ASC' |
@@ -89,7 +89,7 @@ discard block |
||
| 89 | 89 | //if folder doesn't exist then create it |
| 90 | 90 | $data = DB::queryFirstRow( |
| 91 | 91 | 'SELECT id |
| 92 | - FROM ' . prefixTable('nested_tree') . ' |
|
| 92 | + FROM ' . prefixTable('nested_tree').' |
|
| 93 | 93 | WHERE title = %s AND parent_id = %i', |
| 94 | 94 | $user['id'], |
| 95 | 95 | 0 |