Skip to content

Commit

Permalink
Merge branch 'feature-process_polling-7.6' into feature-process_polling
Browse files Browse the repository at this point in the history
  • Loading branch information
alexandrevryghem committed Feb 8, 2024
2 parents 359d452 + ecb20bb commit 110633c
Show file tree
Hide file tree
Showing 4 changed files with 26 additions and 14 deletions.
14 changes: 8 additions & 6 deletions src/app/core/data/processes/process-data.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -175,12 +175,14 @@ export class ProcessDataService extends IdentifiableDataService<Process> impleme
)
).subscribe((processRD: RemoteData<Process>) => {
this.clearCurrentTimeout(processId);
const nextTimeout = this.timer(() => {
this.activelyBeingPolled.delete(processId);
this.invalidateByHref(processRD.payload._links.self.href);
}, pollingIntervalInMs);

this.activelyBeingPolled.set(processId, nextTimeout);
if (processRD.hasSucceeded) {
const nextTimeout = this.timer(() => {
this.activelyBeingPolled.delete(processId);
this.invalidateByHref(processRD.payload._links.self.href);
}, pollingIntervalInMs);

this.activelyBeingPolled.set(processId, nextTimeout);
}
});

// When the process completes create a one off subscription (the `find` completes the
Expand Down
9 changes: 7 additions & 2 deletions src/app/process-page/detail/process-detail.component.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import { HttpClient } from '@angular/common/http';
import { Component, Inject, NgZone, OnInit, PLATFORM_ID } from '@angular/core';
import { ActivatedRoute, Router } from '@angular/router';
import { BehaviorSubject, Observable } from 'rxjs';
import { finalize, map, switchMap, take, tap, find, startWith } from 'rxjs/operators';
import { finalize, map, switchMap, take, tap, find, startWith, filter } from 'rxjs/operators';
import { AuthService } from '../../core/auth/auth.service';
import { DSONameService } from '../../core/breadcrumbs/dso-name.service';
import { BitstreamDataService } from '../../core/data/bitstream-data.service';
Expand Down Expand Up @@ -80,6 +80,8 @@ export class ProcessDetailComponent implements OnInit {

isRefreshing$: Observable<boolean>;

isDeleting: boolean;

/**
* Reference to NgbModal
*/
Expand Down Expand Up @@ -113,6 +115,7 @@ export class ProcessDetailComponent implements OnInit {
return [data.process as RemoteData<Process>];
}
}),
filter(() => !this.isDeleting),
redirectOn4xx(this.router, this.authService),
);

Expand Down Expand Up @@ -203,15 +206,17 @@ export class ProcessDetailComponent implements OnInit {
* @param process
*/
deleteProcess(process: Process) {
this.isDeleting = true;
this.processService.delete(process.processId).pipe(
getFirstCompletedRemoteData()
).subscribe((rd) => {
if (rd.hasSucceeded) {
this.notificationsService.success(this.translateService.get('process.detail.delete.success'));
this.closeModal();
this.router.navigateByUrl(getProcessListRoute());
void this.router.navigateByUrl(getProcessListRoute());
} else {
this.notificationsService.error(this.translateService.get('process.detail.delete.error'));
this.isDeleting = false;
}
});
}
Expand Down
10 changes: 5 additions & 5 deletions src/app/process-page/process-breadcrumb.resolver.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,9 @@ import { Process } from './processes/process.model';
import { followLink } from '../shared/utils/follow-link-config.model';
import { ProcessDataService } from '../core/data/processes/process-data.service';
import { BreadcrumbConfig } from '../breadcrumbs/breadcrumb/breadcrumb-config.model';
import { getRemoteDataPayload, getFirstSucceededRemoteData } from '../core/shared/operators';
import { getFirstCompletedRemoteData } from '../core/shared/operators';
import { ProcessBreadcrumbsService } from './process-breadcrumbs.service';
import { RemoteData } from '../core/data/remote-data';

/**
* This class represents a resolver that requests a specific process before the route is activated
Expand All @@ -28,12 +29,11 @@ export class ProcessBreadcrumbResolver implements Resolve<BreadcrumbConfig<Proce
const id = route.params.id;

return this.processService.findById(route.params.id, true, false, followLink('script')).pipe(
getFirstSucceededRemoteData(),
getRemoteDataPayload(),
map((object: Process) => {
getFirstCompletedRemoteData(),
map((object: RemoteData<Process>) => {
const fullPath = state.url;
const url = fullPath.substr(0, fullPath.indexOf(id)) + id;
return { provider: this.breadcrumbService, key: object, url: url };
return { provider: this.breadcrumbService, key: object.payload, url: url };
})
);
}
Expand Down
7 changes: 6 additions & 1 deletion src/app/process-page/process-breadcrumbs.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ import { Injectable } from '@angular/core';
import { BreadcrumbsProviderService } from '../core/breadcrumbs/breadcrumbsProviderService';
import { Breadcrumb } from '../breadcrumbs/breadcrumb/breadcrumb.model';
import { Process } from './processes/process.model';
import { hasValue } from '../shared/empty.util';

/**
* Service to calculate process breadcrumbs for a single part of the route
Expand All @@ -16,6 +17,10 @@ export class ProcessBreadcrumbsService implements BreadcrumbsProviderService<Pro
* @param url The url to use as a link for this breadcrumb
*/
getBreadcrumbs(key: Process, url: string): Observable<Breadcrumb[]> {
return observableOf([new Breadcrumb(key.processId + ' - ' + key.scriptName, url)]);
if (hasValue(key)) {
return observableOf([new Breadcrumb(key.processId + ' - ' + key.scriptName, url)]);
} else {
return observableOf([]);
}
}
}

0 comments on commit 110633c

Please sign in to comment.