COMPASS-2750: Adding agg pipeline telemetry data

Author: durran

package-lock.json

@@ -210,7 +210,7 @@
     "url": "git://github.com/10gen/compass.git"
   },
   "dependencies": {
-    "@mongodb-js/compass-aggregations": "^0.2.6",
+    "@mongodb-js/compass-aggregations": "^0.2.7",
     "@mongodb-js/compass-auth-kerberos": "^0.1.0",
     "@mongodb-js/compass-auth-ldap": "^0.1.0",
     "@mongodb-js/compass-auth-x509": "^0.1.0",

package.json

@@ -139,6 +139,21 @@ const DocumentResource = BaseResource.extend({
   }
 });
 
+// Aggregation resource.
+const AggregationResource = BaseResource.extend({
+  id: 'Aggregation',
+  eventTrackers: ['stitch'],
+  executed: function(metadata, callback) {
+    this._send_event(metadata, callback);
+  },
+  saved: function(metadata, callback) {
+    this._send_event(metadata, callback);
+  },
+  deleted: function(metadata, callback) {
+    this._send_event(metadata, callback);
+  }
+});
+
 // Resource for the connect window.
 const ConnectResource = BaseResource.extend({
   id: 'Connect',
@@ -241,6 +256,7 @@ featureResources['Validation Rules'] = new ValidationRulesResource();
 featureResources.Explain = new ExplainResource();
 featureResources.Import = new ImportResource();
 featureResources.Export = new ExportResource();
+featureResources.Aggregation = new AggregationResource();
 featureResources.Document = new DocumentResource();
 featureResources.Documents = new DocumentsResource();
 featureResources.DocumentsListView = new DocumentsListViewResource();

src/internal-plugins/metrics/lib/features.js

@@ -238,6 +238,34 @@ module.exports = [
     condition: () => true,
     metadata: () => ({})
   },
+  {
+    registryEvent: 'agg-pipeline-executed',
+    resource: 'Aggregation',
+    action: 'executed',
+    condition: () => true,
+    metadata: (data) => ({
+      numStages: data.numStages,
+      stageOperators: data.stageOperators
+    })
+  },
+  {
+    registryEvent: 'agg-pipeline-saved',
+    resource: 'Aggregation',
+    action: 'saved',
+    condition: () => true,
+    metadata: (data) => ({
+      name: data.name
+    })
+  },
+  {
+    registryEvent: 'agg-pipeline-deleted',
+    resource: 'Aggregation',
+    action: 'deleted',
+    condition: () => true,
+    metadata: (data) => ({
+      name: data.name
+    })
+  },
   {
     store: 'License.Store',
     resource: 'License',