123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190 |
- <?php
- namespace OC\Cache;
- use OC\Files\Filesystem;
- use OC\Files\View;
- use OCP\ICache;
- use OCP\IUserSession;
- use OCP\Security\ISecureRandom;
- use OCP\Server;
- use Psr\Log\LoggerInterface;
- class File implements ICache {
-
- protected $storage;
-
- protected function getStorage() {
- if ($this->storage !== null) {
- return $this->storage;
- }
- $session = Server::get(IUserSession::class);
- if ($session->isLoggedIn()) {
- $rootView = new View();
- $userId = $session->getUser()->getUID();
- Filesystem::initMountPoints($userId);
- if (!$rootView->file_exists('/' . $userId . '/cache')) {
- $rootView->mkdir('/' . $userId . '/cache');
- }
- $this->storage = new View('/' . $userId . '/cache');
- return $this->storage;
- } else {
- Server::get(LoggerInterface::class)->error('Can\'t get cache storage, user not logged in', ['app' => 'core']);
- throw new \OC\ForbiddenException('Can\t get cache storage, user not logged in');
- }
- }
-
- public function get($key) {
- $result = null;
- if ($this->hasKey($key)) {
- $storage = $this->getStorage();
- $result = $storage->file_get_contents($key);
- }
- return $result;
- }
-
- public function size($key) {
- $result = 0;
- if ($this->hasKey($key)) {
- $storage = $this->getStorage();
- $result = $storage->filesize($key);
- }
- return $result;
- }
-
- public function set($key, $value, $ttl = 0) {
- $storage = $this->getStorage();
- $result = false;
-
- $uniqueId = Server::get(ISecureRandom::class)->generate(
- 16,
- ISecureRandom::CHAR_ALPHANUMERIC
- );
-
-
- $keyPart = $key . '.' . $uniqueId . '.part';
- if ($storage && $storage->file_put_contents($keyPart, $value)) {
- if ($ttl === 0) {
- $ttl = 86400;
- }
- $result = $storage->touch($keyPart, time() + $ttl);
- $result &= $storage->rename($keyPart, $key);
- }
- return $result;
- }
-
- public function hasKey($key) {
- $storage = $this->getStorage();
- if ($storage && $storage->is_file($key) && $storage->isReadable($key)) {
- return true;
- }
- return false;
- }
-
- public function remove($key) {
- $storage = $this->getStorage();
- if (!$storage) {
- return false;
- }
- return $storage->unlink($key);
- }
-
- public function clear($prefix = '') {
- $storage = $this->getStorage();
- if ($storage && $storage->is_dir('/')) {
- $dh = $storage->opendir('/');
- if (is_resource($dh)) {
- while (($file = readdir($dh)) !== false) {
- if ($file !== '.' && $file !== '..' && ($prefix === '' || str_starts_with($file, $prefix))) {
- $storage->unlink('/' . $file);
- }
- }
- }
- }
- return true;
- }
-
- public function gc() {
- $storage = $this->getStorage();
- if ($storage) {
-
-
- $now = time() - 3600;
- $dh = $storage->opendir('/');
- if (!is_resource($dh)) {
- return null;
- }
- while (($file = readdir($dh)) !== false) {
- if ($file !== '.' && $file !== '..') {
- try {
- $mtime = $storage->filemtime('/' . $file);
- if ($mtime < $now) {
- $storage->unlink('/' . $file);
- }
- } catch (\OCP\Lock\LockedException $e) {
-
- Server::get(LoggerInterface::class)->debug('Could not cleanup locked chunk "' . $file . '"', ['app' => 'core']);
- } catch (\OCP\Files\ForbiddenException $e) {
- Server::get(LoggerInterface::class)->debug('Could not cleanup forbidden chunk "' . $file . '"', ['app' => 'core']);
- } catch (\OCP\Files\LockNotAcquiredException $e) {
- Server::get(LoggerInterface::class)->debug('Could not cleanup locked chunk "' . $file . '"', ['app' => 'core']);
- }
- }
- }
- }
- }
- public static function isAvailable(): bool {
- return true;
- }
- }
|