use OC\Repair\Events\RepairStepEvent;
use OC\Repair\Events\RepairWarningEvent;
use OC\Repair\MoveUpdaterStepFile;
-use OC\Repair\NC11\FixMountStorages;
use OC\Repair\NC13\AddLogRotateJob;
use OC\Repair\NC14\AddPreviewBackgroundCleanupJob;
use OC\Repair\NC16\AddClenupLoginFlowV2BackgroundJob;
\OC::$server->getConfig()
),
new MigrateOauthTables(\OC::$server->get(Connection::class)),
- new FixMountStorages(\OC::$server->getDatabaseConnection()),
new UpdateLanguageCodes(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig()),
new AddLogRotateJob(\OC::$server->getJobList()),
new ClearFrontendCaches(\OC::$server->getMemCacheFactory(), \OCP\Server::get(JSCombiner::class)),
+++ /dev/null
-<?php
-/**
- * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
- * SPDX-License-Identifier: AGPL-3.0-or-later
- */
-namespace OC\Repair\NC11;
-
-use OCP\DB\QueryBuilder\IQueryBuilder;
-use OCP\IDBConnection;
-use OCP\Migration\IOutput;
-use OCP\Migration\IRepairStep;
-
-class FixMountStorages implements IRepairStep {
- /** @var IDBConnection */
- private $db;
-
- /**
- * @param IDBConnection $db
- */
- public function __construct(IDBConnection $db) {
- $this->db = $db;
- }
-
- /**
- * @return string
- */
- public function getName() {
- return 'Fix potential broken mount points';
- }
-
- public function run(IOutput $output) {
- $query = $this->db->getQueryBuilder();
- $query->select('m.id', 'f.storage')
- ->from('mounts', 'm')
- ->leftJoin('m', 'filecache', 'f', $query->expr()->eq('m.root_id', 'f.fileid'))
- ->where($query->expr()->neq('m.storage_id', 'f.storage'));
-
- $update = $this->db->getQueryBuilder();
- $update->update('mounts')
- ->set('storage_id', $update->createParameter('storage'))
- ->where($query->expr()->eq('id', $update->createParameter('mount')));
-
- $result = $query->execute();
- $entriesUpdated = 0;
- while ($row = $result->fetch()) {
- $update->setParameter('storage', $row['storage'], IQueryBuilder::PARAM_INT)
- ->setParameter('mount', $row['id'], IQueryBuilder::PARAM_INT);
- $update->execute();
- $entriesUpdated++;
- }
- $result->closeCursor();
-
- if ($entriesUpdated > 0) {
- $output->info($entriesUpdated . ' mounts updated');
- return;
- }
-
- $output->info('No mounts updated');
- }
-}
+++ /dev/null
-<?php
-/**
- * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
- * SPDX-License-Identifier: AGPL-3.0-or-later
- */
-
-namespace Test\Repair\NC11;
-
-use OC\Repair\NC11\FixMountStorages;
-use OCP\DB\QueryBuilder\IQueryBuilder;
-use OCP\IDBConnection;
-use OCP\Migration\IOutput;
-use Test\TestCase;
-
-/**
- * Class FixMountStoragesTest
- *
- * @package Test\Repair\NC11
- * @group DB
- */
-class FixMountStoragesTest extends TestCase {
- /** @var IDBConnection */
- private $db;
-
- /** @var FixMountStorages */
- private $repair;
-
- protected function setUp(): void {
- parent::setUp();
-
- $this->db = \OC::$server->getDatabaseConnection();
-
- $this->repair = new FixMountStorages(
- $this->db
- );
- }
-
- public function testGetName() {
- $this->assertSame('Fix potential broken mount points', $this->repair->getName());
- }
-
- public function testRun() {
- // Valid mount
- $file1 = $this->createFile(42);
- $mount1 = $this->createMount($file1, 42);
- $this->assertStorage($mount1, 42);
-
- // Broken mount
- $file2 = $this->createFile(23);
- $mount2 = $this->createMount($file2, 1337);
- $this->assertStorage($mount2, 1337);
-
- /** @var IOutput|\PHPUnit\Framework\MockObject\MockObject $output */
- $output = $this->createMock(IOutput::class);
- $output->expects($this->exactly(2))
- ->method('info')
- ->withConsecutive(
- ['1 mounts updated'],
- ['No mounts updated']
- );
-
- $this->repair->run($output);
- $this->assertStorage($mount1, 42);
- $this->assertStorage($mount2, 23);
-
- $this->repair->run($output);
- $this->assertStorage($mount1, 42);
- $this->assertStorage($mount2, 23);
- }
-
-
- protected function createFile($storage) {
- $query = $this->db->getQueryBuilder();
-
- $query->insert('filecache')
- ->values([
- 'storage' => $query->createNamedParameter($storage, IQueryBuilder::PARAM_INT),
- 'path_hash' => $query->createNamedParameter(static::getUniqueID(), IQueryBuilder::PARAM_STR),
- 'encrypted' => $query->createNamedParameter(0, IQueryBuilder::PARAM_INT),
- 'size' => $query->createNamedParameter(0, IQueryBuilder::PARAM_INT),
- 'unencrypted_size' => $query->createNamedParameter(0, IQueryBuilder::PARAM_INT),
- ]);
- $query->execute();
-
- return $query->getLastInsertId();
- }
-
- protected function createMount($fileId, $storage) {
- $query = $this->db->getQueryBuilder();
-
- $query->insert('mounts')
- ->values([
- 'storage_id' => $query->createNamedParameter($storage, IQueryBuilder::PARAM_INT),
- 'root_id' => $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT),
- 'user_id' => $query->createNamedParameter(static::getUniqueID(), IQueryBuilder::PARAM_STR),
- 'mount_point' => $query->createNamedParameter(static::getUniqueID(), IQueryBuilder::PARAM_STR),
- ]);
- $query->execute();
-
- return $query->getLastInsertId();
- }
-
- protected function assertStorage($mount, $storage) {
- $query = $this->db->getQueryBuilder();
- $query->select('storage_id')
- ->from('mounts')
- ->where($query->expr()->eq('id', $query->createNamedParameter($mount, IQueryBuilder::PARAM_INT)));
- $result = $query->execute();
- $row = $result->fetch();
- $result->closeCursor();
-
- $this->assertEquals($storage, $row['storage_id']);
- }
-}