123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272 |
- <?php
- namespace OC\Files\Cache;
- use OC\DB\Exceptions\DbalException;
- use OC\Files\FileInfo;
- use OCP\Files\Cache\ICacheEntry;
- use OCP\Files\Cache\IUpdater;
- use OCP\Files\Storage\IStorage;
- use Psr\Log\LoggerInterface;
- class Updater implements IUpdater {
-
- protected $enabled = true;
-
- protected $storage;
-
- protected $propagator;
-
- protected $scanner;
-
- protected $cache;
- private LoggerInterface $logger;
-
- public function __construct(\OC\Files\Storage\Storage $storage) {
- $this->storage = $storage;
- $this->propagator = $storage->getPropagator();
- $this->scanner = $storage->getScanner();
- $this->cache = $storage->getCache();
- $this->logger = \OC::$server->get(LoggerInterface::class);
- }
-
- public function disable() {
- $this->enabled = false;
- }
-
- public function enable() {
- $this->enabled = true;
- }
-
- public function getPropagator() {
- return $this->propagator;
- }
-
- public function propagate($path, $time = null) {
- if (Scanner::isPartialFile($path)) {
- return;
- }
- $this->propagator->propagateChange($path, $time);
- }
-
- public function update($path, $time = null) {
- if (!$this->enabled or Scanner::isPartialFile($path)) {
- return;
- }
- if (is_null($time)) {
- $time = time();
- }
- $data = $this->scanner->scan($path, Scanner::SCAN_SHALLOW, -1, false);
- if (
- isset($data['oldSize']) && isset($data['size']) &&
- !$data['encrypted']
- ) {
- $sizeDifference = $data['size'] - $data['oldSize'];
- } else {
-
- $sizeDifference = 0;
- if ($this->cache instanceof Cache) {
- $this->cache->correctFolderSize($path, $data);
- }
- }
- $this->correctParentStorageMtime($path);
- $this->propagator->propagateChange($path, $time, $sizeDifference);
- }
-
- public function remove($path) {
- if (!$this->enabled or Scanner::isPartialFile($path)) {
- return;
- }
- $parent = dirname($path);
- if ($parent === '.') {
- $parent = '';
- }
- $entry = $this->cache->get($path);
- $this->cache->remove($path);
- $this->correctParentStorageMtime($path);
- if ($entry instanceof ICacheEntry) {
- $this->propagator->propagateChange($path, time(), -$entry->getSize());
- } else {
- $this->propagator->propagateChange($path, time());
- if ($this->cache instanceof Cache) {
- $this->cache->correctFolderSize($parent);
- }
- }
- }
-
- public function renameFromStorage(IStorage $sourceStorage, $source, $target) {
- if (!$this->enabled or Scanner::isPartialFile($source) or Scanner::isPartialFile($target)) {
- return;
- }
- $time = time();
- $sourceCache = $sourceStorage->getCache();
- $sourceUpdater = $sourceStorage->getUpdater();
- $sourcePropagator = $sourceStorage->getPropagator();
- $sourceInfo = $sourceCache->get($source);
- if ($sourceInfo !== false) {
- if ($this->cache->inCache($target)) {
- $this->cache->remove($target);
- }
- if ($sourceStorage === $this->storage) {
- $this->cache->move($source, $target);
- } else {
- $this->cache->moveFromCache($sourceCache, $source, $target);
- }
- $sourceExtension = pathinfo($source, PATHINFO_EXTENSION);
- $targetExtension = pathinfo($target, PATHINFO_EXTENSION);
- $targetIsTrash = preg_match("/d\d+/", $targetExtension);
- if ($sourceExtension !== $targetExtension && $sourceInfo->getMimeType() !== FileInfo::MIMETYPE_FOLDER && !$targetIsTrash) {
-
- $mimeType = $this->storage->getMimeType($target);
- $fileId = $this->cache->getId($target);
- $this->cache->update($fileId, ['mimetype' => $mimeType]);
- }
- }
- if ($sourceCache instanceof Cache) {
- $sourceCache->correctFolderSize($source);
- }
- if ($this->cache instanceof Cache) {
- $this->cache->correctFolderSize($target);
- }
- if ($sourceUpdater instanceof Updater) {
- $sourceUpdater->correctParentStorageMtime($source);
- }
- $this->correctParentStorageMtime($target);
- $this->updateStorageMTimeOnly($target);
- $sourcePropagator->propagateChange($source, $time);
- $this->propagator->propagateChange($target, $time);
- }
- private function updateStorageMTimeOnly($internalPath) {
- $fileId = $this->cache->getId($internalPath);
- if ($fileId !== -1) {
- $mtime = $this->storage->filemtime($internalPath);
- if ($mtime !== false) {
- $this->cache->update(
- $fileId, [
- 'mtime' => null,
- 'storage_mtime' => $mtime
- ]
- );
- }
- }
- }
-
- private function correctParentStorageMtime($internalPath) {
- $parentId = $this->cache->getParentId($internalPath);
- $parent = dirname($internalPath);
- if ($parentId != -1) {
- $mtime = $this->storage->filemtime($parent);
- if ($mtime !== false) {
- try {
- $this->cache->update($parentId, ['storage_mtime' => $mtime]);
- } catch (DbalException $e) {
-
-
-
- $this->logger->warning("Error while updating parent storage_mtime, should be safe to ignore", ['exception' => $e]);
- }
- }
- }
- }
- }
|