marcells/node-build-monitor

var request = require('request'),
    async = require('async');

module.exports = function () {
    var self = this,
        requestBuilds = function (callback) {
            bitriseRequest(
                '/apps/' + self.configuration.slug + '/builds',
                function(error, response, body) {
                    callback(error, body.data);
                }
            );
        },
        requestBuild = function (build, callback) {
            bitriseRequest(
                '/apps/' + self.configuration.slug + '/builds/' + build.slug,
                function(error, response, body) {
                    if (error) {
                      callback(error);
                      return;
                    }

                    callback(error, simplifyBuild(body.data));
                }
            );
        },
        queryBuilds = function (callback) {
            requestBuilds(function (error, body) {
                if (error) {
                  callback(error);
                  return;
                }

                async.map(body, requestBuild, function (error, results) {
                    callback(error, results);
                });
            });
        },
        parseDate = function (dateAsString) {
            return new Date(dateAsString);
        },
        getStatus = function (status) {
            var statuses = [ "Blue", "Green", "Red", "Gray" ];
            return statuses[status];
        },
        getStatusText = function(text) {
            var map = {
                success: 'finished'
            };

            return map[text] || text;
        },
        simplifyBuild = function (res) {
            return {
                id: res.slug,
                project: self.configuration.appName,
                number: res.build_number,
                isRunning: res.status === 0,
                startedAt: parseDate(res.triggered_at),
                finishedAt: parseDate(res.finished_at),
                requestedFor: (res.original_build_params.pull_request_author || res.triggered_by || '') + " building " + res.branch,
                status: getStatus(res.status),
                statusText: getStatusText(res.status_text),
                reason: res.triggered_workflow,
                hasErrors: false,
                hasWarnings: false,
                url: 'https://www.' + self.configuration.url + '/build/' + res.slug
            };
        },
        bitriseRequest = function (path, callback) {
            var options = {
                'url': 'https://api.' + self.configuration.apiUrl + path,
                'json' : true,
                'headers': { Authorization: 'token ' + self.configuration.token }
            };

            request(options, callback);
        };

    self.configure = function (config) {
        self.configuration = config;

        self.configuration.apiVersion = self.configuration.apiVersion || 'v0.1';
        self.configuration.url = self.configuration.url || 'bitrise.io';
        self.configuration.apiUrl = self.configuration.url + '/' + self.configuration.apiVersion;
        self.configuration.token = self.configuration.token || '';

        bitriseRequest(
            '/apps/' + self.configuration.slug,
            function (error, response, body) {
                self.configuration.appName = body.data.repo_owner + '/' + body.data.title;
            }
        );
    };

    self.check = function (callback) {
        queryBuilds(callback);
    };
};