Impl

Author: samedson

firebase-sessions/src/main/kotlin/com/google/firebase/sessions/EventGDTLogger.kt

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2023 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.firebase.sessions
+
+import com.google.android.datatransport.Encoding
+import com.google.android.datatransport.Event
+import com.google.android.datatransport.TransportFactory
+
+internal class EventGDTLogger(private val transportFactory: TransportFactory) {
+
+  fun log(sessionEvent: SessionEvent) {
+    transportFactory
+      .getTransport(
+        EventGDTLogger.AQS_LOG_SOURCE,
+        SessionEvent::class.java,
+        Encoding.of("json"),
+        this::apply,
+      )
+      .send(Event.ofData(sessionEvent))
+  }
+
+  private fun apply(value: SessionEvent): ByteArray {
+    return SessionEvents.SESSION_EVENT_ENCODER.encode(value).toByteArray()
+  }
+
+  companion object {
+    // TODO AQS Log Source
+    private const val AQS_LOG_SOURCE = "AQS_LOG_SOURCE"
+  }
+}

firebase-sessions/src/main/kotlin/com/google/firebase/sessions/FirebaseSessions.kt

@@ -34,8 +34,9 @@ internal constructor(
   transportFactory: TransportFactory,
 ) {
   private val sessionGenerator = SessionGenerator(collectEvents = true)
+  private val eventGDTLogger = EventGDTLogger(transportFactory)
   private val sessionCoordinator =
-    SessionCoordinator(firebaseInstallations, backgroundDispatcher, transportFactory)
+    SessionCoordinator(firebaseInstallations, backgroundDispatcher, eventGDTLogger)
 
   init {
     val sessionInitiator = SessionInitiator(WallClock::elapsedRealtime, this::initiateSessionStart)

firebase-sessions/src/main/kotlin/com/google/firebase/sessions/SessionCoordinator.kt

@@ -17,15 +17,14 @@
 package com.google.firebase.sessions
 
 import android.util.Log
+import com.google.android.datatransport.Encoding
+import com.google.android.datatransport.Event
 import com.google.android.datatransport.TransportFactory
 import com.google.firebase.installations.FirebaseInstallationsApi
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.tasks.await
-import sun.jvm.hotspot.debugger.win32.coff.DebugVC50X86RegisterEnums.TAG
-
-
 
 
 /**
@@ -37,7 +36,7 @@ import sun.jvm.hotspot.debugger.win32.coff.DebugVC50X86RegisterEnums.TAG
 internal class SessionCoordinator(
   private val firebaseInstallations: FirebaseInstallationsApi,
   backgroundDispatcher: CoroutineDispatcher,
-  private val transportFactory: TransportFactory,
+  private val eventGDTLogger: EventGDTLogger,
 ) {
   private val scope = CoroutineScope(backgroundDispatcher)
 
@@ -55,20 +54,7 @@ internal class SessionCoordinator(
       Log.i(TAG, "Initiate session start: $sessionEvent")
 
       try {
-        transportFactory
-          .getTransport(
-            FirelogAnalytics.FCM_LOG_SOURCE,
-            MessagingClientEventExtension::class.java,
-            Encoding.of("proto"),
-            MessagingClientEventExtension::toByteArray
-          )
-          .send(
-            Event.ofData(
-              MessagingClientEventExtension.newBuilder()
-                .setMessagingClientEvent(clientEvent)
-                .build()
-            )
-          )
+        eventGDTLogger.log(sessionEvent)
       } catch (e: RuntimeException) {
         Log.w(TAG, "Failed to log Session Start event: ", e)
       }