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

@@ -0,0 +1,104 @@
+using System;
+using System.Collections.Generic;
+using UnityEngine;
+
+namespace GoogleMobileAds.Common
+{
+    [Serializable]
+    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);
+            if (Debug.isDebugBuild)
+            {
+                Debug.Log("CUI queued for batch.");
+            }
+        }
+
+        /// <summary>
+        /// Builds and sends a batch of CUI reports.
+        /// </summary>
+        protected override void SendBatch(List<Insight> batch)
+        {
+            if (Debug.isDebugBuild)
+            {
+                Debug.Log(string.Format("Processing and sending a batch of {0} CUIs...",
+                                        batch.Count));
+            }
+
+            var payloads = new List<CuiLoggablePayload>();
+            foreach (var report in batch)
+            {
+                payloads.Add(new CuiLoggablePayload
+                {
+                    unity_gma_sdk_cui_message = report
+                });
+            }
+
+            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)
+            {
+                Debug.Log("rcs jspb payload is not null: " + jspbPayload);
+                SendToRcs(jspbPayload);
+            }
+        }
+    }
+}

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

@@ -20,6 +20,10 @@ internal static string ToJspb<TPayload>(LoggableRemoteCaptureRequest<TPayload> r
                     {
                         payloads.Add(ToJspb((ExceptionLoggablePayload)(object)payload));
                     }
+                    else if (payload is CuiLoggablePayload)
+                    {
+                        payloads.Add(ToJspb((CuiLoggablePayload)(object)payload));
+                    }
                     else
                     {
                         Debug.LogError("JspbConverter encountered an unknown payload type: " +
@@ -43,6 +47,18 @@ internal static string ToJspb(ClientPingMetadata metadata)
             return string.Format("[{0}]", metadata.binary_name);
         }
 
+        // VisibleForTesting
+        internal static string ToListJspb(List<string> list)
+        {
+            if (list == null) return "null";
+            var quotedElements = new List<string>();
+            foreach(string item in list)
+            {
+                quotedElements.Add(QuoteString(item));
+            }
+            return string.Format("[{0}]", string.Join(",", quotedElements.ToArray()));
+        }
+
         // VisibleForTesting
         internal static string QuoteString(string s)
         {
@@ -140,5 +156,50 @@ internal static string ToJspb(ExceptionReport report)
             return string.Format("[{0}]", string.Join(",", fields.ToArray()));
         }
         #endregion
+
+        #region CUI handling
+        // VisibleForTesting
+        internal static string ToJspb(CuiLoggablePayload payload)
+        {
+            if (payload.unity_gma_sdk_cui_message == null) return "[]";
+
+            // unity_gma_sdk_cui_message has field index 36.
+            return string.Format("[{{\"36\":{0}}}]",
+                                 ToJspb(payload.unity_gma_sdk_cui_message));
+        }
+
+        // VisibleForTesting
+        internal static string ToJspb(Insight insight)
+        {
+            return string.Format(
+                "[{0},{1},{2},{3},{4},{5},{6},{7},{8},{9},{10},{11},{12},{13},{14}]",
+                (int)insight.Name,
+                insight.Success.ToString().ToLower(),
+                insight.StartTimeEpochMillis.ToString(),
+                QuoteString(insight.SdkVersion),
+                QuoteString(insight.AppId),
+                QuoteString(insight.AdUnitId),
+                (int)insight.Format,
+                (int)insight.Platform,
+                QuoteString(insight.AppVersionName),
+                QuoteString(insight.UnityVersion),
+                QuoteString(insight.OSVersion),
+                QuoteString(insight.DeviceModel),
+                ToListJspb(insight.Tags),
+                ToJspb(insight.Tracing),
+                QuoteString(insight.Details));
+                }
+        // VisibleForTesting
+        internal static string ToJspb(Insight.TracingActivity tracing)
+        {
+            if (tracing == null) return "null";
+            return string.Format("[{0},{1},{2},{3},{4}]",
+                                 QuoteString(tracing.OperationName),
+                                 QuoteString(tracing.Id),
+                                 QuoteString(tracing.ParentId),
+                                 tracing.DurationMillis,
+                                 tracing.HasEnded.ToString().ToLower());
+        }
+        #endregion
     }
 }

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

@@ -230,7 +230,7 @@ protected override void SendBatch(List<ExceptionReport> batch)
             string jspbPayload = JspbConverter.ToJspb(request);
             if (jspbPayload != null)
             {
-                SendToRcs(jspbPayload);
+                // SendToRcs(jspbPayload);
             }
         }
         #endregion

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

@@ -6,7 +6,8 @@ public class InsightsEmitter : IInsightsEmitter
   {
       public void Emit(Insight insight)
       {
-          // Intentionally left blank.
+              CuiHandler.Instance.ReportCui(insight);
+
       }
   }
 }

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

@@ -28,8 +28,8 @@ public abstract class RcsClient<TReport> : MonoBehaviour where TReport : class
     {
         // 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

@@ -36,7 +36,9 @@ private MobileAdsClient() : base(Utils.OnInitializationCompleteListenerClassName
             _mobileAdsClass = new AndroidJavaClass(Utils.UnityMobileAdsClassName);
             _tracer = new Tracer(_insightsEmitter);
             // Ensures GlobalExceptionHandler is initialized to handle Android untrapped exceptions.
-            var _ = GlobalExceptionHandler.Instance;
+            // var _ = GlobalExceptionHandler.Instance;
+            // Ensures CuiHandler is initialized to handle CUIs.
+            var __ = CuiHandler.Instance;
         }
 
         public static MobileAdsClient Instance
@@ -184,10 +186,10 @@ public void onInitializationComplete(AndroidJavaObject initStatus)
               nativePluginVersion = string.Format("{0}.{1}.{2}", assemblyVersion.Major,
                                                   assemblyVersion.Minor, assemblyVersion.Revision);
             } catch (Exception e) {
-              if (GlobalExceptionHandler.Instance != null)
-              {
-                GlobalExceptionHandler.Instance.ReportTrappedException(e);
-              }
+              // if (GlobalExceptionHandler.Instance != null)
+              // {
+                // GlobalExceptionHandler.Instance.ReportTrappedException(e);
+              // }
             }
             string versionString = AdRequest.BuildVersionString(nativePluginVersion);
             _mobileAdsClass.CallStatic("setPlugin", versionString);