feat(meetings): incremental log uploads

packages/@webex/internal-plugin-support/src/support.js

@@ -107,6 +107,8 @@ const Support = WebexPlugin.extend({
         return this.webex.upload(options);
       })
       .then((body) => {
+        this.webex.logger.clearBuffers();
+
         if (userId && !body.userId) {
           body.userId = userId;
         }

packages/@webex/plugin-logger/src/logger.js

@@ -252,6 +252,20 @@ const Logger = WebexPlugin.extend({
     return this.getCurrentLevel();
   },
 
+  /**
+   * Clears the log buffers
+   *
+   * @instance
+   * @memberof Logger
+   * @public
+   * @returns {undefined}
+   */
+  clearBuffers() {
+    this.clientBuffer = [];
+    this.sdkBuffer = [];
+    this.buffer = [];
+  },
+
   /**
    * Format logs (for upload)
    *

packages/@webex/plugin-meetings/src/config.ts

@@ -92,5 +92,6 @@ export default {
     degradationPreferences: {
       maxMacroblocksLimit: 8192,
     },
+    logUploadInterval: 60 * 10, // in seconds
   },
 };

packages/@webex/plugin-meetings/src/meeting/index.ts

@@ -5,6 +5,7 @@ import jwtDecode from 'jwt-decode';
 import {StatelessWebexPlugin} from '@webex/webex-core';
 // @ts-ignore - Types not available for @webex/common
 import {Defer} from '@webex/common';
+import {safeSetTimeout, safeSetInterval} from '@webex/common-timers';
 import {
   ClientEvent,
   ClientEventLeaveReason,
@@ -700,6 +701,7 @@ export default class Meeting extends StatelessWebexPlugin {
   private iceCandidateErrors: Map<string, number>;
   private iceCandidatesCount: number;
   private rtcMetrics?: RtcMetrics;
+  private uploadLogsIntervalId?: ReturnType<typeof setInterval>;
 
   /**
    * @param {Object} attrs
@@ -3964,6 +3966,43 @@ export default class Meeting extends StatelessWebexPlugin {
     Trigger.trigger(this, options, EVENTS.REQUEST_UPLOAD_LOGS, this);
   }
 
+  /**
+   * Starts a periodic upload of logs
+   *
+   * @returns {undefined}
+   */
+  public startPeriodicLogUpload() {
+    if (!this.uploadLogsIntervalId) {
+      // start a periodic log upload after an initial delay of a few seconds to let things settle down first
+      safeSetTimeout(() => {
+        this.uploadLogs();
+
+        this.uploadLogsIntervalId = safeSetInterval(() => {
+          this.uploadLogs();
+
+          // just as an extra precaution, to avoid uploading logs forever in case something goes wrong
+          // and the page remains opened, we stop it if there is no media connection
+          if (!this.mediaProperties.webrtcMediaConnection) {
+            this.stopPeriodicLogUpload();
+          }
+          // @ts-ignore - config coming from registerPlugin
+        }, this.config.logUploadInterval * 1000);
+      }, 3000);
+    }
+  }
+
+  /**
+   * Stops the periodic upload of logs
+   *
+   * @returns {undefined}
+   */
+  public stopPeriodicLogUpload() {
+    if (this.uploadLogsIntervalId) {
+      clearInterval(this.uploadLogsIntervalId);
+      this.uploadLogsIntervalId = undefined;
+    }
+  }
+
   /**
    * Removes remote audio, video and share streams from class instance's mediaProperties
    * @returns {undefined}
@@ -7130,6 +7169,7 @@ export default class Meeting extends StatelessWebexPlugin {
 
       // We can log ReceiveSlot SSRCs only after the SDP exchange, so doing it here:
       this.remoteMediaManager?.logAllReceiveSlots();
+      this.startPeriodicLogUpload();
     } catch (error) {
       LoggerProxy.logger.error(`${LOG_HEADER} failed to establish media connection: `, error);
 

packages/@webex/plugin-meetings/src/meeting/util.ts

@@ -171,6 +171,7 @@ const MeetingUtil = {
 
   cleanUp: (meeting) => {
     meeting.getWebexObject().internal.device.meetingEnded();
+    meeting.stopPeriodicLogUpload();
 
     meeting.breakouts.cleanUp();
     meeting.simultaneousInterpretation.cleanUp();