Track how much time people spend waiting for queues to be flushed

Summary: Added stats, so that we know how much people have to wait when opening plugin after we open the queue GK

Reviewed By: jknoxville

Differential Revision: D19598730

fbshipit-source-id: f955123f2bae5b870eada8f787385d6c0450453e

src/PluginContainer.tsx

@@ -192,7 +192,7 @@ class PluginContainer extends PureComponent<Props, State> {
         pluginKey &&
         pendingMessages?.length
       ) {
-        // this.setState({progress: {current: 0, total: 0}});
+        const start = Date.now();
         this.idler = new Idler();
         processMessageQueue(
           activePlugin,
@@ -202,7 +202,18 @@ class PluginContainer extends PureComponent<Props, State> {
             this.setState({progress});
           },
           this.idler,
-        );
+        ).then(completed => {
+          const duration = Date.now() - start;
+          this.props.logger.track(
+            'duration',
+            'queue-processing-before-plugin-open',
+            {
+              completed,
+              duration,
+            },
+            activePlugin.id,
+          );
+        });
       }
     }
   }

src/utils/messageQueue.tsx

@@ -204,9 +204,9 @@ export async function processMessageQueue(
   store: MiddlewareAPI,
   progressCallback?: (progress: {current: number; total: number}) => void,
   idler: BaseIdler = new Idler(),
-) {
+): Promise<boolean> {
   if (!plugin.persistedStateReducer) {
-    return;
+    return true;
   }
   const total = getPendingMessages(store, pluginKey).length;
   let progress = 0;
@@ -249,12 +249,13 @@ export async function processMessageQueue(
     }
 
     if (idler.isCancelled()) {
-      return;
+      return false;
     }
 
     await idler.idle();
     // new messages might have arrived, so keep looping
   } while (getPendingMessages(store, pluginKey).length);
+  return true;
 }
 
 function getPendingMessages(