statefulSet.js

'use strict';

angular
  .module('openshiftConsole')
  .controller('StatefulSetController', function(
    $filter,
    $scope,
    $routeParams,
    AlertMessageService,
    BreadcrumbsService,
    DataService,
    ProjectsService) {

    $scope.projectName = $routeParams.project;
    $scope.statefulSetName = $routeParams.statefulset;
    $scope.forms = {};
    $scope.alerts = {};
    $scope.breadcrumbs = BreadcrumbsService.getBreadcrumbs({
      name: $scope.statefulSetName,
      kind: 'statefulSet',
      namespace: $routeParams.project
    });
    $scope.emptyMessage = "Loading...";

    var altTextForValueFrom = $filter('altTextForValueFrom');
    var updateEnvVars = function(statefulSet) {
      _.each(statefulSet.spec.template.spec.containers, function(container) {
        _.each(container.env, altTextForValueFrom);
      });
      return statefulSet;
    };

    AlertMessageService.getAlerts().forEach(function(alert) {
      $scope.alerts[alert.name] = alert.data;
    });
    AlertMessageService.clearAlerts();

    var watches = [];
    var projectContext;

    var updatePods = function(pods, selector) {
      if (!pods || !selector) {
        return;
      }
      return selector.select(pods);
    };

    var resourceGroupVersion = {
      resource: 'statefulsets',
      group: 'apps',
      version: 'v1beta1'
    };

    ProjectsService
      .get($routeParams.project)
      .then(_.spread(function(project, context) {
        projectContext = context;

        DataService
          .get(resourceGroupVersion, $scope.statefulSetName, context)
          .then(function(statefulSet) {
          
            angular.extend($scope, {
              statefulSet: updateEnvVars(statefulSet),
              project: project,
              projectContext: context,
              loaded: true,
              // TODO: support scaling(?). currently no scale subresource.
              isScalable: function() {
                return false;
              },
              scale: function() {}
            });

            watches.push(DataService.watchObject(resourceGroupVersion, $scope.statefulSetName, context, function(statefulSet) {
              angular.extend($scope, {
                resourceGroupVersion: resourceGroupVersion,
                statefulSet: updateEnvVars(statefulSet)
              });
            }));

            var pods;
            var selector;
            $scope.$watch('statefulSet.spec.selector', function() {
              selector = new LabelSelector($scope.statefulSet.spec.selector);
              $scope.podsForStatefulSet = updatePods(pods, selector);
            }, true);

            watches.push(DataService.watch('pods', context, function(podData) {
              pods = podData.by('metadata.name');
              $scope.podsForStatefulSet = updatePods(pods, selector);
            }));

          });
      }));

    $scope.$on('$destroy', function(){
      DataService.unwatchAll(watches);
    });

  });