Add analytics to analyzer-cli and analysis server.

pkg/analysis_server/lib/src/analysis_server.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:core';
 import 'dart:io' as io;
 import 'dart:math' show max;
 
@@ skipping 43 matching lines @@
 import 'package:analyzer/src/generated/sdk.dart';
 import 'package:analyzer/src/generated/source.dart';
 import 'package:analyzer/src/generated/source_io.dart';
 import 'package:analyzer/src/generated/utilities_general.dart';
 import 'package:analyzer/src/util/glob.dart';
 import 'package:analyzer_plugin/protocol/protocol_common.dart' hide Element;
 import 'package:front_end/src/base/performace_logger.dart';
 import 'package:front_end/src/incremental/byte_store.dart';
 import 'package:front_end/src/incremental/file_byte_store.dart';
 import 'package:plugin/plugin.dart';
+import 'package:telemetry/crash_reporting.dart';
+import 'package:telemetry/telemetry.dart' as telemetry;
 import 'package:watcher/watcher.dart';
 
 typedef void OptionUpdater(AnalysisOptionsImpl options);
 
 /**
  * Enum representing reasons why analysis might be done for a given file.
  */
 class AnalysisDoneReason {
   /**
    * Analysis of the file completed successfully.
@@ skipping 697 matching lines @@
       stackTrace = StackTrace.current;
       buffer.writeln();
       buffer.write(stackTrace);
     }
 
     // send the notification
     channel.sendNotification(
         new ServerErrorParams(fatal, message, buffer.toString())
             .toNotification());
 
+    // send to crash reporting
+    options.crashReportSender?.sendReport(exception, stackTrace: stackTrace);
+
     // remember the last few exceptions
     if (exception is CaughtException) {
       stackTrace ??= exception.stackTrace;
     }
     exceptions.add(new ServerException(message, exception, stackTrace, fatal));
   }
 
   /**
    * Send status notification to the client. The state of analysis is given by
    * the [status] information.
@@ skipping 106 matching lines @@
   }
 
   /**
    * Returns `true` if errors should be reported for [file] with the given
    * absolute path.
    */
   bool shouldSendErrorsNotificationFor(String file) {
     return contextManager.isInAnalysisRoot(file);
   }
 
-  void shutdown() {
+  Future<Null> shutdown() async {
     running = false;
+
+    await options.analytics
+        ?.waitForLastPing(timeout: new Duration(milliseconds: 200));
+    options.analytics?.close();
+
     // Defer closing the channel and shutting down the instrumentation server so
     // that the shutdown response can be sent and logged.
     new Future(() {
       instrumentationService.shutdown();
       channel.close();
     });
   }
 
   /**
    * Implementation for `analysis.updateContent`.
@@ skipping 125 matching lines @@
 }
 
 class AnalysisServerOptions {
   bool useAnalysisHighlight2 = false;
   String fileReadMode = 'as-is';
   String newAnalysisDriverLog;
 
   String clientId;
   String clientVersion;
 
+  /// The analytics instance; note, this object can be `null`, and should be

[Brian Wilkerson, 2017/07/02 15:54:26]

Perhaps use a doc comment style consistent with existing code?

[devoncarew, 2017/07/04 02:35:48]

Done.

+  /// accessed via a null-aware operator.
+  telemetry.Analytics analytics;
+
+  /// The crash report sender instance; note, this object can be `null`, and
+  /// should be accessed via a null-aware operator.
+  CrashReportSender crashReportSender;
+
   // IDE options

[Brian Wilkerson, 2017/07/02 15:54:26]

This should have been a doc comment (one disadvantage of using '///'; it's too
easy to miss a slash). But it clearly isn't in the right place anymore. It
probably belongs on the enclosing class. Would you mind moving and fixing it (or
deleting it given that it doesn't really add any value)?

[devoncarew, 2017/07/04 02:35:48]

Sure - moved to the AnalysisServerOptions class.

   bool enableVerboseFlutterCompletions = false;
 }
 
 /**
  * A [PriorityChangeEvent] indicates the set the priority files has changed.
  */
 class PriorityChangeEvent {
   final Source firstSource;
 
   PriorityChangeEvent(this.firstSource);
@@ skipping 400 matching lines @@
   /**
    * The [PerformanceTag] for time spent in server request handlers.
    */
   static PerformanceTag serverRequests = server.createChild('requests');
 
   /**
    * The [PerformanceTag] for time spent in split store microtasks.
    */
   static PerformanceTag splitStore = new PerformanceTag('splitStore');
 }