From 0a25bf0a32977b60dce2519e8f80256eabde06d4 Mon Sep 17 00:00:00 2001
From: kurilova <sonnycactus@gmail.com>
Date: Thu, 4 Apr 2024 11:25:05 +0000
Subject: [PATCH] Disable device item if device in progress

---
 .../device-item/device-item.component.html    |  2 ++
 .../device-item/device-item.component.scss    |  9 ++++++
 .../device-item/device-item.component.spec.ts | 22 +++++++++++++
 .../device-item/device-item.component.ts      |  1 +
 .../devices/device-repository.component.html  |  5 ++-
 .../device-repository.component.spec.ts       |  9 ++++++
 .../app/pages/devices/devices.store.spec.ts   |  7 +++-
 .../ui/src/app/pages/devices/devices.store.ts |  8 ++++-
 .../src/app/services/test-run.service.spec.ts |  7 +++-
 .../ui/src/app/services/test-run.service.ts   |  7 +++-
 modules/ui/src/app/store/actions.ts           |  5 +++
 modules/ui/src/app/store/effects.spec.ts      | 13 ++++++++
 modules/ui/src/app/store/effects.ts           | 17 ++++++++++
 modules/ui/src/app/store/reducers.spec.ts     | 32 +++++++++++++++++++
 modules/ui/src/app/store/reducers.ts          |  6 ++++
 modules/ui/src/app/store/selectors.spec.ts    |  7 ++++
 modules/ui/src/app/store/selectors.ts         |  5 +++
 modules/ui/src/app/store/state.ts             |  2 ++
 18 files changed, 159 insertions(+), 5 deletions(-)

diff --git a/modules/ui/src/app/components/device-item/device-item.component.html b/modules/ui/src/app/components/device-item/device-item.component.html
index 84117dd34..c2d69f7cc 100644
--- a/modules/ui/src/app/components/device-item/device-item.component.html
+++ b/modules/ui/src/app/components/device-item/device-item.component.html
@@ -36,6 +36,7 @@
   *ngIf="deviceView === DeviceView.WithActions"
   class="device-item-with-actions">
   <button
+    [disabled]="disabled"
     [tabIndex]="tabIndex"
     (click)="itemClick()"
     attr.aria-label="Edit device {{ label }}"
@@ -57,6 +58,7 @@
     </div>
   </button>
   <button
+    [disabled]="disabled"
     (click)="startTestrunClick()"
     attr.aria-label="Start new testrun for device {{ label }}"
     class="button-start"
diff --git a/modules/ui/src/app/components/device-item/device-item.component.scss b/modules/ui/src/app/components/device-item/device-item.component.scss
index f613ec2f1..f7516f219 100644
--- a/modules/ui/src/app/components/device-item/device-item.component.scss
+++ b/modules/ui/src/app/components/device-item/device-item.component.scss
@@ -90,6 +90,11 @@ $border-radius: 12px;
       width: 24px;
     }
   }
+
+  &:disabled {
+    pointer-events: none;
+    opacity: 0.5;
+  }
 }
 
 .item-manufacturer {
@@ -170,6 +175,10 @@ $border-radius: 12px;
       color: $white;
     }
   }
+  &:disabled {
+    pointer-events: none;
+    opacity: 0.5;
+  }
 }
 
 .button-start-icon {
diff --git a/modules/ui/src/app/components/device-item/device-item.component.spec.ts b/modules/ui/src/app/components/device-item/device-item.component.spec.ts
index 9319bb0ef..e774c22e9 100644
--- a/modules/ui/src/app/components/device-item/device-item.component.spec.ts
+++ b/modules/ui/src/app/components/device-item/device-item.component.spec.ts
@@ -109,5 +109,27 @@ describe('DeviceItemComponent', () => {
 
       expect(clickSpy).toHaveBeenCalledWith(component.device);
     });
+
+    it('should disable buttons if disable set to true', () => {
+      component.disabled = true;
+      fixture.detectChanges();
+
+      const startBtn = compiled.querySelector('.button-start') as HTMLElement;
+      const editBtn = compiled.querySelector('.button-edit') as HTMLElement;
+
+      expect(editBtn.getAttribute('disabled')).not.toBeNull();
+      expect(startBtn.getAttribute('disabled')).toBeTruthy();
+    });
+
+    it('should not disable buttons if disable set to false', () => {
+      component.disabled = false;
+      fixture.detectChanges();
+
+      const startBtn = compiled.querySelector('.button-start') as HTMLElement;
+      const editBtn = compiled.querySelector('.button-edit') as HTMLElement;
+
+      expect(editBtn.getAttribute('disabled')).toBeNull();
+      expect(startBtn.getAttribute('disabled')).toBeFalsy();
+    });
   });
 });
