DataConnectCredentialsTokenManager.kt: get rid of initialize() method and just initialize in the constructor

Author: dconeybe

firebase-dataconnect/src/androidTest/kotlin/com/google/firebase/dataconnect/AuthIntegrationTest.kt

@@ -17,6 +17,7 @@
 package com.google.firebase.dataconnect
 
 import com.google.firebase.auth.FirebaseAuth
+import com.google.firebase.dataconnect.core.FirebaseDataConnectInternal
 import com.google.firebase.dataconnect.testutil.DataConnectBackend
 import com.google.firebase.dataconnect.testutil.DataConnectIntegrationTestBase
 import com.google.firebase.dataconnect.testutil.InProcessDataConnectGrpcServer
@@ -201,6 +202,7 @@ class AuthIntegrationTest : DataConnectIntegrationTestBase() {
   }
 
   private suspend fun signIn() {
+    (personSchema.dataConnect as FirebaseDataConnectInternal).awaitAuthReady()
     val authResult = auth.run { signInAnonymously().await() }
     withClue("authResult.user returned from signInAnonymously()") {
       authResult.user.shouldNotBeNull()

firebase-dataconnect/src/main/kotlin/com/google/firebase/dataconnect/core/DataConnectAppCheck.kt

@@ -32,24 +32,20 @@ internal class DataConnectAppCheck(
   blockingDispatcher: CoroutineDispatcher,
   logger: Logger,
 ) :
-  DataConnectCredentialsTokenManager<InteropAppCheckTokenProvider, AppCheckTokenListener>(
+  DataConnectCredentialsTokenManager<InteropAppCheckTokenProvider>(
     deferredProvider = deferredAppCheckTokenProvider,
     parentCoroutineScope = parentCoroutineScope,
     blockingDispatcher = blockingDispatcher,
     logger = logger,
   ) {
-  override fun newTokenListener(): AppCheckTokenListener = AppCheckTokenListenerImpl(logger)
+  private val appCheckTokenListener = AppCheckTokenListenerImpl(logger)
 
   @DeferredApi
-  override fun addTokenListener(
-    provider: InteropAppCheckTokenProvider,
-    listener: AppCheckTokenListener
-  ) = provider.addAppCheckTokenListener(listener)
+  override fun addTokenListener(provider: InteropAppCheckTokenProvider) =
+    provider.addAppCheckTokenListener(appCheckTokenListener)
 
-  override fun removeTokenListener(
-    provider: InteropAppCheckTokenProvider,
-    listener: AppCheckTokenListener
-  ) = provider.removeAppCheckTokenListener(listener)
+  override fun removeTokenListener(provider: InteropAppCheckTokenProvider) =
+    provider.removeAppCheckTokenListener(appCheckTokenListener)
 
   override suspend fun getToken(provider: InteropAppCheckTokenProvider, forceRefresh: Boolean) =
     provider.getToken(forceRefresh).await().let { GetTokenResult(it.token) }

firebase-dataconnect/src/main/kotlin/com/google/firebase/dataconnect/core/DataConnectAuth.kt

@@ -32,20 +32,20 @@ internal class DataConnectAuth(
   blockingDispatcher: CoroutineDispatcher,
   logger: Logger,
 ) :
-  DataConnectCredentialsTokenManager<InternalAuthProvider, IdTokenListener>(
+  DataConnectCredentialsTokenManager<InternalAuthProvider>(
     deferredProvider = deferredAuthProvider,
     parentCoroutineScope = parentCoroutineScope,
     blockingDispatcher = blockingDispatcher,
     logger = logger,
   ) {
-  override fun newTokenListener(): IdTokenListener = IdTokenListenerImpl(logger)
+  private val idTokenListener = IdTokenListenerImpl(logger)
 
   @DeferredApi
-  override fun addTokenListener(provider: InternalAuthProvider, listener: IdTokenListener) =
-    provider.addIdTokenListener(listener)
+  override fun addTokenListener(provider: InternalAuthProvider) =
+    provider.addIdTokenListener(idTokenListener)
 
-  override fun removeTokenListener(provider: InternalAuthProvider, listener: IdTokenListener) =
-    provider.removeIdTokenListener(listener)
+  override fun removeTokenListener(provider: InternalAuthProvider) =
+    provider.removeIdTokenListener(idTokenListener)
 
   override suspend fun getToken(provider: InternalAuthProvider, forceRefresh: Boolean) =
     provider.getAccessToken(forceRefresh).await().let { GetTokenResult(it.token) }