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

Revert to getFirstCompletedRemoteData but check if payload has completed

Browse Source
This commit is contained in:
Nathan Buckingham
2022-05-06 14:03:14 -04:00
parent cb1b7ceb0a
commit 79bf27c659
1 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/app/shared/rss-feed/rss.component.ts
View File

@@ -9,7 +9,7 @@ import { BehaviorSubject, Observable, Subscription } from 'rxjs';
import { GroupDataService } from '../../core/eperson/group-data.service';
import { LinkHeadService } from '../../core/services/link-head.service';
import { ConfigurationDataService } from '../../core/data/configuration-data.service';
import { getFirstSucceededRemoteDataWithNotEmptyPayload } from '../../core/shared/operators';
import { getFirstCompletedRemoteData } from '../../core/shared/operators';
import { environment } from '../../../../src/environments/environment';
import { SearchConfigurationService } from '../../core/shared/search/search-configuration.service';
import { SortOptions } from '../../core/cache/models/sort-options.model';
@@ -17,6 +17,7 @@ import { PaginationService } from '../../core/pagination/pagination.service';
import { Router } from '@angular/router';
import { map, switchMap } from 'rxjs/operators';
import { PaginatedSearchOptions } from '../search/models/paginated-search-options.model';
import { RemoteData } from '../../core/data/remote-data';
/**
@@ -67,20 +68,30 @@ export class RSSComponent implements OnInit, OnDestroy {
this.configuration$ = this.searchConfigurationService.getCurrentConfiguration('default');
this.subs.push(this.configurationService.findByPropertyName('websvc.opensearch.enable').pipe(
getFirstSucceededRemoteDataWithNotEmptyPayload(),
getFirstCompletedRemoteData(),
).subscribe((result) => {
const enabled = (result.values[0] === 'true');
this.isEnabled$.next(enabled);
if (result.hasSucceeded) {
const enabled = (result.payload.values[0] === 'true');
this.isEnabled$.next(enabled);
}
}));
this.subs.push(this.configurationService.findByPropertyName('websvc.opensearch.svccontext').pipe(
getFirstSucceededRemoteDataWithNotEmptyPayload(),
map((result) => result.values[0]),
switchMap((openSearchUri: string) =>
getFirstCompletedRemoteData(),
map((result: RemoteData<any>) => {
if (result.hasSucceeded) {
return result.payload.values[0];
}
return null;
}),
switchMap((openSearchUri: string) =>
this.searchConfigurationService.paginatedSearchOptions.pipe(
map((searchOptions: PaginatedSearchOptions) => ({ openSearchUri, searchOptions }))
)
),
).subscribe(({ openSearchUri, searchOptions }) => {
if (!openSearchUri) {
return null;
}
this.uuid = this.groupDataService.getUUIDFromString(this.router.url);
const route = environment.rest.baseUrl + this.formulateRoute(this.uuid, openSearchUri, searchOptions.sort, searchOptions.query);
this.addLinks(route);