/** * An element which displays the builds panel for a repository view. */ angular.module('quay').directive('repoPanelBuilds', function () { var directiveDefinitionObject = { priority: 0, templateUrl: '/static/directives/repo-view/repo-panel-builds.html', replace: false, transclude: false, restrict: 'C', scope: { 'repository': '=repository', 'builds': '=builds' }, controller: function($scope, $element, $filter, $routeParams, ApiService, TriggerService, UserService) { var orderBy = $filter('orderBy'); $scope.TriggerService = TriggerService; UserService.updateUserIn($scope); $scope.options = { 'filter': 'recent', 'reverse': false, 'predicate': 'started_datetime' }; $scope.currentFilter = null; $scope.currentStartTrigger = null; $scope.currentSetupTrigger = null; $scope.showBuildDialogCounter = 0; $scope.showTriggerStartDialogCounter = 0; $scope.showTriggerSetupCounter = 0; var updateBuilds = function() { if (!$scope.allBuilds) { return; } var unordered = $scope.allBuilds.map(function(build_info) { var commit_sha = null; var job_config = build_info.job_config || {}; if (job_config.trigger_metadata) { commit_sha = job_config.trigger_metadata.commit_sha; } return $.extend(build_info, { 'started_datetime': (new Date(build_info.started)).valueOf() * (-1), 'building_tags': job_config.docker_tags || [], 'commit_sha': commit_sha }); }); $scope.fullBuilds = orderBy(unordered, $scope.options.predicate, $scope.options.reverse); }; var loadBuilds = function() { if (!$scope.builds || !$scope.repository || !$scope.options.filter) { return; } // Note: We only refresh if the filter has changed. var filter = $scope.options.filter; if ($scope.buildsResource && filter == $scope.currentFilter) { return; } var since = null; if ($scope.options.filter == '48hour') { since = Math.floor(moment().subtract(2, 'days').valueOf() / 1000); } else if ($scope.options.filter == '30day') { since = Math.floor(moment().subtract(30, 'days').valueOf() / 1000); } else { since = null; } var params = { 'repository': $scope.repository.namespace + '/' + $scope.repository.name, 'limit': 100, 'since': since }; $scope.buildsResource = ApiService.getRepoBuildsAsResource(params).get(function(resp) { $scope.allBuilds = resp.builds; $scope.currentFilter = filter; updateBuilds(); }); }; var buildsChanged = function() { if (!$scope.allBuilds) { loadBuilds(); return; } if (!$scope.builds || !$scope.repository) { return; } // Replace any build records with updated records from the server. $scope.builds.map(function(build) { for (var i = 0; i < $scope.allBuilds.length; ++i) { var current = $scope.allBuilds[i]; if (current.id == build.id && current.phase != build.phase) { $scope.allBuilds[i] = build; break } } }); updateBuilds(); }; var loadBuildTriggers = function() { if (!$scope.repository || !$scope.repository.can_admin) { return; } var params = { 'repository': $scope.repository.namespace + '/' + $scope.repository.name }; $scope.triggersResource = ApiService.listBuildTriggersAsResource(params).get(function(resp) { $scope.triggers = resp.triggers; // Check to see if we need to setup any trigger. var newTriggerId = $routeParams.newtrigger; if (newTriggerId) { $scope.triggers.map(function(trigger) { if (trigger['id'] == newTriggerId && !trigger['is_active']) { $scope.setupTrigger(trigger); } }); } }); }; $scope.$watch('repository', loadBuildTriggers); $scope.$watch('repository', loadBuilds); $scope.$watch('builds', buildsChanged); $scope.$watch('options.filter', loadBuilds); $scope.$watch('options.predicate', updateBuilds); $scope.$watch('options.reverse', updateBuilds); $scope.tablePredicateClass = function(name, predicate, reverse) { if (name != predicate) { return ''; } return 'current ' + (reverse ? 'reversed' : ''); }; $scope.orderBy = function(predicate) { if (predicate == $scope.options.predicate) { $scope.options.reverse = !$scope.options.reverse; return; } $scope.options.reverse = false; $scope.options.predicate = predicate; }; $scope.askDeleteTrigger = function(trigger) { $scope.deleteTriggerInfo = { 'trigger': trigger }; }; $scope.askRunTrigger = function(trigger) { if ($scope.user.username != trigger.connected_user) { bootbox.alert('For security reasons, only user "' + trigger.connected_user + '" can manually invoke this trigger'); return; } $scope.currentStartTrigger = trigger; $scope.showTriggerStartDialogCounter++; }; $scope.cancelSetupTrigger = function(trigger) { if ($scope.currentSetupTrigger != trigger) { return; } $scope.currentSetupTrigger = null; $scope.deleteTrigger(trigger); }; $scope.setupTrigger = function(trigger) { $scope.currentSetupTrigger = trigger; $scope.showTriggerSetupCounter++; }; $scope.startTrigger = function(trigger, opt_custom) { var parameters = TriggerService.getRunParameters(trigger.service); if (parameters.length && !opt_custom) { $scope.currentStartTrigger = trigger; $scope.showTriggerStartDialogCounter++; return; } var params = { 'repository': $scope.repository.namespace + '/' + $scope.repository.name, 'trigger_uuid': trigger.id }; ApiService.manuallyStartBuildTrigger(opt_custom || {}, params).then(function(resp) { $scope.allBuilds.push(resp); updateBuilds(); }, ApiService.errorDisplay('Could not start build')); }; $scope.deleteTrigger = function(trigger, opt_callback) { if (!trigger) { return; } var params = { 'repository': $scope.repository.namespace + '/' + $scope.repository.name, 'trigger_uuid': trigger.id }; var errorHandler = ApiService.errorDisplay('Could not delete build trigger', function() { opt_callback && opt_callback(false); }); ApiService.deleteBuildTrigger(null, params).then(function(resp) { $scope.triggers.splice($scope.triggers.indexOf(trigger), 1); opt_callback && opt_callback(true); }, errorHandler); }; $scope.showNewBuildDialog = function() { $scope.showBuildDialogCounter++; }; $scope.handleBuildStarted = function(build) { $scope.allBuilds.push(build); updateBuilds(); }; } }; return directiveDefinitionObject; });