Skip to content

Commit 4f98ea4

Browse files
dmytroreutovgastonfournier
dmytroreutov
and
gastonfournier
authored
feat: add loglevel (#135)
* feat: add loglevel * chore: respect Log.isLoggable plus refactor * chore: rename LoggerWrapper to UnleashLogger --------- Co-authored-by: Gastón Fournier <[email protected]>
1 parent 36c528d commit 4f98ea4

File tree

13 files changed

+130
-66
lines changed

13 files changed

+130
-66
lines changed

‎unleashandroidsdk/src/main/java/io/getunleash/android/DefaultUnleash.kt‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package io.getunleash.android
22

33
import android.content.Context
4-
import android.util.Log
54
import androidx.lifecycle.Lifecycle
65
import androidx.lifecycle.LifecycleOwner
76
import androidx.lifecycle.ProcessLifecycleOwner
@@ -31,6 +30,7 @@ import io.getunleash.android.metrics.NoOpMetrics
3130
import io.getunleash.android.polling.UnleashFetcher
3231
import io.getunleash.android.tasks.DataJob
3332
import io.getunleash.android.tasks.LifecycleAwareTaskManager
33+
import io.getunleash.android.util.UnleashLogger
3434
import kotlinx.collections.immutable.toImmutableList
3535
import kotlinx.coroutines.CoroutineExceptionHandler
3636
import kotlinx.coroutines.CoroutineScope
@@ -56,7 +56,7 @@ import java.util.concurrent.TimeoutException
5656
import java.util.concurrent.atomic.AtomicBoolean
5757

5858
val unleashExceptionHandler = CoroutineExceptionHandler { _, exception ->
59-
Log.e("UnleashHandler", "Caught unhandled exception: ${exception.message}", exception)
59+
UnleashLogger.e("UnleashHandler", "Caught unhandled exception: ${exception.message}", exception)
6060
}
6161

6262
private val job = SupervisorJob()
@@ -151,7 +151,7 @@ class DefaultUnleash(
151151
bootstrap: List<Toggle>
152152
) {
153153
if (!started.compareAndSet(false, true)) {
154-
Log.w(TAG, "Unleash already started, ignoring start call")
154+
UnleashLogger.w(TAG, "Unleash already started, ignoring start call")
155155
return
156156
}
157157
initialListeners.forEach { addUnleashEventListener(it) }
@@ -170,14 +170,14 @@ class DefaultUnleash(
170170
cache.subscribeTo(fetcher.getFeaturesReceivedFlow())
171171
lifecycle.addObserver(taskManager)
172172
if (bootstrapFile != null && bootstrapFile.exists()) {
173-
Log.i(TAG, "Using provided bootstrap file")
173+
UnleashLogger.i(TAG, "Using provided bootstrap file")
174174
Parser.proxyResponseAdapter.fromJson(bootstrapFile.readText())?.let { state ->
175175
val toggles = state.toggles.groupBy { it.name }
176176
.mapValues { (_, v) -> v.first() }
177177
cache.write(UnleashState(unleashContextState.value, toggles))
178178
}
179179
} else if (bootstrap.isNotEmpty()) {
180-
Log.i(TAG, "Using provided bootstrap toggles")
180+
UnleashLogger.i(TAG, "Using provided bootstrap toggles")
181181
cache.write(UnleashState(unleashContextState.value, bootstrap.associateBy { it.name }))
182182
}
183183
}
@@ -213,13 +213,13 @@ class DefaultUnleash(
213213
// subscribe to feature updates from upstream
214214
localBackup.subscribeTo(fetcher.getFeaturesReceivedFlow())
215215
unleashContextState.asStateFlow().takeWhile { !ready.get() }.collect { ctx ->
216-
Log.d(TAG, "Loading state from backup for $ctx")
216+
UnleashLogger.d(TAG, "Loading state from backup for $ctx")
217217
localBackup.loadFromDisc(unleashContextState.value)?.let { state ->
218218
if (!ready.get()) {
219-
Log.i(TAG, "Loaded state from backup for $ctx")
219+
UnleashLogger.i(TAG, "Loaded state from backup for $ctx")
220220
cache.write(state)
221221
} else {
222-
Log.d(TAG, "Ignoring backup, Unleash is already ready")
222+
UnleashLogger.d(TAG, "Ignoring backup, Unleash is already ready")
223223
}
224224
}
225225
}
@@ -336,7 +336,7 @@ class DefaultUnleash(
336336
if (listener is UnleashReadyListener) {
337337
val job = coroutineScope.launch {
338338
readyOnFeaturesReceived()
339-
Log.d(TAG, "Notifying UnleashReadyListener")
339+
UnleashLogger.d(TAG, "Notifying UnleashReadyListener")
340340
listener.onReady()
341341
}
342342
registerListenerJob(listener, job)
@@ -391,9 +391,9 @@ class DefaultUnleash(
391391
val first = cache.getUpdatesFlow().first { it ->
392392
it.toggles.isNotEmpty()
393393
}
394-
Log.d(TAG, "Received first cache update: $first")
394+
UnleashLogger.d(TAG, "Received first cache update: $first")
395395
if (ready.compareAndSet(false, true)) {
396-
Log.d(TAG, "Unleash state changed to ready")
396+
UnleashLogger.d(TAG, "Unleash state changed to ready")
397397
}
398398
}
399399

@@ -408,9 +408,9 @@ class DefaultUnleash(
408408

409409
private fun getLifecycle(androidContext: Context) =
410410
if (androidContext is LifecycleOwner) {
411-
Log.d("Unleash", "Using lifecycle from Android context")
411+
UnleashLogger.d("Unleash", "Using lifecycle from Android context")
412412
androidContext.lifecycle
413413
} else {
414-
Log.d("Unleash", "Using lifecycle from ProcessLifecycleOwner")
414+
UnleashLogger.d("Unleash", "Using lifecycle from ProcessLifecycleOwner")
415415
ProcessLifecycleOwner.get().lifecycle
416416
}

‎unleashandroidsdk/src/main/java/io/getunleash/android/backup/LocalBackup.kt‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
11
package io.getunleash.android.backup
22

3-
import android.util.Log
43
import com.squareup.moshi.JsonAdapter
54
import io.getunleash.android.data.Parser.moshi
65
import io.getunleash.android.data.Toggle
76
import io.getunleash.android.data.UnleashContext
87
import io.getunleash.android.data.UnleashState
98
import io.getunleash.android.unleashScope
9+
import io.getunleash.android.util.UnleashLogger
1010
import kotlinx.coroutines.Dispatchers
1111
import kotlinx.coroutines.flow.Flow
1212
import kotlinx.coroutines.launch
@@ -39,7 +39,7 @@ open class LocalBackup(
3939
lastContext = it.context
4040
writeToDisc(it)
4141
} else {
42-
Log.d(TAG, "Context unchanged, not writing to disc")
42+
UnleashLogger.d(TAG, "Context unchanged, not writing to disc")
4343
}
4444
}
4545
}
@@ -58,9 +58,9 @@ open class LocalBackup(
5858
)
5959
).toByteArray(Charsets.UTF_8)
6060
)
61-
Log.d(TAG, "Written state to ${contextBackup.absolutePath}")
61+
UnleashLogger.d(TAG, "Written state to ${contextBackup.absolutePath}")
6262
} catch (e: Exception) {
63-
Log.i(TAG, "Error writing to disc", e)
63+
UnleashLogger.i(TAG, "Error writing to disc", e)
6464
}
6565
}
6666

