androidApp/src/main/java/bou/amine/apps/readerforselfossv2/android/HomeActivity.kt

@@ -869,9 +869,7 @@ class HomeActivity : AppCompatActivity(), SearchView.OnQueryTextListener, DIAwar
                 return true
             }
             R.id.action_disconnect -> {
-                CoroutineScope(Dispatchers.Main).launch {
+                appSettingsService.clearAll()
-                    repository.logout()
-                }
                 val intent = Intent(this, LoginActivity::class.java)
                 this.startActivity(intent)
                 this@HomeActivity.finish()

androidApp/src/test/kotlin/RepositoryTest.kt

@@ -1023,7 +1023,7 @@ class RepositoryTest {
 
     @Test
     fun create_source() {
-        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any()) } returns
+        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any(), any()) } returns
                 SuccessResponse(true)
 
         initializeRepository()
@@ -1045,6 +1045,7 @@ class RepositoryTest {
                 any(),
                 any(),
                 any(),
+                any()
             )
         }
         assertSame(true, response)
@@ -1052,7 +1053,7 @@ class RepositoryTest {
 
     @Test
     fun create_source_but_response_fails() {
-        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any()) } returns
+        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any(), any()) } returns
                 SuccessResponse(false)
 
         initializeRepository()
@@ -1074,6 +1075,7 @@ class RepositoryTest {
                 any(),
                 any(),
                 any(),
+                any()
             )
         }
         assertSame(false, response)
@@ -1081,7 +1083,7 @@ class RepositoryTest {
 
     @Test
     fun create_source_without_connection() {
-        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any()) } returns
+        coEvery { api.createSourceForVersion(any(), any(), any(), any(), any(), any()) } returns
                 SuccessResponse(true)
 
         initializeRepository(MutableStateFlow(false))
@@ -1102,6 +1104,7 @@ class RepositoryTest {
                 any(),
                 any(),
                 any(),
+                any(),
                 any()
             )
         }

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/model/ResultModel.kt

@@ -23,14 +23,6 @@ class StatusAndData<T>(val success: Boolean, val data: T? = null) {
     }
 }
 
-suspend fun responseOrSuccessIf404(r: HttpResponse): SuccessResponse {
-    return if (r.status === HttpStatusCode.NotFound) {
-        SuccessResponse(true)
-    } else {
-        maybeResponse(r)
-    }
-}
-
 suspend fun maybeResponse(r: HttpResponse): SuccessResponse {
     return if (r.status.isSuccess()) {
         r.body()

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/repository/RepositoryImpl.kt

@@ -340,7 +340,8 @@ class Repository(private val api: SelfossApi, private val appSettingsService: Ap
                 url,
                 spout,
                 tags,
-                filter
+                filter,
+                appSettingsService.getApiVersion()
             ).isSuccess == true
         }
 
@@ -372,29 +373,12 @@ class Repository(private val api: SelfossApi, private val appSettingsService: Ap
                 val response = api.login()
                 result = response.isSuccess == true
             } catch (cause: Throwable) {
-                Napier.e(cause.stackTraceToString(), tag = "RepositoryImpl.login")
+                Napier.e(cause.stackTraceToString(), tag = "RepositoryImpl.updateRemote")
             }
         }
         return result
     }
 
