src/app/components/queue-rack/queue-rack.component.ts

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import { Component, OnInit, Input, Output, EventEmitter } from '@angular/core';

import { QueueInfo, ToggleQueueChildrenEvent } from '@app/models/queue-info.model';
import { NOT_AVAILABLE } from '@app/utils/constants';

@Component({
  selector: 'app-queue-rack',
  templateUrl: './queue-rack.component.html',
  styleUrls: ['./queue-rack.component.scss'],
})
export class QueueRackComponent implements OnInit {
  @Input() queueList: QueueInfo[] | null = [];
  @Input() nextLevel = '';

  @Output() toggleChildren = new EventEmitter<ToggleQueueChildrenEvent>();
  @Output() queueSelected = new EventEmitter<QueueInfo>();

  constructor() {}

  ngOnInit() {}

  toggleQueueChildren(event: Event, item: QueueInfo) {
    event.preventDefault();
    event.stopPropagation();
    this.collapseQueueList(item);
    item.isExpanded = !item.isExpanded;
    this.toggleChildren.emit({
      queueItem: item,
      nextLevel: this.nextLevel,
    });
  }

  collapseQueueList(item: QueueInfo) {
    if (this.queueList) {
      this.queueList.forEach((queue) => {
        if (queue !== item) {
          queue.isExpanded = false;
        }
      });
    }
  }

  onQueueSelected(queue: QueueInfo) {
    queue.isSelected = !queue.isSelected;
    this.queueSelected.emit(queue);
  }

  // FIXME: Implement using absolute usage value in new /{partition}/queues REST API.
  // Currently absolute usage value is not available in /{partition}/queues REST API.
  getQueueCapacityColor(queue: QueueInfo) {
    return '#fff';
  }

  // FIXME: Implement using absolute usage value in new /{partition}/queues REST API.
  // Currently absolute usage value is not available in /{partition}/queues REST API.
  getProgressBarValue(queue: QueueInfo) {
    return 0;
  }

  getMaxAbsValue(absCapacities: string): number {
    let max = 0;
    if (absCapacities !== null) {
      const splitted = absCapacities
        .replace(NOT_AVAILABLE, '0')
        .replace(/[^:0-9]/g, '')
        .split(':');
      if (splitted.length !== 0) {
        const capacities: number[] = splitted.map((x) => +x);
        max = Math.max(...capacities);
      }
    }
    return max;
  }
}