hazza/dspace-angular
1
0
Fork 1
mirror of https://github.com/DSpace/dspace-angular.git synced 2025-10-07 01:54:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Removed nested subscribe

Browse Source
This commit is contained in:
Giuseppe Digilio
2021-01-15 15:20:47 +01:00
parent 00153fa92f
commit 31045ff156
2 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/app/core/data/comcol-data.service.spec.ts
View File

@@ -207,12 +207,12 @@ describe('ComColDataService', () => {
it('top level community cache refreshed', () => {
scheduler.schedule(() => (service as any).refreshCache(data));
scheduler.flush();
expect(requestService.removeByHrefSubstring).toHaveBeenCalledWith('https://rest.api/core/communities/search/top');
expect(requestService.setStaleByHrefSubstring).toHaveBeenCalledWith('https://rest.api/core/communities/search/top');
});
it('top level community without parent link, cache not refreshed', () => {
scheduler.schedule(() => (service as any).refreshCache(communityWithoutParentHref));
scheduler.flush();
expect(requestService.removeByHrefSubstring).not.toHaveBeenCalled();
expect(requestService.setStaleByHrefSubstring).not.toHaveBeenCalled();
});
});
@@ -245,7 +245,7 @@ describe('ComColDataService', () => {
it('child level community cache refreshed', () => {
scheduler.schedule(() => (service as any).refreshCache(data));
scheduler.flush();
expect(requestService.removeByHrefSubstring).toHaveBeenCalledWith('a20da287-e174-466a-9926-f66as300d399');
expect(requestService.setStaleByHrefSubstring).toHaveBeenCalledWith('a20da287-e174-466a-9926-f66as300d399');
});
});
});

17
src/app/core/data/comcol-data.service.ts
View File

@@ -1,5 +1,5 @@
import { distinctUntilChanged, filter, map, switchMap, take, tap } from 'rxjs/operators';
import { Observable } from 'rxjs';
import { combineLatest as observableCombineLatest, Observable } from 'rxjs';
import { hasValue, isEmpty, isNotEmpty } from '../../shared/empty.util';
import { ObjectCacheService } from '../cache/object-cache.service';
import { Community } from '../shared/community.model';
@@ -116,15 +116,16 @@ export abstract class ComColDataService<T extends Community | Collection> extend
if (!hasValue(parentCommunityUrl)) {
return;
}
this.findByHref(parentCommunityUrl).pipe(
getFirstCompletedRemoteData(),
).subscribe((rd: RemoteData<any>) => {
observableCombineLatest([
this.findByHref(parentCommunityUrl).pipe(
getFirstCompletedRemoteData(),
),
this.halService.getEndpoint('communities/search/top').pipe(take(1))
]).subscribe(([rd, topHref]: [RemoteData<any>, string]) => {
if (rd.hasSucceeded && isNotEmpty(rd.payload) && isNotEmpty(rd.payload.id)) {
this.requestService.removeByHrefSubstring(rd.payload.id);
this.requestService.setStaleByHrefSubstring(rd.payload.id);
} else {
this.halService.getEndpoint('communities/search/top')
.pipe(take(1))
.subscribe((href) => this.requestService.removeByHrefSubstring(href));
this.requestService.setStaleByHrefSubstring(topHref);
}
});
}