Gecko [ paroquia-rio-de-mouro.pt ]

Name	Size	Permission	Date
Wrapper	[ DIR ]	drwxr-xr-x	2018-04-19 18:15
Cache.php	25.89 KB	-rw-r--r--	2018-04-19 18:15
CacheEntry.php	2.28 KB	-rw-r--r--	2018-04-19 18:15
FailedCache.php	2.66 KB	-rw-r--r--	2018-04-19 18:15
HomeCache.php	2.84 KB	-rw-r--r--	2018-04-19 18:15
HomePropagator.php	1.51 KB	-rw-r--r--	2018-04-19 18:15
MoveFromCacheTrait.php	2.53 KB	-rw-r--r--	2018-04-19 18:15
Propagator.php	5.79 KB	-rw-r--r--	2018-04-19 18:15
Scanner.php	17.56 KB	-rw-r--r--	2018-04-19 18:15
Storage.php	7.75 KB	-rw-r--r--	2018-04-19 18:15
Updater.php	6.59 KB	-rw-r--r--	2018-04-19 18:15
Watcher.php	3.76 KB	-rw-r--r--	2018-04-19 18:15

Rename

<?php
/**
 * @author Joas Schilling <coding@schilljs.com>
 * @author Jörn Friedrich Dreyer <jfd@butonic.de>
 * @author Morris Jobke <hey@morrisjobke.de>
 * @author Robin Appelman <icewind@owncloud.com>
 * @author Robin McCorkell <robin@mccorkell.me.uk>
 * @author Thomas Müller <thomas.mueller@tmit.eu>
 * @author Vincent Petry <pvince81@owncloud.com>
 *
 * @copyright Copyright (c) 2018, ownCloud GmbH
 * @license AGPL-3.0
 *
 * This code is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License, version 3,
 * as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License, version 3,
 * along with this program.  If not, see <http://www.gnu.org/licenses/>
 *
 */

namespace OC\Files\Cache;
use OC\Cache\CappedMemoryCache;
use OCP\ICache;

/**
 * Handle the mapping between the string and numeric storage ids
 *
 * Each storage has 2 different ids
 * 	a string id which is generated by the storage backend and reflects the configuration of the storage (e.g. 'smb://user@host/share')
 * 	and a numeric storage id which is referenced in the file cache
 *
 * A mapping between the two storage ids is stored in the database and accessible trough this class
 *
 * @package OC\Files\Cache
 */
