Merge branch '7922-main-autherror' into 'main' (c058245a) · Commits · e / os / AccountManager

app/build.gradle

+12 −1

Original line number	Diff line number	Diff line
		@@ -20,10 +20,21 @@ def buildDate = { ->
		android {
		compileSdk 34

		def localPropsFile = rootProject.file("local.properties")
		def localProps = new Properties()

		if (localPropsFile.exists()) {
		localProps.load(new FileInputStream(localPropsFile))
		}

		def appVersionCode = localProps.getProperty('VERSION_CODE', '403090007').toInteger() + 1
		localProps.setProperty('VERSION_CODE', appVersionCode.toString())
		localProps.store(new FileOutputStream(localPropsFile), null)

		defaultConfig {
		applicationId "foundation.e.accountmanager"

		versionCode 403090007
		versionCode appVersionCode
		versionName '4.3.9-7'

		buildConfigField "long", "buildTime", System.currentTimeMillis() + "L"

app/src/main/kotlin/at/bitfire/davdroid/Constants.kt

+2 −0

Original line number	Diff line number	Diff line
		@@ -34,4 +34,6 @@ object Constants {
		const val E_SYNC_URL = "e.email"

		const val MURENA_DAV_URL = "https://murena.io/remote.php/dav"

		const val HTTP_STATUS_CODE_TOO_MANY_REQUESTS = 429
		}

app/src/main/kotlin/at/bitfire/davdroid/db/Credentials.kt

+2 −1

Original line number	Diff line number	Diff line
		@@ -13,7 +13,8 @@ data class Credentials(
		val authState: AuthState? = null,
		val certificateAlias: String? = null,
		val serverUri: URI? = null,
		val clientSecret: String? = null
		val clientSecret: String? = null,
		var passwordNeedsUpdate: Boolean = false
		) {

		override fun toString(): String {

app/src/main/kotlin/at/bitfire/davdroid/settings/AccountSettings.kt

+10 −1

Original line number	Diff line number	Diff line
		@@ -73,6 +73,7 @@ class AccountSettings(
		const val KEY_AUTH_STATE = "auth_state"
		const val KEY_CLIENT_SECRET = "client_secret"
		const val KEY_CERTIFICATE_ALIAS = "certificate_alias"
		const val KEY_PASSWORD_NEEDS_UPDATE = "password_needs_update"

		const val KEY_WIFI_ONLY = "wifi_only" // sync on WiFi only (default: false)
		const val KEY_WIFI_ONLY_SSIDS = "wifi_only_ssids" // restrict sync to specific WiFi SSIDs
		@@ -156,6 +157,9 @@ class AccountSettings(
		if (credentials.clientSecret != null) {
		bundle.putString(KEY_CLIENT_SECRET, credentials.clientSecret)
		}

		bundle.putString(KEY_PASSWORD_NEEDS_UPDATE,
		credentials.passwordNeedsUpdate.toString())
		}

		if (!cookies.isNullOrEmpty()) {
		@@ -270,7 +274,9 @@ class AccountSettings(
		accountManager.getUserData(account, KEY_USERNAME),
		accountManager.getPassword(account),
		null,
		accountManager.getUserData(account, KEY_CERTIFICATE_ALIAS)
		accountManager.getUserData(account, KEY_CERTIFICATE_ALIAS),
		passwordNeedsUpdate = accountManager.getUserData(
		account, KEY_PASSWORD_NEEDS_UPDATE).toBoolean()
		)
		} else {
		Credentials(
		@@ -287,6 +293,9 @@ class AccountSettings(
		// Basic/Digest auth
		accountManager.setAndVerifyUserData(account, KEY_USERNAME, credentials.userName)
		accountManager.setPassword(account, credentials.password)
		accountManager.setAndVerifyUserData(account, KEY_PASSWORD_NEEDS_UPDATE,
		credentials.passwordNeedsUpdate.toString()
		)

		// client certificate
		accountManager.setAndVerifyUserData(account, KEY_CERTIFICATE_ALIAS, credentials.certificateAlias)

app/src/main/kotlin/at/bitfire/davdroid/syncadapter/SyncManager.kt

+17 −4

Original line number	Diff line number	Diff line
		@@ -179,8 +179,14 @@ abstract class SyncManager<ResourceType: LocalResource<*>, out CollectionType: L
		* Call performSync with default retry values
		*/
		fun performSync() {
		val authState = accountSettings.credentials().authState
		val credentials = accountSettings.credentials()
		if (credentials.passwordNeedsUpdate) {
		val exception = UnauthorizedException(context.getString(R.string.sync_error_authentication_failed))
		notifyException(exception, null, null)
		return
		}

		val authState = credentials.authState
		if (authState == null \|\| !authState.needsTokenRefresh) {
		performSync(DEFAULT_RETRY_AFTER, DEFAULT_SECOND_RETRY_AFTER, DEFAULT_MAX_RETRY_TIME)
		return
		@@ -222,8 +228,7 @@ abstract class SyncManager<ResourceType: LocalResource<*>, out CollectionType: L
		* @param secondRetryAfter optional param, in seconds. Used to calculate fibonnacci sequence for rety on unhandled exception
		* @param maxRetryTime optional param, in seconds. On unhandled exception, max time the method should retry.
		*/
		fun performSync(retryAfter: Int, secondRetryAfter: Int, maxRetryTime: Int) {

		private fun performSync(retryAfter: Int, secondRetryAfter: Int, maxRetryTime: Int) {
		// dismiss previous error notifications
		notificationManager.cancel(notificationTag, NotificationUtils.NOTIFY_SYNC_ERROR)

		@@ -379,6 +384,11 @@ abstract class SyncManager<ResourceType: LocalResource<*>, out CollectionType: L

		is UnauthorizedException -> {
		Logger.log.log(Level.WARNING, "Got 401 Unauthorized", e)
		val credentials = accountSettings.credentials()
		if (credentials.authState == null) {
		credentials.passwordNeedsUpdate = true
		accountSettings.credentials(credentials)
		}
		notifyException(e, local, remote)
		return@unwrapExceptions
		}
		@@ -407,6 +417,10 @@ abstract class SyncManager<ResourceType: LocalResource<*>, out CollectionType: L
		if (retryAfter > 0 && secondRetryAfter > 0 && retryAfter <= maxRetryTime) {
		try {
		Logger.log.severe("Faced unhandled exception $e, Will retry sync")
		if (e is HttpException && e.code == Constants.HTTP_STATUS_CODE_TOO_MANY_REQUESTS) {
		Logger.log.info("HTTP 429 Too Many Requests: Retry sync cancelled")
		return false
		}
		Logger.log.info("Retry sync after $retryAfter seconds")
		Thread.sleep(retryAfter * 1000L)
		performSync(secondRetryAfter, retryAfter + secondRetryAfter, maxRetryTime)
		@@ -940,7 +954,6 @@ abstract class SyncManager<ResourceType: LocalResource<*>, out CollectionType: L
		.setCategory(NotificationCompat.CATEGORY_ERROR)
		viewItemAction?.let { builder.addAction(it) }


		notificationManager.notifyIfPossible(tag, NotificationUtils.NOTIFY_SYNC_ERROR, builder.build())
		}