services/workbench2/src/components/subprocess-progress-bar/subprocess-progress-bar.cy.js

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import React from "react";
   6 import { createServices } from "services/services";
   7 import { configureStore } from "store/store";
   8 import { createBrowserHistory } from "history";
   9 import { mockConfig } from 'common/config';
  10 import Axios from "axios";
  11 import { ContainerState } from "models/container";
  12 import { SubprocessProgressBar } from "./subprocess-progress-bar";
  13 import { Provider } from "react-redux";
  14 import { FilterBuilder } from 'services/api/filter-builder';
  15 import { ProcessStatusFilter, buildProcessStatusFilters } from 'store/resource-type-filters/resource-type-filters';
  16
  17 describe("<SubprocessProgressBar />", () => {
  18     const axiosInst = Axios.create({ headers: {} });
  19
  20     let store;
  21     let services;
  22     const config = {};
  23     const actions = {
  24         progressFn: (id, working) => { },
  25         errorFn: (id, message) => { }
  26     };
  27     let statusResponse = {
  28         [ProcessStatusFilter.COMPLETED]: 0,
  29         [ProcessStatusFilter.RUNNING]: 0,
  30         [ProcessStatusFilter.FAILED]: 0,
  31         [ProcessStatusFilter.QUEUED]: 0,
  32     };
  33
  34     const createMockListFunc = (uuid) => (async (args) => {
  35         const baseFilter = new FilterBuilder().addEqual('requesting_container_uuid', uuid).getFilters();
  36
  37         const filterResponses = Object.keys(statusResponse)
  38             .map(status => ({filters: buildProcessStatusFilters(new FilterBuilder(baseFilter), status).getFilters(), value: statusResponse[status]}));
  39
  40         const matchedFilter = filterResponses.find(response => response.filters === args.filters);
  41         if (matchedFilter) {
  42             return { itemsAvailable: matchedFilter.value };
  43         } else {
  44             return { itemsAvailable: 0 };
  45         }
  46     });
  47
  48     beforeEach(() => {
  49         services = createServices(mockConfig({}), actions, axiosInst);
  50         store = configureStore(createBrowserHistory(), services, config);
  51     });
  52
  53     it("requests subprocess progress stats for stopped processes and displays progress", async () => {
  54         // when
  55         const process = {
  56             container: {
  57                 state: ContainerState.COMPLETE,
  58             },
  59             containerRequest: {
  60                 containerUuid: 'zzzzz-dz642-000000000000000',
  61             },
  62         };
  63
  64         statusResponse = {
  65             [ProcessStatusFilter.COMPLETED]: 100,
  66             [ProcessStatusFilter.RUNNING]: 200,
  67
  68             // Combined into failed segment
  69             [ProcessStatusFilter.FAILED]: 200,
  70             [ProcessStatusFilter.CANCELLED]: 100,
  71
  72             // Combined into queued segment
  73             [ProcessStatusFilter.QUEUED]: 300,
  74             [ProcessStatusFilter.ONHOLD]: 100,
  75         };
  76
  77         services.containerRequestService.list = createMockListFunc(process.containerRequest.containerUuid);
  78
  79         cy.mount(
  80             <Provider store={store}>
  81                 <SubprocessProgressBar process={process} />
  82             </Provider>);
  83
  84         // expects 6 subprocess status list requests
  85         const expectedFilters = [
  86             ProcessStatusFilter.COMPLETED,
  87             ProcessStatusFilter.RUNNING,
  88             ProcessStatusFilter.FAILED,
  89             ProcessStatusFilter.CANCELLED,
  90             ProcessStatusFilter.QUEUED,
  91             ProcessStatusFilter.ONHOLD,
  92         ].map((state) =>
  93             buildProcessStatusFilters(
  94                 new FilterBuilder().addEqual(
  95                     "requesting_container_uuid",
  96                     process.containerRequest.containerUuid
  97                 ),
  98                 state
  99             ).getFilters()
 100         );
 101
 102         cy.spy(services.containerRequestService, 'list').as('list');
 103
 104         expectedFilters.forEach((filter) => {
 105             cy.get('@list').should('have.been.calledWith', {limit: 0, offset: 0, filters: filter});
 106         });
 107
 108         // Verify progress bar with correct degment widths
 109         ['10%', '20%', '30%', '40%'].forEach((value, i) => {
 110             cy.get('div[class=progress]').eq(i).should('have.attr', 'style').and('include', `width: ${value};`);
 111
 112         });
 113     });
 114
 115     it("dislays correct progress bar widths with different values", async () => {
 116         const process = {
 117             container: {
 118                 state: ContainerState.COMPLETE,
 119             },
 120             containerRequest: {
 121                 containerUuid: 'zzzzz-dz642-000000000000001',
 122             },
 123         };
 124
 125         statusResponse = {
 126             [ProcessStatusFilter.COMPLETED]: 50,
 127             [ProcessStatusFilter.RUNNING]: 55,
 128
 129             [ProcessStatusFilter.FAILED]: 30,
 130             [ProcessStatusFilter.CANCELLED]: 30,
 131
 132             [ProcessStatusFilter.QUEUED]: 235,
 133             [ProcessStatusFilter.ONHOLD]: 100,
 134         };
 135
 136         services.containerRequestService.list = createMockListFunc(process.containerRequest.containerUuid);
 137
 138         cy.mount(
 139             <Provider store={store}>
 140                 <SubprocessProgressBar process={process} />
 141             </Provider>);
 142
 143         // Verify progress bar with correct degment widths
 144         ['10%', '11%', '12%', '67%'].forEach((value, i) => {
 145             cy.get('div[class=progress]').eq(i).should('have.attr', 'style').and('include', `width: ${value};`);
 146         });
 147     });
 148
 149 });