-    suspend fun logout() {
-        if (isNetworkAvailable()) {
-            try {
-                val response = api.logout()
-                if (response.isSuccess) {
-                    Napier.e("Couldn't logout.", tag = "RepositoryImpl.logout")
-                }
-            } catch (cause: Throwable) {
-                Napier.e(cause.stackTraceToString(), tag = "RepositoryImpl.logout")
-            } finally {
-                appSettingsService.clearAll()
-            }
-        } else {
-            appSettingsService.clearAll()
-        }
-    }
-
     fun refreshLoginInformation(url: String, login: String, password: String) {
         appSettingsService.refreshLoginInformation(url, login, password)
         baseUrl = url

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/rest/SelfossApi.kt

@@ -2,12 +2,11 @@ package bou.amine.apps.readerforselfossv2.rest
 
 import bou.amine.apps.readerforselfossv2.model.*
 import bou.amine.apps.readerforselfossv2.service.AppSettingsService
-import io.github.aakira.napier.Napier
 import io.ktor.client.*
+import io.ktor.client.call.*
 import io.ktor.client.plugins.*
 import io.ktor.client.plugins.cache.*
 import io.ktor.client.plugins.contentnegotiation.*
-import io.ktor.client.plugins.cookies.*
 import io.ktor.client.plugins.logging.*
 import io.ktor.client.request.*
 import io.ktor.client.request.forms.*
@@ -21,7 +20,7 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
     var client = createHttpClient()
 
     private fun createHttpClient(): HttpClient {
-        val client = HttpClient {
+        return HttpClient {
             install(ContentNegotiation) {
                 install(HttpCache)
                 json(Json {
@@ -33,7 +32,7 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
             install(Logging) {
                 logger = object : Logger {
                     override fun log(message: String) {
-                        Napier.d(message, tag = "LogApiCalls")
+                        appSettingsService.logApiCalls(message)
                     }
                 }
                 level = LogLevel.INFO
@@ -41,26 +40,22 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
             install(HttpTimeout) {
                 requestTimeoutMillis = appSettingsService.getApiTimeout()
             }
-            install(HttpCookies)
+            /* TODO: Auth as basic
+            if (apiDetailsService.getUserName().isNotEmpty() && apiDetailsService.getPassword().isNotEmpty()) {
+
+                install(Auth) {
+                    basic {
+                        credentials {
+                            BasicAuthCredentials(username = apiDetailsService.getUserName(), password = apiDetailsService.getPassword())
+                        }
+                        sendWithoutRequest {
+                            true
+                        }
+                    }
+                }
+            }*/
             expectSuccess = false
         }
-
-        client.plugin(HttpSend).intercept { request ->
-            val originalCall = execute(request)
-            if (originalCall.response.status == HttpStatusCode.Forbidden && shouldHavePostLogin() && hasLoginInfo()) {
-                Napier.i("Forbidden action, will try to login and retry", tag = "HttpSend")
-
-                if (login().isSuccess) {
-                    Napier.i("Logged in worked", tag = "HttpSend")
-                    execute(request)
-                }
-                originalCall
-            } else {
-                originalCall
-            }
-        }
-
-        return client
     }
 
     fun url(path: String) =
@@ -71,38 +66,11 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
         client = createHttpClient()
     }
 
-    // Api version was introduces after the POST login, so when there is a version, it should be available
-    private fun shouldHavePostLogin() = appSettingsService.getApiVersion() != -1
-    private fun hasLoginInfo() = appSettingsService.getUserName() != null && appSettingsService.getPassword() != null
-
     suspend fun login(): SuccessResponse =
-        if (shouldHavePostLogin()) {
+        maybeResponse(client.get(url("/login")) {
-            postLogin()
+            parameter("username", appSettingsService.getUserName())
-        } else {
+            parameter("password", appSettingsService.getPassword())
-            getLogin()
+        })
-        }
-
-    private suspend fun getLogin() = maybeResponse(client.get(url("/login")) {
-        parameter("username", appSettingsService.getUserName())
-        parameter("password", appSettingsService.getPassword())
-    })
-
-    private suspend fun postLogin() = maybeResponse(client.post(url("/login")) {
-        parameter("username", appSettingsService.getUserName())
-        parameter("password", appSettingsService.getPassword())
-    })
-
-    private fun shouldHaveNewLogout() = appSettingsService.getApiVersion() >= 5 // We are missing 4.1.0
-    suspend fun logout(): SuccessResponse =
-        if (shouldHaveNewLogout()) {
-            doLogout()
-        } else {
-            maybeLogoutIfAvailable()
-        }
-
-    private suspend fun maybeLogoutIfAvailable() = responseOrSuccessIf404(client.get(url("/logout")))
-
-    private suspend fun doLogout() = maybeResponse(client.delete(url("/api/session/current")))
 
     suspend fun getItems(
         type: String,
@@ -114,102 +82,80 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
         items: Int? = null
     ): StatusAndData<List<SelfossModel.Item>> =
         bodyOrFailure(client.get(url("/items")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+                parameter("type", type)
-            parameter("type", type)
+                parameter("tag", tag)
-            parameter("tag", tag)
+                parameter("source", source)
-            parameter("source", source)
+                parameter("search", search)
-            parameter("search", search)
+                parameter("updatedsince", updatedSince)
-            parameter("updatedsince", updatedSince)
+                parameter("items", items ?: appSettingsService.getItemsNumber())
-            parameter("items", items ?: appSettingsService.getItemsNumber())
+                parameter("offset", offset)
-            parameter("offset", offset)
+            })
-        })
 
     suspend fun stats(): StatusAndData<SelfossModel.Stats> =
         bodyOrFailure(client.get(url("/stats")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 
     suspend fun tags(): StatusAndData<List<SelfossModel.Tag>> =
         bodyOrFailure(client.get(url("/tags")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 
     suspend fun update(): StatusAndData<String> =
         bodyOrFailure(client.get(url("/update")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 
     suspend fun spouts(): StatusAndData<Map<String, SelfossModel.Spout>> =
         bodyOrFailure(client.get(url("/sources/spouts")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 
     suspend fun sources(): StatusAndData<ArrayList<SelfossModel.Source>> =
         bodyOrFailure(client.get(url("/sources/list")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 
     suspend fun version(): StatusAndData<SelfossModel.ApiVersion> =
         bodyOrFailure(client.get(url("/api/about")))
 
     suspend fun markAsRead(id: String): SuccessResponse =
         maybeResponse(client.post(url("/mark/$id")) {
-            if (!shouldHavePostLogin()) {
+            parameter("username", appSettingsService.getUserName())
-                parameter("username", appSettingsService.getUserName())
+            parameter("password", appSettingsService.getPassword())
-                parameter("password", appSettingsService.getPassword())
-            }
         })
 
     suspend fun unmarkAsRead(id: String): SuccessResponse =
         maybeResponse(client.post(url("/unmark/$id")) {
-            if (!shouldHavePostLogin()) {
+            parameter("username", appSettingsService.getUserName())
-                parameter("username", appSettingsService.getUserName())
+            parameter("password", appSettingsService.getPassword())
-                parameter("password", appSettingsService.getPassword())
-            }
         })
 
     suspend fun starr(id: String): SuccessResponse =
         maybeResponse(client.post(url("/starr/$id")) {
-            if (!shouldHavePostLogin()) {
+            parameter("username", appSettingsService.getUserName())
-                parameter("username", appSettingsService.getUserName())
+            parameter("password", appSettingsService.getPassword())
-                parameter("password", appSettingsService.getPassword())
-            }
         })
 
     suspend fun unstarr(id: String): SuccessResponse =
         maybeResponse(client.post(url("/unstarr/$id")) {
-            if (!shouldHavePostLogin()) {
+            parameter("username", appSettingsService.getUserName())
-                parameter("username", appSettingsService.getUserName())
+            parameter("password", appSettingsService.getPassword())
-                parameter("password", appSettingsService.getPassword())
-            }
         })
 
     suspend fun markAllAsRead(ids: List<String>): SuccessResponse =
         maybeResponse(client.submitForm(
             url = url("/mark"),
             formParameters = Parameters.build {
-                if (!shouldHavePostLogin()) {
+                append("username", appSettingsService.getUserName())
-                    append("username", appSettingsService.getUserName())
+                append("password", appSettingsService.getPassword())
-                    append("password", appSettingsService.getPassword())
-                }
                 ids.map { append("ids[]", it) }
             }
         ))
@@ -219,17 +165,18 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
         url: String,
         spout: String,
         tags: String,
-        filter: String
+        filter: String,
+        version: Int
     ): SuccessResponse =
         maybeResponse(
-            if (appSettingsService.getApiVersion() > 1) {
+            if (version > 1) {
                 createSource2(title, url, spout, tags, filter)
             } else {
                 createSource(title, url, spout, tags, filter)
             }
         )
 
-    private suspend fun createSource(
+    suspend fun createSource(
         title: String,
         url: String,
         spout: String,
@@ -237,13 +184,8 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
         filter: String
     ): HttpResponse =
         client.submitForm(
-            url = url("/source"),
+            url = url("/source?username=${appSettingsService.getUserName()}&password=${appSettingsService.getPassword()}"),
             formParameters = Parameters.build {
-                // TODO: test this
-                if (!shouldHavePostLogin()) {
-                    append("username", appSettingsService.getUserName())
-                    append("password", appSettingsService.getPassword())
-                }
                 append("title", title)
                 append("url", url)
                 append("spout", spout)
@@ -252,7 +194,7 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
             }
         )
 
-    private suspend fun createSource2(
+    suspend fun createSource2(
         title: String,
         url: String,
         spout: String,
@@ -260,12 +202,8 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
         filter: String
     ): HttpResponse =
         client.submitForm(
-            url = url("/source"),
+            url = url("/source?username=${appSettingsService.getUserName()}&password=${appSettingsService.getPassword()}"),
             formParameters = Parameters.build {
-                if (!shouldHavePostLogin()) {
-                    append("username", appSettingsService.getUserName())
-                    append("password", appSettingsService.getPassword())
-                }
                 append("title", title)
                 append("url", url)
                 append("spout", spout)
@@ -276,9 +214,7 @@ class SelfossApi(private val appSettingsService: AppSettingsService) {
 
     suspend fun deleteSource(id: Int): SuccessResponse =
         maybeResponse(client.delete(url("/source/$id")) {
-            if (!shouldHavePostLogin()) {
                 parameter("username", appSettingsService.getUserName())
                 parameter("password", appSettingsService.getPassword())
-            }
+            })
-        })
 }

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/service/AppSettingsService.kt

@@ -44,6 +44,10 @@ class AppSettingsService {
         refreshUserSettings()
     }
 
+    fun logApiCalls(message: String) {
+        Napier.d(message, tag = "LogApiCalls")
+    }
+
     fun getApiVersion(): Int {
         if (_apiVersion == -1) {
             refreshApiVersion()