class Storage {
	private $storageId;
	private $numericId;

/** @var CappedMemoryCache */
	protected static $localCache = null;

/** @var ICache  */
	private static $distributedCache = null;

private static $distributedCacheTTL = 300; // 5 Min

/**
	 * @param \OC\Files\Storage\Storage|string $storage
	 * @param bool $isAvailable
	 * @throws \RuntimeException
	 */
	public function __construct($storage, $isAvailable = true) {
		if ($storage instanceof \OC\Files\Storage\Storage) {
			$this->storageId = $storage->getId();
		} else {
			$this->storageId = $storage;
		}
		$this->storageId = self::adjustStorageId($this->storageId);

if ($row = self::getStorageById($this->storageId)) {
			$this->numericId = (int)$row['numeric_id'];
		} else {
			self::unsetCache($this->storageId);

$connection = \OC::$server->getDatabaseConnection();
			$available = $isAvailable ? 1 : 0;
			$storageData = ['id' => $this->storageId, 'available' => $available];

if ($connection->insertIfNotExist('*PREFIX*storages', $storageData)) {
				$this->numericId = (int)$connection->lastInsertId('*PREFIX*storages');

// add missing fields before caching
				$storageData['numeric_id'] = $this->numericId;
				$storageData['last_checked'] = null;

// local cache has been initialized by self::getStorageById
				self::$localCache->set($this->storageId, $storageData);

// distributed cache may need initializing
				self::getDistributedCache()->set(
					$this->storageId, $storageData, self::$distributedCacheTTL
				);

} else {
				if ($row = self::getStorageById($this->storageId)) {
					$this->numericId = (int)$row['numeric_id'];
				} else {
					throw new \RuntimeException('Storage could neither be inserted nor be selected from the database');
				}
			}
		}
	}

/**
	 * query the local cache, a distributed cache and the db for a storageid
	 * @param string $storageId
	 * @return array|false
	 */
	public static function getStorageById($storageId) {
		if (self::$localCache === null) {
			self::$localCache = new CappedMemoryCache();
		}
		$result = self::$localCache->get($storageId);
		if ($result === null || !isset($result['numeric_id'])) {
			$result = self::getStorageByIdFromCache($storageId);
			self::$localCache->set($storageId, $result);
		}
		return $result;
	}

/**
	 * @return ICache
	 */
	private static function getDistributedCache() {
		if (self::$distributedCache === null) {
			self::$distributedCache =
				\OC::$server->getMemCacheFactory()->create('getStorageById');
		}
		return self::$distributedCache;
	}

/**
	 * query the distributed cache for a storageid
	 * @param string $storageId
	 * @return array|false
	 */
	private static function getStorageByIdFromCache($storageId) {
		$result = self::getDistributedCache()->get($storageId);
		if ($result === null || !isset($result['numeric_id'])) {
			$result = self::getStorageByIdFromDb($storageId);
			self::getDistributedCache()->set(
				$storageId,	$result, self::$distributedCacheTTL
			);
		}
		return $result;
	}

/**
	 * query the db for a storageid
	 * @param string $storageId
	 * @return array|false
	 */
	private static function getStorageByIdFromDb($storageId) {
		$sql = 'SELECT * FROM `*PREFIX*storages` WHERE `id` = ?';
		$resultSet = \OC_DB::executeAudited($sql, [$storageId]);
		return $resultSet->fetchRow();
	}

private static function unsetCache($storageId) {
		// delete from local cache
		if(self::$localCache !== null) {
			self::$localCache->remove($storageId);
		}
		// delete from distributed cache
		self::getDistributedCache()->remove($storageId);
	}

/**
	 * Adjusts the storage id to use md5 if too long
	 * @param string $storageId storage id
	 * @return string unchanged $storageId if its length is less than 64 characters,
	 * else returns the md5 of $storageId
	 */
	public static function adjustStorageId($storageId) {
		if (strlen($storageId) > 64) {
			return md5($storageId);
		}
		return $storageId;
	}

/**
	 * Get the numeric id for the storage
	 *
	 * @return int
	 */
	public function getNumericId() {
		return $this->numericId;
	}

/**
	 * Get the string id for the storage
	 *
	 * @param int $numericId
	 * @return string|null either the storage id string or null if the numeric id is not known
	 */
	public static function getStorageId($numericId) {

$sql = 'SELECT `id` FROM `*PREFIX*storages` WHERE `numeric_id` = ?';
		$result = \OC_DB::executeAudited($sql, [$numericId]);
		if ($row = $result->fetchRow()) {
			return $row['id'];
		} else {
			return null;
		}
	}

/**
	 * Get the numeric of the storage with the provided string id
	 *
	 * @param $storageId
	 * @return int|null either the numeric storage id or null if the storage id is not knwon
	 */
	public static function getNumericStorageId($storageId) {
		$storageId = self::adjustStorageId($storageId);

if ($row = self::getStorageById($storageId)) {
			return (int)$row['numeric_id'];
		} else {
			return null;
		}
	}

/**
	 * @return array|null [ available, last_checked ]
	 */
	public function getAvailability() {
		if ($row = self::getStorageById($this->storageId)) {
			return [
				'available' => ((int)$row['available'] === 1),
				'last_checked' => $row['last_checked']
			];
		} else {
			return null;
		}
	}

/**
	 * @param bool $isAvailable
	 */
	public function setAvailability($isAvailable) {
		// delete from local cache
		self::unsetCache($this->storageId);
		$sql = 'UPDATE `*PREFIX*storages` SET `available` = ?, `last_checked` = ? WHERE `id` = ?';
		$available = $isAvailable ? 1 : 0;
		\OC_DB::executeAudited($sql, [$available, time(), $this->storageId]);
	}

/**
	 * Check if a string storage id is known
	 *
	 * @param string $storageId
	 * @return bool
	 */
	public static function exists($storageId) {
		return !is_null(self::getNumericStorageId($storageId));
	}

/**
	 * remove the entry for the storage
	 *
	 * @param string $storageId
	 */
	public static function remove($storageId) {
		$storageId = self::adjustStorageId($storageId);
		$numericId = self::getNumericStorageId($storageId);
		$sql = 'DELETE FROM `*PREFIX*storages` WHERE `id` = ?';
		\OC_DB::executeAudited($sql, [$storageId]);

// delete from local cache
		self::unsetCache($storageId);
		// delete from db
		if (!is_null($numericId)) {
			$sql = 'DELETE FROM `*PREFIX*filecache` WHERE `storage` = ?';
			\OC_DB::executeAudited($sql, [$numericId]);
		}
	}
}