@@ -32,359 +32,359 @@ |
||
| 32 | 32 | |
| 33 | 33 | class Migration { |
| 34 | 34 | |
| 35 | - private $moduleId; |
|
| 36 | - /** @var \OC\Files\View */ |
|
| 37 | - private $view; |
|
| 38 | - /** @var \OCP\IDBConnection */ |
|
| 39 | - private $connection; |
|
| 40 | - /** @var IConfig */ |
|
| 41 | - private $config; |
|
| 42 | - /** @var ILogger */ |
|
| 43 | - private $logger; |
|
| 44 | - /** @var string*/ |
|
| 45 | - protected $installedVersion; |
|
| 46 | - |
|
| 47 | - /** |
|
| 48 | - * @param IConfig $config |
|
| 49 | - * @param View $view |
|
| 50 | - * @param IDBConnection $connection |
|
| 51 | - * @param ILogger $logger |
|
| 52 | - */ |
|
| 53 | - public function __construct(IConfig $config, View $view, IDBConnection $connection, ILogger $logger) { |
|
| 54 | - $this->view = $view; |
|
| 55 | - $this->view->disableCacheUpdate(); |
|
| 56 | - $this->connection = $connection; |
|
| 57 | - $this->moduleId = \OCA\Encryption\Crypto\Encryption::ID; |
|
| 58 | - $this->config = $config; |
|
| 59 | - $this->logger = $logger; |
|
| 60 | - $this->installedVersion = $this->config->getAppValue('files_encryption', 'installed_version', '-1'); |
|
| 61 | - } |
|
| 62 | - |
|
| 63 | - public function finalCleanUp() { |
|
| 64 | - $this->view->deleteAll('files_encryption/public_keys'); |
|
| 65 | - $this->updateFileCache(); |
|
| 66 | - $this->config->deleteAppValue('files_encryption', 'installed_version'); |
|
| 67 | - } |
|
| 68 | - |
|
| 69 | - /** |
|
| 70 | - * update file cache, copy unencrypted_size to the 'size' column |
|
| 71 | - */ |
|
| 72 | - private function updateFileCache() { |
|
| 73 | - // make sure that we don't update the file cache multiple times |
|
| 74 | - // only update during the first run |
|
| 75 | - if ($this->installedVersion !== '-1') { |
|
| 76 | - $query = $this->connection->getQueryBuilder(); |
|
| 77 | - $query->update('filecache') |
|
| 78 | - ->set('size', 'unencrypted_size') |
|
| 79 | - ->where($query->expr()->eq('encrypted', $query->createParameter('encrypted'))) |
|
| 80 | - ->setParameter('encrypted', 1); |
|
| 81 | - $query->execute(); |
|
| 82 | - } |
|
| 83 | - } |
|
| 84 | - |
|
| 85 | - /** |
|
| 86 | - * iterate through users and reorganize the folder structure |
|
| 87 | - */ |
|
| 88 | - public function reorganizeFolderStructure() { |
|
| 89 | - $this->reorganizeSystemFolderStructure(); |
|
| 90 | - |
|
| 91 | - $limit = 500; |
|
| 92 | - $offset = 0; |
|
| 93 | - do { |
|
| 94 | - $users = \OCP\User::getUsers('', $limit, $offset); |
|
| 95 | - foreach ($users as $user) { |
|
| 96 | - $this->reorganizeFolderStructureForUser($user); |
|
| 97 | - } |
|
| 98 | - $offset += $limit; |
|
| 99 | - } while (count($users) >= $limit); |
|
| 100 | - } |
|
| 101 | - |
|
| 102 | - /** |
|
| 103 | - * reorganize system wide folder structure |
|
| 104 | - */ |
|
| 105 | - public function reorganizeSystemFolderStructure() { |
|
| 106 | - |
|
| 107 | - $this->createPathForKeys('/files_encryption'); |
|
| 108 | - |
|
| 109 | - // backup system wide folders |
|
| 110 | - $this->backupSystemWideKeys(); |
|
| 111 | - |
|
| 112 | - // rename system wide mount point |
|
| 113 | - $this->renameFileKeys('', '/files_encryption/keys'); |
|
| 114 | - |
|
| 115 | - // rename system private keys |
|
| 116 | - $this->renameSystemPrivateKeys(); |
|
| 117 | - |
|
| 118 | - $storage = $this->view->getMount('')->getStorage(); |
|
| 119 | - $storage->getScanner()->scan('files_encryption'); |
|
| 120 | - } |
|
| 121 | - |
|
| 122 | - |
|
| 123 | - /** |
|
| 124 | - * reorganize folder structure for user |
|
| 125 | - * |
|
| 126 | - * @param string $user |
|
| 127 | - */ |
|
| 128 | - public function reorganizeFolderStructureForUser($user) { |
|
| 129 | - // backup all keys |
|
| 130 | - \OC_Util::tearDownFS(); |
|
| 131 | - \OC_Util::setupFS($user); |
|
| 132 | - if ($this->backupUserKeys($user)) { |
|
| 133 | - // rename users private key |
|
| 134 | - $this->renameUsersPrivateKey($user); |
|
| 135 | - $this->renameUsersPublicKey($user); |
|
| 136 | - // rename file keys |
|
| 137 | - $path = '/files_encryption/keys'; |
|
| 138 | - $this->renameFileKeys($user, $path); |
|
| 139 | - $trashPath = '/files_trashbin/keys'; |
|
| 140 | - if (\OC_App::isEnabled('files_trashbin') && $this->view->is_dir($user . '/' . $trashPath)) { |
|
| 141 | - $this->renameFileKeys($user, $trashPath, true); |
|
| 142 | - $this->view->deleteAll($trashPath); |
|
| 143 | - } |
|
| 144 | - // delete old folders |
|
| 145 | - $this->deleteOldKeys($user); |
|
| 146 | - $this->view->getMount('/' . $user)->getStorage()->getScanner()->scan('files_encryption'); |
|
| 147 | - } |
|
| 148 | - } |
|
| 149 | - |
|
| 150 | - /** |
|
| 151 | - * update database |
|
| 152 | - */ |
|
| 153 | - public function updateDB() { |
|
| 154 | - |
|
| 155 | - // make sure that we don't update the file cache multiple times |
|
| 156 | - // only update during the first run |
|
| 157 | - if ($this->installedVersion === '-1') { |
|
| 158 | - return; |
|
| 159 | - } |
|
| 160 | - |
|
| 161 | - // delete left-over from old encryption which is no longer needed |
|
| 162 | - $this->config->deleteAppValue('files_encryption', 'ocsid'); |
|
| 163 | - $this->config->deleteAppValue('files_encryption', 'types'); |
|
| 164 | - $this->config->deleteAppValue('files_encryption', 'enabled'); |
|
| 165 | - |
|
| 166 | - $oldAppValues = $this->connection->getQueryBuilder(); |
|
| 167 | - $oldAppValues->select('*') |
|
| 168 | - ->from('appconfig') |
|
| 169 | - ->where($oldAppValues->expr()->eq('appid', $oldAppValues->createParameter('appid'))) |
|
| 170 | - ->setParameter('appid', 'files_encryption'); |
|
| 171 | - $appSettings = $oldAppValues->execute(); |
|
| 172 | - |
|
| 173 | - while ($row = $appSettings->fetch()) { |
|
| 174 | - // 'installed_version' gets deleted at the end of the migration process |
|
| 175 | - if ($row['configkey'] !== 'installed_version' ) { |
|
| 176 | - $this->config->setAppValue('encryption', $row['configkey'], $row['configvalue']); |
|
| 177 | - $this->config->deleteAppValue('files_encryption', $row['configkey']); |
|
| 178 | - } |
|
| 179 | - } |
|
| 180 | - |
|
| 181 | - $oldPreferences = $this->connection->getQueryBuilder(); |
|
| 182 | - $oldPreferences->select('*') |
|
| 183 | - ->from('preferences') |
|
| 184 | - ->where($oldPreferences->expr()->eq('appid', $oldPreferences->createParameter('appid'))) |
|
| 185 | - ->setParameter('appid', 'files_encryption'); |
|
| 186 | - $preferenceSettings = $oldPreferences->execute(); |
|
| 187 | - |
|
| 188 | - while ($row = $preferenceSettings->fetch()) { |
|
| 189 | - $this->config->setUserValue($row['userid'], 'encryption', $row['configkey'], $row['configvalue']); |
|
| 190 | - $this->config->deleteUserValue($row['userid'], 'files_encryption', $row['configkey']); |
|
| 191 | - } |
|
| 192 | - } |
|
| 193 | - |
|
| 194 | - /** |
|
| 195 | - * create backup of system-wide keys |
|
| 196 | - */ |
|
| 197 | - private function backupSystemWideKeys() { |
|
| 198 | - $backupDir = 'encryption_migration_backup_' . date("Y-m-d_H-i-s"); |
|
| 199 | - $this->view->mkdir($backupDir); |
|
| 200 | - $this->view->copy('files_encryption', $backupDir . '/files_encryption'); |
|
| 201 | - } |
|
| 202 | - |
|
| 203 | - /** |
|
| 204 | - * create backup of user specific keys |
|
| 205 | - * |
|
| 206 | - * @param string $user |
|
| 207 | - * @return bool |
|
| 208 | - */ |
|
| 209 | - private function backupUserKeys($user) { |
|
| 210 | - $encryptionDir = $user . '/files_encryption'; |
|
| 211 | - if ($this->view->is_dir($encryptionDir)) { |
|
| 212 | - $backupDir = $user . '/encryption_migration_backup_' . date("Y-m-d_H-i-s"); |
|
| 213 | - $this->view->mkdir($backupDir); |
|
| 214 | - $this->view->copy($encryptionDir, $backupDir); |
|
| 215 | - return true; |
|
| 216 | - } |
|
| 217 | - return false; |
|
| 218 | - } |
|
| 219 | - |
|
| 220 | - /** |
|
| 221 | - * rename system-wide private keys |
|
| 222 | - */ |
|
| 223 | - private function renameSystemPrivateKeys() { |
|
| 224 | - $dh = $this->view->opendir('files_encryption'); |
|
| 225 | - $this->createPathForKeys('/files_encryption/' . $this->moduleId ); |
|
| 226 | - if (is_resource($dh)) { |
|
| 227 | - while (($privateKey = readdir($dh)) !== false) { |
|
| 228 | - if (!\OC\Files\Filesystem::isIgnoredDir($privateKey) ) { |
|
| 229 | - if (!$this->view->is_dir('/files_encryption/' . $privateKey)) { |
|
| 230 | - $this->view->rename('files_encryption/' . $privateKey, 'files_encryption/' . $this->moduleId . '/' . $privateKey); |
|
| 231 | - $this->renameSystemPublicKey($privateKey); |
|
| 232 | - } |
|
| 233 | - } |
|
| 234 | - } |
|
| 235 | - closedir($dh); |
|
| 236 | - } |
|
| 237 | - } |
|
| 238 | - |
|
| 239 | - /** |
|
| 240 | - * rename system wide public key |
|
| 241 | - * |
|
| 242 | - * @param string $privateKey private key for which we want to rename the corresponding public key |
|
| 243 | - */ |
|
| 244 | - private function renameSystemPublicKey($privateKey) { |
|
| 245 | - $publicKey = substr($privateKey,0 , strrpos($privateKey, '.privateKey')) . '.publicKey'; |
|
| 246 | - $this->view->rename('files_encryption/public_keys/' . $publicKey, 'files_encryption/' . $this->moduleId . '/' . $publicKey); |
|
| 247 | - } |
|
| 248 | - |
|
| 249 | - /** |
|
| 250 | - * rename user-specific private keys |
|
| 251 | - * |
|
| 252 | - * @param string $user |
|
| 253 | - */ |
|
| 254 | - private function renameUsersPrivateKey($user) { |
|
| 255 | - $oldPrivateKey = $user . '/files_encryption/' . $user . '.privateKey'; |
|
| 256 | - $newPrivateKey = $user . '/files_encryption/' . $this->moduleId . '/' . $user . '.privateKey'; |
|
| 257 | - if ($this->view->file_exists($oldPrivateKey)) { |
|
| 258 | - $this->createPathForKeys(dirname($newPrivateKey)); |
|
| 259 | - $this->view->rename($oldPrivateKey, $newPrivateKey); |
|
| 260 | - } |
|
| 261 | - } |
|
| 262 | - |
|
| 263 | - /** |
|
| 264 | - * rename user-specific public keys |
|
| 265 | - * |
|
| 266 | - * @param string $user |
|
| 267 | - */ |
|
| 268 | - private function renameUsersPublicKey($user) { |
|
| 269 | - $oldPublicKey = '/files_encryption/public_keys/' . $user . '.publicKey'; |
|
| 270 | - $newPublicKey = $user . '/files_encryption/' . $this->moduleId . '/' . $user . '.publicKey'; |
|
| 271 | - if ($this->view->file_exists($oldPublicKey)) { |
|
| 272 | - $this->createPathForKeys(dirname($newPublicKey)); |
|
| 273 | - $this->view->rename($oldPublicKey, $newPublicKey); |
|
| 274 | - } |
|
| 275 | - } |
|
| 276 | - |
|
| 277 | - /** |
|
| 278 | - * rename file keys |
|
| 279 | - * |
|
| 280 | - * @param string $user |
|
| 281 | - * @param string $path |
|
| 282 | - * @param bool $trash |
|
| 283 | - */ |
|
| 284 | - private function renameFileKeys($user, $path, $trash = false) { |
|
| 285 | - |
|
| 286 | - if ($this->view->is_dir($user . '/' . $path) === false) { |
|
| 287 | - $this->logger->info('Skip dir /' . $user . '/' . $path . ': does not exist'); |
|
| 288 | - return; |
|
| 289 | - } |
|
| 290 | - |
|
| 291 | - $dh = $this->view->opendir($user . '/' . $path); |
|
| 292 | - |
|
| 293 | - if (is_resource($dh)) { |
|
| 294 | - while (($file = readdir($dh)) !== false) { |
|
| 295 | - if (!\OC\Files\Filesystem::isIgnoredDir($file)) { |
|
| 296 | - if ($this->view->is_dir($user . '/' . $path . '/' . $file)) { |
|
| 297 | - $this->renameFileKeys($user, $path . '/' . $file, $trash); |
|
| 298 | - } else { |
|
| 299 | - $target = $this->getTargetDir($user, $path, $file, $trash); |
|
| 300 | - if ($target !== false) { |
|
| 301 | - $this->createPathForKeys(dirname($target)); |
|
| 302 | - $this->view->rename($user . '/' . $path . '/' . $file, $target); |
|
| 303 | - } else { |
|
| 304 | - $this->logger->warning( |
|
| 305 | - 'did not move key "' . $file |
|
| 306 | - . '" could not find the corresponding file in /data/' . $user . '/files.' |
|
| 307 | - . 'Most likely the key was already moved in a previous migration run and is already on the right place.'); |
|
| 308 | - } |
|
| 309 | - } |
|
| 310 | - } |
|
| 311 | - } |
|
| 312 | - closedir($dh); |
|
| 313 | - } |
|
| 314 | - } |
|
| 315 | - |
|
| 316 | - /** |
|
| 317 | - * get system mount points |
|
| 318 | - * wrap static method so that it can be mocked for testing |
|
| 319 | - * |
|
| 320 | - * @internal |
|
| 321 | - * @return array |
|
| 322 | - */ |
|
| 323 | - protected function getSystemMountPoints() { |
|
| 324 | - return \OC_Mount_Config::getSystemMountPoints(); |
|
| 325 | - } |
|
| 326 | - |
|
| 327 | - /** |
|
| 328 | - * generate target directory |
|
| 329 | - * |
|
| 330 | - * @param string $user |
|
| 331 | - * @param string $keyPath |
|
| 332 | - * @param string $filename |
|
| 333 | - * @param bool $trash |
|
| 334 | - * @return string |
|
| 335 | - */ |
|
| 336 | - private function getTargetDir($user, $keyPath, $filename, $trash) { |
|
| 337 | - if ($trash) { |
|
| 338 | - $filePath = substr($keyPath, strlen('/files_trashbin/keys/')); |
|
| 339 | - $targetDir = $user . '/files_encryption/keys/files_trashbin/' . $filePath . '/' . $this->moduleId . '/' . $filename; |
|
| 340 | - } else { |
|
| 341 | - $filePath = substr($keyPath, strlen('/files_encryption/keys/')); |
|
| 342 | - $targetDir = $user . '/files_encryption/keys/files/' . $filePath . '/' . $this->moduleId . '/' . $filename; |
|
| 343 | - } |
|
| 344 | - |
|
| 345 | - if ($user === '') { |
|
| 346 | - // for system wide mounts we need to check if the mount point really exists |
|
| 347 | - $normalized = \OC\Files\Filesystem::normalizePath($filePath); |
|
| 348 | - $systemMountPoints = $this->getSystemMountPoints(); |
|
| 349 | - foreach ($systemMountPoints as $mountPoint) { |
|
| 350 | - $normalizedMountPoint = \OC\Files\Filesystem::normalizePath($mountPoint['mountpoint']) . '/'; |
|
| 351 | - if (strpos($normalized, $normalizedMountPoint) === 0) |
|
| 352 | - return $targetDir; |
|
| 353 | - } |
|
| 354 | - } else if ($trash === false && $this->view->file_exists('/' . $user. '/files/' . $filePath)) { |
|
| 355 | - return $targetDir; |
|
| 356 | - } else if ($trash === true && $this->view->file_exists('/' . $user. '/files_trashbin/' . $filePath)) { |
|
| 357 | - return $targetDir; |
|
| 358 | - } |
|
| 359 | - |
|
| 360 | - return false; |
|
| 361 | - } |
|
| 362 | - |
|
| 363 | - /** |
|
| 364 | - * delete old keys |
|
| 365 | - * |
|
| 366 | - * @param string $user |
|
| 367 | - */ |
|
| 368 | - private function deleteOldKeys($user) { |
|
| 369 | - $this->view->deleteAll($user . '/files_encryption/keyfiles'); |
|
| 370 | - $this->view->deleteAll($user . '/files_encryption/share-keys'); |
|
| 371 | - } |
|
| 372 | - |
|
| 373 | - /** |
|
| 374 | - * create directories for the keys recursively |
|
| 375 | - * |
|
| 376 | - * @param string $path |
|
| 377 | - */ |
|
| 378 | - private function createPathForKeys($path) { |
|
| 379 | - if (!$this->view->file_exists($path)) { |
|
| 380 | - $sub_dirs = explode('/', $path); |
|
| 381 | - $dir = ''; |
|
| 382 | - foreach ($sub_dirs as $sub_dir) { |
|
| 383 | - $dir .= '/' . $sub_dir; |
|
| 384 | - if (!$this->view->is_dir($dir)) { |
|
| 385 | - $this->view->mkdir($dir); |
|
| 386 | - } |
|
| 387 | - } |
|
| 388 | - } |
|
| 389 | - } |
|
| 35 | + private $moduleId; |
|
| 36 | + /** @var \OC\Files\View */ |
|
| 37 | + private $view; |
|
| 38 | + /** @var \OCP\IDBConnection */ |
|
| 39 | + private $connection; |
|
| 40 | + /** @var IConfig */ |
|
| 41 | + private $config; |
|
| 42 | + /** @var ILogger */ |
|
| 43 | + private $logger; |
|
| 44 | + /** @var string*/ |
|
| 45 | + protected $installedVersion; |
|
| 46 | + |
|
| 47 | + /** |
|
| 48 | + * @param IConfig $config |
|
| 49 | + * @param View $view |
|
| 50 | + * @param IDBConnection $connection |
|
| 51 | + * @param ILogger $logger |
|
| 52 | + */ |
|
| 53 | + public function __construct(IConfig $config, View $view, IDBConnection $connection, ILogger $logger) { |
|
| 54 | + $this->view = $view; |
|
| 55 | + $this->view->disableCacheUpdate(); |
|
| 56 | + $this->connection = $connection; |
|
| 57 | + $this->moduleId = \OCA\Encryption\Crypto\Encryption::ID; |
|
| 58 | + $this->config = $config; |
|
| 59 | + $this->logger = $logger; |
|
| 60 | + $this->installedVersion = $this->config->getAppValue('files_encryption', 'installed_version', '-1'); |
|
| 61 | + } |
|
| 62 | + |
|
| 63 | + public function finalCleanUp() { |
|
| 64 | + $this->view->deleteAll('files_encryption/public_keys'); |
|
| 65 | + $this->updateFileCache(); |
|
| 66 | + $this->config->deleteAppValue('files_encryption', 'installed_version'); |
|
| 67 | + } |
|
| 68 | + |
|
| 69 | + /** |
|
| 70 | + * update file cache, copy unencrypted_size to the 'size' column |
|
| 71 | + */ |
|
| 72 | + private function updateFileCache() { |
|
| 73 | + // make sure that we don't update the file cache multiple times |
|
| 74 | + // only update during the first run |
|
| 75 | + if ($this->installedVersion !== '-1') { |
|
| 76 | + $query = $this->connection->getQueryBuilder(); |
|
| 77 | + $query->update('filecache') |
|
| 78 | + ->set('size', 'unencrypted_size') |
|
| 79 | + ->where($query->expr()->eq('encrypted', $query->createParameter('encrypted'))) |
|
| 80 | + ->setParameter('encrypted', 1); |
|
| 81 | + $query->execute(); |
|
| 82 | + } |
|
| 83 | + } |
|
| 84 | + |
|
| 85 | + /** |
|
| 86 | + * iterate through users and reorganize the folder structure |
|
| 87 | + */ |
|
| 88 | + public function reorganizeFolderStructure() { |
|
| 89 | + $this->reorganizeSystemFolderStructure(); |
|
| 90 | + |
|
| 91 | + $limit = 500; |
|
| 92 | + $offset = 0; |
|
| 93 | + do { |
|
| 94 | + $users = \OCP\User::getUsers('', $limit, $offset); |
|
| 95 | + foreach ($users as $user) { |
|
| 96 | + $this->reorganizeFolderStructureForUser($user); |
|
| 97 | + } |
|
| 98 | + $offset += $limit; |
|
| 99 | + } while (count($users) >= $limit); |
|
| 100 | + } |
|
| 101 | + |
|
| 102 | + /** |
|
| 103 | + * reorganize system wide folder structure |
|
| 104 | + */ |
|
| 105 | + public function reorganizeSystemFolderStructure() { |
|
| 106 | + |
|
| 107 | + $this->createPathForKeys('/files_encryption'); |
|
| 108 | + |
|
| 109 | + // backup system wide folders |
|
| 110 | + $this->backupSystemWideKeys(); |
|
| 111 | + |
|
| 112 | + // rename system wide mount point |
|
| 113 | + $this->renameFileKeys('', '/files_encryption/keys'); |
|
| 114 | + |
|
| 115 | + // rename system private keys |
|
| 116 | + $this->renameSystemPrivateKeys(); |
|
| 117 | + |
|
| 118 | + $storage = $this->view->getMount('')->getStorage(); |
|
| 119 | + $storage->getScanner()->scan('files_encryption'); |
|
| 120 | + } |
|
| 121 | + |
|
| 122 | + |
|
| 123 | + /** |
|
| 124 | + * reorganize folder structure for user |
|
| 125 | + * |
|
| 126 | + * @param string $user |
|
| 127 | + */ |
|
| 128 | + public function reorganizeFolderStructureForUser($user) { |
|
| 129 | + // backup all keys |
|
| 130 | + \OC_Util::tearDownFS(); |
|
| 131 | + \OC_Util::setupFS($user); |
|
| 132 | + if ($this->backupUserKeys($user)) { |
|
| 133 | + // rename users private key |
|
| 134 | + $this->renameUsersPrivateKey($user); |
|
| 135 | + $this->renameUsersPublicKey($user); |
|
| 136 | + // rename file keys |
|
| 137 | + $path = '/files_encryption/keys'; |
|
| 138 | + $this->renameFileKeys($user, $path); |
|
| 139 | + $trashPath = '/files_trashbin/keys'; |
|
| 140 | + if (\OC_App::isEnabled('files_trashbin') && $this->view->is_dir($user . '/' . $trashPath)) { |
|
| 141 | + $this->renameFileKeys($user, $trashPath, true); |
|
| 142 | + $this->view->deleteAll($trashPath); |
|
| 143 | + } |
|
| 144 | + // delete old folders |
|
| 145 | + $this->deleteOldKeys($user); |
|
| 146 | + $this->view->getMount('/' . $user)->getStorage()->getScanner()->scan('files_encryption'); |
|
| 147 | + } |
|
| 148 | + } |
|
| 149 | + |
|
| 150 | + /** |
|
| 151 | + * update database |
|
| 152 | + */ |
|
| 153 | + public function updateDB() { |
|
| 154 | + |
|
| 155 | + // make sure that we don't update the file cache multiple times |
|
| 156 | + // only update during the first run |
|
| 157 | + if ($this->installedVersion === '-1') { |
|
| 158 | + return; |
|
| 159 | + } |
|
| 160 | + |
|
| 161 | + // delete left-over from old encryption which is no longer needed |
|
| 162 | + $this->config->deleteAppValue('files_encryption', 'ocsid'); |
|
| 163 | + $this->config->deleteAppValue('files_encryption', 'types'); |
|
| 164 | + $this->config->deleteAppValue('files_encryption', 'enabled'); |
|
| 165 | + |
|
| 166 | + $oldAppValues = $this->connection->getQueryBuilder(); |
|
| 167 | + $oldAppValues->select('*') |
|
| 168 | + ->from('appconfig') |
|
| 169 | + ->where($oldAppValues->expr()->eq('appid', $oldAppValues->createParameter('appid'))) |
|
| 170 | + ->setParameter('appid', 'files_encryption'); |
|
| 171 | + $appSettings = $oldAppValues->execute(); |
|
| 172 | + |
|
| 173 | + while ($row = $appSettings->fetch()) { |
|
| 174 | + // 'installed_version' gets deleted at the end of the migration process |
|
| 175 | + if ($row['configkey'] !== 'installed_version' ) { |
|
| 176 | + $this->config->setAppValue('encryption', $row['configkey'], $row['configvalue']); |
|
| 177 | + $this->config->deleteAppValue('files_encryption', $row['configkey']); |
|
| 178 | + } |
|
| 179 | + } |
|
| 180 | + |
|
| 181 | + $oldPreferences = $this->connection->getQueryBuilder(); |
|
| 182 | + $oldPreferences->select('*') |
|
| 183 | + ->from('preferences') |
|
| 184 | + ->where($oldPreferences->expr()->eq('appid', $oldPreferences->createParameter('appid'))) |
|
| 185 | + ->setParameter('appid', 'files_encryption'); |
|
| 186 | + $preferenceSettings = $oldPreferences->execute(); |
|
| 187 | + |
|
| 188 | + while ($row = $preferenceSettings->fetch()) { |
|
| 189 | + $this->config->setUserValue($row['userid'], 'encryption', $row['configkey'], $row['configvalue']); |
|
| 190 | + $this->config->deleteUserValue($row['userid'], 'files_encryption', $row['configkey']); |
|
| 191 | + } |
|
| 192 | + } |
|
| 193 | + |
|
| 194 | + /** |
|
| 195 | + * create backup of system-wide keys |
|
| 196 | + */ |
|
| 197 | + private function backupSystemWideKeys() { |
|
| 198 | + $backupDir = 'encryption_migration_backup_' . date("Y-m-d_H-i-s"); |
|
| 199 | + $this->view->mkdir($backupDir); |
|
| 200 | + $this->view->copy('files_encryption', $backupDir . '/files_encryption'); |
|
| 201 | + } |
|
| 202 | + |
|
| 203 | + /** |
|
| 204 | + * create backup of user specific keys |
|
| 205 | + * |
|
| 206 | + * @param string $user |
|
| 207 | + * @return bool |
|
| 208 | + */ |
|
| 209 | + private function backupUserKeys($user) { |
|
| 210 | + $encryptionDir = $user . '/files_encryption'; |
|
| 211 | + if ($this->view->is_dir($encryptionDir)) { |
|
| 212 | + $backupDir = $user . '/encryption_migration_backup_' . date("Y-m-d_H-i-s"); |
|
| 213 | + $this->view->mkdir($backupDir); |
|
| 214 | + $this->view->copy($encryptionDir, $backupDir); |
|
| 215 | + return true; |
|
| 216 | + } |
|
| 217 | + return false; |
|
| 218 | + } |
|
| 219 | + |
|
| 220 | + /** |
|
| 221 | + * rename system-wide private keys |
|
| 222 | + */ |
|
| 223 | + private function renameSystemPrivateKeys() { |
|
| 224 | + $dh = $this->view->opendir('files_encryption'); |
|
| 225 | + $this->createPathForKeys('/files_encryption/' . $this->moduleId ); |
|
| 226 | + if (is_resource($dh)) { |
|
| 227 | + while (($privateKey = readdir($dh)) !== false) { |
|
| 228 | + if (!\OC\Files\Filesystem::isIgnoredDir($privateKey) ) { |
|
| 229 | + if (!$this->view->is_dir('/files_encryption/' . $privateKey)) { |
|
| 230 | + $this->view->rename('files_encryption/' . $privateKey, 'files_encryption/' . $this->moduleId . '/' . $privateKey); |
|
| 231 | + $this->renameSystemPublicKey($privateKey); |
|
| 232 | + } |
|
| 233 | + } |
|
| 234 | + } |
|
| 235 | + closedir($dh); |
|
| 236 | + } |
|
| 237 | + } |
|
| 238 | + |
|
| 239 | + /** |
|
| 240 | + * rename system wide public key |
|
| 241 | + * |
|
| 242 | + * @param string $privateKey private key for which we want to rename the corresponding public key |
|
| 243 | + */ |
|
| 244 | + private function renameSystemPublicKey($privateKey) { |
|
| 245 | + $publicKey = substr($privateKey,0 , strrpos($privateKey, '.privateKey')) . '.publicKey'; |
|
| 246 | + $this->view->rename('files_encryption/public_keys/' . $publicKey, 'files_encryption/' . $this->moduleId . '/' . $publicKey); |
|
| 247 | + } |
|
| 248 | + |
|
| 249 | + /** |
|
| 250 | + * rename user-specific private keys |
|
| 251 | + * |
|
| 252 | + * @param string $user |
|
| 253 | + */ |
|
| 254 | + private function renameUsersPrivateKey($user) { |
|
| 255 | + $oldPrivateKey = $user . '/files_encryption/' . $user . '.privateKey'; |
|
| 256 | + $newPrivateKey = $user . '/files_encryption/' . $this->moduleId . '/' . $user . '.privateKey'; |
|
| 257 | + if ($this->view->file_exists($oldPrivateKey)) { |
|
| 258 | + $this->createPathForKeys(dirname($newPrivateKey)); |
|
| 259 | + $this->view->rename($oldPrivateKey, $newPrivateKey); |
|
| 260 | + } |
|
| 261 | + } |
|
| 262 | + |
|
| 263 | + /** |
|
| 264 | + * rename user-specific public keys |
|
| 265 | + * |
|
| 266 | + * @param string $user |
|
| 267 | + */ |
|
| 268 | + private function renameUsersPublicKey($user) { |
|
| 269 | + $oldPublicKey = '/files_encryption/public_keys/' . $user . '.publicKey'; |
|
| 270 | + $newPublicKey = $user . '/files_encryption/' . $this->moduleId . '/' . $user . '.publicKey'; |
|
| 271 | + if ($this->view->file_exists($oldPublicKey)) { |
|
| 272 | + $this->createPathForKeys(dirname($newPublicKey)); |
|
| 273 | + $this->view->rename($oldPublicKey, $newPublicKey); |
|
| 274 | + } |
|
| 275 | + } |
|
| 276 | + |
|
| 277 | + /** |
|
| 278 | + * rename file keys |
|
| 279 | + * |
|
| 280 | + * @param string $user |
|
| 281 | + * @param string $path |
|
| 282 | + * @param bool $trash |
|
| 283 | + */ |
|
| 284 | + private function renameFileKeys($user, $path, $trash = false) { |
|
| 285 | + |
|
| 286 | + if ($this->view->is_dir($user . '/' . $path) === false) { |
|
| 287 | + $this->logger->info('Skip dir /' . $user . '/' . $path . ': does not exist'); |
|
| 288 | + return; |
|
| 289 | + } |
|
| 290 | + |
|
| 291 | + $dh = $this->view->opendir($user . '/' . $path); |
|
| 292 | + |
|
| 293 | + if (is_resource($dh)) { |
|
| 294 | + while (($file = readdir($dh)) !== false) { |
|
| 295 | + if (!\OC\Files\Filesystem::isIgnoredDir($file)) { |
|
| 296 | + if ($this->view->is_dir($user . '/' . $path . '/' . $file)) { |
|
| 297 | + $this->renameFileKeys($user, $path . '/' . $file, $trash); |
|
| 298 | + } else { |
|
| 299 | + $target = $this->getTargetDir($user, $path, $file, $trash); |
|
| 300 | + if ($target !== false) { |
|
| 301 | + $this->createPathForKeys(dirname($target)); |
|
| 302 | + $this->view->rename($user . '/' . $path . '/' . $file, $target); |
|
| 303 | + } else { |
|
| 304 | + $this->logger->warning( |
|
| 305 | + 'did not move key "' . $file |
|
| 306 | + . '" could not find the corresponding file in /data/' . $user . '/files.' |
|
| 307 | + . 'Most likely the key was already moved in a previous migration run and is already on the right place.'); |
|
| 308 | + } |
|
| 309 | + } |
|
| 310 | + } |
|
| 311 | + } |
|
| 312 | + closedir($dh); |
|
| 313 | + } |
|
| 314 | + } |
|
| 315 | + |
|
| 316 | + /** |
|
| 317 | + * get system mount points |
|
| 318 | + * wrap static method so that it can be mocked for testing |
|
| 319 | + * |
|
| 320 | + * @internal |
|
| 321 | + * @return array |
|
| 322 | + */ |
|
| 323 | + protected function getSystemMountPoints() { |
|
| 324 | + return \OC_Mount_Config::getSystemMountPoints(); |
|
| 325 | + } |
|
| 326 | + |
|
| 327 | + /** |
|
| 328 | + * generate target directory |
|
| 329 | + * |
|
| 330 | + * @param string $user |
|
| 331 | + * @param string $keyPath |
|
| 332 | + * @param string $filename |
|
| 333 | + * @param bool $trash |
|
| 334 | + * @return string |
|
| 335 | + */ |
|
| 336 | + private function getTargetDir($user, $keyPath, $filename, $trash) { |
|
| 337 | + if ($trash) { |
|
| 338 | + $filePath = substr($keyPath, strlen('/files_trashbin/keys/')); |
|
| 339 | + $targetDir = $user . '/files_encryption/keys/files_trashbin/' . $filePath . '/' . $this->moduleId . '/' . $filename; |
|
| 340 | + } else { |
|
| 341 | + $filePath = substr($keyPath, strlen('/files_encryption/keys/')); |
|
| 342 | + $targetDir = $user . '/files_encryption/keys/files/' . $filePath . '/' . $this->moduleId . '/' . $filename; |
|
| 343 | + } |
|
| 344 | + |
|
| 345 | + if ($user === '') { |
|
| 346 | + // for system wide mounts we need to check if the mount point really exists |
|
| 347 | + $normalized = \OC\Files\Filesystem::normalizePath($filePath); |
|
| 348 | + $systemMountPoints = $this->getSystemMountPoints(); |
|
| 349 | + foreach ($systemMountPoints as $mountPoint) { |
|
| 350 | + $normalizedMountPoint = \OC\Files\Filesystem::normalizePath($mountPoint['mountpoint']) . '/'; |
|
| 351 | + if (strpos($normalized, $normalizedMountPoint) === 0) |
|
| 352 | + return $targetDir; |
|
| 353 | + } |
|
| 354 | + } else if ($trash === false && $this->view->file_exists('/' . $user. '/files/' . $filePath)) { |
|
| 355 | + return $targetDir; |
|
| 356 | + } else if ($trash === true && $this->view->file_exists('/' . $user. '/files_trashbin/' . $filePath)) { |
|
| 357 | + return $targetDir; |
|
| 358 | + } |
|
| 359 | + |
|
| 360 | + return false; |
|
| 361 | + } |
|
| 362 | + |
|
| 363 | + /** |
|
| 364 | + * delete old keys |
|
| 365 | + * |
|
| 366 | + * @param string $user |
|
| 367 | + */ |
|
| 368 | + private function deleteOldKeys($user) { |
|
| 369 | + $this->view->deleteAll($user . '/files_encryption/keyfiles'); |
|
| 370 | + $this->view->deleteAll($user . '/files_encryption/share-keys'); |
|
| 371 | + } |
|
| 372 | + |
|
| 373 | + /** |
|
| 374 | + * create directories for the keys recursively |
|
| 375 | + * |
|
| 376 | + * @param string $path |
|
| 377 | + */ |
|
| 378 | + private function createPathForKeys($path) { |
|
| 379 | + if (!$this->view->file_exists($path)) { |
|
| 380 | + $sub_dirs = explode('/', $path); |
|
| 381 | + $dir = ''; |
|
| 382 | + foreach ($sub_dirs as $sub_dir) { |
|
| 383 | + $dir .= '/' . $sub_dir; |
|
| 384 | + if (!$this->view->is_dir($dir)) { |
|
| 385 | + $this->view->mkdir($dir); |
|
| 386 | + } |
|
| 387 | + } |
|
| 388 | + } |
|
| 389 | + } |
|
| 390 | 390 | } |
@@ -32,58 +32,58 @@ |
||
| 32 | 32 | use OCP\IUserSession; |
| 33 | 33 | |
| 34 | 34 | class Setup { |
| 35 | - /** |
|
| 36 | - * @var Crypt |
|
| 37 | - */ |
|
| 38 | - private $crypt; |
|
| 39 | - /** |
|
| 40 | - * @var KeyManager |
|
| 41 | - */ |
|
| 42 | - private $keyManager; |
|
| 43 | - /** |
|
| 44 | - * @var ILogger |
|
| 45 | - */ |
|
| 46 | - private $logger; |
|
| 47 | - /** |
|
| 48 | - * @var bool|string |
|
| 49 | - */ |
|
| 50 | - private $user; |
|
| 35 | + /** |
|
| 36 | + * @var Crypt |
|
| 37 | + */ |
|
| 38 | + private $crypt; |
|
| 39 | + /** |
|
| 40 | + * @var KeyManager |
|
| 41 | + */ |
|
| 42 | + private $keyManager; |
|
| 43 | + /** |
|
| 44 | + * @var ILogger |
|
| 45 | + */ |
|
| 46 | + private $logger; |
|
| 47 | + /** |
|
| 48 | + * @var bool|string |
|
| 49 | + */ |
|
| 50 | + private $user; |
|
| 51 | 51 | |
| 52 | 52 | |
| 53 | - /** |
|
| 54 | - * @param ILogger $logger |
|
| 55 | - * @param IUserSession $userSession |
|
| 56 | - * @param Crypt $crypt |
|
| 57 | - * @param KeyManager $keyManager |
|
| 58 | - */ |
|
| 59 | - public function __construct(ILogger $logger, |
|
| 60 | - IUserSession $userSession, |
|
| 61 | - Crypt $crypt, |
|
| 62 | - KeyManager $keyManager) { |
|
| 63 | - $this->logger = $logger; |
|
| 64 | - $this->user = $userSession && $userSession->isLoggedIn() ? $userSession->getUser()->getUID() : false; |
|
| 65 | - $this->crypt = $crypt; |
|
| 66 | - $this->keyManager = $keyManager; |
|
| 67 | - } |
|
| 53 | + /** |
|
| 54 | + * @param ILogger $logger |
|
| 55 | + * @param IUserSession $userSession |
|
| 56 | + * @param Crypt $crypt |
|
| 57 | + * @param KeyManager $keyManager |
|
| 58 | + */ |
|
| 59 | + public function __construct(ILogger $logger, |
|
| 60 | + IUserSession $userSession, |
|
| 61 | + Crypt $crypt, |
|
| 62 | + KeyManager $keyManager) { |
|
| 63 | + $this->logger = $logger; |
|
| 64 | + $this->user = $userSession && $userSession->isLoggedIn() ? $userSession->getUser()->getUID() : false; |
|
| 65 | + $this->crypt = $crypt; |
|
| 66 | + $this->keyManager = $keyManager; |
|
| 67 | + } |
|
| 68 | 68 | |
| 69 | - /** |
|
| 70 | - * @param string $uid user id |
|
| 71 | - * @param string $password user password |
|
| 72 | - * @return bool |
|
| 73 | - */ |
|
| 74 | - public function setupUser($uid, $password) { |
|
| 75 | - if (!$this->keyManager->userHasKeys($uid)) { |
|
| 76 | - return $this->keyManager->storeKeyPair($uid, $password, |
|
| 77 | - $this->crypt->createKeyPair()); |
|
| 78 | - } |
|
| 79 | - return true; |
|
| 80 | - } |
|
| 69 | + /** |
|
| 70 | + * @param string $uid user id |
|
| 71 | + * @param string $password user password |
|
| 72 | + * @return bool |
|
| 73 | + */ |
|
| 74 | + public function setupUser($uid, $password) { |
|
| 75 | + if (!$this->keyManager->userHasKeys($uid)) { |
|
| 76 | + return $this->keyManager->storeKeyPair($uid, $password, |
|
| 77 | + $this->crypt->createKeyPair()); |
|
| 78 | + } |
|
| 79 | + return true; |
|
| 80 | + } |
|
| 81 | 81 | |
| 82 | - /** |
|
| 83 | - * make sure that all system keys exists |
|
| 84 | - */ |
|
| 85 | - public function setupSystem() { |
|
| 86 | - $this->keyManager->validateShareKey(); |
|
| 87 | - $this->keyManager->validateMasterKey(); |
|
| 88 | - } |
|
| 82 | + /** |
|
| 83 | + * make sure that all system keys exists |
|
| 84 | + */ |
|
| 85 | + public function setupSystem() { |
|
| 86 | + $this->keyManager->validateShareKey(); |
|
| 87 | + $this->keyManager->validateMasterKey(); |
|
| 88 | + } |
|
| 89 | 89 | } |
@@ -38,129 +38,129 @@ |
||
| 38 | 38 | |
| 39 | 39 | class SettingsController extends Controller { |
| 40 | 40 | |
| 41 | - /** @var IL10N */ |
|
| 42 | - private $l; |
|
| 43 | - |
|
| 44 | - /** @var IUserManager */ |
|
| 45 | - private $userManager; |
|
| 46 | - |
|
| 47 | - /** @var IUserSession */ |
|
| 48 | - private $userSession; |
|
| 49 | - |
|
| 50 | - /** @var KeyManager */ |
|
| 51 | - private $keyManager; |
|
| 52 | - |
|
| 53 | - /** @var Crypt */ |
|
| 54 | - private $crypt; |
|
| 55 | - |
|
| 56 | - /** @var Session */ |
|
| 57 | - private $session; |
|
| 58 | - |
|
| 59 | - /** @var ISession */ |
|
| 60 | - private $ocSession; |
|
| 61 | - |
|
| 62 | - /** @var Util */ |
|
| 63 | - private $util; |
|
| 64 | - |
|
| 65 | - /** |
|
| 66 | - * @param string $AppName |
|
| 67 | - * @param IRequest $request |
|
| 68 | - * @param IL10N $l10n |
|
| 69 | - * @param IUserManager $userManager |
|
| 70 | - * @param IUserSession $userSession |
|
| 71 | - * @param KeyManager $keyManager |
|
| 72 | - * @param Crypt $crypt |
|
| 73 | - * @param Session $session |
|
| 74 | - * @param ISession $ocSession |
|
| 75 | - * @param Util $util |
|
| 76 | - */ |
|
| 77 | - public function __construct($AppName, |
|
| 78 | - IRequest $request, |
|
| 79 | - IL10N $l10n, |
|
| 80 | - IUserManager $userManager, |
|
| 81 | - IUserSession $userSession, |
|
| 82 | - KeyManager $keyManager, |
|
| 83 | - Crypt $crypt, |
|
| 84 | - Session $session, |
|
| 85 | - ISession $ocSession, |
|
| 86 | - Util $util |
|
| 41 | + /** @var IL10N */ |
|
| 42 | + private $l; |
|
| 43 | + |
|
| 44 | + /** @var IUserManager */ |
|
| 45 | + private $userManager; |
|
| 46 | + |
|
| 47 | + /** @var IUserSession */ |
|
| 48 | + private $userSession; |
|
| 49 | + |
|
| 50 | + /** @var KeyManager */ |
|
| 51 | + private $keyManager; |
|
| 52 | + |
|
| 53 | + /** @var Crypt */ |
|
| 54 | + private $crypt; |
|
| 55 | + |
|
| 56 | + /** @var Session */ |
|
| 57 | + private $session; |
|
| 58 | + |
|
| 59 | + /** @var ISession */ |
|
| 60 | + private $ocSession; |
|
| 61 | + |
|
| 62 | + /** @var Util */ |
|
| 63 | + private $util; |
|
| 64 | + |
|
| 65 | + /** |
|
| 66 | + * @param string $AppName |
|
| 67 | + * @param IRequest $request |
|
| 68 | + * @param IL10N $l10n |
|
| 69 | + * @param IUserManager $userManager |
|
| 70 | + * @param IUserSession $userSession |
|
| 71 | + * @param KeyManager $keyManager |
|
| 72 | + * @param Crypt $crypt |
|
| 73 | + * @param Session $session |
|
| 74 | + * @param ISession $ocSession |
|
| 75 | + * @param Util $util |
|
| 76 | + */ |
|
| 77 | + public function __construct($AppName, |
|
| 78 | + IRequest $request, |
|
| 79 | + IL10N $l10n, |
|
| 80 | + IUserManager $userManager, |
|
| 81 | + IUserSession $userSession, |
|
| 82 | + KeyManager $keyManager, |
|
| 83 | + Crypt $crypt, |
|
| 84 | + Session $session, |
|
| 85 | + ISession $ocSession, |
|
| 86 | + Util $util |
|
| 87 | 87 | ) { |
| 88 | - parent::__construct($AppName, $request); |
|
| 89 | - $this->l = $l10n; |
|
| 90 | - $this->userSession = $userSession; |
|
| 91 | - $this->userManager = $userManager; |
|
| 92 | - $this->keyManager = $keyManager; |
|
| 93 | - $this->crypt = $crypt; |
|
| 94 | - $this->session = $session; |
|
| 95 | - $this->ocSession = $ocSession; |
|
| 96 | - $this->util = $util; |
|
| 97 | - } |
|
| 98 | - |
|
| 99 | - |
|
| 100 | - /** |
|
| 101 | - * @NoAdminRequired |
|
| 102 | - * @UseSession |
|
| 103 | - * |
|
| 104 | - * @param string $oldPassword |
|
| 105 | - * @param string $newPassword |
|
| 106 | - * @return DataResponse |
|
| 107 | - */ |
|
| 108 | - public function updatePrivateKeyPassword($oldPassword, $newPassword) { |
|
| 109 | - $result = false; |
|
| 110 | - $uid = $this->userSession->getUser()->getUID(); |
|
| 111 | - $errorMessage = $this->l->t('Could not update the private key password.'); |
|
| 112 | - |
|
| 113 | - //check if password is correct |
|
| 114 | - $passwordCorrect = $this->userManager->checkPassword($uid, $newPassword); |
|
| 115 | - if ($passwordCorrect === false) { |
|
| 116 | - // if check with uid fails we need to check the password with the login name |
|
| 117 | - // e.g. in the ldap case. For local user we need to check the password with |
|
| 118 | - // the uid because in this case the login name is case insensitive |
|
| 119 | - $loginName = $this->ocSession->get('loginname'); |
|
| 120 | - $passwordCorrect = $this->userManager->checkPassword($loginName, $newPassword); |
|
| 121 | - } |
|
| 122 | - |
|
| 123 | - if ($passwordCorrect !== false) { |
|
| 124 | - $encryptedKey = $this->keyManager->getPrivateKey($uid); |
|
| 125 | - $decryptedKey = $this->crypt->decryptPrivateKey($encryptedKey, $oldPassword, $uid); |
|
| 126 | - |
|
| 127 | - if ($decryptedKey) { |
|
| 128 | - $encryptedKey = $this->crypt->encryptPrivateKey($decryptedKey, $newPassword, $uid); |
|
| 129 | - $header = $this->crypt->generateHeader(); |
|
| 130 | - if ($encryptedKey) { |
|
| 131 | - $this->keyManager->setPrivateKey($uid, $header . $encryptedKey); |
|
| 132 | - $this->session->setPrivateKey($decryptedKey); |
|
| 133 | - $result = true; |
|
| 134 | - } |
|
| 135 | - } else { |
|
| 136 | - $errorMessage = $this->l->t('The old password was not correct, please try again.'); |
|
| 137 | - } |
|
| 138 | - } else { |
|
| 139 | - $errorMessage = $this->l->t('The current log-in password was not correct, please try again.'); |
|
| 140 | - } |
|
| 141 | - |
|
| 142 | - if ($result === true) { |
|
| 143 | - $this->session->setStatus(Session::INIT_SUCCESSFUL); |
|
| 144 | - return new DataResponse( |
|
| 145 | - ['message' => (string) $this->l->t('Private key password successfully updated.')] |
|
| 146 | - ); |
|
| 147 | - } else { |
|
| 148 | - return new DataResponse( |
|
| 149 | - ['message' => (string) $errorMessage], |
|
| 150 | - Http::STATUS_BAD_REQUEST |
|
| 151 | - ); |
|
| 152 | - } |
|
| 153 | - |
|
| 154 | - } |
|
| 155 | - |
|
| 156 | - /** |
|
| 157 | - * @UseSession |
|
| 158 | - * |
|
| 159 | - * @param bool $encryptHomeStorage |
|
| 160 | - * @return DataResponse |
|
| 161 | - */ |
|
| 162 | - public function setEncryptHomeStorage($encryptHomeStorage) { |
|
| 163 | - $this->util->setEncryptHomeStorage($encryptHomeStorage); |
|
| 164 | - return new DataResponse(); |
|
| 165 | - } |
|
| 88 | + parent::__construct($AppName, $request); |
|
| 89 | + $this->l = $l10n; |
|
| 90 | + $this->userSession = $userSession; |
|
| 91 | + $this->userManager = $userManager; |
|
| 92 | + $this->keyManager = $keyManager; |
|
| 93 | + $this->crypt = $crypt; |
|
| 94 | + $this->session = $session; |
|
| 95 | + $this->ocSession = $ocSession; |
|
| 96 | + $this->util = $util; |
|
| 97 | + } |
|
| 98 | + |
|
| 99 | + |
|
| 100 | + /** |
|
| 101 | + * @NoAdminRequired |
|
| 102 | + * @UseSession |
|
| 103 | + * |
|
| 104 | + * @param string $oldPassword |
|
| 105 | + * @param string $newPassword |
|
| 106 | + * @return DataResponse |
|
| 107 | + */ |
|
| 108 | + public function updatePrivateKeyPassword($oldPassword, $newPassword) { |
|
| 109 | + $result = false; |
|
| 110 | + $uid = $this->userSession->getUser()->getUID(); |
|
| 111 | + $errorMessage = $this->l->t('Could not update the private key password.'); |
|
| 112 | + |
|
| 113 | + //check if password is correct |
|
| 114 | + $passwordCorrect = $this->userManager->checkPassword($uid, $newPassword); |
|
| 115 | + if ($passwordCorrect === false) { |
|
| 116 | + // if check with uid fails we need to check the password with the login name |
|
| 117 | + // e.g. in the ldap case. For local user we need to check the password with |
|
| 118 | + // the uid because in this case the login name is case insensitive |
|
| 119 | + $loginName = $this->ocSession->get('loginname'); |
|
| 120 | + $passwordCorrect = $this->userManager->checkPassword($loginName, $newPassword); |
|
| 121 | + } |
|
| 122 | + |
|
| 123 | + if ($passwordCorrect !== false) { |
|
| 124 | + $encryptedKey = $this->keyManager->getPrivateKey($uid); |
|
| 125 | + $decryptedKey = $this->crypt->decryptPrivateKey($encryptedKey, $oldPassword, $uid); |
|
| 126 | + |
|
| 127 | + if ($decryptedKey) { |
|
| 128 | + $encryptedKey = $this->crypt->encryptPrivateKey($decryptedKey, $newPassword, $uid); |
|
| 129 | + $header = $this->crypt->generateHeader(); |
|
| 130 | + if ($encryptedKey) { |
|
| 131 | + $this->keyManager->setPrivateKey($uid, $header . $encryptedKey); |
|
| 132 | + $this->session->setPrivateKey($decryptedKey); |
|
| 133 | + $result = true; |
|
| 134 | + } |
|
| 135 | + } else { |
|
| 136 | + $errorMessage = $this->l->t('The old password was not correct, please try again.'); |
|
| 137 | + } |
|
| 138 | + } else { |
|
| 139 | + $errorMessage = $this->l->t('The current log-in password was not correct, please try again.'); |
|
| 140 | + } |
|
| 141 | + |
|
| 142 | + if ($result === true) { |
|
| 143 | + $this->session->setStatus(Session::INIT_SUCCESSFUL); |
|
| 144 | + return new DataResponse( |
|
| 145 | + ['message' => (string) $this->l->t('Private key password successfully updated.')] |
|
| 146 | + ); |
|
| 147 | + } else { |
|
| 148 | + return new DataResponse( |
|
| 149 | + ['message' => (string) $errorMessage], |
|
| 150 | + Http::STATUS_BAD_REQUEST |
|
| 151 | + ); |
|
| 152 | + } |
|
| 153 | + |
|
| 154 | + } |
|
| 155 | + |
|
| 156 | + /** |
|
| 157 | + * @UseSession |
|
| 158 | + * |
|
| 159 | + * @param bool $encryptHomeStorage |
|
| 160 | + * @return DataResponse |
|
| 161 | + */ |
|
| 162 | + public function setEncryptHomeStorage($encryptHomeStorage) { |
|
| 163 | + $this->util->setEncryptHomeStorage($encryptHomeStorage); |
|
| 164 | + return new DataResponse(); |
|
| 165 | + } |
|
| 166 | 166 | } |
@@ -34,160 +34,160 @@ |
||
| 34 | 34 | use OCP\AppFramework\Http\DataResponse; |
| 35 | 35 | |
| 36 | 36 | class RecoveryController extends Controller { |
| 37 | - /** |
|
| 38 | - * @var IConfig |
|
| 39 | - */ |
|
| 40 | - private $config; |
|
| 41 | - /** |
|
| 42 | - * @var IL10N |
|
| 43 | - */ |
|
| 44 | - private $l; |
|
| 45 | - /** |
|
| 46 | - * @var Recovery |
|
| 47 | - */ |
|
| 48 | - private $recovery; |
|
| 49 | - |
|
| 50 | - /** |
|
| 51 | - * @param string $AppName |
|
| 52 | - * @param IRequest $request |
|
| 53 | - * @param IConfig $config |
|
| 54 | - * @param IL10N $l10n |
|
| 55 | - * @param Recovery $recovery |
|
| 56 | - */ |
|
| 57 | - public function __construct($AppName, |
|
| 58 | - IRequest $request, |
|
| 59 | - IConfig $config, |
|
| 60 | - IL10N $l10n, |
|
| 61 | - Recovery $recovery) { |
|
| 62 | - parent::__construct($AppName, $request); |
|
| 63 | - $this->config = $config; |
|
| 64 | - $this->l = $l10n; |
|
| 65 | - $this->recovery = $recovery; |
|
| 66 | - } |
|
| 67 | - |
|
| 68 | - /** |
|
| 69 | - * @param string $recoveryPassword |
|
| 70 | - * @param string $confirmPassword |
|
| 71 | - * @param string $adminEnableRecovery |
|
| 72 | - * @return DataResponse |
|
| 73 | - */ |
|
| 74 | - public function adminRecovery($recoveryPassword, $confirmPassword, $adminEnableRecovery) { |
|
| 75 | - // Check if both passwords are the same |
|
| 76 | - if (empty($recoveryPassword)) { |
|
| 77 | - $errorMessage = (string)$this->l->t('Missing recovery key password'); |
|
| 78 | - return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 79 | - Http::STATUS_BAD_REQUEST); |
|
| 80 | - } |
|
| 81 | - |
|
| 82 | - if (empty($confirmPassword)) { |
|
| 83 | - $errorMessage = (string)$this->l->t('Please repeat the recovery key password'); |
|
| 84 | - return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 85 | - Http::STATUS_BAD_REQUEST); |
|
| 86 | - } |
|
| 87 | - |
|
| 88 | - if ($recoveryPassword !== $confirmPassword) { |
|
| 89 | - $errorMessage = (string)$this->l->t('Repeated recovery key password does not match the provided recovery key password'); |
|
| 90 | - return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 91 | - Http::STATUS_BAD_REQUEST); |
|
| 92 | - } |
|
| 93 | - |
|
| 94 | - if (isset($adminEnableRecovery) && $adminEnableRecovery === '1') { |
|
| 95 | - if ($this->recovery->enableAdminRecovery($recoveryPassword)) { |
|
| 96 | - return new DataResponse(['data' => ['message' => (string)$this->l->t('Recovery key successfully enabled')]]); |
|
| 97 | - } |
|
| 98 | - return new DataResponse(['data' => ['message' => (string)$this->l->t('Could not enable recovery key. Please check your recovery key password!')]], Http::STATUS_BAD_REQUEST); |
|
| 99 | - } elseif (isset($adminEnableRecovery) && $adminEnableRecovery === '0') { |
|
| 100 | - if ($this->recovery->disableAdminRecovery($recoveryPassword)) { |
|
| 101 | - return new DataResponse(['data' => ['message' => (string)$this->l->t('Recovery key successfully disabled')]]); |
|
| 102 | - } |
|
| 103 | - return new DataResponse(['data' => ['message' => (string)$this->l->t('Could not disable recovery key. Please check your recovery key password!')]], Http::STATUS_BAD_REQUEST); |
|
| 104 | - } |
|
| 105 | - // this response should never be sent but just in case. |
|
| 106 | - return new DataResponse(['data' => ['message' => (string)$this->l->t('Missing parameters')]], Http::STATUS_BAD_REQUEST); |
|
| 107 | - } |
|
| 108 | - |
|
| 109 | - /** |
|
| 110 | - * @param string $newPassword |
|
| 111 | - * @param string $oldPassword |
|
| 112 | - * @param string $confirmPassword |
|
| 113 | - * @return DataResponse |
|
| 114 | - */ |
|
| 115 | - public function changeRecoveryPassword($newPassword, $oldPassword, $confirmPassword) { |
|
| 116 | - //check if both passwords are the same |
|
| 117 | - if (empty($oldPassword)) { |
|
| 118 | - $errorMessage = (string)$this->l->t('Please provide the old recovery password'); |
|
| 119 | - return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 120 | - } |
|
| 121 | - |
|
| 122 | - if (empty($newPassword)) { |
|
| 123 | - $errorMessage = (string)$this->l->t('Please provide a new recovery password'); |
|
| 124 | - return new DataResponse (['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 125 | - } |
|
| 126 | - |
|
| 127 | - if (empty($confirmPassword)) { |
|
| 128 | - $errorMessage = (string)$this->l->t('Please repeat the new recovery password'); |
|
| 129 | - return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 130 | - } |
|
| 131 | - |
|
| 132 | - if ($newPassword !== $confirmPassword) { |
|
| 133 | - $errorMessage = (string)$this->l->t('Repeated recovery key password does not match the provided recovery key password'); |
|
| 134 | - return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 135 | - } |
|
| 136 | - |
|
| 137 | - $result = $this->recovery->changeRecoveryKeyPassword($newPassword, |
|
| 138 | - $oldPassword); |
|
| 139 | - |
|
| 140 | - if ($result) { |
|
| 141 | - return new DataResponse( |
|
| 142 | - [ |
|
| 143 | - 'data' => [ |
|
| 144 | - 'message' => (string)$this->l->t('Password successfully changed.')] |
|
| 145 | - ] |
|
| 146 | - ); |
|
| 147 | - } |
|
| 148 | - return new DataResponse( |
|
| 149 | - [ |
|
| 150 | - 'data' => [ |
|
| 151 | - 'message' => (string)$this->l->t('Could not change the password. Maybe the old password was not correct.') |
|
| 152 | - ] |
|
| 153 | - ], Http::STATUS_BAD_REQUEST); |
|
| 154 | - } |
|
| 155 | - |
|
| 156 | - /** |
|
| 157 | - * @NoAdminRequired |
|
| 158 | - * |
|
| 159 | - * @param string $userEnableRecovery |
|
| 160 | - * @return DataResponse |
|
| 161 | - */ |
|
| 162 | - public function userSetRecovery($userEnableRecovery) { |
|
| 163 | - if ($userEnableRecovery === '0' || $userEnableRecovery === '1') { |
|
| 164 | - |
|
| 165 | - $result = $this->recovery->setRecoveryForUser($userEnableRecovery); |
|
| 166 | - |
|
| 167 | - if ($result) { |
|
| 168 | - if ($userEnableRecovery === '0') { |
|
| 169 | - return new DataResponse( |
|
| 170 | - [ |
|
| 171 | - 'data' => [ |
|
| 172 | - 'message' => (string)$this->l->t('Recovery Key disabled')] |
|
| 173 | - ] |
|
| 174 | - ); |
|
| 175 | - } |
|
| 176 | - return new DataResponse( |
|
| 177 | - [ |
|
| 178 | - 'data' => [ |
|
| 179 | - 'message' => (string)$this->l->t('Recovery Key enabled')] |
|
| 180 | - ] |
|
| 181 | - ); |
|
| 182 | - } |
|
| 183 | - |
|
| 184 | - } |
|
| 185 | - return new DataResponse( |
|
| 186 | - [ |
|
| 187 | - 'data' => [ |
|
| 188 | - 'message' => (string)$this->l->t('Could not enable the recovery key, please try again or contact your administrator') |
|
| 189 | - ] |
|
| 190 | - ], Http::STATUS_BAD_REQUEST); |
|
| 191 | - } |
|
| 37 | + /** |
|
| 38 | + * @var IConfig |
|
| 39 | + */ |
|
| 40 | + private $config; |
|
| 41 | + /** |
|
| 42 | + * @var IL10N |
|
| 43 | + */ |
|
| 44 | + private $l; |
|
| 45 | + /** |
|
| 46 | + * @var Recovery |
|
| 47 | + */ |
|
| 48 | + private $recovery; |
|
| 49 | + |
|
| 50 | + /** |
|
| 51 | + * @param string $AppName |
|
| 52 | + * @param IRequest $request |
|
| 53 | + * @param IConfig $config |
|
| 54 | + * @param IL10N $l10n |
|
| 55 | + * @param Recovery $recovery |
|
| 56 | + */ |
|
| 57 | + public function __construct($AppName, |
|
| 58 | + IRequest $request, |
|
| 59 | + IConfig $config, |
|
| 60 | + IL10N $l10n, |
|
| 61 | + Recovery $recovery) { |
|
| 62 | + parent::__construct($AppName, $request); |
|
| 63 | + $this->config = $config; |
|
| 64 | + $this->l = $l10n; |
|
| 65 | + $this->recovery = $recovery; |
|
| 66 | + } |
|
| 67 | + |
|
| 68 | + /** |
|
| 69 | + * @param string $recoveryPassword |
|
| 70 | + * @param string $confirmPassword |
|
| 71 | + * @param string $adminEnableRecovery |
|
| 72 | + * @return DataResponse |
|
| 73 | + */ |
|
| 74 | + public function adminRecovery($recoveryPassword, $confirmPassword, $adminEnableRecovery) { |
|
| 75 | + // Check if both passwords are the same |
|
| 76 | + if (empty($recoveryPassword)) { |
|
| 77 | + $errorMessage = (string)$this->l->t('Missing recovery key password'); |
|
| 78 | + return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 79 | + Http::STATUS_BAD_REQUEST); |
|
| 80 | + } |
|
| 81 | + |
|
| 82 | + if (empty($confirmPassword)) { |
|
| 83 | + $errorMessage = (string)$this->l->t('Please repeat the recovery key password'); |
|
| 84 | + return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 85 | + Http::STATUS_BAD_REQUEST); |
|
| 86 | + } |
|
| 87 | + |
|
| 88 | + if ($recoveryPassword !== $confirmPassword) { |
|
| 89 | + $errorMessage = (string)$this->l->t('Repeated recovery key password does not match the provided recovery key password'); |
|
| 90 | + return new DataResponse(['data' => ['message' => $errorMessage]], |
|
| 91 | + Http::STATUS_BAD_REQUEST); |
|
| 92 | + } |
|
| 93 | + |
|
| 94 | + if (isset($adminEnableRecovery) && $adminEnableRecovery === '1') { |
|
| 95 | + if ($this->recovery->enableAdminRecovery($recoveryPassword)) { |
|
| 96 | + return new DataResponse(['data' => ['message' => (string)$this->l->t('Recovery key successfully enabled')]]); |
|
| 97 | + } |
|
| 98 | + return new DataResponse(['data' => ['message' => (string)$this->l->t('Could not enable recovery key. Please check your recovery key password!')]], Http::STATUS_BAD_REQUEST); |
|
| 99 | + } elseif (isset($adminEnableRecovery) && $adminEnableRecovery === '0') { |
|
| 100 | + if ($this->recovery->disableAdminRecovery($recoveryPassword)) { |
|
| 101 | + return new DataResponse(['data' => ['message' => (string)$this->l->t('Recovery key successfully disabled')]]); |
|
| 102 | + } |
|
| 103 | + return new DataResponse(['data' => ['message' => (string)$this->l->t('Could not disable recovery key. Please check your recovery key password!')]], Http::STATUS_BAD_REQUEST); |
|
| 104 | + } |
|
| 105 | + // this response should never be sent but just in case. |
|
| 106 | + return new DataResponse(['data' => ['message' => (string)$this->l->t('Missing parameters')]], Http::STATUS_BAD_REQUEST); |
|
| 107 | + } |
|
| 108 | + |
|
| 109 | + /** |
|
| 110 | + * @param string $newPassword |
|
| 111 | + * @param string $oldPassword |
|
| 112 | + * @param string $confirmPassword |
|
| 113 | + * @return DataResponse |
|
| 114 | + */ |
|
| 115 | + public function changeRecoveryPassword($newPassword, $oldPassword, $confirmPassword) { |
|
| 116 | + //check if both passwords are the same |
|
| 117 | + if (empty($oldPassword)) { |
|
| 118 | + $errorMessage = (string)$this->l->t('Please provide the old recovery password'); |
|
| 119 | + return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 120 | + } |
|
| 121 | + |
|
| 122 | + if (empty($newPassword)) { |
|
| 123 | + $errorMessage = (string)$this->l->t('Please provide a new recovery password'); |
|
| 124 | + return new DataResponse (['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 125 | + } |
|
| 126 | + |
|
| 127 | + if (empty($confirmPassword)) { |
|
| 128 | + $errorMessage = (string)$this->l->t('Please repeat the new recovery password'); |
|
| 129 | + return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 130 | + } |
|
| 131 | + |
|
| 132 | + if ($newPassword !== $confirmPassword) { |
|
| 133 | + $errorMessage = (string)$this->l->t('Repeated recovery key password does not match the provided recovery key password'); |
|
| 134 | + return new DataResponse(['data' => ['message' => $errorMessage]], Http::STATUS_BAD_REQUEST); |
|
| 135 | + } |
|
| 136 | + |
|
| 137 | + $result = $this->recovery->changeRecoveryKeyPassword($newPassword, |
|
| 138 | + $oldPassword); |
|
| 139 | + |
|
| 140 | + if ($result) { |
|
| 141 | + return new DataResponse( |
|
| 142 | + [ |
|
| 143 | + 'data' => [ |
|
| 144 | + 'message' => (string)$this->l->t('Password successfully changed.')] |
|
| 145 | + ] |
|
| 146 | + ); |
|
| 147 | + } |
|
| 148 | + return new DataResponse( |
|
| 149 | + [ |
|
| 150 | + 'data' => [ |
|
| 151 | + 'message' => (string)$this->l->t('Could not change the password. Maybe the old password was not correct.') |
|
| 152 | + ] |
|
| 153 | + ], Http::STATUS_BAD_REQUEST); |
|
| 154 | + } |
|
| 155 | + |
|
| 156 | + /** |
|
| 157 | + * @NoAdminRequired |
|
| 158 | + * |
|
| 159 | + * @param string $userEnableRecovery |
|
| 160 | + * @return DataResponse |
|
| 161 | + */ |
|
| 162 | + public function userSetRecovery($userEnableRecovery) { |
|
| 163 | + if ($userEnableRecovery === '0' || $userEnableRecovery === '1') { |
|
| 164 | + |
|
| 165 | + $result = $this->recovery->setRecoveryForUser($userEnableRecovery); |
|
| 166 | + |
|
| 167 | + if ($result) { |
|
| 168 | + if ($userEnableRecovery === '0') { |
|
| 169 | + return new DataResponse( |
|
| 170 | + [ |
|
| 171 | + 'data' => [ |
|
| 172 | + 'message' => (string)$this->l->t('Recovery Key disabled')] |
|
| 173 | + ] |
|
| 174 | + ); |
|
| 175 | + } |
|
| 176 | + return new DataResponse( |
|
| 177 | + [ |
|
| 178 | + 'data' => [ |
|
| 179 | + 'message' => (string)$this->l->t('Recovery Key enabled')] |
|
| 180 | + ] |
|
| 181 | + ); |
|
| 182 | + } |
|
| 183 | + |
|
| 184 | + } |
|
| 185 | + return new DataResponse( |
|
| 186 | + [ |
|
| 187 | + 'data' => [ |
|
| 188 | + 'message' => (string)$this->l->t('Could not enable the recovery key, please try again or contact your administrator') |
|
| 189 | + ] |
|
| 190 | + ], Http::STATUS_BAD_REQUEST); |
|
| 191 | + } |
|
| 192 | 192 | |
| 193 | 193 | } |
@@ -25,14 +25,14 @@ |
||
| 25 | 25 | |
| 26 | 26 | class PublicKeyMissingException extends GenericEncryptionException { |
| 27 | 27 | |
| 28 | - /** |
|
| 29 | - * @param string $userId |
|
| 30 | - */ |
|
| 31 | - public function __construct($userId) { |
|
| 32 | - if(empty($userId)) { |
|
| 33 | - $userId = "<no-user-id-given>"; |
|
| 34 | - } |
|
| 35 | - parent::__construct("Public Key missing for user: $userId"); |
|
| 36 | - } |
|
| 28 | + /** |
|
| 29 | + * @param string $userId |
|
| 30 | + */ |
|
| 31 | + public function __construct($userId) { |
|
| 32 | + if(empty($userId)) { |
|
| 33 | + $userId = "<no-user-id-given>"; |
|
| 34 | + } |
|
| 35 | + parent::__construct("Public Key missing for user: $userId"); |
|
| 36 | + } |
|
| 37 | 37 | |
| 38 | 38 | } |
@@ -28,14 +28,14 @@ |
||
| 28 | 28 | |
| 29 | 29 | class PrivateKeyMissingException extends GenericEncryptionException { |
| 30 | 30 | |
| 31 | - /** |
|
| 32 | - * @param string $userId |
|
| 33 | - */ |
|
| 34 | - public function __construct($userId) { |
|
| 35 | - if(empty($userId)) { |
|
| 36 | - $userId = "<no-user-id-given>"; |
|
| 37 | - } |
|
| 38 | - parent::__construct("Private Key missing for user: $userId"); |
|
| 39 | - } |
|
| 31 | + /** |
|
| 32 | + * @param string $userId |
|
| 33 | + */ |
|
| 34 | + public function __construct($userId) { |
|
| 35 | + if(empty($userId)) { |
|
| 36 | + $userId = "<no-user-id-given>"; |
|
| 37 | + } |
|
| 38 | + parent::__construct("Private Key missing for user: $userId"); |
|
| 39 | + } |
|
| 40 | 40 | |
| 41 | 41 | } |
@@ -38,293 +38,293 @@ |
||
| 38 | 38 | class Recovery { |
| 39 | 39 | |
| 40 | 40 | |
| 41 | - /** |
|
| 42 | - * @var null|IUser |
|
| 43 | - */ |
|
| 44 | - protected $user; |
|
| 45 | - /** |
|
| 46 | - * @var Crypt |
|
| 47 | - */ |
|
| 48 | - protected $crypt; |
|
| 49 | - /** |
|
| 50 | - * @var ISecureRandom |
|
| 51 | - */ |
|
| 52 | - private $random; |
|
| 53 | - /** |
|
| 54 | - * @var KeyManager |
|
| 55 | - */ |
|
| 56 | - private $keyManager; |
|
| 57 | - /** |
|
| 58 | - * @var IConfig |
|
| 59 | - */ |
|
| 60 | - private $config; |
|
| 61 | - /** |
|
| 62 | - * @var IStorage |
|
| 63 | - */ |
|
| 64 | - private $keyStorage; |
|
| 65 | - /** |
|
| 66 | - * @var View |
|
| 67 | - */ |
|
| 68 | - private $view; |
|
| 69 | - /** |
|
| 70 | - * @var IFile |
|
| 71 | - */ |
|
| 72 | - private $file; |
|
| 73 | - |
|
| 74 | - /** |
|
| 75 | - * @param IUserSession $user |
|
| 76 | - * @param Crypt $crypt |
|
| 77 | - * @param ISecureRandom $random |
|
| 78 | - * @param KeyManager $keyManager |
|
| 79 | - * @param IConfig $config |
|
| 80 | - * @param IStorage $keyStorage |
|
| 81 | - * @param IFile $file |
|
| 82 | - * @param View $view |
|
| 83 | - */ |
|
| 84 | - public function __construct(IUserSession $user, |
|
| 85 | - Crypt $crypt, |
|
| 86 | - ISecureRandom $random, |
|
| 87 | - KeyManager $keyManager, |
|
| 88 | - IConfig $config, |
|
| 89 | - IStorage $keyStorage, |
|
| 90 | - IFile $file, |
|
| 91 | - View $view) { |
|
| 92 | - $this->user = ($user && $user->isLoggedIn()) ? $user->getUser() : false; |
|
| 93 | - $this->crypt = $crypt; |
|
| 94 | - $this->random = $random; |
|
| 95 | - $this->keyManager = $keyManager; |
|
| 96 | - $this->config = $config; |
|
| 97 | - $this->keyStorage = $keyStorage; |
|
| 98 | - $this->view = $view; |
|
| 99 | - $this->file = $file; |
|
| 100 | - } |
|
| 101 | - |
|
| 102 | - /** |
|
| 103 | - * @param string $password |
|
| 104 | - * @return bool |
|
| 105 | - */ |
|
| 106 | - public function enableAdminRecovery($password) { |
|
| 107 | - $appConfig = $this->config; |
|
| 108 | - $keyManager = $this->keyManager; |
|
| 109 | - |
|
| 110 | - if (!$keyManager->recoveryKeyExists()) { |
|
| 111 | - $keyPair = $this->crypt->createKeyPair(); |
|
| 112 | - if(!is_array($keyPair)) { |
|
| 113 | - return false; |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - $this->keyManager->setRecoveryKey($password, $keyPair); |
|
| 117 | - } |
|
| 118 | - |
|
| 119 | - if ($keyManager->checkRecoveryPassword($password)) { |
|
| 120 | - $appConfig->setAppValue('encryption', 'recoveryAdminEnabled', 1); |
|
| 121 | - return true; |
|
| 122 | - } |
|
| 123 | - |
|
| 124 | - return false; |
|
| 125 | - } |
|
| 126 | - |
|
| 127 | - /** |
|
| 128 | - * change recovery key id |
|
| 129 | - * |
|
| 130 | - * @param string $newPassword |
|
| 131 | - * @param string $oldPassword |
|
| 132 | - * @return bool |
|
| 133 | - */ |
|
| 134 | - public function changeRecoveryKeyPassword($newPassword, $oldPassword) { |
|
| 135 | - $recoveryKey = $this->keyManager->getSystemPrivateKey($this->keyManager->getRecoveryKeyId()); |
|
| 136 | - $decryptedRecoveryKey = $this->crypt->decryptPrivateKey($recoveryKey, $oldPassword); |
|
| 137 | - if($decryptedRecoveryKey === false) { |
|
| 138 | - return false; |
|
| 139 | - } |
|
| 140 | - $encryptedRecoveryKey = $this->crypt->encryptPrivateKey($decryptedRecoveryKey, $newPassword); |
|
| 141 | - $header = $this->crypt->generateHeader(); |
|
| 142 | - if ($encryptedRecoveryKey) { |
|
| 143 | - $this->keyManager->setSystemPrivateKey($this->keyManager->getRecoveryKeyId(), $header . $encryptedRecoveryKey); |
|
| 144 | - return true; |
|
| 145 | - } |
|
| 146 | - return false; |
|
| 147 | - } |
|
| 148 | - |
|
| 149 | - /** |
|
| 150 | - * @param string $recoveryPassword |
|
| 151 | - * @return bool |
|
| 152 | - */ |
|
| 153 | - public function disableAdminRecovery($recoveryPassword) { |
|
| 154 | - $keyManager = $this->keyManager; |
|
| 155 | - |
|
| 156 | - if ($keyManager->checkRecoveryPassword($recoveryPassword)) { |
|
| 157 | - // Set recoveryAdmin as disabled |
|
| 158 | - $this->config->setAppValue('encryption', 'recoveryAdminEnabled', 0); |
|
| 159 | - return true; |
|
| 160 | - } |
|
| 161 | - return false; |
|
| 162 | - } |
|
| 163 | - |
|
| 164 | - /** |
|
| 165 | - * check if recovery is enabled for user |
|
| 166 | - * |
|
| 167 | - * @param string $user if no user is given we check the current logged-in user |
|
| 168 | - * |
|
| 169 | - * @return bool |
|
| 170 | - */ |
|
| 171 | - public function isRecoveryEnabledForUser($user = '') { |
|
| 172 | - $uid = empty($user) ? $this->user->getUID() : $user; |
|
| 173 | - $recoveryMode = $this->config->getUserValue($uid, |
|
| 174 | - 'encryption', |
|
| 175 | - 'recoveryEnabled', |
|
| 176 | - 0); |
|
| 177 | - |
|
| 178 | - return ($recoveryMode === '1'); |
|
| 179 | - } |
|
| 180 | - |
|
| 181 | - /** |
|
| 182 | - * check if recovery is key is enabled by the administrator |
|
| 183 | - * |
|
| 184 | - * @return bool |
|
| 185 | - */ |
|
| 186 | - public function isRecoveryKeyEnabled() { |
|
| 187 | - $enabled = $this->config->getAppValue('encryption', 'recoveryAdminEnabled', 0); |
|
| 188 | - |
|
| 189 | - return ($enabled === '1'); |
|
| 190 | - } |
|
| 191 | - |
|
| 192 | - /** |
|
| 193 | - * @param string $value |
|
| 194 | - * @return bool |
|
| 195 | - */ |
|
| 196 | - public function setRecoveryForUser($value) { |
|
| 197 | - |
|
| 198 | - try { |
|
| 199 | - $this->config->setUserValue($this->user->getUID(), |
|
| 200 | - 'encryption', |
|
| 201 | - 'recoveryEnabled', |
|
| 202 | - $value); |
|
| 203 | - |
|
| 204 | - if ($value === '1') { |
|
| 205 | - $this->addRecoveryKeys('/' . $this->user->getUID() . '/files/'); |
|
| 206 | - } else { |
|
| 207 | - $this->removeRecoveryKeys('/' . $this->user->getUID() . '/files/'); |
|
| 208 | - } |
|
| 209 | - |
|
| 210 | - return true; |
|
| 211 | - } catch (PreConditionNotMetException $e) { |
|
| 212 | - return false; |
|
| 213 | - } |
|
| 214 | - } |
|
| 215 | - |
|
| 216 | - /** |
|
| 217 | - * add recovery key to all encrypted files |
|
| 218 | - * @param string $path |
|
| 219 | - */ |
|
| 220 | - private function addRecoveryKeys($path) { |
|
| 221 | - $dirContent = $this->view->getDirectoryContent($path); |
|
| 222 | - foreach ($dirContent as $item) { |
|
| 223 | - $filePath = $item->getPath(); |
|
| 224 | - if ($item['type'] === 'dir') { |
|
| 225 | - $this->addRecoveryKeys($filePath . '/'); |
|
| 226 | - } else { |
|
| 227 | - $fileKey = $this->keyManager->getFileKey($filePath, $this->user->getUID()); |
|
| 228 | - if (!empty($fileKey)) { |
|
| 229 | - $accessList = $this->file->getAccessList($filePath); |
|
| 230 | - $publicKeys = array(); |
|
| 231 | - foreach ($accessList['users'] as $uid) { |
|
| 232 | - $publicKeys[$uid] = $this->keyManager->getPublicKey($uid); |
|
| 233 | - } |
|
| 234 | - |
|
| 235 | - $publicKeys = $this->keyManager->addSystemKeys($accessList, $publicKeys, $this->user->getUID()); |
|
| 236 | - |
|
| 237 | - $encryptedKeyfiles = $this->crypt->multiKeyEncrypt($fileKey, $publicKeys); |
|
| 238 | - $this->keyManager->setAllFileKeys($filePath, $encryptedKeyfiles); |
|
| 239 | - } |
|
| 240 | - } |
|
| 241 | - } |
|
| 242 | - } |
|
| 243 | - |
|
| 244 | - /** |
|
| 245 | - * remove recovery key to all encrypted files |
|
| 246 | - * @param string $path |
|
| 247 | - */ |
|
| 248 | - private function removeRecoveryKeys($path) { |
|
| 249 | - $dirContent = $this->view->getDirectoryContent($path); |
|
| 250 | - foreach ($dirContent as $item) { |
|
| 251 | - $filePath = $item->getPath(); |
|
| 252 | - if ($item['type'] === 'dir') { |
|
| 253 | - $this->removeRecoveryKeys($filePath . '/'); |
|
| 254 | - } else { |
|
| 255 | - $this->keyManager->deleteShareKey($filePath, $this->keyManager->getRecoveryKeyId()); |
|
| 256 | - } |
|
| 257 | - } |
|
| 258 | - } |
|
| 259 | - |
|
| 260 | - /** |
|
| 261 | - * recover users files with the recovery key |
|
| 262 | - * |
|
| 263 | - * @param string $recoveryPassword |
|
| 264 | - * @param string $user |
|
| 265 | - */ |
|
| 266 | - public function recoverUsersFiles($recoveryPassword, $user) { |
|
| 267 | - $encryptedKey = $this->keyManager->getSystemPrivateKey($this->keyManager->getRecoveryKeyId()); |
|
| 268 | - |
|
| 269 | - $privateKey = $this->crypt->decryptPrivateKey($encryptedKey, $recoveryPassword); |
|
| 270 | - if($privateKey !== false) { |
|
| 271 | - $this->recoverAllFiles('/' . $user . '/files/', $privateKey, $user); |
|
| 272 | - } |
|
| 273 | - } |
|
| 274 | - |
|
| 275 | - /** |
|
| 276 | - * recover users files |
|
| 277 | - * |
|
| 278 | - * @param string $path |
|
| 279 | - * @param string $privateKey |
|
| 280 | - * @param string $uid |
|
| 281 | - */ |
|
| 282 | - private function recoverAllFiles($path, $privateKey, $uid) { |
|
| 283 | - $dirContent = $this->view->getDirectoryContent($path); |
|
| 284 | - |
|
| 285 | - foreach ($dirContent as $item) { |
|
| 286 | - // Get relative path from encryption/keyfiles |
|
| 287 | - $filePath = $item->getPath(); |
|
| 288 | - if ($this->view->is_dir($filePath)) { |
|
| 289 | - $this->recoverAllFiles($filePath . '/', $privateKey, $uid); |
|
| 290 | - } else { |
|
| 291 | - $this->recoverFile($filePath, $privateKey, $uid); |
|
| 292 | - } |
|
| 293 | - } |
|
| 294 | - |
|
| 295 | - } |
|
| 296 | - |
|
| 297 | - /** |
|
| 298 | - * recover file |
|
| 299 | - * |
|
| 300 | - * @param string $path |
|
| 301 | - * @param string $privateKey |
|
| 302 | - * @param string $uid |
|
| 303 | - */ |
|
| 304 | - private function recoverFile($path, $privateKey, $uid) { |
|
| 305 | - $encryptedFileKey = $this->keyManager->getEncryptedFileKey($path); |
|
| 306 | - $shareKey = $this->keyManager->getShareKey($path, $this->keyManager->getRecoveryKeyId()); |
|
| 307 | - |
|
| 308 | - if ($encryptedFileKey && $shareKey && $privateKey) { |
|
| 309 | - $fileKey = $this->crypt->multiKeyDecrypt($encryptedFileKey, |
|
| 310 | - $shareKey, |
|
| 311 | - $privateKey); |
|
| 312 | - } |
|
| 313 | - |
|
| 314 | - if (!empty($fileKey)) { |
|
| 315 | - $accessList = $this->file->getAccessList($path); |
|
| 316 | - $publicKeys = array(); |
|
| 317 | - foreach ($accessList['users'] as $user) { |
|
| 318 | - $publicKeys[$user] = $this->keyManager->getPublicKey($user); |
|
| 319 | - } |
|
| 320 | - |
|
| 321 | - $publicKeys = $this->keyManager->addSystemKeys($accessList, $publicKeys, $uid); |
|
| 322 | - |
|
| 323 | - $encryptedKeyfiles = $this->crypt->multiKeyEncrypt($fileKey, $publicKeys); |
|
| 324 | - $this->keyManager->setAllFileKeys($path, $encryptedKeyfiles); |
|
| 325 | - } |
|
| 326 | - |
|
| 327 | - } |
|
| 41 | + /** |
|
| 42 | + * @var null|IUser |
|
| 43 | + */ |
|
| 44 | + protected $user; |
|
| 45 | + /** |
|
| 46 | + * @var Crypt |
|
| 47 | + */ |
|
| 48 | + protected $crypt; |
|
| 49 | + /** |
|
| 50 | + * @var ISecureRandom |
|
| 51 | + */ |
|
| 52 | + private $random; |
|
| 53 | + /** |
|
| 54 | + * @var KeyManager |
|
| 55 | + */ |
|
| 56 | + private $keyManager; |
|
| 57 | + /** |
|
| 58 | + * @var IConfig |
|
| 59 | + */ |
|
| 60 | + private $config; |
|
| 61 | + /** |
|
| 62 | + * @var IStorage |
|
| 63 | + */ |
|
| 64 | + private $keyStorage; |
|
| 65 | + /** |
|
| 66 | + * @var View |
|
| 67 | + */ |
|
| 68 | + private $view; |
|
| 69 | + /** |
|
| 70 | + * @var IFile |
|
| 71 | + */ |
|
| 72 | + private $file; |
|
| 73 | + |
|
| 74 | + /** |
|
| 75 | + * @param IUserSession $user |
|
| 76 | + * @param Crypt $crypt |
|
| 77 | + * @param ISecureRandom $random |
|
| 78 | + * @param KeyManager $keyManager |
|
| 79 | + * @param IConfig $config |
|
| 80 | + * @param IStorage $keyStorage |
|
| 81 | + * @param IFile $file |
|
| 82 | + * @param View $view |
|
| 83 | + */ |
|
| 84 | + public function __construct(IUserSession $user, |
|
| 85 | + Crypt $crypt, |
|
| 86 | + ISecureRandom $random, |
|
| 87 | + KeyManager $keyManager, |
|
| 88 | + IConfig $config, |
|
| 89 | + IStorage $keyStorage, |
|
| 90 | + IFile $file, |
|
| 91 | + View $view) { |
|
| 92 | + $this->user = ($user && $user->isLoggedIn()) ? $user->getUser() : false; |
|
| 93 | + $this->crypt = $crypt; |
|
| 94 | + $this->random = $random; |
|
| 95 | + $this->keyManager = $keyManager; |
|
| 96 | + $this->config = $config; |
|
| 97 | + $this->keyStorage = $keyStorage; |
|
| 98 | + $this->view = $view; |
|
| 99 | + $this->file = $file; |
|
| 100 | + } |
|
| 101 | + |
|
| 102 | + /** |
|
| 103 | + * @param string $password |
|
| 104 | + * @return bool |
|
| 105 | + */ |
|
| 106 | + public function enableAdminRecovery($password) { |
|
| 107 | + $appConfig = $this->config; |
|
| 108 | + $keyManager = $this->keyManager; |
|
| 109 | + |
|
| 110 | + if (!$keyManager->recoveryKeyExists()) { |
|
| 111 | + $keyPair = $this->crypt->createKeyPair(); |
|
| 112 | + if(!is_array($keyPair)) { |
|
| 113 | + return false; |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + $this->keyManager->setRecoveryKey($password, $keyPair); |
|
| 117 | + } |
|
| 118 | + |
|
| 119 | + if ($keyManager->checkRecoveryPassword($password)) { |
|
| 120 | + $appConfig->setAppValue('encryption', 'recoveryAdminEnabled', 1); |
|
| 121 | + return true; |
|
| 122 | + } |
|
| 123 | + |
|
| 124 | + return false; |
|
| 125 | + } |
|
| 126 | + |
|
| 127 | + /** |
|
| 128 | + * change recovery key id |
|
| 129 | + * |
|
| 130 | + * @param string $newPassword |
|
| 131 | + * @param string $oldPassword |
|
| 132 | + * @return bool |
|
| 133 | + */ |
|
| 134 | + public function changeRecoveryKeyPassword($newPassword, $oldPassword) { |
|
| 135 | + $recoveryKey = $this->keyManager->getSystemPrivateKey($this->keyManager->getRecoveryKeyId()); |
|
| 136 | + $decryptedRecoveryKey = $this->crypt->decryptPrivateKey($recoveryKey, $oldPassword); |
|
| 137 | + if($decryptedRecoveryKey === false) { |
|
| 138 | + return false; |
|
| 139 | + } |
|
| 140 | + $encryptedRecoveryKey = $this->crypt->encryptPrivateKey($decryptedRecoveryKey, $newPassword); |
|
| 141 | + $header = $this->crypt->generateHeader(); |
|
| 142 | + if ($encryptedRecoveryKey) { |
|
| 143 | + $this->keyManager->setSystemPrivateKey($this->keyManager->getRecoveryKeyId(), $header . $encryptedRecoveryKey); |
|
| 144 | + return true; |
|
| 145 | + } |
|
| 146 | + return false; |
|
| 147 | + } |
|
| 148 | + |
|
| 149 | + /** |
|
| 150 | + * @param string $recoveryPassword |
|
| 151 | + * @return bool |
|
| 152 | + */ |
|
| 153 | + public function disableAdminRecovery($recoveryPassword) { |
|
| 154 | + $keyManager = $this->keyManager; |
|
| 155 | + |
|
| 156 | + if ($keyManager->checkRecoveryPassword($recoveryPassword)) { |
|
| 157 | + // Set recoveryAdmin as disabled |
|
| 158 | + $this->config->setAppValue('encryption', 'recoveryAdminEnabled', 0); |
|
| 159 | + return true; |
|
| 160 | + } |
|
| 161 | + return false; |
|
| 162 | + } |
|
| 163 | + |
|
| 164 | + /** |
|
| 165 | + * check if recovery is enabled for user |
|
| 166 | + * |
|
| 167 | + * @param string $user if no user is given we check the current logged-in user |
|
| 168 | + * |
|
| 169 | + * @return bool |
|
| 170 | + */ |
|
| 171 | + public function isRecoveryEnabledForUser($user = '') { |
|
| 172 | + $uid = empty($user) ? $this->user->getUID() : $user; |
|
| 173 | + $recoveryMode = $this->config->getUserValue($uid, |
|
| 174 | + 'encryption', |
|
| 175 | + 'recoveryEnabled', |
|
| 176 | + 0); |
|
| 177 | + |
|
| 178 | + return ($recoveryMode === '1'); |
|
| 179 | + } |
|
| 180 | + |
|
| 181 | + /** |
|
| 182 | + * check if recovery is key is enabled by the administrator |
|
| 183 | + * |
|
| 184 | + * @return bool |
|
| 185 | + */ |
|
| 186 | + public function isRecoveryKeyEnabled() { |
|
| 187 | + $enabled = $this->config->getAppValue('encryption', 'recoveryAdminEnabled', 0); |
|
| 188 | + |
|
| 189 | + return ($enabled === '1'); |
|
| 190 | + } |
|
| 191 | + |
|
| 192 | + /** |
|
| 193 | + * @param string $value |
|
| 194 | + * @return bool |
|
| 195 | + */ |
|
| 196 | + public function setRecoveryForUser($value) { |
|
| 197 | + |
|
| 198 | + try { |
|
| 199 | + $this->config->setUserValue($this->user->getUID(), |
|
| 200 | + 'encryption', |
|
| 201 | + 'recoveryEnabled', |
|
| 202 | + $value); |
|
| 203 | + |
|
| 204 | + if ($value === '1') { |
|
| 205 | + $this->addRecoveryKeys('/' . $this->user->getUID() . '/files/'); |
|
| 206 | + } else { |
|
| 207 | + $this->removeRecoveryKeys('/' . $this->user->getUID() . '/files/'); |
|
| 208 | + } |
|
| 209 | + |
|
| 210 | + return true; |
|
| 211 | + } catch (PreConditionNotMetException $e) { |
|
| 212 | + return false; |
|
| 213 | + } |
|
| 214 | + } |
|
| 215 | + |
|
| 216 | + /** |
|
| 217 | + * add recovery key to all encrypted files |
|
| 218 | + * @param string $path |
|
| 219 | + */ |
|
| 220 | + private function addRecoveryKeys($path) { |
|
| 221 | + $dirContent = $this->view->getDirectoryContent($path); |
|
| 222 | + foreach ($dirContent as $item) { |
|
| 223 | + $filePath = $item->getPath(); |
|
| 224 | + if ($item['type'] === 'dir') { |
|
| 225 | + $this->addRecoveryKeys($filePath . '/'); |
|
| 226 | + } else { |
|
| 227 | + $fileKey = $this->keyManager->getFileKey($filePath, $this->user->getUID()); |
|
| 228 | + if (!empty($fileKey)) { |
|
| 229 | + $accessList = $this->file->getAccessList($filePath); |
|
| 230 | + $publicKeys = array(); |
|
| 231 | + foreach ($accessList['users'] as $uid) { |
|
| 232 | + $publicKeys[$uid] = $this->keyManager->getPublicKey($uid); |
|
| 233 | + } |
|
| 234 | + |
|
| 235 | + $publicKeys = $this->keyManager->addSystemKeys($accessList, $publicKeys, $this->user->getUID()); |
|
| 236 | + |
|
| 237 | + $encryptedKeyfiles = $this->crypt->multiKeyEncrypt($fileKey, $publicKeys); |
|
| 238 | + $this->keyManager->setAllFileKeys($filePath, $encryptedKeyfiles); |
|
| 239 | + } |
|
| 240 | + } |
|
| 241 | + } |
|
| 242 | + } |
|
| 243 | + |
|
| 244 | + /** |
|
| 245 | + * remove recovery key to all encrypted files |
|
| 246 | + * @param string $path |
|
| 247 | + */ |
|
| 248 | + private function removeRecoveryKeys($path) { |
|
| 249 | + $dirContent = $this->view->getDirectoryContent($path); |
|
| 250 | + foreach ($dirContent as $item) { |
|
| 251 | + $filePath = $item->getPath(); |
|
| 252 | + if ($item['type'] === 'dir') { |
|
| 253 | + $this->removeRecoveryKeys($filePath . '/'); |
|
| 254 | + } else { |
|
| 255 | + $this->keyManager->deleteShareKey($filePath, $this->keyManager->getRecoveryKeyId()); |
|
| 256 | + } |
|
| 257 | + } |
|
| 258 | + } |
|
| 259 | + |
|
| 260 | + /** |
|
| 261 | + * recover users files with the recovery key |
|
| 262 | + * |
|
| 263 | + * @param string $recoveryPassword |
|
| 264 | + * @param string $user |
|
| 265 | + */ |
|
| 266 | + public function recoverUsersFiles($recoveryPassword, $user) { |
|
| 267 | + $encryptedKey = $this->keyManager->getSystemPrivateKey($this->keyManager->getRecoveryKeyId()); |
|
| 268 | + |
|
| 269 | + $privateKey = $this->crypt->decryptPrivateKey($encryptedKey, $recoveryPassword); |
|
| 270 | + if($privateKey !== false) { |
|
| 271 | + $this->recoverAllFiles('/' . $user . '/files/', $privateKey, $user); |
|
| 272 | + } |
|
| 273 | + } |
|
| 274 | + |
|
| 275 | + /** |
|
| 276 | + * recover users files |
|
| 277 | + * |
|
| 278 | + * @param string $path |
|
| 279 | + * @param string $privateKey |
|
| 280 | + * @param string $uid |
|
| 281 | + */ |
|
| 282 | + private function recoverAllFiles($path, $privateKey, $uid) { |
|
| 283 | + $dirContent = $this->view->getDirectoryContent($path); |
|
| 284 | + |
|
| 285 | + foreach ($dirContent as $item) { |
|
| 286 | + // Get relative path from encryption/keyfiles |
|
| 287 | + $filePath = $item->getPath(); |
|
| 288 | + if ($this->view->is_dir($filePath)) { |
|
| 289 | + $this->recoverAllFiles($filePath . '/', $privateKey, $uid); |
|
| 290 | + } else { |
|
| 291 | + $this->recoverFile($filePath, $privateKey, $uid); |
|
| 292 | + } |
|
| 293 | + } |
|
| 294 | + |
|
| 295 | + } |
|
| 296 | + |
|
| 297 | + /** |
|
| 298 | + * recover file |
|
| 299 | + * |
|
| 300 | + * @param string $path |
|
| 301 | + * @param string $privateKey |
|
| 302 | + * @param string $uid |
|
| 303 | + */ |
|
| 304 | + private function recoverFile($path, $privateKey, $uid) { |
|
| 305 | + $encryptedFileKey = $this->keyManager->getEncryptedFileKey($path); |
|
| 306 | + $shareKey = $this->keyManager->getShareKey($path, $this->keyManager->getRecoveryKeyId()); |
|
| 307 | + |
|
| 308 | + if ($encryptedFileKey && $shareKey && $privateKey) { |
|
| 309 | + $fileKey = $this->crypt->multiKeyDecrypt($encryptedFileKey, |
|
| 310 | + $shareKey, |
|
| 311 | + $privateKey); |
|
| 312 | + } |
|
| 313 | + |
|
| 314 | + if (!empty($fileKey)) { |
|
| 315 | + $accessList = $this->file->getAccessList($path); |
|
| 316 | + $publicKeys = array(); |
|
| 317 | + foreach ($accessList['users'] as $user) { |
|
| 318 | + $publicKeys[$user] = $this->keyManager->getPublicKey($user); |
|
| 319 | + } |
|
| 320 | + |
|
| 321 | + $publicKeys = $this->keyManager->addSystemKeys($accessList, $publicKeys, $uid); |
|
| 322 | + |
|
| 323 | + $encryptedKeyfiles = $this->crypt->multiKeyEncrypt($fileKey, $publicKeys); |
|
| 324 | + $this->keyManager->setAllFileKeys($path, $encryptedKeyfiles); |
|
| 325 | + } |
|
| 326 | + |
|
| 327 | + } |
|
| 328 | 328 | |
| 329 | 329 | |
| 330 | 330 | } |
@@ -36,91 +36,91 @@ |
||
| 36 | 36 | |
| 37 | 37 | class MigrateKeys extends Command { |
| 38 | 38 | |
| 39 | - /** @var IUserManager */ |
|
| 40 | - private $userManager; |
|
| 41 | - /** @var View */ |
|
| 42 | - private $view; |
|
| 43 | - /** @var IDBConnection */ |
|
| 44 | - private $connection; |
|
| 45 | - /** @var IConfig */ |
|
| 46 | - private $config; |
|
| 47 | - /** @var ILogger */ |
|
| 48 | - private $logger; |
|
| 39 | + /** @var IUserManager */ |
|
| 40 | + private $userManager; |
|
| 41 | + /** @var View */ |
|
| 42 | + private $view; |
|
| 43 | + /** @var IDBConnection */ |
|
| 44 | + private $connection; |
|
| 45 | + /** @var IConfig */ |
|
| 46 | + private $config; |
|
| 47 | + /** @var ILogger */ |
|
| 48 | + private $logger; |
|
| 49 | 49 | |
| 50 | - /** |
|
| 51 | - * @param IUserManager $userManager |
|
| 52 | - * @param View $view |
|
| 53 | - * @param IDBConnection $connection |
|
| 54 | - * @param IConfig $config |
|
| 55 | - * @param ILogger $logger |
|
| 56 | - */ |
|
| 57 | - public function __construct(IUserManager $userManager, |
|
| 58 | - View $view, |
|
| 59 | - IDBConnection $connection, |
|
| 60 | - IConfig $config, |
|
| 61 | - ILogger $logger) { |
|
| 50 | + /** |
|
| 51 | + * @param IUserManager $userManager |
|
| 52 | + * @param View $view |
|
| 53 | + * @param IDBConnection $connection |
|
| 54 | + * @param IConfig $config |
|
| 55 | + * @param ILogger $logger |
|
| 56 | + */ |
|
| 57 | + public function __construct(IUserManager $userManager, |
|
| 58 | + View $view, |
|
| 59 | + IDBConnection $connection, |
|
| 60 | + IConfig $config, |
|
| 61 | + ILogger $logger) { |
|
| 62 | 62 | |
| 63 | - $this->userManager = $userManager; |
|
| 64 | - $this->view = $view; |
|
| 65 | - $this->connection = $connection; |
|
| 66 | - $this->config = $config; |
|
| 67 | - $this->logger = $logger; |
|
| 68 | - parent::__construct(); |
|
| 69 | - } |
|
| 63 | + $this->userManager = $userManager; |
|
| 64 | + $this->view = $view; |
|
| 65 | + $this->connection = $connection; |
|
| 66 | + $this->config = $config; |
|
| 67 | + $this->logger = $logger; |
|
| 68 | + parent::__construct(); |
|
| 69 | + } |
|
| 70 | 70 | |
| 71 | - protected function configure() { |
|
| 72 | - $this |
|
| 73 | - ->setName('encryption:migrate') |
|
| 74 | - ->setDescription('initial migration to encryption 2.0') |
|
| 75 | - ->addArgument( |
|
| 76 | - 'user_id', |
|
| 77 | - InputArgument::OPTIONAL | InputArgument::IS_ARRAY, |
|
| 78 | - 'will migrate keys of the given user(s)' |
|
| 79 | - ); |
|
| 80 | - } |
|
| 71 | + protected function configure() { |
|
| 72 | + $this |
|
| 73 | + ->setName('encryption:migrate') |
|
| 74 | + ->setDescription('initial migration to encryption 2.0') |
|
| 75 | + ->addArgument( |
|
| 76 | + 'user_id', |
|
| 77 | + InputArgument::OPTIONAL | InputArgument::IS_ARRAY, |
|
| 78 | + 'will migrate keys of the given user(s)' |
|
| 79 | + ); |
|
| 80 | + } |
|
| 81 | 81 | |
| 82 | - protected function execute(InputInterface $input, OutputInterface $output) { |
|
| 82 | + protected function execute(InputInterface $input, OutputInterface $output) { |
|
| 83 | 83 | |
| 84 | - // perform system reorganization |
|
| 85 | - $migration = new Migration($this->config, $this->view, $this->connection, $this->logger); |
|
| 84 | + // perform system reorganization |
|
| 85 | + $migration = new Migration($this->config, $this->view, $this->connection, $this->logger); |
|
| 86 | 86 | |
| 87 | - $users = $input->getArgument('user_id'); |
|
| 88 | - if (!empty($users)) { |
|
| 89 | - foreach ($users as $user) { |
|
| 90 | - if ($this->userManager->userExists($user)) { |
|
| 91 | - $output->writeln("Migrating keys <info>$user</info>"); |
|
| 92 | - $migration->reorganizeFolderStructureForUser($user); |
|
| 93 | - } else { |
|
| 94 | - $output->writeln("<error>Unknown user $user</error>"); |
|
| 95 | - } |
|
| 96 | - } |
|
| 97 | - } else { |
|
| 98 | - $output->writeln("Reorganize system folder structure"); |
|
| 99 | - $migration->reorganizeSystemFolderStructure(); |
|
| 100 | - $migration->updateDB(); |
|
| 101 | - foreach($this->userManager->getBackends() as $backend) { |
|
| 102 | - $name = get_class($backend); |
|
| 87 | + $users = $input->getArgument('user_id'); |
|
| 88 | + if (!empty($users)) { |
|
| 89 | + foreach ($users as $user) { |
|
| 90 | + if ($this->userManager->userExists($user)) { |
|
| 91 | + $output->writeln("Migrating keys <info>$user</info>"); |
|
| 92 | + $migration->reorganizeFolderStructureForUser($user); |
|
| 93 | + } else { |
|
| 94 | + $output->writeln("<error>Unknown user $user</error>"); |
|
| 95 | + } |
|
| 96 | + } |
|
| 97 | + } else { |
|
| 98 | + $output->writeln("Reorganize system folder structure"); |
|
| 99 | + $migration->reorganizeSystemFolderStructure(); |
|
| 100 | + $migration->updateDB(); |
|
| 101 | + foreach($this->userManager->getBackends() as $backend) { |
|
| 102 | + $name = get_class($backend); |
|
| 103 | 103 | |
| 104 | - if ($backend instanceof IUserBackend) { |
|
| 105 | - $name = $backend->getBackendName(); |
|
| 106 | - } |
|
| 104 | + if ($backend instanceof IUserBackend) { |
|
| 105 | + $name = $backend->getBackendName(); |
|
| 106 | + } |
|
| 107 | 107 | |
| 108 | - $output->writeln("Migrating keys for users on backend <info>$name</info>"); |
|
| 108 | + $output->writeln("Migrating keys for users on backend <info>$name</info>"); |
|
| 109 | 109 | |
| 110 | - $limit = 500; |
|
| 111 | - $offset = 0; |
|
| 112 | - do { |
|
| 113 | - $users = $backend->getUsers('', $limit, $offset); |
|
| 114 | - foreach ($users as $user) { |
|
| 115 | - $output->writeln(" <info>$user</info>"); |
|
| 116 | - $migration->reorganizeFolderStructureForUser($user); |
|
| 117 | - } |
|
| 118 | - $offset += $limit; |
|
| 119 | - } while(count($users) >= $limit); |
|
| 120 | - } |
|
| 121 | - } |
|
| 110 | + $limit = 500; |
|
| 111 | + $offset = 0; |
|
| 112 | + do { |
|
| 113 | + $users = $backend->getUsers('', $limit, $offset); |
|
| 114 | + foreach ($users as $user) { |
|
| 115 | + $output->writeln(" <info>$user</info>"); |
|
| 116 | + $migration->reorganizeFolderStructureForUser($user); |
|
| 117 | + } |
|
| 118 | + $offset += $limit; |
|
| 119 | + } while(count($users) >= $limit); |
|
| 120 | + } |
|
| 121 | + } |
|
| 122 | 122 | |
| 123 | - $migration->finalCleanUp(); |
|
| 123 | + $migration->finalCleanUp(); |
|
| 124 | 124 | |
| 125 | - } |
|
| 125 | + } |
|
| 126 | 126 | } |
@@ -34,54 +34,54 @@ |
||
| 34 | 34 | |
| 35 | 35 | class EnableMasterKey extends Command { |
| 36 | 36 | |
| 37 | - /** @var Util */ |
|
| 38 | - protected $util; |
|
| 39 | - |
|
| 40 | - /** @var IConfig */ |
|
| 41 | - protected $config; |
|
| 42 | - |
|
| 43 | - /** @var QuestionHelper */ |
|
| 44 | - protected $questionHelper; |
|
| 45 | - |
|
| 46 | - /** |
|
| 47 | - * @param Util $util |
|
| 48 | - * @param IConfig $config |
|
| 49 | - * @param QuestionHelper $questionHelper |
|
| 50 | - */ |
|
| 51 | - public function __construct(Util $util, |
|
| 52 | - IConfig $config, |
|
| 53 | - QuestionHelper $questionHelper) { |
|
| 54 | - |
|
| 55 | - $this->util = $util; |
|
| 56 | - $this->config = $config; |
|
| 57 | - $this->questionHelper = $questionHelper; |
|
| 58 | - parent::__construct(); |
|
| 59 | - } |
|
| 60 | - |
|
| 61 | - protected function configure() { |
|
| 62 | - $this |
|
| 63 | - ->setName('encryption:enable-master-key') |
|
| 64 | - ->setDescription('Enable the master key. Only available for fresh installations with no existing encrypted data! There is also no way to disable it again.'); |
|
| 65 | - } |
|
| 66 | - |
|
| 67 | - protected function execute(InputInterface $input, OutputInterface $output) { |
|
| 68 | - |
|
| 69 | - $isAlreadyEnabled = $this->util->isMasterKeyEnabled(); |
|
| 70 | - |
|
| 71 | - if($isAlreadyEnabled) { |
|
| 72 | - $output->writeln('Master key already enabled'); |
|
| 73 | - } else { |
|
| 74 | - $question = new ConfirmationQuestion( |
|
| 75 | - 'Warning: Only available for fresh installations with no existing encrypted data! ' |
|
| 76 | - . 'There is also no way to disable it again. Do you want to continue? (y/n) ', false); |
|
| 77 | - if ($this->questionHelper->ask($input, $output, $question)) { |
|
| 78 | - $this->config->setAppValue('encryption', 'useMasterKey', '1'); |
|
| 79 | - $output->writeln('Master key successfully enabled.'); |
|
| 80 | - } else { |
|
| 81 | - $output->writeln('aborted.'); |
|
| 82 | - } |
|
| 83 | - } |
|
| 84 | - |
|
| 85 | - } |
|
| 37 | + /** @var Util */ |
|
| 38 | + protected $util; |
|
| 39 | + |
|
| 40 | + /** @var IConfig */ |
|
| 41 | + protected $config; |
|
| 42 | + |
|
| 43 | + /** @var QuestionHelper */ |
|
| 44 | + protected $questionHelper; |
|
| 45 | + |
|
| 46 | + /** |
|
| 47 | + * @param Util $util |
|
| 48 | + * @param IConfig $config |
|
| 49 | + * @param QuestionHelper $questionHelper |
|
| 50 | + */ |
|
| 51 | + public function __construct(Util $util, |
|
| 52 | + IConfig $config, |
|
| 53 | + QuestionHelper $questionHelper) { |
|
| 54 | + |
|
| 55 | + $this->util = $util; |
|
| 56 | + $this->config = $config; |
|
| 57 | + $this->questionHelper = $questionHelper; |
|
| 58 | + parent::__construct(); |
|
| 59 | + } |
|
| 60 | + |
|
| 61 | + protected function configure() { |
|
| 62 | + $this |
|
| 63 | + ->setName('encryption:enable-master-key') |
|
| 64 | + ->setDescription('Enable the master key. Only available for fresh installations with no existing encrypted data! There is also no way to disable it again.'); |
|
| 65 | + } |
|
| 66 | + |
|
| 67 | + protected function execute(InputInterface $input, OutputInterface $output) { |
|
| 68 | + |
|
| 69 | + $isAlreadyEnabled = $this->util->isMasterKeyEnabled(); |
|
| 70 | + |
|
| 71 | + if($isAlreadyEnabled) { |
|
| 72 | + $output->writeln('Master key already enabled'); |
|
| 73 | + } else { |
|
| 74 | + $question = new ConfirmationQuestion( |
|
| 75 | + 'Warning: Only available for fresh installations with no existing encrypted data! ' |
|
| 76 | + . 'There is also no way to disable it again. Do you want to continue? (y/n) ', false); |
|
| 77 | + if ($this->questionHelper->ask($input, $output, $question)) { |
|
| 78 | + $this->config->setAppValue('encryption', 'useMasterKey', '1'); |
|
| 79 | + $output->writeln('Master key successfully enabled.'); |
|
| 80 | + } else { |
|
| 81 | + $output->writeln('aborted.'); |
|
| 82 | + } |
|
| 83 | + } |
|
| 84 | + |
|
| 85 | + } |
|
| 86 | 86 | |
| 87 | 87 | } |