1
0

Repair.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  1. <?php
  2. /**
  3. * @copyright Copyright (c) 2016, ownCloud, Inc.
  4. *
  5. * @author Arthur Schiwon <blizzz@arthur-schiwon.de>
  6. * @author Christoph Wurst <christoph@winzerhof-wurst.at>
  7. * @author Daniel Kesselberg <mail@danielkesselberg.de>
  8. * @author Georg Ehrke <oc.list@georgehrke.com>
  9. * @author Joas Schilling <coding@schilljs.com>
  10. * @author John Molakvoæ <skjnldsv@protonmail.com>
  11. * @author Julius Härtl <jus@bitgrid.net>
  12. * @author Lukas Reschke <lukas@statuscode.ch>
  13. * @author Michael Weimann <mail@michael-weimann.eu>
  14. * @author Morris Jobke <hey@morrisjobke.de>
  15. * @author Robin Appelman <robin@icewind.nl>
  16. * @author Roeland Jago Douma <roeland@famdouma.nl>
  17. * @author Thomas Müller <thomas.mueller@tmit.eu>
  18. * @author Vincent Petry <vincent@nextcloud.com>
  19. *
  20. * @license AGPL-3.0
  21. *
  22. * This code is free software: you can redistribute it and/or modify
  23. * it under the terms of the GNU Affero General Public License, version 3,
  24. * as published by the Free Software Foundation.
  25. *
  26. * This program is distributed in the hope that it will be useful,
  27. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  28. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  29. * GNU Affero General Public License for more details.
  30. *
  31. * You should have received a copy of the GNU Affero General Public License, version 3,
  32. * along with this program. If not, see <http://www.gnu.org/licenses/>
  33. *
  34. */
  35. namespace OC;
  36. use OC\DB\Connection;
  37. use OC\DB\ConnectionAdapter;
  38. use OC\Repair\AddBruteForceCleanupJob;
  39. use OC\Repair\AddCleanupUpdaterBackupsJob;
  40. use OC\Repair\AddMetadataMigrationJob;
  41. use OC\Repair\AddRemoveOldTasksBackgroundJob;
  42. use OC\Repair\CleanTags;
  43. use OC\Repair\CleanUpAbandonedApps;
  44. use OC\Repair\ClearFrontendCaches;
  45. use OC\Repair\ClearGeneratedAvatarCache;
  46. use OC\Repair\Collation;
  47. use OC\Repair\Events\RepairAdvanceEvent;
  48. use OC\Repair\Events\RepairErrorEvent;
  49. use OC\Repair\Events\RepairFinishEvent;
  50. use OC\Repair\Events\RepairInfoEvent;
  51. use OC\Repair\Events\RepairStartEvent;
  52. use OC\Repair\Events\RepairStepEvent;
  53. use OC\Repair\Events\RepairWarningEvent;
  54. use OC\Repair\MoveUpdaterStepFile;
  55. use OC\Repair\NC11\FixMountStorages;
  56. use OC\Repair\NC13\AddLogRotateJob;
  57. use OC\Repair\NC14\AddPreviewBackgroundCleanupJob;
  58. use OC\Repair\NC16\AddClenupLoginFlowV2BackgroundJob;
  59. use OC\Repair\NC16\CleanupCardDAVPhotoCache;
  60. use OC\Repair\NC16\ClearCollectionsAccessCache;
  61. use OC\Repair\NC18\ResetGeneratedAvatarFlag;
  62. use OC\Repair\NC20\EncryptionLegacyCipher;
  63. use OC\Repair\NC20\EncryptionMigration;
  64. use OC\Repair\NC20\ShippedDashboardEnable;
  65. use OC\Repair\NC21\AddCheckForUserCertificatesJob;
  66. use OC\Repair\NC21\ValidatePhoneNumber;
  67. use OC\Repair\NC22\LookupServerSendCheck;
  68. use OC\Repair\NC24\AddTokenCleanupJob;
  69. use OC\Repair\NC25\AddMissingSecretJob;
  70. use OC\Repair\OldGroupMembershipShares;
  71. use OC\Repair\Owncloud\CleanPreviews;
  72. use OC\Repair\Owncloud\DropAccountTermsTable;
  73. use OC\Repair\Owncloud\MigrateOauthTables;
  74. use OC\Repair\Owncloud\MoveAvatars;
  75. use OC\Repair\Owncloud\SaveAccountsTableData;
  76. use OC\Repair\Owncloud\UpdateLanguageCodes;
  77. use OC\Repair\RemoveLinkShares;
  78. use OC\Repair\RepairDavShares;
  79. use OC\Repair\RepairInvalidShares;
  80. use OC\Repair\RepairMimeTypes;
  81. use OC\Repair\SqliteAutoincrement;
  82. use OC\Template\JSCombiner;
  83. use OCA\DAV\Migration\DeleteSchedulingObjects;
  84. use OCP\AppFramework\QueryException;
  85. use OCP\AppFramework\Utility\ITimeFactory;
  86. use OCP\Collaboration\Resources\IManager;
  87. use OCP\EventDispatcher\IEventDispatcher;
  88. use OCP\Migration\IOutput;
  89. use OCP\Migration\IRepairStep;
  90. use Psr\Log\LoggerInterface;
  91. use Throwable;
  92. class Repair implements IOutput {
  93. /** @var IRepairStep[] */
  94. private array $repairSteps;
  95. private IEventDispatcher $dispatcher;
  96. private string $currentStep;
  97. private LoggerInterface $logger;
  98. /**
  99. * Creates a new repair step runner
  100. *
  101. * @param IRepairStep[] $repairSteps array of RepairStep instances
  102. */
  103. public function __construct(array $repairSteps, IEventDispatcher $dispatcher, LoggerInterface $logger) {
  104. $this->repairSteps = $repairSteps;
  105. $this->dispatcher = $dispatcher;
  106. $this->logger = $logger;
  107. }
  108. /**
  109. * Run a series of repair steps for common problems
  110. */
  111. public function run() {
  112. if (count($this->repairSteps) === 0) {
  113. $this->dispatcher->dispatchTyped(new RepairInfoEvent('No repair steps available'));
  114. return;
  115. }
  116. // run each repair step
  117. foreach ($this->repairSteps as $step) {
  118. $this->currentStep = $step->getName();
  119. $this->dispatcher->dispatchTyped(new RepairStepEvent($this->currentStep));
  120. try {
  121. $step->run($this);
  122. } catch (\Exception $e) {
  123. $this->logger->error("Exception while executing repair step " . $step->getName(), ['exception' => $e]);
  124. $this->dispatcher->dispatchTyped(new RepairErrorEvent($e->getMessage()));
  125. }
  126. }
  127. }
  128. /**
  129. * Add repair step
  130. *
  131. * @param IRepairStep|string $repairStep repair step
  132. * @throws \Exception
  133. */
  134. public function addStep($repairStep) {
  135. if (is_string($repairStep)) {
  136. try {
  137. $s = \OC::$server->get($repairStep);
  138. } catch (QueryException $e) {
  139. if (class_exists($repairStep)) {
  140. try {
  141. // Last resort: hope there are no constructor arguments
  142. $s = new $repairStep();
  143. } catch (Throwable $inner) {
  144. // Well, it was worth a try
  145. throw new \Exception("Repair step '$repairStep' can't be instantiated: " . $e->getMessage(), 0, $e);
  146. }
  147. } else {
  148. throw new \Exception("Repair step '$repairStep' is unknown", 0, $e);
  149. }
  150. }
  151. if ($s instanceof IRepairStep) {
  152. $this->repairSteps[] = $s;
  153. } else {
  154. throw new \Exception("Repair step '$repairStep' is not of type \\OCP\\Migration\\IRepairStep");
  155. }
  156. } else {
  157. $this->repairSteps[] = $repairStep;
  158. }
  159. }
  160. /**
  161. * Returns the default repair steps to be run on the
  162. * command line or after an upgrade.
  163. *
  164. * @return IRepairStep[]
  165. */
  166. public static function getRepairSteps(): array {
  167. return [
  168. new Collation(\OC::$server->getConfig(), \OC::$server->get(LoggerInterface::class), \OC::$server->getDatabaseConnection(), false),
  169. new RepairMimeTypes(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
  170. new CleanTags(\OC::$server->getDatabaseConnection(), \OC::$server->getUserManager()),
  171. new RepairInvalidShares(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
  172. new MoveUpdaterStepFile(\OC::$server->getConfig()),
  173. new MoveAvatars(
  174. \OC::$server->getJobList(),
  175. \OC::$server->getConfig()
  176. ),
  177. new CleanPreviews(
  178. \OC::$server->getJobList(),
  179. \OC::$server->getUserManager(),
  180. \OC::$server->getConfig()
  181. ),
  182. new MigrateOauthTables(\OC::$server->get(Connection::class)),
  183. new FixMountStorages(\OC::$server->getDatabaseConnection()),
  184. new UpdateLanguageCodes(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig()),
  185. new AddLogRotateJob(\OC::$server->getJobList()),
  186. new ClearFrontendCaches(\OC::$server->getMemCacheFactory(), \OC::$server->query(JSCombiner::class)),
  187. \OCP\Server::get(ClearGeneratedAvatarCache::class),
  188. new AddPreviewBackgroundCleanupJob(\OC::$server->getJobList()),
  189. new AddCleanupUpdaterBackupsJob(\OC::$server->getJobList()),
  190. new CleanupCardDAVPhotoCache(\OC::$server->getConfig(), \OC::$server->getAppDataDir('dav-photocache'), \OC::$server->get(LoggerInterface::class)),
  191. new AddClenupLoginFlowV2BackgroundJob(\OC::$server->getJobList()),
  192. new RemoveLinkShares(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig(), \OC::$server->getGroupManager(), \OC::$server->getNotificationManager(), \OC::$server->query(ITimeFactory::class)),
  193. new ClearCollectionsAccessCache(\OC::$server->getConfig(), \OC::$server->query(IManager::class)),
  194. \OCP\Server::get(ResetGeneratedAvatarFlag::class),
  195. \OCP\Server::get(EncryptionLegacyCipher::class),
  196. \OCP\Server::get(EncryptionMigration::class),
  197. \OCP\Server::get(ShippedDashboardEnable::class),
  198. \OCP\Server::get(AddBruteForceCleanupJob::class),
  199. \OCP\Server::get(AddCheckForUserCertificatesJob::class),
  200. \OCP\Server::get(RepairDavShares::class),
  201. \OCP\Server::get(LookupServerSendCheck::class),
  202. \OCP\Server::get(AddTokenCleanupJob::class),
  203. \OCP\Server::get(CleanUpAbandonedApps::class),
  204. \OCP\Server::get(AddMissingSecretJob::class),
  205. \OCP\Server::get(AddRemoveOldTasksBackgroundJob::class),
  206. \OCP\Server::get(AddMetadataMigrationJob::class),
  207. ];
  208. }
  209. /**
  210. * Returns expensive repair steps to be run on the
  211. * command line with a special option.
  212. *
  213. * @return IRepairStep[]
  214. */
  215. public static function getExpensiveRepairSteps() {
  216. return [
  217. new OldGroupMembershipShares(\OC::$server->getDatabaseConnection(), \OC::$server->getGroupManager()),
  218. \OC::$server->get(ValidatePhoneNumber::class),
  219. \OC::$server->get(DeleteSchedulingObjects::class),
  220. ];
  221. }
  222. /**
  223. * Returns the repair steps to be run before an
  224. * upgrade.
  225. *
  226. * @return IRepairStep[]
  227. */
  228. public static function getBeforeUpgradeRepairSteps() {
  229. /** @var Connection $connection */
  230. $connection = \OC::$server->get(Connection::class);
  231. /** @var ConnectionAdapter $connectionAdapter */
  232. $connectionAdapter = \OC::$server->get(ConnectionAdapter::class);
  233. $config = \OC::$server->getConfig();
  234. $steps = [
  235. new Collation(\OC::$server->getConfig(), \OC::$server->get(LoggerInterface::class), $connectionAdapter, true),
  236. new SqliteAutoincrement($connection),
  237. new SaveAccountsTableData($connectionAdapter, $config),
  238. new DropAccountTermsTable($connectionAdapter),
  239. ];
  240. return $steps;
  241. }
  242. public function debug(string $message): void {
  243. }
  244. /**
  245. * @param string $message
  246. */
  247. public function info($message) {
  248. // for now just emit as we did in the past
  249. $this->dispatcher->dispatchTyped(new RepairInfoEvent($message));
  250. }
  251. /**
  252. * @param string $message
  253. */
  254. public function warning($message) {
  255. // for now just emit as we did in the past
  256. $this->dispatcher->dispatchTyped(new RepairWarningEvent($message));
  257. }
  258. /**
  259. * @param int $max
  260. */
  261. public function startProgress($max = 0) {
  262. // for now just emit as we did in the past
  263. $this->dispatcher->dispatchTyped(new RepairStartEvent($max, $this->currentStep));
  264. }
  265. /**
  266. * @param int $step number of step to advance
  267. * @param string $description
  268. */
  269. public function advance($step = 1, $description = '') {
  270. // for now just emit as we did in the past
  271. $this->dispatcher->dispatchTyped(new RepairAdvanceEvent($step, $description));
  272. }
  273. /**
  274. * @param int $max
  275. */
  276. public function finishProgress() {
  277. // for now just emit as we did in the past
  278. $this->dispatcher->dispatchTyped(new RepairFinishEvent());
  279. }
  280. }