nextcloud / server

	/**

	 * run timed job for resources

	 */

	private function runResources() {

		$resourceBackends = $this->resourceManager->getBackends();

		$cachedResources = $this->getCached($this->resourceDbTable);

		$cachedResourceIds = $this->getCachedResourceIds($cachedResources);

		$remoteResourceIds = [];

		foreach($resourceBackends as $resourceBackend) {

			try {

				$remoteResourceIds[$resourceBackend->getBackendIdentifier()] =

					$resourceBackend->listAllResources();

			} catch(BackendTemporarilyUnavailableException $ex) {

				// If the backend is temporarily unavailable

				// ignore this backend in this execution

				unset($cachedResourceIds[$resourceBackend->getBackendIdentifier()]);

			}

		}

		$sortedResources = $this->sortByNewDeletedExisting($cachedResourceIds, $remoteResourceIds);

		foreach($sortedResources['new'] as $backendId => $newResources) {

			foreach ($newResources as $newResource) {

				$backend = $this->resourceManager->getBackend($backendId);

				if ($backend === null) {

					continue;

				}

				$resource = $backend->getResource($newResource);

				$this->addToCache($this->resourceDbTable, $resource);

			}

		}

		foreach($sortedResources['deleted'] as $backendId => $deletedResources) {

			foreach ($deletedResources as $deletedResource) {

				$this->deleteFromCache($this->resourceDbTable,

					$this->resourcePrincipalUri, $backendId, $deletedResource);

			}

		}

		foreach($sortedResources['edited'] as $backendId => $editedResources) {

			foreach ($editedResources as $editedResource) {

				$backend = $this->resourceManager->getBackend($backendId);

				if ($backend === null) {

					continue;

				}

				$resource = $backend->getResource($editedResource);

				$this->updateCache($this->resourceDbTable, $resource);

			}

		}

	}

	/**

	 * run timed job for rooms

	/**

	 * run timed job for rooms

	 */

	private function runRooms() {

		$roomBackends = $this->roomManager->getBackends();

		$cachedRooms = $this->getCached($this->roomDbTable);

		$cachedRoomIds = $this->getCachedRoomIds($cachedRooms);

		$remoteRoomIds = [];

		foreach($roomBackends as $roomBackend) {

			try {

				$remoteRoomIds[$roomBackend->getBackendIdentifier()] =

					$roomBackend->listAllRooms();

			} catch(BackendTemporarilyUnavailableException $ex) {

				// If the backend is temporarily unavailable

				// ignore this backend in this execution

				unset($cachedRoomIds[$roomBackend->getBackendIdentifier()]);

			}

		}

		$sortedRooms = $this->sortByNewDeletedExisting($cachedRoomIds, $remoteRoomIds);

		foreach($sortedRooms['new'] as $backendId => $newRooms) {

			foreach ($newRooms as $newRoom) {

				$backend = $this->roomManager->getBackend($backendId);

				if ($backend === null) {

					continue;

				}

				$resource = $backend->getRoom($newRoom);

				$this->addToCache($this->roomDbTable, $resource);

			}

		}

		foreach($sortedRooms['deleted'] as $backendId => $deletedRooms) {

			foreach ($deletedRooms as $deletedRoom) {

				$this->deleteFromCache($this->roomDbTable,

					$this->roomPrincipalUri, $backendId, $deletedRoom);

			}

		}

		foreach($sortedRooms['edited'] as $backendId => $editedRooms) {

			foreach ($editedRooms as $editedRoom) {

				$backend = $this->roomManager->getBackend($backendId);

				if ($backend === null) {

					continue;

				}

				$resource = $backend->getRoom($editedRoom);

				$this->updateCache($this->roomDbTable, $resource);

			}

		}

	}

	/**

	 * get cached db rows for resources / rooms