10096633062

Committed 25 Jul 2024 03:06PM UTC coverage: 82.319%. Remained the same

Build # 10096633062

Build Type

Pull #72

github

Committed by

web-flow

Commit Message

Merge 3c37fee00 into 0238abdc4

Pull Request Pull Request #72: chore: pre release validation

Run Details

209 of 284 branches covered (73.59%)

Branch coverage included in aggregate %.

643 of 751 relevant lines covered (85.62%)

5.45 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

78.72

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

package io.getunleash.android.metrics

import android.util.Log
import io.getunleash.android.UnleashConfig
import io.getunleash.android.data.Parser.metricsBodyAdapter
import io.getunleash.android.data.Variant
import io.getunleash.android.http.Throttler
import okhttp3.Call
import okhttp3.Callback
import okhttp3.Headers.Companion.toHeaders
import okhttp3.HttpUrl.Companion.toHttpUrl
import okhttp3.MediaType.Companion.toMediaType
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.RequestBody.Companion.toRequestBody
import okhttp3.Response
import java.io.IOException
import java.util.Date
import java.util.concurrent.TimeUnit

class MetricsSender(
    private val config: UnleashConfig,
    private val httpClient: OkHttpClient,
    private val applicationHeaders: Map<String, String> = config.getApplicationHeaders(config.metricsStrategy)
): MetricsHandler {
    companion object {
        private const val TAG: String = "MetricsSender"
    }
    private val metricsUrl = config.proxyUrl.toHttpUrl().newBuilder().addPathSegment("client")
        .addPathSegment("metrics").build()
    private var bucket: CountBucket = CountBucket(start = Date())
    private val throttler =
        Throttler(
            TimeUnit.MILLISECONDS.toSeconds(config.metricsStrategy.interval),
            longestAcceptableIntervalSeconds = 300,
            metricsUrl.toString()
        )

    override suspend fun sendMetrics() {
        if (bucket.isEmpty()) {
            Log.d(TAG, "No metrics to report")
            return
        }
        if (throttler.performAction()) {
            val toReport = swapAndFreeze()
            val payload = MetricsPayload(
                appName = config.appName,
                instanceId = config.instanceId,
                bucket = toReport
            )
            val request = Request.Builder()
                .headers(applicationHeaders.toHeaders())
                .url(metricsUrl).post(
                    metricsBodyAdapter.toJson(payload)
                        .toRequestBody("application/json".toMediaType())
                ).build()
            httpClient.newCall(request).enqueue(object : Callback {
                override fun onFailure(call: Call, e: IOException) {
                    Log.i(TAG, "Failed to report metrics for interval", e)
                }

                override fun onResponse(call: Call, response: Response) {
                    Log.d(
                        TAG,
                        "Received status code ${response.code} from ${request.method} $metricsUrl"
                    )
                    throttler.handle(response.code)
                    response.body.use { // Need to consume body to ensure we don't keep connection open
                    }
                }
            })
        } else {
            throttler.skipped()
        }
    }

    private fun swapAndFreeze(): Bucket {
        val bucketRef = bucket
        bucket = CountBucket(start = Date())
        return bucketRef.copy().toBucket(bucket.start)
    }

    override fun count(featureName: String, enabled: Boolean): Boolean {
        return bucket.count(featureName, enabled)
    }

    override fun countVariant(featureName: String, variant: Variant): Variant {
        return bucket.countVariant(featureName, variant)
    }
}

1	package io.getunleash.android.metrics
2
3	import android.util.Log
4	import io.getunleash.android.UnleashConfig
5	import io.getunleash.android.data.Parser.metricsBodyAdapter
6	import io.getunleash.android.data.Variant
7	import io.getunleash.android.http.Throttler
8	import okhttp3.Call
9	import okhttp3.Callback
10	import okhttp3.Headers.Companion.toHeaders
11	import okhttp3.HttpUrl.Companion.toHttpUrl
12	import okhttp3.MediaType.Companion.toMediaType
13	import okhttp3.OkHttpClient
14	import okhttp3.Request
15	import okhttp3.RequestBody.Companion.toRequestBody
16	import okhttp3.Response
17	import java.io.IOException
18	import java.util.Date
19	import java.util.concurrent.TimeUnit
20
21	class MetricsSender(	11✔
22	private val config: UnleashConfig,	3✔
23	private val httpClient: OkHttpClient,	3✔
24	private val applicationHeaders: Map<String, String> = config.getApplicationHeaders(config.metricsStrategy)	8✔
25	): MetricsHandler {
26	companion object {
27	private const val TAG: String = "MetricsSender"
28	}
29	private val metricsUrl = config.proxyUrl.toHttpUrl().newBuilder().addPathSegment("client")	8✔
30	.addPathSegment("metrics").build()	5✔
31	private var bucket: CountBucket = CountBucket(start = Date())	13✔
32	private val throttler =
33	Throttler(	5✔
34	TimeUnit.MILLISECONDS.toSeconds(config.metricsStrategy.interval),	6✔
35	longestAcceptableIntervalSeconds = 300,	1✔
36	metricsUrl.toString()	3✔
37	)
38
39	override suspend fun sendMetrics() {
40	if (bucket.isEmpty()) {	4✔
41	Log.d(TAG, "No metrics to report")	4✔
42	return	2✔
43	}
44	if (throttler.performAction()) {	4!
45	val toReport = swapAndFreeze()	3✔
46	val payload = MetricsPayload(	4✔
47	appName = config.appName,	3✔
48	instanceId = config.instanceId,	3✔
49	bucket = toReport	1✔
50	)
51	val request = Request.Builder()	4✔
52	.headers(applicationHeaders.toHeaders())	5✔
53	.url(metricsUrl).post(	4✔
54	metricsBodyAdapter.toJson(payload)	7✔
55	.toRequestBody("application/json".toMediaType())	5✔
56	).build()	1✔
57	httpClient.newCall(request).enqueue(object : Callback {	15✔
58	override fun onFailure(call: Call, e: IOException) {
59	Log.i(TAG, "Failed to report metrics for interval", e)	×
60	}	×
61
62	override fun onResponse(call: Call, response: Response) {
63	Log.d(	×
64	TAG,	×
65	"Received status code ${response.code} from ${request.method} $metricsUrl"	×
66	)
67	throttler.handle(response.code)	×
68	response.body.use { // Need to consume body to ensure we don't keep connection open	×
69	}
70	}	×
71	})
72	} else {
73	throttler.skipped()	×
74	}
75	}	2✔
76
77	private fun swapAndFreeze(): Bucket {
78	val bucketRef = bucket	3✔
79	bucket = CountBucket(start = Date())	13✔
80	return bucketRef.copy().toBucket(bucket.start)	13✔
81	}
82
83	override fun count(featureName: String, enabled: Boolean): Boolean {
84	return bucket.count(featureName, enabled)	6✔
85	}
86
87	override fun countVariant(featureName: String, variant: Variant): Variant {
88	return bucket.countVariant(featureName, variant)	6✔
89	}
90	}	1✔

Unleash / unleash-android / 10096633062

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous