network/com.wire.kalium.network.utils

Package-level declarations

Types

CustomErrors

object CustomErrors

HttpErrorCodes

enum HttpErrorCodes : Enum<HttpErrorCodes>

MockUnboundNetworkClient

object MockUnboundNetworkClient

MockWebSocketSession

class MockWebSocketSession(val coroutineContext: <Error class: unknown class> = EmptyCoroutineContext)

NetworkResponse

sealed class NetworkResponse<out T : Any>

Properties

sensitiveJsonKeys

val sensitiveJsonKeys: <Error class: unknown class>

UnreachableRemoteBackends

internal val <Error class: unknown class>.UnreachableRemoteBackends: <Error class: unknown class>

Custom HttpStatusCode to handle when one or more federated remote servers are unreachable.

Functions

deleteSensitiveItemsFromJson

fun deleteSensitiveItemsFromJson(text: String): String

flatMap

internal inline fun <T : Any, R : Any> NetworkResponse<T>.flatMap(fn: (NetworkResponse.Success<T>) -> NetworkResponse<R>): NetworkResponse<R>

handleUnsuccessfulResponse

internal suspend fun handleUnsuccessfulResponse(result: <Error class: unknown class>): NetworkResponse.Error

installWireDefaultRequest

fun <Error class: unknown class><out <Error class: unknown class>>.installWireDefaultRequest(serverConfigDTO: <Error class: unknown class>)

isSuccessful

fun <T : Any> NetworkResponse<T>.isSuccessful(): Boolean

mapSuccess

internal inline fun <T : Any, U : Any> NetworkResponse<T>.mapSuccess(mapping: (T) -> U): NetworkResponse<U>

If the request is successful, perform mapping and create a new Success with its result

obfuscatedJsonElement

fun obfuscatedJsonElement(element: <Error class: unknown class>): <Error class: unknown class>

obfuscatedJsonMessage

fun obfuscatedJsonMessage(text: String): String

obfuscatePath

fun obfuscatePath(url: <Error class: unknown class>): String

onFailure

internal inline fun <T : Any> NetworkResponse<T>.onFailure(fn: (NetworkResponse.Error) -> Unit): NetworkResponse<T>

onSuccess

internal inline fun <T : Any> NetworkResponse<T>.onSuccess(fn: (NetworkResponse.Success<T>) -> Unit): NetworkResponse<T>

setUrl

internal fun <Error class: unknown class>.setUrl(baseUrl: <Error class: unknown class>, vararg path: String)

internal fun <Error class: unknown class>.setUrl(baseUrl: String, vararg path: String)

setWSSUrl

internal fun <Error class: unknown class>.setWSSUrl(baseUrl: <Error class: unknown class>, vararg path: String)

splitSetCookieHeader

internal fun String.splitSetCookieHeader(): List<String>

wrapFederationResponse

suspend fun <T : Any> wrapFederationResponse(response: <Error class: unknown class>, delegatedHandler: suspend (<Error class: unknown class>) -> NetworkResponse<T>): NetworkResponse<T>

Wrap and handles federation aware endpoints that can send errors responses And raise specific federated context exceptions,

wrapKaliumResponse

internal inline suspend fun <BodyType : Any> wrapKaliumResponse(unsuccessfulResponseOverride: (<Error class: unknown class>) -> NetworkResponse<BodyType>? = { null }, performRequest: () -> <Error class: unknown class>): NetworkResponse<BodyType>

Wraps a producer of HttpResponse and attempts to parse the server response based on the BodyType.