Merge pull request #1195 from DataDog/jward/android-clear-text

feat: Add internal property for supporting clear text transport.

Author: fuzzybinary

packages/core/android/src/main/kotlin/com/datadog/reactnative/DdSdkImplementation.kt

@@ -405,6 +405,7 @@ class DdSdkImplementation(
         internal const val DEFAULT_APP_VERSION = "?"
         internal const val DD_VERSION = "_dd.version"
         internal const val DD_VERSION_SUFFIX = "_dd.version_suffix"
+        internal const val DD_NEEDS_CLEAR_TEXT_HTTP = "_dd.needsClearTextHttp"
         internal const val DD_DROP_RESOURCE = "_dd.resource.drop_resource"
         internal const val DD_DROP_ACTION = "_dd.action.drop_action"
         internal const val MONITOR_JS_ERROR_MESSAGE = "Error monitoring JS refresh rate"

packages/core/android/src/main/kotlin/com/datadog/reactnative/DdSdkNativeInitialization.kt

@@ -21,6 +21,7 @@ import com.datadog.android.log.LogsConfiguration
 import com.datadog.android.privacy.TrackingConsent
 import com.datadog.android.rum.Rum
 import com.datadog.android.rum.RumConfiguration
+import com.datadog.android._InternalProxy
 import com.datadog.android.rum._RumInternalProxy
 import com.datadog.android.rum.configuration.VitalsUpdateFrequency
 import com.datadog.android.rum.metric.networksettled.TimeBasedInitialResourceIdentifier
@@ -313,6 +314,10 @@ class DdSdkNativeInitialization internal constructor(
 
         configBuilder.setBatchProcessingLevel(buildBatchProcessingLevel(configuration.batchProcessingLevel))
 
+        if (additionalConfig?.get(DdSdkImplementation.DD_NEEDS_CLEAR_TEXT_HTTP) == true) {
+            _InternalProxy.allowClearTextHttp(configBuilder)
+        }
+
         return configBuilder.build()
     }
 

packages/core/android/src/test/kotlin/com/datadog/reactnative/DdSdkTest.kt

@@ -582,6 +582,60 @@ internal class DdSdkTest {
 
     // endregion
 
+    // region initialize / needsClearTextHttp
+
+    @Test
+    fun `𝕄 initialize native SDK 𝕎 initialize() {needsClearTextHttp=true}`() {
+        // Given
+        val additionalConfig = (
+            fakeConfiguration.additionalConfiguration?.toMutableMap() ?: mutableMapOf()
+            ).also { it[DdSdkImplementation.DD_NEEDS_CLEAR_TEXT_HTTP] = true }
+        val bridgeConfiguration = fakeConfiguration.copy(additionalConfiguration = additionalConfig)
+        val sdkConfigCaptor = argumentCaptor<Configuration>()
+        val rumConfigCaptor = argumentCaptor<RumConfiguration>()
+        val logsConfigCaptor = argumentCaptor<LogsConfiguration>()
+        val traceConfigCaptor = argumentCaptor<TraceConfiguration>()
+
+        val rumMock = org.mockito.Mockito.mockStatic(Rum::class.java)
+        val traceMock = org.mockito.Mockito.mockStatic(Trace::class.java)
+        val logsMock = org.mockito.Mockito.mockStatic(Logs::class.java)
+
+        try {
+            rumMock.`when`<Unit> { Rum.enable(any(), any()) }.then { }
+            logsMock.`when`<Unit> { Logs.enable(any(), any()) }.then { }
+            traceMock.`when`<Unit> { Trace.enable(any(), any()) }.then { }
+
+            // When
+            testedBridgeSdk.initialize(bridgeConfiguration.toReadableJavaOnlyMap(), mockPromise)
+
+            // Then
+            inOrder(mockDatadog) {
+                verify(mockDatadog).initialize(
+                    same(mockContext),
+                    sdkConfigCaptor.capture(),
+                    any()
+                )
+                rumMock.verify { Rum.enable(rumConfigCaptor.capture(), any()) }
+                traceMock.verify { Trace.enable(traceConfigCaptor.capture(), any()) }
+                logsMock.verify { Logs.enable(logsConfigCaptor.capture(), any()) }
+            }
+            assertThat(sdkConfigCaptor.firstValue)
+                .hasField("coreConfig") {
+                    it.hasFieldEqualTo("needsClearTextHttp", true)
+                    it.hasFieldEqualTo("firstPartyHostsWithHeaderTypes", emptyMap<String, String>())
+                }
+                .hasFieldEqualTo("clientToken", fakeConfiguration.clientToken)
+                .hasFieldEqualTo("env", fakeConfiguration.env)
+                .hasFieldEqualTo("variant", "")
+        } finally {
+            rumMock.close()
+            logsMock.close()
+            traceMock.close()
+        }
+    }
+
+    // endregion
+
     // region initialize / site
 
     @Test