appData.service.js

/**
 * SPDX-FileCopyrightText: 2023 Nextcloud GmbH and Nextcloud contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

import packageJson from '../../package.json'
import { getCapabilities, getCurrentUserData } from '../shared/ocs.service.js'

/**
 * Re-fetch capabilities and userMetadata and update appData
 *
 * @param {import('./AppData.js').appData} appData appData
 * @param {boolean} [persist] Persist after re-fetch
 * @return {Promise<void>}
 * @throws {Error}
 */
export async function refetchAppData(appData, persist = false) {
	const [userMetadata, capabilitiesResponse] = await Promise.all([
		getCurrentUserData(appData.serverUrl),
		getCapabilities(appData.serverUrl),
	])
	const talkCapabilities = capabilitiesResponse.capabilities.spreed
	appData.talkHash = null
	appData.talkHashDirty = false
	appData.userMetadata = userMetadata
	appData.capabilities = capabilitiesResponse.capabilities
	appData.version.nextcloud = capabilitiesResponse.version
	appData.version.talk = talkCapabilities.version
	appData.version.desktop = packageJson.version
	if (persist) {
		appData.persist()
	}
}

/**
 * Re-fetch capabilities and userMetadata with retry and update appData
 *
 * @param {import('./AppData.js').appData} appData appData
 * @return {Promise<void>}
 */
export async function refetchAppDataWithRetry(appData) {
	await new Promise((resolve) => {
		/**
		 * Try to re-fetch appData
		 *
		 * @return {Promise<boolean>} true if re-fetch finished and should not be retried
		 */
		async function doRefetch() {
			try {
				await refetchAppData(appData, true)
				console.debug('AppData re-fetched')
				return true
			} catch (error) {
				if (error.response?.status === 401) {
					appData.reset().persist()
					console.debug('AppData credentials are invalid... Resetting')
					return true
				}
				// Network error, maintenance, service unavailable etc.
				// Let's try again later
				console.debug(`Cannot get AppData... Error: ${error.code}. Response status: ${error.response?.status || 'unknown'}`)
				return false
			}
		}

		/**
		 * Recursively re-try a re-fetch attempt with a timeout
		 *
		 * @param {number} [delay] delay in milliseconds
		 */
		function retryRefetch(delay = 1_000) {
			const MAX_DELAY = 2 ** 7 * 1000 // 128_000 = ~2 minutes

			console.debug(`Retry in ${delay} ms...`)
			setTimeout(async () => {
				if (await doRefetch()) {
					return resolve()
				}
				retryRefetch(delay < MAX_DELAY ? delay * 2 : delay)
			}, delay)
		}

		doRefetch()
			.then((success) => {
				if (success) {
					return resolve()
				}
				retryRefetch()
			})
	})
}