X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=inline;f=webapp-frontend%2Fsrc%2Fapp%2Fei-coordinator%2Fei-job.datasource.ts;h=072762594ca2165efe84bd201431375be89f71a5;hb=62697dfde02c5fb5ded820ddfab89d8e4080479e;hp=27a70c4f5e2ce6f771b8f76fea892a30f2f8c855;hpb=b4bb55e832f97270e71f1afc8321aa2899b55b5d;p=portal%2Fnonrtric-controlpanel.git diff --git a/webapp-frontend/src/app/ei-coordinator/ei-job.datasource.ts b/webapp-frontend/src/app/ei-coordinator/ei-job.datasource.ts index 27a70c4..0727625 100644 --- a/webapp-frontend/src/app/ei-coordinator/ei-job.datasource.ts +++ b/webapp-frontend/src/app/ei-coordinator/ei-job.datasource.ts @@ -24,6 +24,10 @@ import { BehaviorSubject } from 'rxjs/BehaviorSubject'; import { EIJob } from '../interfaces/ei.types'; import { EIService } from '../services/ei/ei.service'; +import { MatTableDataSource } from '@angular/material'; +import { ViewChild } from '@angular/core'; +import { MatSort } from '@angular/material/sort'; +import { delay } from 'rxjs/operators'; @Injectable({ providedIn: 'root' @@ -32,9 +36,12 @@ import { EIService } from '../services/ei/ei.service'; export class EIJobDataSource { private jobs: Array = []; + private dataSource: MatTableDataSource = new MatTableDataSource(); + @ViewChild(MatSort, { static: true }) sort: MatSort; - public eiJobs(): EIJob[] { - return this.jobs; + + public jobsDataSource(): MatTableDataSource { + return this.dataSource; } private loadingSubject = new BehaviorSubject(false); @@ -55,14 +62,21 @@ export class EIJobDataSource { producerIds.forEach(id => { this.getJobsForProducer(id); }); + //this.dataSource = new MatTableDataSource(); + this.dataSource.data = this.jobs; + this.dataSource.sort = this.sort; + console.log("datasource: "+this.dataSource.data); }); this.rowCount = this.jobs.length; } private getJobsForProducer(id: string) { console.log('Getting jobs for producer ID: ', id); - this.eiSvc.getJobsForProducer(id).subscribe(producerJobs => { - this.jobs = this.jobs.concat(producerJobs); + this.eiSvc.getJobsForProducer(id)//.pipe(delay(5000)) + .subscribe(producerJobs => { + this.jobs = this.jobs.concat(producerJobs); + console.log("producerJobs: "+producerJobs); + }); } }