Simplify logAndMapErrors calls

app/src/main/java/gq/kirmanak/mealient/data/add/impl/AddRecipeDataSourceImpl.kt

@@ -17,8 +17,7 @@ class AddRecipeDataSourceImpl @Inject constructor(
     override suspend fun addRecipe(recipe: AddRecipeRequest): String {
         logger.v { "addRecipe() called with: recipe = $recipe" }
         val service = addRecipeServiceFactory.provideService()
-        val response = logAndMapErrors(
-            logger,
+        val response = logger.logAndMapErrors(
             block = { service.addRecipe(recipe) },
             logProvider = { "addRecipe: can't add recipe" }
         )

app/src/main/java/gq/kirmanak/mealient/data/auth/impl/AuthDataSourceImpl.kt

@@ -5,7 +5,7 @@ import gq.kirmanak.mealient.data.network.ErrorDetail
 import gq.kirmanak.mealient.data.network.NetworkError.NotMealie
 import gq.kirmanak.mealient.data.network.NetworkError.Unauthorized
 import gq.kirmanak.mealient.data.network.ServiceFactory
-import gq.kirmanak.mealient.extensions.decodeErrorBodyOrNull
+import gq.kirmanak.mealient.extensions.decodeErrorBody
 import gq.kirmanak.mealient.extensions.logAndMapErrors
 import gq.kirmanak.mealient.logging.Logger
 import kotlinx.serialization.json.Json
@@ -34,8 +34,7 @@ class AuthDataSourceImpl @Inject constructor(
         authService: AuthService,
         username: String,
         password: String
-    ): Response<GetTokenResponse> = logAndMapErrors(
-        logger,
+    ): Response<GetTokenResponse> = logger.logAndMapErrors(
         block = { authService.getToken(username = username, password = password) },
         logProvider = { "sendRequest: can't get token" },
     )
@@ -46,7 +45,9 @@ class AuthDataSourceImpl @Inject constructor(
         response.body()?.accessToken ?: throw NotMealie(NullPointerException("Body is null"))
     } else {
         val cause = HttpException(response)
-        val errorDetail: ErrorDetail? = response.decodeErrorBodyOrNull(json, logger)
+        val errorDetail = json.runCatching<Json, ErrorDetail> { decodeErrorBody(response) }
+            .onFailure { logger.e(it) { "Can't decode error body" } }
+            .getOrNull()
         throw when (errorDetail?.detail) {
             "Unauthorized" -> Unauthorized(cause)
             else -> NotMealie(cause)

app/src/main/java/gq/kirmanak/mealient/data/baseurl/impl/VersionDataSourceImpl.kt

@@ -19,8 +19,7 @@ class VersionDataSourceImpl @Inject constructor(
         logger.v { "getVersionInfo() called with: baseUrl = $baseUrl" }
 
         val service = serviceFactory.provideService(baseUrl)
-        val response = logAndMapErrors(
-            logger,
+        val response = logger.logAndMapErrors(
             block = { service.getVersion() },
             logProvider = { "getVersionInfo: can't request version" }
         )

app/src/main/java/gq/kirmanak/mealient/extensions/NetworkExtensions.kt

@@ -8,28 +8,23 @@ import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.decodeFromStream
 import retrofit2.HttpException
 import retrofit2.Response
-import java.io.InputStream
-
-inline fun <T, reified R> Response<T>.decodeErrorBodyOrNull(json: Json, logger: Logger): R? =
-    errorBody()?.byteStream()?.let { json.decodeFromStreamOrNull<R>(it, logger) }
 
 @OptIn(ExperimentalSerializationApi::class)
-inline fun <reified T> Json.decodeFromStreamOrNull(stream: InputStream, logger: Logger): T? =
-    runCatching { decodeFromStream<T>(stream) }
-        .onFailure { logger.e(it) { "decodeFromStreamOrNull: can't decode" } }
-        .getOrNull()
+inline fun <T, reified R> Json.decodeErrorBody(response: Response<T>): R =
+    checkNotNull(response.errorBody()) { "Can't decode absent error body" }
+        .byteStream()
+        .let(::decodeFromStream)
+
 
 fun Throwable.mapToNetworkError(): NetworkError = when (this) {
     is HttpException, is SerializationException -> NetworkError.NotMealie(this)
     else -> NetworkError.NoServerConnection(this)
 }
 
-inline fun <T> logAndMapErrors(
-    logger: Logger,
+inline fun <T> Logger.logAndMapErrors(
     block: () -> T,
     noinline logProvider: () -> String
-): T =
-    runCatchingExceptCancel(block).getOrElse {
-        logger.e(it, messageSupplier = logProvider)
-        throw it.mapToNetworkError()
-    }
+): T = runCatchingExceptCancel(block).getOrElse {
+    e(it, messageSupplier = logProvider)
+    throw it.mapToNetworkError()
+}