setName('files:repair-tree') ->setDescription('Try and repair malformed filesystem tree structures') ->addOption('dry-run'); } public function execute(InputInterface $input, OutputInterface $output): int { $rows = $this->findBrokenTreeBits(); $fix = !$input->getOption('dry-run'); $output->writeln('Found ' . count($rows) . ' file entries with an invalid path'); if ($fix) { $this->connection->beginTransaction(); } $query = $this->connection->getQueryBuilder(); $query->update('filecache') ->set('path', $query->createParameter('path')) ->set('path_hash', $query->func()->md5($query->createParameter('path'))) ->set('storage', $query->createParameter('storage')) ->where($query->expr()->eq('fileid', $query->createParameter('fileid'))); foreach ($rows as $row) { $output->writeln("Path of file {$row['fileid']} is {$row['path']} but should be {$row['parent_path']}/{$row['name']} based on its parent", OutputInterface::VERBOSITY_VERBOSE); if ($fix) { $fileId = $this->getFileId((int)$row['parent_storage'], $row['parent_path'] . '/' . $row['name']); if ($fileId > 0) { $output->writeln("Cache entry has already be recreated with id $fileId, deleting instead"); $this->deleteById((int)$row['fileid']); } else { $query->setParameters([ 'fileid' => $row['fileid'], 'path' => $row['parent_path'] . '/' . $row['name'], 'storage' => $row['parent_storage'], ]); $query->execute(); } } } if ($fix) { $this->connection->commit(); } return self::SUCCESS; } private function getFileId(int $storage, string $path) { $query = $this->connection->getQueryBuilder(); $query->select('fileid') ->from('filecache') ->where($query->expr()->eq('storage', $query->createNamedParameter($storage))) ->andWhere($query->expr()->eq('path_hash', $query->createNamedParameter(md5($path)))); return $query->execute()->fetch(\PDO::FETCH_COLUMN); } private function deleteById(int $fileId): void { $query = $this->connection->getQueryBuilder(); $query->delete('filecache') ->where($query->expr()->eq('fileid', $query->createNamedParameter($fileId))); $query->execute(); } private function findBrokenTreeBits(): array { $query = $this->connection->getQueryBuilder(); $query->select('f.fileid', 'f.path', 'f.parent', 'f.name') ->selectAlias('p.path', 'parent_path') ->selectAlias('p.storage', 'parent_storage') ->from('filecache', 'f') ->innerJoin('f', 'filecache', 'p', $query->expr()->eq('f.parent', 'p.fileid')) ->where($query->expr()->orX( $query->expr()->andX( $query->expr()->neq('p.path_hash', $query->createNamedParameter(md5(''))), $query->expr()->neq('f.path', $query->func()->concat('p.path', $query->func()->concat($query->createNamedParameter('/'), 'f.name'))) ), $query->expr()->andX( $query->expr()->eq('p.path_hash', $query->createNamedParameter(md5(''))), $query->expr()->neq('f.path', 'f.name') ), $query->expr()->neq('f.storage', 'p.storage') )); return $query->execute()->fetchAll(); } } >/golang.org/x/net/context/pre_go19.go

blob: b105f80be4fe2bbcb225ae4343b551fc6d851b15 (plain)