fix: handle DataStore preferences corruption gracefully

- Add ReplaceFileCorruptionHandler to automatically recover from corrupted preferences
- Create safer access methods with proper error handling
- Update all direct DataStore access points to use error-handled methods
- Prevent app crashes when preferences proto is corrupted

Author: ismartcoding

app/src/main/java/com/ismartcoding/plain/MainApp.kt

@@ -27,6 +27,7 @@ import com.ismartcoding.plain.preference.PasswordPreference
 import com.ismartcoding.plain.preference.UrlTokenPreference
 import com.ismartcoding.plain.preference.WebPreference
 import com.ismartcoding.plain.preference.dataStore
+import com.ismartcoding.plain.preference.getPreferencesAsync
 import com.ismartcoding.plain.receivers.PlugInControlReceiver
 import com.ismartcoding.plain.web.HttpServerManager
 import com.ismartcoding.plain.workers.FeedFetchWorker
@@ -50,7 +51,7 @@ class MainApp : Application() {
         }
 
         coIO {
-            val preferences = dataStore.data.first()
+            val preferences = dataStore.getPreferencesAsync()
             TempData.webEnabled = WebPreference.get(preferences)
             TempData.webHttps = HttpsPreference.get(preferences)
             TempData.httpPort = HttpPortPreference.get(preferences)

app/src/main/java/com/ismartcoding/plain/preference/DataStore.kt

@@ -4,12 +4,22 @@ import android.content.Context
 import androidx.datastore.core.DataStore
 import androidx.datastore.preferences.core.*
 import androidx.datastore.preferences.preferencesDataStore
+import androidx.datastore.core.handlers.ReplaceFileCorruptionHandler
 import com.ismartcoding.lib.logcat.LogCat
 import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.flow.Flow
 import java.io.IOException
 
-val Context.dataStore: DataStore<Preferences> by preferencesDataStore(name = "settings")
+val Context.dataStore: DataStore<Preferences> by preferencesDataStore(
+    name = "settings",
+    corruptionHandler = ReplaceFileCorruptionHandler(
+        produceNewData = { 
+            LogCat.e("DataStore preferences corrupted, creating new empty preferences")
+            emptyPreferences() 
+        }
+    )
+)
 
 suspend fun <T> DataStore<Preferences>.put(
     key: Preferences.Key<T>,
@@ -32,3 +42,26 @@ suspend fun <T> DataStore<Preferences>.getAsync(key: Preferences.Key<T>): T? {
         }
     }.first()[key] as T
 }
+
+suspend fun DataStore<Preferences>.getPreferencesAsync(): Preferences {
+    return data.catch { exception ->
+        if (exception is IOException) {
+            LogCat.e("Get data store preferences error $exception")
+            exception.printStackTrace()
+            emit(emptyPreferences())
+        } else {
+            throw exception
+        }
+    }.first()
+}
+
+val DataStore<Preferences>.dataFlow: Flow<Preferences>
+    get() = data.catch { exception ->
+        if (exception is IOException) {
+            LogCat.e("Get data store flow error $exception")
+            exception.printStackTrace()
+            emit(emptyPreferences())
+        } else {
+            throw exception
+        }
+    }

app/src/main/java/com/ismartcoding/plain/preference/Settings.kt

@@ -66,7 +66,7 @@ fun SettingsProvider(content: @Composable () -> Unit) {
         )
     val settings =
         remember {
-            context.dataStore.data.map {
+            context.dataStore.dataFlow.map {
                 Settings(
                     themeIndex = ThemeIndexPreference.get(it),
                     customPrimaryColor = CustomPrimaryColorPreference.get(it),

app/src/main/java/com/ismartcoding/plain/preference/WebSettings.kt

@@ -38,7 +38,7 @@ fun WebSettingsProvider(content: @Composable () -> Unit) {
         )
     val settings =
         remember {
-            context.dataStore.data.map {
+            context.dataStore.dataFlow.map {
                 WebSettings(
                     passwordType = PasswordTypePreference.get(it),
                     password = PasswordPreference.get(it),