@@ -71,15 +71,15 @@ open class LocalBackup(
7171
val backupState =
7272
backupAdapter.fromJson(stateBackup.readText(Charsets.UTF_8)) ?: return null
7373
if (backupState.contextId != id(context)) {
74-
Log.i(TAG, "Context id mismatch, ignoring backup for context id ${backupState.contextId}")
74+
UnleashLogger.i(TAG, "Context id mismatch, ignoring backup for context id ${backupState.contextId}")
7575
return null
7676
}
7777
return UnleashState(context, backupState.toggles)
7878
} else {
79-
Log.d(TAG, "No backup found at ${stateBackup.absolutePath}")
79+
UnleashLogger.d(TAG, "No backup found at ${stateBackup.absolutePath}")
8080
}
8181
} catch (e: Exception) {
82-
Log.w(TAG, "Error loading from disc ${stateBackup.absolutePath}", e)
82+
UnleashLogger.w(TAG, "Error loading from disc ${stateBackup.absolutePath}", e)
8383
}
8484
return null
8585
}

‎unleashandroidsdk/src/main/java/io/getunleash/android/cache/CacheDirectoryProvider.kt‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package io.getunleash.android.cache
22

33
import android.content.Context
4-
import android.util.Log
54
import io.getunleash.android.backup.LocalStorageConfig
5+
import io.getunleash.android.util.UnleashLogger
66
import java.io.File
77

