Implement Bigo Adapter's initialization logic.

PiperOrigin-RevId: 813425795

Author: Mobile Ads Developer Relations

ThirdPartyAdapters/bigo/bigo/src/main/kotlin/com/google/ads/mediation/bigo/BigoMediationAdapter.kt

@@ -40,6 +40,7 @@ import com.google.android.gms.ads.mediation.rtb.RtbAdapter
 import com.google.android.gms.ads.mediation.rtb.RtbSignalData
 import com.google.android.gms.ads.mediation.rtb.SignalCallbacks
 import sg.bigo.ads.BigoAdSdk
+import sg.bigo.ads.api.AdConfig
 
 /**
  * Bigo Adapter for GMA SDK used to initialize and load ads from the Bigo SDK. This class should not
@@ -104,8 +105,40 @@ class BigoMediationAdapter : RtbAdapter() {
     initializationCompleteCallback: InitializationCompleteCallback,
     mediationConfigurations: List<MediationConfiguration>,
   ) {
-    // TODO: Implement this method.
-    initializationCompleteCallback.onInitializationSucceeded()
+    if (BigoAdSdk.isInitialized()) {
+      initializationCompleteCallback.onInitializationSucceeded()
+      return
+    }
+
+    val applicationIds =
+      mediationConfigurations.mapNotNull {
+        val appId = it.serverParameters.getString(APP_ID_KEY)
+        if (appId.isNullOrEmpty()) {
+          null
+        } else {
+          appId
+        }
+      }
+    if (applicationIds.isEmpty()) {
+      initializationCompleteCallback.onInitializationFailed(ERROR_MSG_MISSING_APP_ID)
+      return
+    }
+    val appId = applicationIds[0]
+    if (appId.isEmpty()) {
+      initializationCompleteCallback.onInitializationFailed(ERROR_MSG_MISSING_APP_ID)
+      return
+    }
+    if (applicationIds.size > 1) {
+      val message =
+        "Multiple $APP_ID_KEY entries found: ${applicationIds}. Using '${appId}' to initialize the Bigo SDK"
+      Log.w(TAG, message)
+    }
+
+    val adConfig = AdConfig.Builder().setAppId(appId).build()
+
+    BigoAdSdk.initialize(context, adConfig) {
+      initializationCompleteCallback.onInitializationSucceeded()
+    }
   }
 
   override fun collectSignals(signalData: RtbSignalData, callback: SignalCallbacks) {
@@ -179,5 +212,7 @@ class BigoMediationAdapter : RtbAdapter() {
     @VisibleForTesting var adapterVersionDelegate: String? = null
     const val ADAPTER_ERROR_DOMAIN = "com.google.ads.mediation.bigo"
     const val SDK_ERROR_DOMAIN = "" // TODO: Update the third party SDK error domain.
+    const val APP_ID_KEY = "application_id"
+    const val ERROR_MSG_MISSING_APP_ID = "App Id to initialize Bigo SDK is empty or missing."
   }
 }

ThirdPartyAdapters/bigo/bigo/src/test/kotlin/com/google/ads/mediation/bigo/BigoMediationAdapterTest.kt

@@ -14,21 +14,49 @@
 
 package com.google.ads.mediation.bigo
 
+import android.content.Context
+import androidx.core.os.bundleOf
+import androidx.test.core.app.ApplicationProvider
 import androidx.test.ext.junit.runners.AndroidJUnit4
+import com.google.ads.mediation.adaptertestkit.AdapterTestKitConstants.TEST_APP_ID
 import com.google.ads.mediation.adaptertestkit.assertGetSdkVersion
 import com.google.ads.mediation.adaptertestkit.assertGetVersionInfo
+import com.google.ads.mediation.bigo.BigoMediationAdapter.Companion.APP_ID_KEY
+import com.google.ads.mediation.bigo.BigoMediationAdapter.Companion.ERROR_MSG_MISSING_APP_ID
+import com.google.android.gms.ads.AdFormat
+import com.google.android.gms.ads.mediation.InitializationCompleteCallback
+import com.google.android.gms.ads.mediation.MediationConfiguration
+import org.junit.After
 import org.junit.Before
 import org.junit.Test
 import org.junit.runner.RunWith
+import org.mockito.MockedStatic
+import org.mockito.Mockito.mockStatic
+import org.mockito.kotlin.any
+import org.mockito.kotlin.argumentCaptor
+import org.mockito.kotlin.eq
+import org.mockito.kotlin.mock
+import org.mockito.kotlin.verify
+import sg.bigo.ads.BigoAdSdk
 
 @RunWith(AndroidJUnit4::class)
 class BigoMediationAdapterTest {
   // Subject of testing
   private lateinit var adapter: BigoMediationAdapter
+  private lateinit var mockBigoSdk: MockedStatic<BigoAdSdk>
+
+  private val context = ApplicationProvider.getApplicationContext<Context>()
+  private val mockInitializationCallback: InitializationCompleteCallback = mock()
 
   @Before
   fun setUp() {
     adapter = BigoMediationAdapter()
+    mockBigoSdk = mockStatic(BigoAdSdk::class.java)
+  }
+
+  @After
+  fun tearDown() {
+    mockBigoSdk.close()
   }
 
   // region Version tests
@@ -48,5 +76,50 @@ class BigoMediationAdapterTest {
 
   // endregion
 
-  // TODO: Add tests for the methods that are implemented in the adapter.
+  // region Initialize tests
+  @Test
+  fun initialize_withEmptyConfiguration_invokesOnInitializationFailed() {
+    adapter.initialize(context, mockInitializationCallback, mediationConfigurations = listOf())
+
+    verify(mockInitializationCallback).onInitializationFailed(eq(ERROR_MSG_MISSING_APP_ID))
+  }
+
+  @Test
+  fun initialize_withoutAnySourceId_invokesOnInitializationFailed() {
+    val mediationConfiguration =
+      MediationConfiguration(AdFormat.BANNER, /* serverParameters= */ bundleOf())
+
+    adapter.initialize(context, mockInitializationCallback, listOf(mediationConfiguration))
+
+    verify(mockInitializationCallback).onInitializationFailed(eq(ERROR_MSG_MISSING_APP_ID))
+  }
+
+  @Test
+  fun initialize_withEmptySourceId_invokesOnInitializationFailed() {
+    val mediationConfiguration =
+      MediationConfiguration(AdFormat.BANNER, /* serverParameters= */ bundleOf(APP_ID_KEY to ""))
+
+    adapter.initialize(context, mockInitializationCallback, listOf(mediationConfiguration))
+
+    verify(mockInitializationCallback).onInitializationFailed(eq(ERROR_MSG_MISSING_APP_ID))
+  }
+
+  @Test
+  fun initialize_invokesOnInitializationSucceeded() {
+    val mediationConfiguration =
+      MediationConfiguration(
+        AdFormat.BANNER,
+        /* serverParameters= */ bundleOf(APP_ID_KEY to TEST_APP_ID),
+      )
+    val callbackCaptor = argumentCaptor<BigoAdSdk.InitListener>()
+
+    adapter.initialize(context, mockInitializationCallback, listOf(mediationConfiguration))
+
+    mockBigoSdk.verify { BigoAdSdk.initialize(eq(context), any(), callbackCaptor.capture()) }
+    callbackCaptor.firstValue.onInitialized()
+    verify(mockInitializationCallback).onInitializationSucceeded()
+  }
+
+  // endregion
+
 }