summaryrefslogtreecommitdiffstats
path: root/tasks/metrics.js
blob: 9044306cf405b5c7e0b37857af358e5d02ffa2c8 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
var _ = require('underscore'),
    async = require('async'),
    git = require('./util/git'),
    Keen = require('keen.io'),
    metrics = require('../bench');

module.exports = function(grunt) {
  grunt.registerTask('metrics', function() {
    var done = this.async(),
        execName = grunt.option('name'),
        events = {},

        projectId = process.env.KEEN_PROJECTID,
        writeKey = process.env.KEEN_WRITEKEY,
        keen;

    if (!execName && projectId && writeKey) {
      keen = Keen.configure({
        projectId: projectId,
        writeKey: writeKey
      });
    }

    async.each(_.keys(metrics), function(name, complete) {
        if (/^_/.test(name) || (execName && name !== execName)) {
          return complete();
        }

        metrics[name](grunt, function(data) {
          events[name] = data;
          complete();
        });
      },
      function() {
        if (!keen) {
          return done();
        }

        emit(keen, events, function(err) {
          if (err) {
            throw err;
          }

          grunt.log.writeln('Metrics recorded.');
          done();
        });
      });
  });
};
function emit(keen, collections, callback) {
  git.commitInfo(function(err, info) {
    _.each(collections, function(collection) {
      _.each(collection, function(event) {
        if (info.tagName) {
          event.tag = info.tagName;
        }
        event.sha = info.head;
      });
    });

    keen.addEvents(collections, callback);
  });
}