index.js

var _ = require('lodash');
var Q = require('q');
var globalOptions = require('./lib/options');
var pipelineReader = require('./lib/gocd/pipelineFeedReader');
var ccTrayReader = require('./lib/cc/ccTrayReader');

GoCd = {

  getCcTrayInstance: function(newOptions) {
    newOptions = newOptions || {};
    newOptions.type = 'CCTRAY';
    globalOptions.set(newOptions);

    return {
      readActivity: function(filterByPipeline, customStageValidator) {
        return ccTrayReader.readActivity(filterByPipeline, customStageValidator).then(function(activity) {
          return {
            pipeline: filterByPipeline,
            activity: activity
          };
        });
      }
    }
  },

  getInstance : function(newOptions, type) {
    newOptions = newOptions || {};
    newOptions.type = type || 'GOCD';
    globalOptions.set(newOptions);

    function refreshPipelineNames () {
      return globalOptions.getHistoryRequestor().getPipelineNames();
    }

    var readData = function(filterByPipeline) {

      function enrichActivityWithHistory(pipelineRuns, activity) {

        function findHistoryStage(historyPipelineRun, activityStage) {
          return _.find(historyPipelineRun.stages, function(stage) {
            return stage.name === activityStage.name;
          });
        }

        function mapAuthorInitialsFromHistoryToActivity(activityStage, historyPipelineRun) {
          activityStage.initials = historyPipelineRun.summary && historyPipelineRun.summary.author? historyPipelineRun.summary.author.initials : undefined;
        }

        function moreAccurateJobActivity(activityStage, historyPipelineRun) {
          if(activityStage.activity === 'Building') {
            var historyStage = findHistoryStage(historyPipelineRun, activityStage);
            activityStage.gocdActivity = historyStage && historyStage.summary ? historyStage.summary.state : activityStage.activity;
            activityStage.isBuilding = function() {
              return _.includes(['Assigned', 'Prepared', 'Building'], activityStage.gocdActivity);
            };
            activityStage.isScheduled = function() {
              return activityStage.gocdActivity === 'Scheduled';
            };
          }
        }

        function moreAccurateJobResult(activityStage, historyPipelineRun) {
          if(activityStage.lastBuildStatus === 'Failure') {
            var historyStage = findHistoryStage(historyPipelineRun, activityStage);
            if (historyStage.result === 'Cancelled') {
              activityStage.lastBuildStatus = 'Cancelled';
              activityStage.info2 = activityStage.info2.replace('Failure', 'Cancelled');
            }

          }
        }

        _.each(activity.stages, function(stage) {
          var historyWithSameKey = pipelineRuns[stage.buildNumber];
          if(historyWithSameKey) {
            mapAuthorInitialsFromHistoryToActivity(stage, historyWithSameKey);
            moreAccurateJobActivity(stage, historyWithSameKey);
            moreAccurateJobResult(stage, historyWithSameKey);
          }
        });

      }

      return refreshPipelineNames().then(function(pipelineNames) {
        if (!_.includes(pipelineNames, filterByPipeline)) {
          return Q.reject("Pipeline unknown: '" + filterByPipeline + "'");
        }
      }).then(function() {

        return ccTrayReader.readActivity(filterByPipeline).then(function(activity) {
          return pipelineReader.readHistory({ pipeline: filterByPipeline }).then(function(history) {
            var pipelineRuns = history.pipelineRuns;

            enrichActivityWithHistory(pipelineRuns, activity);

            _.each(activity.stages, function(stage) {
              if(stage.gocdActivity === 'Scheduled' || stage.gocdActivity === 'Building') {
                delete pipelineRuns[stage.buildNumber];
              }
            });

            return {
              pipeline: filterByPipeline,
              activity: activity,
              history: {
                pipelineRuns: pipelineRuns,
                statistics: history.statistics
              }
            };
          });

        });
      });
    };

    return refreshPipelineNames().then(function(pipelineNames) {
      return pipelineReader.initFullCache(pipelineNames).then(function() {
        return {
          readData: readData,
          pipelineNames: pipelineNames
        };
      });

    }).fail(function(error) {
      console.log("ERROR creating gocd api instance", error);
    });


  }

};

module.exports = GoCd;