diff --git a/modules/ui/src/app/components/device-item/device-item.component.ts b/modules/ui/src/app/components/device-item/device-item.component.ts
index 2b1c44e0f..60bc1a443 100644
--- a/modules/ui/src/app/components/device-item/device-item.component.ts
+++ b/modules/ui/src/app/components/device-item/device-item.component.ts
@@ -30,6 +30,7 @@ export class DeviceItemComponent {
   @Input() device!: Device;
   @Input() tabIndex = 0;
   @Input() deviceView!: string;
+  @Input() disabled = false;
   @Output() itemClicked = new EventEmitter<Device>();
   @Output() startTestrunClicked = new EventEmitter<Device>();
   readonly DeviceView = DeviceView;
diff --git a/modules/ui/src/app/pages/devices/device-repository.component.html b/modules/ui/src/app/pages/devices/device-repository.component.html
index efd61fc2e..142929517 100644
--- a/modules/ui/src/app/pages/devices/device-repository.component.html
+++ b/modules/ui/src/app/pages/devices/device-repository.component.html
@@ -26,7 +26,10 @@ <h2 class="title">Devices</h2>
           (startTestrunClicked)="openStartTestrun($event, vm.devices)"
           [deviceView]="DeviceView.WithActions"
           [class.device-item-selected]="device === vm.selectedDevice"
-          [device]="device"></app-device-item>
+          [device]="device"
+          [disabled]="
+            device?.mac_addr === vm.deviceInProgress?.mac_addr
+          "></app-device-item>
       </ng-container>
     </div>
   </ng-container>
diff --git a/modules/ui/src/app/pages/devices/device-repository.component.spec.ts b/modules/ui/src/app/pages/devices/device-repository.component.spec.ts
index 30c84b660..7949b37ac 100644
--- a/modules/ui/src/app/pages/devices/device-repository.component.spec.ts
+++ b/modules/ui/src/app/pages/devices/device-repository.component.spec.ts
@@ -79,6 +79,7 @@ describe('DeviceRepositoryComponent', () => {
       component.viewModel$ = of({
         devices: [] as Device[],
         selectedDevice: null,
+        deviceInProgress: null,
       });
       mockDevicesStore.devices$ = of([]);
       mockDevicesStore.isOpenAddDevice$ = of(true);
@@ -107,6 +108,7 @@ describe('DeviceRepositoryComponent', () => {
       component.viewModel$ = of({
         devices: [device, device, device],
         selectedDevice: device,
+        deviceInProgress: device,
       });
       fixture.detectChanges();
     });
@@ -204,6 +206,12 @@ describe('DeviceRepositoryComponent', () => {
         openSpy.calls.reset();
       });
     });
+
+    it('should disable device if deviceInProgress is exist', () => {
+      const item = compiled.querySelector('app-device-item');
+
+      expect(item?.getAttribute('ng-reflect-disabled')).toBeTruthy();
+    });
   });
 
   it('should call setIsOpenAddDevice if dialog closes with null', () => {
@@ -235,6 +243,7 @@ describe('DeviceRepositoryComponent', () => {
       component.viewModel$ = of({
         devices: [device, device, device],
         selectedDevice: device,
+        deviceInProgress: null,
       });
       fixture.detectChanges();
     });
diff --git a/modules/ui/src/app/pages/devices/devices.store.spec.ts b/modules/ui/src/app/pages/devices/devices.store.spec.ts
index e60f612d6..0cf340b32 100644
--- a/modules/ui/src/app/pages/devices/devices.store.spec.ts
+++ b/modules/ui/src/app/pages/devices/devices.store.spec.ts
@@ -17,7 +17,10 @@ import { TestBed } from '@angular/core/testing';
 import { of, skip, take } from 'rxjs';
 import { MockStore, provideMockStore } from '@ngrx/store/testing';
 import { AppState } from '../../store/state';
-import { selectHasDevices } from '../../store/selectors';
+import {
+  selectDeviceInProgress,
+  selectHasDevices,
+} from '../../store/selectors';
 import { TestRunService } from '../../services/test-run.service';
 import SpyObj = jasmine.SpyObj;
 import { device, updated_device } from '../../mocks/device.mock';
@@ -45,6 +48,7 @@ describe('DevicesStore', () => {
           selectors: [
             { selector: selectDevices, value: [device] },
             { selector: selectIsOpenAddDevice, value: true },
+            { selector: selectDeviceInProgress, value: device },
           ],
         }),
         { provide: TestRunService, useValue: mockService },
@@ -79,6 +83,7 @@ describe('DevicesStore', () => {
         expect(store).toEqual({
           devices: [device],
           selectedDevice: null,
+          deviceInProgress: device,
         });
         done();
       });
diff --git a/modules/ui/src/app/pages/devices/devices.store.ts b/modules/ui/src/app/pages/devices/devices.store.ts
index 5417701c8..58cc131fd 100644
--- a/modules/ui/src/app/pages/devices/devices.store.ts
+++ b/modules/ui/src/app/pages/devices/devices.store.ts
@@ -22,7 +22,11 @@ import { tap, withLatestFrom } from 'rxjs/operators';
 import { Device } from '../../model/device';
 import { AppState } from '../../store/state';
 import { Store } from '@ngrx/store';
-import { selectDevices, selectIsOpenAddDevice } from '../../store/selectors';
+import {
+  selectDeviceInProgress,
+  selectDevices,
+  selectIsOpenAddDevice,
+} from '../../store/selectors';
 import { setDevices, setIsOpenAddDevice } from '../../store/actions';
 
 export interface DevicesComponentState {
@@ -34,12 +38,14 @@ export interface DevicesComponentState {
 export class DevicesStore extends ComponentStore<DevicesComponentState> {
   devices$ = this.store.select(selectDevices);
   isOpenAddDevice$ = this.store.select(selectIsOpenAddDevice);
+  private deviceInProgress$ = this.store.select(selectDeviceInProgress);
   private selectedDevice$ = this.select(state => state.selectedDevice);
 
   testModules = this.testRunService.getTestModules();
   viewModel$ = this.select({
     devices: this.devices$,
     selectedDevice: this.selectedDevice$,
+    deviceInProgress: this.deviceInProgress$,
   });
 
   selectDevice = this.updater((state, device: Device | null) => ({
diff --git a/modules/ui/src/app/services/test-run.service.spec.ts b/modules/ui/src/app/services/test-run.service.spec.ts
index d7dffdfb3..3d6c223e6 100644
--- a/modules/ui/src/app/services/test-run.service.spec.ts
+++ b/modules/ui/src/app/services/test-run.service.spec.ts
@@ -26,6 +26,8 @@ import { MOCK_PROGRESS_DATA_IN_PROGRESS } from '../mocks/progress.mock';
 import { StatusOfTestResult, TestrunStatus } from '../model/testrun-status';
 import { device } from '../mocks/device.mock';
 import { NEW_VERSION, VERSION } from '../mocks/version.mock';
+import { MockStore, provideMockStore } from '@ngrx/store/testing';
+import { AppState } from '../store/state';
 
 const MOCK_SYSTEM_CONFIG: SystemConfig = {
   network: {
@@ -38,15 +40,18 @@ describe('TestRunService', () => {
   let injector: TestBed;
   let httpTestingController: HttpTestingController;
   let service: TestRunService;
+  let store: MockStore<AppState>;
 
   beforeEach(() => {
     TestBed.configureTestingModule({
       imports: [HttpClientTestingModule],
-      providers: [TestRunService],
+      providers: [TestRunService, provideMockStore({})],
     });
     injector = getTestBed();
     httpTestingController = injector.get(HttpTestingController);
     service = injector.get(TestRunService);
+    store = TestBed.inject(MockStore);
+    spyOn(store, 'dispatch').and.callFake(() => {});
   });
 
   afterEach(() => {
diff --git a/modules/ui/src/app/services/test-run.service.ts b/modules/ui/src/app/services/test-run.service.ts
index ff07200fc..2475ac4b5 100644
--- a/modules/ui/src/app/services/test-run.service.ts
+++ b/modules/ui/src/app/services/test-run.service.ts
@@ -26,6 +26,8 @@ import {
   TestrunStatus,
 } from '../model/testrun-status';
 import { Version } from '../model/version';
+import { Store } from '@ngrx/store';
+import { AppState } from '../store/state';
 
 const API_URL = `http://${window.location.hostname}:8000`;
 export const SYSTEM_STOP = '/system/stop';
@@ -76,7 +78,10 @@ export class TestRunService {
 
   private version = new BehaviorSubject<Version | null>(null);
 
-  constructor(private http: HttpClient) {}
+  constructor(
+    private http: HttpClient,
+    private store: Store<AppState>
+  ) {}
 
   fetchDevices(): Observable<Device[]> {
     return this.http.get<Device[]>(`${API_URL}/devices`);
diff --git a/modules/ui/src/app/store/actions.ts b/modules/ui/src/app/store/actions.ts
index 5bd7220a5..5be2a25b4 100644
--- a/modules/ui/src/app/store/actions.ts
+++ b/modules/ui/src/app/store/actions.ts
@@ -90,3 +90,8 @@ export const setIsTestrunStarted = createAction(
   '[Shared] Set Testrun Started',
   props<{ isTestrunStarted: boolean }>()
 );
+
+export const setDeviceInProgress = createAction(
+  '[Shared] Set Device In Progress',
+  props<{ device: Device | null }>()
+);
diff --git a/modules/ui/src/app/store/effects.spec.ts b/modules/ui/src/app/store/effects.spec.ts
index 819959c3f..2067cd4e6 100644
--- a/modules/ui/src/app/store/effects.spec.ts
+++ b/modules/ui/src/app/store/effects.spec.ts
@@ -25,6 +25,7 @@ import { MockStore, provideMockStore } from '@ngrx/store/testing';
 import { AppState } from './state';
 import { selectMenuOpened } from './selectors';
 import { device } from '../mocks/device.mock';
+import { MOCK_PROGRESS_DATA_IN_PROGRESS } from '../mocks/progress.mock';
 describe('Effects', () => {
   let actions$ = new Observable<Action>();
   let effects: AppEffects;
@@ -55,6 +56,18 @@ describe('Effects', () => {
     store.refreshState();
   });
 
+  it('onSetDevices$ should call setDeviceInProgress when testrun in progress', done => {
+    const status = MOCK_PROGRESS_DATA_IN_PROGRESS;
+    actions$ = of(actions.setTestrunStatus({ systemStatus: status }));
+
+    effects.onSetTestrunStatus$.subscribe(action => {
+      expect(action).toEqual(
+        actions.setDeviceInProgress({ device: status.device })
+      );
+      done();
+    });
+  });
+
   it('onSetDevices$ should call setHasDevices', done => {
     actions$ = of(actions.setDevices({ devices: [device] }));
 
diff --git a/modules/ui/src/app/store/effects.ts b/modules/ui/src/app/store/effects.ts
index f3b2c602a..c6a5ff499 100644
--- a/modules/ui/src/app/store/effects.ts
+++ b/modules/ui/src/app/store/effects.ts
@@ -24,6 +24,7 @@ import { AppState } from './state';
 import { TestRunService } from '../services/test-run.service';
 import { filter, combineLatest } from 'rxjs';
 import { selectMenuOpened } from './selectors';
+import { StatusOfTestrun } from '../model/testrun-status';
 
 @Injectable()
 export class AppEffects {
@@ -95,6 +96,22 @@ export class AppEffects {
     );
   });
 
+  onSetTestrunStatus$ = createEffect(() => {
+    return this.actions$.pipe(
+      ofType(AppActions.setTestrunStatus),
+      map(({ systemStatus }) =>
+        AppActions.setDeviceInProgress({
+          device:
+            systemStatus.status === StatusOfTestrun.Monitoring ||
+            systemStatus.status === StatusOfTestrun.InProgress ||
+            systemStatus.status === StatusOfTestrun.WaitingForDevice
+              ? systemStatus.device
+              : null,
+        })
+      )
+    );
+  });
+
   constructor(
     private actions$: Actions,
     private testrunService: TestRunService,
diff --git a/modules/ui/src/app/store/reducers.spec.ts b/modules/ui/src/app/store/reducers.spec.ts
index 70a4b9a25..895ee6b8f 100644
--- a/modules/ui/src/app/store/reducers.spec.ts
+++ b/modules/ui/src/app/store/reducers.spec.ts
@@ -17,6 +17,8 @@ import * as fromReducer from './reducers';
 import { initialAppComponentState, initialSharedState } from './state';
 import {
   fetchInterfacesSuccess,
+  setDeviceInProgress,
+  setDevices,
   setHasConnectionSettings,
   setHasDevices,
   setIsOpenAddDevice,
@@ -27,6 +29,7 @@ import {
   updateError,
   updateFocusNavigation,
 } from './actions';
+import { device } from '../mocks/device.mock';
 import { MOCK_PROGRESS_DATA_CANCELLING } from '../mocks/progress.mock';
 
 describe('Reducer', () => {
@@ -140,6 +143,35 @@ describe('Reducer', () => {
     });
   });
 
+  describe('setDevices action', () => {
+    it('should update state', () => {
+      const initialState = initialSharedState;
+      const devices = [device, device];
+      const action = setDevices({ devices });
+      const state = fromReducer.sharedReducer(initialState, action);
+      const newState = { ...initialState, ...{ devices } };
+
+      expect(state).toEqual(newState);
+      expect(state).not.toBe(initialState);
+    });
+  });
+
+  describe('setDeviceInProgress action', () => {
+    it('should update state', () => {
+      const initialState = initialSharedState;
+      const deviceInProgress = device;
+      const action = setDeviceInProgress({ device: deviceInProgress });
+      const state = fromReducer.sharedReducer(initialState, action);
+      const newState = {
+        ...initialState,
+        ...{ deviceInProgress: deviceInProgress },
+      };
+
+      expect(state).toEqual(newState);
+      expect(state).not.toBe(initialState);
+    });
+  });
+
   describe('setTestrunStatus action', () => {
     it('should update state', () => {
       const initialState = initialSharedState;
diff --git a/modules/ui/src/app/store/reducers.ts b/modules/ui/src/app/store/reducers.ts
index a214a832e..17581c735 100644
--- a/modules/ui/src/app/store/reducers.ts
+++ b/modules/ui/src/app/store/reducers.ts
@@ -82,6 +82,12 @@ export const sharedReducer = createReducer(
       ...state,
       isTestrunStarted,
     };
+  }),
+  on(Actions.setDeviceInProgress, (state, { device }) => {
+    return {
+      ...state,
+      deviceInProgress: device,
+    };
   })
 );
 
diff --git a/modules/ui/src/app/store/selectors.spec.ts b/modules/ui/src/app/store/selectors.spec.ts
index 0cafab942..87012dd29 100644
--- a/modules/ui/src/app/store/selectors.spec.ts
+++ b/modules/ui/src/app/store/selectors.spec.ts
@@ -16,6 +16,7 @@
 
 import { AppState } from './state';
 import {
+  selectDeviceInProgress,
   selectDevices,
   selectError,
   selectHasConnectionSettings,
@@ -46,6 +47,7 @@ describe('Selectors', () => {
       isOpenStartTestrun: false,
       systemStatus: null,
       isTestrunStarted: false,
+      deviceInProgress: null,
     },
   };
 
@@ -98,4 +100,9 @@ describe('Selectors', () => {
     const result = selectIsOpenStartTestrun.projector(initialState);
     expect(result).toEqual(false);
   });
+
+  it('should select deviceInProgress', () => {
+    const result = selectDeviceInProgress.projector(initialState);
+    expect(result).toEqual(null);
+  });
 });
diff --git a/modules/ui/src/app/store/selectors.ts b/modules/ui/src/app/store/selectors.ts
index b5aa1edbd..7ce8538bb 100644
--- a/modules/ui/src/app/store/selectors.ts
+++ b/modules/ui/src/app/store/selectors.ts
@@ -52,6 +52,11 @@ export const selectDevices = createSelector(
   (state: AppState) => state.shared.devices
 );
 
+export const selectDeviceInProgress = createSelector(
+  selectAppState,
+  (state: AppState) => state.shared.deviceInProgress
+);
+
 export const selectError = createSelector(
   selectAppState,
   (state: AppState) => state.appComponent.settingMissedError
diff --git a/modules/ui/src/app/store/state.ts b/modules/ui/src/app/store/state.ts
index ed31d419a..6da1ee6e6 100644
--- a/modules/ui/src/app/store/state.ts
+++ b/modules/ui/src/app/store/state.ts
@@ -48,6 +48,7 @@ export interface SharedState {
   isOpenAddDevice: boolean;
   // app, testrun
   isOpenStartTestrun: boolean;
+  deviceInProgress: Device | null;
 }
 
 export const initialAppComponentState: AppComponentState = {
@@ -64,6 +65,7 @@ export const initialSharedState: SharedState = {
   isOpenAddDevice: false,
   hasDevices: false,
   devices: [],
+  deviceInProgress: null,
   isOpenStartTestrun: false,
   systemStatus: null,
   isTestrunStarted: false,