88
class CacheDirectoryProvider(
@@ -18,7 +18,7 @@ class CacheDirectoryProvider(
1818
val tempStorageDir: File = config.dir?.let { File(it) } ?: context.cacheDir
1919
val tempDir = File(tempStorageDir, tempDirName)
2020
if (!createDirectoryIfNotExists(tempDir)) {
21-
Log.w(TAG, "Failed to create directory ${tempDir.absolutePath}")
21+
UnleashLogger.w(TAG, "Failed to create directory ${tempDir.absolutePath}")
2222
} else {
2323
if (deleteOnShutdown) addShutdownHook(tempDir)
2424
}
@@ -27,14 +27,14 @@ class CacheDirectoryProvider(
2727

2828
private fun createDirectoryIfNotExists(file: File): Boolean {
2929
if (file.exists()) {
30-
Log.d(TAG, "Directory ${file.absolutePath} already exists")
30+
UnleashLogger.d(TAG, "Directory ${file.absolutePath} already exists")
3131
return true
3232
}
3333
if (file.mkdirs()) {
34-
Log.d(TAG, "Created directory ${file.absolutePath}")
34+
UnleashLogger.d(TAG, "Created directory ${file.absolutePath}")
3535
return true
3636
}
37-
Log.w(TAG, "Failed to create directory ${file.absolutePath}")
37+
UnleashLogger.w(TAG, "Failed to create directory ${file.absolutePath}")
3838
return false
3939
}
4040

‎unleashandroidsdk/src/main/java/io/getunleash/android/cache/ObservableCache.kt‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package io.getunleash.android.cache
22

3-
import android.util.Log
43
import io.getunleash.android.data.Toggle
54
import io.getunleash.android.data.UnleashState
65
import io.getunleash.android.unleashScope
6+
import io.getunleash.android.util.UnleashLogger
77
import kotlinx.coroutines.CoroutineScope
88
import kotlinx.coroutines.Dispatchers
99
import kotlinx.coroutines.channels.BufferOverflow
@@ -32,19 +32,19 @@ class ObservableCache(private val cache: ToggleCache, private val coroutineScope
3232

3333
override fun write(state: UnleashState) {
3434
cache.write(state)
35-
Log.d(TAG, "Done writing cache with ${newStateEventFlow.subscriptionCount.value} subscribers")
35+
UnleashLogger.d(TAG, "Done writing cache with ${newStateEventFlow.subscriptionCount.value} subscribers")
3636
coroutineScope.launch {
37-
Log.d(TAG, "Emitting new state with ${state.toggles.size} toggles")
37+
UnleashLogger.d(TAG, "Emitting new state with ${state.toggles.size} toggles")
3838
newStateEventFlow.emit(state)
3939
}
4040
}
4141

4242
override fun subscribeTo(featuresReceived: Flow<UnleashState>) {
43-
Log.d(TAG, "Subscribing to observable cache")
43+
UnleashLogger.d(TAG, "Subscribing to observable cache")
4444
coroutineScope.launch {
4545
featuresReceived.collect { state ->
4646
withContext(Dispatchers.IO) {
47-
Log.d(TAG, "Storing new state with ${state.toggles.size} toggles for $state.context")
47+
UnleashLogger.d(TAG, "Storing new state with ${state.toggles.size} toggles for $state.context")
4848
write(state)
4949
}
5050
}

‎unleashandroidsdk/src/main/java/io/getunleash/android/http/NetworkStatusHelper.kt‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import android.net.Network
66
import android.net.NetworkCapabilities
77
import android.net.NetworkRequest
88
import android.os.Build
9-
import android.util.Log
9+
import io.getunleash.android.util.UnleashLogger
1010

1111
interface NetworkListener {
1212
fun onAvailable()
@@ -77,7 +77,7 @@ class NetworkStatusHelper(private val context: Context) {
7777
private fun getConnectivityManager(): ConnectivityManager? {
7878
val connectivityManager = context.getSystemService(Context.CONNECTIVITY_SERVICE)
7979
if (connectivityManager !is ConnectivityManager) {
80-
Log.w(TAG, "Failed to get ConnectivityManager assuming network is available")
80+
UnleashLogger.w(TAG, "Failed to get ConnectivityManager assuming network is available")
8181
return null
8282
}
8383
return connectivityManager

‎unleashandroidsdk/src/main/java/io/getunleash/android/http/Throttler.kt‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package io.getunleash.android.http
22

3-
import android.util.Log
3+
import io.getunleash.android.util.UnleashLogger
44
import java.net.HttpURLConnection
55
import java.util.concurrent.atomic.AtomicLong
66
import kotlin.math.max
@@ -75,23 +75,23 @@ class Throttler(
7575
|| responseCode == HttpURLConnection.HTTP_FORBIDDEN
7676
) {
7777
maximizeSkips()
78-
Log.e(TAG,
78+
UnleashLogger.e(TAG,
7979
"Client was not authorized to talk to the Unleash API at $target. Backing off to $maxSkips times our poll interval (of $intervalLengthInSeconds seconds) to avoid overloading server",
8080
)
8181
}
8282
if (responseCode == HttpURLConnection.HTTP_NOT_FOUND) {
8383
maximizeSkips()
84-
Log.e(TAG,
84+
UnleashLogger.e(TAG,
8585
"Server said that the endpoint at $target does not exist. Backing off to $maxSkips times our poll interval (of $intervalLengthInSeconds seconds) to avoid overloading server",
8686
)
8787
} else if (responseCode == 429) {
8888
increaseSkipCount()
89-
Log.i(TAG,
89+
UnleashLogger.i(TAG,
9090
"RATE LIMITED for the ${failures.get()}. time. Further backing off. Current backoff at ${skips.get()} times our interval (of $intervalLengthInSeconds seconds)",
9191
)
9292
} else if (responseCode >= HttpURLConnection.HTTP_INTERNAL_ERROR) {
9393
increaseSkipCount()
94-
Log.i(TAG,
94+
UnleashLogger.i(TAG,
9595
"Server failed with a $responseCode status code. Backing off. Current backoff at ${skips.get()} times our poll interval (of $intervalLengthInSeconds seconds)",
9696
)
9797
}

‎unleashandroidsdk/src/main/java/io/getunleash/android/metrics/MetricsSender.kt‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
package io.getunleash.android.metrics
22

3-
import android.util.Log
43
import io.getunleash.android.UnleashConfig
54
import io.getunleash.android.data.Parser.metricsBodyAdapter
65
import io.getunleash.android.data.Variant
76
import io.getunleash.android.http.Throttler
7+
import io.getunleash.android.util.UnleashLogger
88
import okhttp3.Call
99
import okhttp3.Callback
1010
import okhttp3.Headers.Companion.toHeaders
@@ -41,15 +41,15 @@ class MetricsSender(
4141

4242
override suspend fun sendMetrics(onComplete: ((Result<Unit>) -> Unit)?) {
4343
if (metricsUrl == null) {
44-
Log.d(TAG, "No proxy URL configured, skipping metrics reporting")
44+
UnleashLogger.d(TAG, "No proxy URL configured, skipping metrics reporting")
4545
return
4646
}
4747
if (bucket.isEmpty()) {
48-
Log.d(TAG, "No metrics to report")
48+
UnleashLogger.d(TAG, "No metrics to report")
4949
return
5050
}
5151
if (!inFlight.compareAndSet(false, true)) {
52-
Log.d(TAG, "Metrics report already in-flight, skipping this send")
52+
UnleashLogger.d(TAG, "Metrics report already in-flight, skipping this send")
5353
return
5454
}
5555
throttler.runIfAllowed {
@@ -72,13 +72,13 @@ class MetricsSender(
7272
try {
7373
onComplete?.invoke(Result.failure(e))
7474
} catch (t: Throwable) {
75-
Log.w(TAG, "onComplete callback threw", t)
75+
UnleashLogger.w(TAG, "onComplete callback threw", t)
7676
}
77-
Log.i(TAG, "Failed to report metrics for interval", e)
77+
UnleashLogger.i(TAG, "Failed to report metrics for interval", e)
7878
}
7979

8080
override fun onResponse(call: Call, response: Response) {
81-
Log.d(
81+
UnleashLogger.d(
8282
TAG,
8383
"Received status code ${response.code} from ${request.method} $metricsUrl"
8484
)
@@ -89,7 +89,7 @@ class MetricsSender(
8989
try {
9090
onComplete?.invoke(Result.success(Unit))
9191
} catch (t: Throwable) {
92-
Log.w(TAG, "onComplete callback threw", t)
92+
UnleashLogger.w(TAG, "onComplete callback threw", t)
9393
}
9494
}
9595
})

0 commit comments

Comments
 (0)