Adapt to aliases for imports

[portal/nonrtric-controlpanel.git] / webapp-frontend / src / app / ei-coordinator / jobs-list / jobs-list.component.ts

diff --git a/webapp-frontend/src/app/ei-coordinator/jobs-list/jobs-list.component.ts b/webapp-frontend/src/app/ei-coordinator/jobs-list/jobs-list.component.ts
index 5208112..b891021 100644 (file)
--- a/webapp-frontend/src/app/ei-coordinator/jobs-list/jobs-list.component.ts
+++ b/webapp-frontend/src/app/ei-coordinator/jobs-list/jobs-list.component.ts
@@ -17,13 +17,17 @@
  * limitations under the License.
  * ========================LICENSE_END===================================
  */
-import { Component, OnInit } from '@angular/core';
+import { Component, OnInit, ViewChild } from '@angular/core';
 import { FormControl, FormGroup } from '@angular/forms';
+import { MatPaginator } from '@angular/material/paginator';
 import { Sort } from '@angular/material/sort';
 import { MatTableDataSource } from '@angular/material/table';
-import { EIJob } from 'src/app/interfaces/ei.types';
-import { UiService } from 'src/app/services/ui/ui.service';
-import { EIJobDataSource } from '../ei-job.datasource';
+import { forkJoin } from 'rxjs';
+import { BehaviorSubject } from 'rxjs/BehaviorSubject';
+import { mergeMap, finalize } from 'rxjs/operators';
+import { EIJob } from '@interfaces/ei.types';
+import { EIService } from '@services/ei/ei.service';
+import { UiService } from '@services/ui/ui.service';
 
 @Component({
   selector: 'nrcp-jobs-list',
@@ -31,13 +35,18 @@ import { EIJobDataSource } from '../ei-job.datasource';
   styleUrls: ['./jobs-list.component.scss']
 })
 export class JobsListComponent implements OnInit {
-  darkMode: boolean;
-  jobsDataSource: MatTableDataSource<EIJob> = new MatTableDataSource<EIJob>();
 
+  @ViewChild(MatPaginator, { static: true }) paginator: MatPaginator;
+
+  darkMode: boolean;
+  jobsDataSource: MatTableDataSource<EIJob>;
   jobForm: FormGroup;
+  private loadingSubject = new BehaviorSubject<boolean>(false);
+  private jobsSubject = new BehaviorSubject<EIJob[]>([]);
+  public loading$ = this.loadingSubject.asObservable();
 
   constructor(
-    private eiJobsDataSource: EIJobDataSource,
+    private eiSvc: EIService,
     private ui: UiService
   ) {
     this.jobForm = new FormGroup({
@@ -46,29 +55,45 @@ export class JobsListComponent implements OnInit {
       owner: new FormControl(''),
       targetUri: new FormControl('')
     });
-
   }
 
   ngOnInit(): void {
-    this.refresh();
+    this.loadJobs();
+    this.jobsSubject.subscribe((data) => {
+      this.jobsDataSource = new MatTableDataSource<EIJob>(data);
+      this.jobsDataSource.paginator = this.paginator;
+
+      this.jobsDataSource.filterPredicate = ((data: EIJob, filter) => {
+        let searchTerms = JSON.parse(filter);
+        return this.isDataIncluding(data.ei_job_identity, searchTerms.id)
+          && this.isDataIncluding(data.target_uri, searchTerms.targetUri)
+          && this.isDataIncluding(data.owner, searchTerms.owner)
+          && this.isDataIncluding(data.ei_type_identity, searchTerms.typeId);
+      }) as (data: EIJob, filter: any) => boolean;
+    });
 
     this.jobForm.valueChanges.subscribe(value => {
-      const filter = { ...value, id: value.id.trim().toLowerCase() } as string;
-      this.jobsDataSource.filter = filter;
+      this.jobsDataSource.filter = JSON.stringify(value);
     });
 
-    this.jobsDataSource.filterPredicate = ((data: EIJob, filter) => {
-      return this.isDataIncluding(data.ei_job_identity, filter.id)
-        && this.isDataIncluding(data.target_uri, filter.targetUri)
-        && this.isDataIncluding(data.owner, filter.owner)
-        && this.isDataIncluding(data.ei_type_identity, filter.typeId);
-    }) as (data: EIJob, filter: any) => boolean;
-
     this.ui.darkModeState.subscribe((isDark) => {
       this.darkMode = isDark;
     });
   }
 
+  ngOnDestroy() {
+    if (!this.jobsSubject) this.jobsSubject.unsubscribe();
+    if (!this.loadingSubject) this.loadingSubject.unsubscribe();
+    if (!this.ui.darkModeState) this.ui.darkModeState.unsubscribe();
+  }
+
+  clearFilter() {
+    this.jobForm.get('id').setValue('');
+    this.jobForm.get('typeId').setValue('');
+    this.jobForm.get('owner').setValue('');
+    this.jobForm.get('targetUri').setValue('');
+  }
+
   sortJobs(sort: Sort) {
     const data = this.jobsDataSource.data
     data.sort((a: EIJob, b: EIJob) => {
@@ -93,7 +118,8 @@ export class JobsListComponent implements OnInit {
   }
 
   isDataIncluding(data: string, filter: string): boolean {
-    return !filter || data.toLowerCase().includes(filter);
+    const transformedFilter = filter.trim().toLowerCase();
+    return data.toLowerCase().includes(transformedFilter);
   }
 
   getJobTypeId(eiJob: EIJob): string {
@@ -110,11 +136,21 @@ export class JobsListComponent implements OnInit {
     return '< No owner >';
   }
 
-  refresh() {
-    this.eiJobsDataSource.loadJobs();
+  public jobs(): EIJob[] {
+    return this.jobsSubject.value;
+  }
 
-    this.eiJobsDataSource.eiJobsSubject().subscribe((data) => {
-      this.jobsDataSource.data = data;
+  loadJobs() {
+    this.loadingSubject.next(true);
+    let jobs = [];
+    this.eiSvc.getProducerIds().pipe(
+      mergeMap(prodIds =>
+        forkJoin(prodIds.map(id => this.eiSvc.getJobsForProducer(id)))),
+      mergeMap(result => result),
+      finalize(() => this.loadingSubject.next(false))
+    ).subscribe(result => {
+      jobs = jobs.concat(result);
+      this.jobsSubject.next(jobs);
     });
   }