nextcloud-server/lib/private/Files/Cache/StorageGlobal.php

<?php

declare(strict_types=1);

/**
 * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */
namespace OC\Files\Cache;

use OCP\DB\QueryBuilder\IQueryBuilder;
use OCP\IDBConnection;

/**
 * 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 through this class
 *
 * @package OC\Files\Cache
 */
class StorageGlobal {
	/** @var array<string, array{id: string, numeric_id: int, available: bool, last_checked: int}> */
	private array $cache = [];

	/** @var array<int, array{id: string, numeric_id: int, available: bool, last_checked: int}> */
	private array $numericIdCache = [];

	public function __construct(
		private readonly IDBConnection $connection,
	) {
	}

	/**
	 * @param string[] $storageIds
	 */
	public function loadForStorageIds(array $storageIds): void {
		$builder = $this->connection->getQueryBuilder();
		$query = $builder->select(['id', 'numeric_id', 'available', 'last_checked'])
			->from('storages')
			->where($builder->expr()->in('id', $builder->createNamedParameter(array_values($storageIds), IQueryBuilder::PARAM_STR_ARRAY)));

		$result = $query->executeQuery();
		while (($row = $result->fetch()) !== false) {
			$normalizedRow = [
				'id' => (string)$row['id'],
				'numeric_id' => (int)$row['numeric_id'],
				'available' => (bool)$row['available'],
				'last_checked' => (int)$row['last_checked'],
			];

			$this->cache[$normalizedRow['id']] = $normalizedRow;
		}

		$result->closeCursor();
	}

	/**
	 * @return array{id: string, numeric_id: int, available: bool, last_checked: int}|null
	 */
	public function getStorageInfo(string $storageId): ?array {
		if (!isset($this->cache[$storageId])) {
			$builder = $this->connection->getQueryBuilder();
			$query = $builder->select(['id', 'numeric_id', 'available', 'last_checked'])
				->from('storages')
				->where($builder->expr()->eq('id', $builder->createNamedParameter($storageId)));

			$result = $query->executeQuery();
			$row = $result->fetch();
			$result->closeCursor();

			if ($row !== false) {
				$normalizedRow = [
					'id' => (string)$row['id'],
					'numeric_id' => (int)$row['numeric_id'],
					'available' => (bool)$row['available'],
					'last_checked' => (int)$row['last_checked'],
				];

				$this->cache[$storageId] = $normalizedRow;
				$this->numericIdCache[$normalizedRow['numeric_id']] = $normalizedRow;
			}
		}

		return $this->cache[$storageId] ?? null;
	}

	/**
	 * @return array{id: string, numeric_id: int, available: bool, last_checked: int}|null
	 */
	public function getStorageInfoByNumericId(int $numericId): ?array {
		if (!isset($this->numericIdCache[$numericId])) {
			$builder = $this->connection->getQueryBuilder();
			$query = $builder->select(['id', 'numeric_id', 'available', 'last_checked'])
				->from('storages')
				->where($builder->expr()->eq('numeric_id', $builder->createNamedParameter($numericId)));

			$result = $query->executeQuery();
			$row = $result->fetch();
			$result->closeCursor();

			if ($row !== false) {
				$normalizedRow = [
					'id' => (string)$row['id'],
					'numeric_id' => (int)$row['numeric_id'],
					'available' => (bool)$row['available'],
					'last_checked' => (int)$row['last_checked'],
				];

				$this->numericIdCache[$numericId] = $normalizedRow;
				$this->cache[$normalizedRow['id']] = $normalizedRow;
			}
		}

		return $this->numericIdCache[$numericId] ?? null;
	}

	public function clearCache(): void {
		$this->cache = [];
	}
}