do not submit

PiperOrigin-RevId: 829090479

Author: Mobile Ads Developer Relations

samples/HelloWorld/Assets/Scripts/GoogleMobileAdsConsentController.cs

@@ -12,6 +12,7 @@ namespace GoogleMobileAds.Samples
     public class GoogleMobileAdsConsentController : MonoBehaviour
     {
         /// <summary>
+        /// Test
         /// If true, it is safe to call MobileAds.Initialize() and load Ads.
         /// </summary>
         public bool CanRequestAds => ConsentInformation.CanRequestAds();

source/plugin/Assets/GoogleMobileAds/Common/CuiHandler.cs

@@ -9,4 +9,85 @@ public struct CuiLoggablePayload
     {
         public Insight unity_gma_sdk_cui_message;
     }
-}
+    /// <summary>
+    /// A persistent singleton that captures all CUIs and sends them in batches to a backend
+    /// service (RCS) based on either a count or time threshold.
+    /// </summary>
+    public class CuiHandler : RcsClient<Insight>
+    {
+        private static CuiHandler _instance;
+        public static CuiHandler Instance
+        {
+            get
+            {
+                if (_instance == null && Application.isPlaying)
+                {
+                    _instance = FindObjectOfType<CuiHandler>();
+                    if (_instance == null)
+                    {
+                        _instance = new GameObject("CuiHandler")
+                                .AddComponent<CuiHandler>();
+                    }
+                }
+                return _instance;
+            }
+            private set
+            {
+                _instance = value;
+            }
+        }
+
+        #region Unity lifecycle methods
+        private void Awake()
+        {
+            if (_instance != null && _instance != this)
+            {
+                Destroy(gameObject);
+                return;
+            }
+            _instance = this;
+            DontDestroyOnLoad(gameObject);
+        }
+        #endregion
+
+        /// <summary>
+        /// Call this to report a CUI.
+        /// This method is thread-safe and adds the CUI to the queue.
+        /// </summary>
+        public void ReportCui(Insight insight)
+        {
+            if (insight == null) return;
+            Enqueue(insight);
+        }
+
+        /// <summary>
+        /// Builds and sends a batch of CUIs.
+        /// </summary>
+        protected override void SendBatch(List<Insight> batch)
+        {
+            var payloads = new List<CuiLoggablePayload>();
+            foreach (var insight in batch)
+            {
+                payloads.Add(new CuiLoggablePayload
+                {
+                    unity_gma_sdk_cui_message = insight
+                });
+            }
+
+            var request = new LoggableRemoteCaptureRequest<CuiLoggablePayload>
+            {
+                payloads = payloads,
+                client_ping_metadata = new ClientPingMetadata
+                {
+                    binary_name = 21, // UNITY_GMA_SDK
+                }
+            };
+
+            string jspbPayload = JspbConverter.ToJspb(request);
+            if (jspbPayload != null)
+            {
+                SendToRcs(jspbPayload);
+            }
+        }
+    }
+}

source/plugin/Assets/GoogleMobileAds/Common/ProdInsightsEmitter.cs

@@ -6,7 +6,37 @@ public class InsightsEmitter : IInsightsEmitter
   {
       public void Emit(Insight insight)
       {
-          // Intentionally left blank.
+        if (insight == null)
+          {
+              return;
+          }
+          // Currently the dynamic metadata fields are not in the Insight class.
+          var staticMetadata = RcsPayload.GetStaticMetadata();
+
+          // Backfill static metadata if not set.
+          if (string.IsNullOrEmpty(insight.AppId)) insight.AppId = staticMetadata.app_id;
+          if (string.IsNullOrEmpty(insight.AppVersionName)) insight.AppVersionName =
+              staticMetadata.app_version_name;
+          if (insight.Platform == Insight.AdPlatform.Unknown)
+          {
+              try
+              {
+                  insight.Platform = (Insight.AdPlatform)Enum.Parse(
+                      typeof(Insight.AdPlatform), staticMetadata.platform, true);
+              }
+              catch (ArgumentException)
+              {
+                  insight.Platform = Insight.AdPlatform.Unknown;
+              }
+          }
+          if (string.IsNullOrEmpty(insight.UnityVersion)) insight.UnityVersion =
+              staticMetadata.unity_version;
+          if (string.IsNullOrEmpty(insight.OSVersion)) insight.OSVersion =
+              staticMetadata.os_version;
+          if (string.IsNullOrEmpty(insight.DeviceModel)) insight.DeviceModel =
+              staticMetadata.device_model;
+
+          CuiHandler.Instance.ReportCui(insight);
       }
   }
 }

source/plugin/Assets/GoogleMobileAds/Common/RcsClient.cs

@@ -36,8 +36,8 @@ protected override bool ValidateCertificate(byte[] certificateData)
 
         // Batching triggers can be overridden by subclasses. We don't need to expose them in Unity
         // Editor. If any trigger fires, a batch of items will get sent.
-        protected virtual int CountThreshold => 20;
-        protected virtual float TimeThresholdInSeconds => 120.0f;
+        protected virtual int CountThreshold => 2;
+        protected virtual float TimeThresholdInSeconds => 10.0f;
 
         // RCS endpoint for reporting. The `e=1` URL parameter defines JSPB encoding.
         private const string ProdRcsUrl = "https://pagead2.googlesyndication.com/pagead/ping?e=1";

source/plugin/Assets/GoogleMobileAds/Platforms/Android/MobileAdsClient.cs

@@ -35,8 +35,11 @@ public class MobileAdsClient : AndroidJavaProxy, IMobileAdsClient
         private MobileAdsClient() : base(Utils.OnInitializationCompleteListenerClassName) {
             _mobileAdsClass = new AndroidJavaClass(Utils.UnityMobileAdsClassName);
             _tracer = new Tracer(_insightsEmitter);
-            // Ensures GlobalExceptionHandler is initialized to handle Android untrapped exceptions.
+            // Ensures GlobalExceptionHandler is initialized from the main thread to handle Android
+            // untrapped exceptions.
             var _ = GlobalExceptionHandler.Instance;
+            // Ensures CuiHandler is initialized from the main thread to handle CUIs.
+            var __ = CuiHandler.Instance;
         }
 
         public static MobileAdsClient Instance