Implement feedback

src/app/access-control/epeople-registry/epeople-registry.component.spec.ts

@@ -25,10 +25,8 @@ import { NotificationsServiceStub } from '../../shared/testing/notifications-ser
 import { RouterStub } from '../../shared/testing/router.stub';
 import { AuthorizationDataService } from '../../core/data/feature-authorization/authorization-data.service';
 import { RequestService } from '../../core/data/request.service';
-import { PaginationComponentOptions } from '../../../shared/pagination/pagination-component-options.model';
+import { PaginationService } from '../../core/pagination/pagination.service';
-import { SortDirection, SortOptions } from '../../../core/cache/models/sort-options.model';
+import { PaginationServiceStub } from '../../shared/testing/pagination-service.stub';
-import { PaginationService } from '../../../core/pagination/pagination.service';
-import { PaginationServiceStub } from '../../../shared/testing/pagination-service.stub';
 
 describe('EPeopleRegistryComponent', () => {
   let component: EPeopleRegistryComponent;

src/app/access-control/epeople-registry/epeople-registry.component.ts

@@ -20,7 +20,7 @@ import { NgbModal } from '@ng-bootstrap/ng-bootstrap';
 import { RequestService } from '../../core/data/request.service';
 import { PageInfo } from '../../core/shared/page-info.model';
 import { NoContent } from '../../core/shared/NoContent.model';
-import { PaginationService } from '../../../core/pagination/pagination.service';
+import { PaginationService } from '../../core/pagination/pagination.service';
 
 @Component({
   selector: 'ds-epeople-registry',
@@ -157,14 +157,14 @@ export class EPeopleRegistryComponent implements OnInit, OnDestroy {
           const query: string = data.query;
           const scope: string = data.scope;
           if (query != null && this.currentSearchQuery !== query) {
-            this.router.navigate(this.epersonService.getEPeoplePageRouterLink(), {
+            this.router.navigate([this.epersonService.getEPeoplePageRouterLink()], {
               queryParamsHandling: 'merge'
             });
             this.currentSearchQuery = query;
             this.paginationService.resetPage(this.config.id);
           }
           if (scope != null && this.currentSearchScope !== scope) {
-            this.router.navigate(this.epersonService.getEPeoplePageRouterLink(), {
+            this.router.navigate([this.epersonService.getEPeoplePageRouterLink()], {
               queryParamsHandling: 'merge'
             });
             this.currentSearchScope = scope;

src/app/access-control/epeople-registry/eperson-form/eperson-form.component.spec.ts

@@ -26,10 +26,8 @@ import { AuthorizationDataService } from '../../../core/data/feature-authorizati
 import { GroupDataService } from '../../../core/eperson/group-data.service';
 import { createPaginatedList } from '../../../shared/testing/utils.test';
 import { RequestService } from '../../../core/data/request.service';
-import { PaginationComponentOptions } from '../../../../shared/pagination/pagination-component-options.model';
+import { PaginationService } from '../../../core/pagination/pagination.service';
-import { SortDirection, SortOptions } from '../../../../core/cache/models/sort-options.model';
+import { PaginationServiceStub } from '../../../shared/testing/pagination-service.stub';
-import { PaginationService } from '../../../../core/pagination/pagination.service';
-import { PaginationServiceStub } from '../../../../shared/testing/pagination-service.stub';
 
 describe('EPersonFormComponent', () => {
   let component: EPersonFormComponent;

src/app/access-control/epeople-registry/eperson-form/eperson-form.component.ts

@@ -31,7 +31,7 @@ import { ConfirmationModalComponent } from '../../../shared/confirmation-modal/c
 import { NgbModal } from '@ng-bootstrap/ng-bootstrap';
 import { RequestService } from '../../../core/data/request.service';
 import { NoContent } from '../../../core/shared/NoContent.model';
-import { PaginationService } from '../../../../core/pagination/pagination.service';
+import { PaginationService } from '../../../core/pagination/pagination.service';
 
 @Component({
   selector: 'ds-eperson-form',

src/app/access-control/group-registry/group-form/members-list/members-list.component.spec.ts

@@ -26,11 +26,8 @@ import { getMockFormBuilderService } from '../../../../shared/mocks/form-builder
 import { TranslateLoaderMock } from '../../../../shared/testing/translate-loader.mock';
 import { NotificationsServiceStub } from '../../../../shared/testing/notifications-service.stub';
 import { RouterMock } from '../../../../shared/mocks/router.mock';
-import { PaginationComponentOptions } from '../../../../../shared/pagination/pagination-component-options.model';
+import { PaginationService } from '../../../../core/pagination/pagination.service';
-import { SortDirection, SortOptions } from '../../../../../core/cache/models/sort-options.model';
+import { PaginationServiceStub } from '../../../../shared/testing/pagination-service.stub';
-import { FindListOptions } from '../../../../../core/data/request.models';
-import { PaginationService } from '../../../../../core/pagination/pagination.service';
-import { PaginationServiceStub } from '../../../../../shared/testing/pagination-service.stub';
 
 describe('MembersListComponent', () => {
   let component: MembersListComponent;

src/app/access-control/group-registry/group-form/members-list/members-list.component.ts

@@ -23,8 +23,8 @@ import {
 } from '../../../../core/shared/operators';
 import { NotificationsService } from '../../../../shared/notifications/notifications.service';
 import { PaginationComponentOptions } from '../../../../shared/pagination/pagination-component-options.model';
-import { PaginationService } from '../../../../../core/pagination/pagination.service';
 import {EpersonDtoModel} from '../../../../core/eperson/models/eperson-dto.model';
+import { PaginationService } from '../../../../core/pagination/pagination.service';
 
 /**
  * Keys to keep track of specific subscriptions

src/app/access-control/group-registry/group-form/subgroup-list/subgroups-list.component.spec.ts

@@ -35,11 +35,8 @@ import { getMockTranslateService } from '../../../../shared/mocks/translate.serv
 import { TranslateLoaderMock } from '../../../../shared/testing/translate-loader.mock';
 import { NotificationsServiceStub } from '../../../../shared/testing/notifications-service.stub';
 import { map } from 'rxjs/operators';
-import { PaginationComponentOptions } from '../../../../../shared/pagination/pagination-component-options.model';
+import { PaginationService } from '../../../../core/pagination/pagination.service';
-import { SortDirection, SortOptions } from '../../../../../core/cache/models/sort-options.model';
+import { PaginationServiceStub } from '../../../../shared/testing/pagination-service.stub';
-import { FindListOptions } from '../../../../../core/data/request.models';
-import { PaginationService } from '../../../../../core/pagination/pagination.service';
-import { PaginationServiceStub } from '../../../../../shared/testing/pagination-service.stub';
 
 describe('SubgroupsListComponent', () => {
   let component: SubgroupsListComponent;

src/app/access-control/group-registry/group-form/subgroup-list/subgroups-list.component.ts

@@ -16,7 +16,7 @@ import {
 import { NotificationsService } from '../../../../shared/notifications/notifications.service';
 import { PaginationComponentOptions } from '../../../../shared/pagination/pagination-component-options.model';
 import { NoContent } from '../../../../core/shared/NoContent.model';
-import { PaginationService } from '../../../../../core/pagination/pagination.service';
+import { PaginationService } from '../../../../core/pagination/pagination.service';
 
 /**
  * Keys to keep track of specific subscriptions

src/app/access-control/group-registry/groups-registry.component.spec.ts

@@ -28,11 +28,8 @@ import { TranslateLoaderMock } from '../../shared/testing/translate-loader.mock'
 import { NotificationsServiceStub } from '../../shared/testing/notifications-service.stub';
 import { routeServiceStub } from '../../shared/testing/route-service.stub';
 import { RouterMock } from '../../shared/mocks/router.mock';
-import { PaginationComponentOptions } from '../../../shared/pagination/pagination-component-options.model';
+import { PaginationService } from '../../core/pagination/pagination.service';
-import { SortDirection, SortOptions } from '../../../core/cache/models/sort-options.model';
+import { PaginationServiceStub } from '../../shared/testing/pagination-service.stub';
-import { FindListOptions } from '../../../core/data/request.models';
-import { PaginationService } from '../../../core/pagination/pagination.service';
-import { PaginationServiceStub } from '../../../shared/testing/pagination-service.stub';
 
 describe('GroupRegistryComponent', () => {
   let component: GroupsRegistryComponent;

src/app/access-control/group-registry/groups-registry.component.ts

@@ -34,7 +34,7 @@ import { hasValue } from '../../shared/empty.util';
 import { NotificationsService } from '../../shared/notifications/notifications.service';
 import { PaginationComponentOptions } from '../../shared/pagination/pagination-component-options.model';
 import { NoContent } from '../../core/shared/NoContent.model';
-import { PaginationService } from '../../../core/pagination/pagination.service';
+import { PaginationService } from '../../core/pagination/pagination.service';
 
 @Component({
   selector: 'ds-groups-registry',

src/app/core/pagination/pagination.service.ts

@@ -18,10 +18,10 @@ import { isNumeric } from 'rxjs/internal-compatibility';
  * Service to manage the pagination of different components
  * The pagination information will be stored in the route based on a paginationID.
  * The following params are used for the different kind of pagination information:
- *    - For the page: p.{paginationID}
+ *    - For the page: {paginationID}.p
- *    - For the page size: rpp.{paginationID}
+ *    - For the page size: {paginationID}.rpp
- *    - For the sort direction: sd.{paginationID}
+ *    - For the sort direction: {paginationID}.sd
- *    - For the sort field: sf.{paginationID}
+ *    - For the sort field: {paginationID}.sf
  */
 export class PaginationService {
 
@@ -145,7 +145,6 @@ export class PaginationService {
       if (isNotEmpty(difference(parametersWithIdName, currentParametersWithIdName)) || isNotEmpty(extraParams) || isNotEmpty(this.clearParams)) {
         const queryParams = Object.assign({}, this.clearParams, currentParametersWithIdName,
           parametersWithIdName, extraParams);
-        console.log(queryParams, this.clearParams);
         if (retainScrollPosition) {
           this.router.navigate(url, {
             queryParams: queryParams,
@@ -159,7 +158,6 @@ export class PaginationService {
           });
         }
         this.clearParams = {};
-        console.log('postcear', this.clearParams);
       }
     });
   }

src/app/shared/pagination/pagination.component.spec.ts

@@ -127,7 +127,8 @@ describe('Pagination component', () => {
   // waitForAsync beforeEach
   beforeEach(waitForAsync(() => {
     activatedRouteStub = new MockActivatedRoute();
-    routerStub = new RouterMock();                      hostWindowServiceStub = new HostWindowServiceMock(_initialState.width);
+    routerStub = new RouterMock();
+    hostWindowServiceStub = new HostWindowServiceMock(_initialState.width);
 
     currentPagination = new BehaviorSubject<PaginationComponentOptions>(pagination);
     currentSort = new BehaviorSubject<SortOptions>(sort);

src/app/shared/resource-policies/form/eperson-group-list/eperson-group-list.component.ts

@@ -186,7 +186,9 @@ export class EpersonGroupListComponent implements OnInit, OnDestroy {
 
     this.subs.push(search$.pipe(getFirstCompletedRemoteData())
       .subscribe((list: RemoteData<PaginatedList<DSpaceObject>>) => {
+        if (hasValue(this.list$)) {
           this.list$.next(list);
+        }
       })
     );
       });

src/app/shared/search-form/search-form.component.ts

@@ -95,7 +95,8 @@ export class SearchFormComponent {
    */
   updateSearch(data: any) {
       const queryParams =  Object.assign({}, data);
-      queryParams[`page.${this.searchConfig.paginationID}`] = 1;
+      const pageParam = this.paginationService.getPageParam(this.searchConfig.paginationID);
+      queryParams[pageParam] = 1;
 
       this.router.navigate(this.getSearchLinkParts(), {
       queryParams: queryParams,

src/app/shared/search/search-filters/search-filter/search-facet-filter-options/search-facet-option/search-facet-option.component.spec.ts

@@ -140,7 +140,7 @@ describe('SearchFacetOptionComponent', () => {
       (comp as any).updateAddParams(selectedValues);
       expect(comp.addQueryParams).toEqual({
         [mockFilterConfig.paramName]: [`${value1},${operator}`, value.value + ',equals'],
-        ['page.page-id']: 1
+        ['page-id.page']: 1
       });
     });
   });
@@ -155,7 +155,7 @@ describe('SearchFacetOptionComponent', () => {
       (comp as any).updateAddParams(selectedValues);
       expect(comp.addQueryParams).toEqual({
         [mockAuthorityFilterConfig.paramName]: [value1 + ',equals', `${value2},${operator}`],
-        ['page.page-id']: 1
+        ['page-id.page']: 1
       });
     });
   });

src/app/shared/search/search-filters/search-filter/search-facet-filter-options/search-facet-range-option/search-facet-range-option.component.spec.ts

@@ -126,7 +126,7 @@ describe('SearchFacetRangeOptionComponent', () => {
       expect(comp.changeQueryParams).toEqual({
         [mockFilterConfig.paramName + RANGE_FILTER_MIN_SUFFIX]: ['50'],
         [mockFilterConfig.paramName + RANGE_FILTER_MAX_SUFFIX]: ['60'],
-        ['page.page-id']: 1
+        ['page-id.page']: 1
       });
     });
   });

src/app/shared/search/search-filters/search-filter/search-facet-filter-options/search-facet-selected-option/search-facet-selected-option.component.spec.ts

@@ -165,7 +165,7 @@ describe('SearchFacetSelectedOptionComponent', () => {
       (comp as any).updateRemoveParams(selectedValues);
       expect(comp.removeQueryParams).toEqual({
         [mockFilterConfig.paramName]: [value1],
-        ['page.page-id']: 1
+        ['page-id.page']: 1
       });
     });
   });
@@ -181,7 +181,7 @@ describe('SearchFacetSelectedOptionComponent', () => {
       (comp as any).updateRemoveParams(selectedAuthorityValues);
       expect(comp.removeQueryParams).toEqual({
         [mockAuthorityFilterConfig.paramName]: [`${value1},${operator}`],
-        ['page.page-id']: 1
+        ['page-id.page']: 1
       });
     });
   });

src/app/shared/testing/pagination-service.stub.ts

@@ -20,6 +20,6 @@ export class PaginationServiceStub {
   updateRouteWithUrl = jasmine.createSpy('updateRouteWithUrl');
   clearPagination = jasmine.createSpy('clearPagination');
   getRouteParameterValue = jasmine.createSpy('getRouteParameterValue').and.returnValue(observableOf(''));
-  getPageParam = jasmine.createSpy('getPageParam').and.returnValue(`page.${this.pagination.id}`);
+  getPageParam = jasmine.createSpy('getPageParam').and.returnValue(`${this.pagination.id}.page`);
 
 }

src/app/submission/import-external/import-external-searchbar/submission-import-external-searchbar.component.ts

@@ -18,7 +18,7 @@ import { RemoteData } from '../../../core/data/remote-data';
 import { PageInfo } from '../../../core/shared/page-info.model';
 import { createSuccessfulRemoteDataObject } from '../../../shared/remote-data.utils';
 import { FindListOptions } from '../../../core/data/request.models';
-import { getFirstSucceededRemoteDataPayload } from '../../../core/shared/operators';
+import { getFirstSucceededRemoteData, getFirstSucceededRemoteDataPayload } from '../../../core/shared/operators';
 import { HostWindowService } from '../../../shared/host-window.service';
 import { hasValue } from '../../../shared/empty.util';
 
@@ -124,7 +124,7 @@ export class SubmissionImportExternalSearchbarComponent implements OnInit, OnDes
         const paginatedListRD = createSuccessfulRemoteDataObject(paginatedList);
         return observableOf(paginatedListRD);
       }),
-      getFirstSucceededRemoteDataPayload()
+      getFirstSucceededRemoteDataPayload(),
     ).subscribe((externalSource: PaginatedList<ExternalSource>) => {
       externalSource.page.forEach((element) => {
         this.sourceList.push({ id: element.id, name: element.name });
@@ -166,6 +166,7 @@ export class SubmissionImportExternalSearchbarComponent implements OnInit, OnDes
           const paginatedListRD = createSuccessfulRemoteDataObject(paginatedList);
           return observableOf(paginatedListRD);
         }),
+        getFirstSucceededRemoteData(),
         tap(() => this.sourceListLoading = false)
       ).subscribe((externalSource: RemoteData<PaginatedList<ExternalSource>>) => {
         externalSource.payload.page.forEach((element) => {

src/app/submission/import-external/submission-import-external.component.ts

@@ -2,7 +2,7 @@ import { Component, OnDestroy, OnInit } from '@angular/core';
 import { Router } from '@angular/router';
 
 import { BehaviorSubject, combineLatest, Subscription } from 'rxjs';
-import { filter, mergeMap, switchMap, take } from 'rxjs/operators';
+import { filter, mergeMap, switchMap, take, tap } from 'rxjs/operators';
 import { NgbModal, NgbModalRef } from '@ng-bootstrap/ng-bootstrap';
 
 import { ExternalSourceService } from '../../core/data/external-source.service';
@@ -45,7 +45,10 @@ export class SubmissionImportExternalComponent implements OnInit, OnDestroy {
    */
   public isLoading$: BehaviorSubject<boolean> = new BehaviorSubject<boolean>(false);
 
-  public reload$: BehaviorSubject<{query: string, source: string}> = new BehaviorSubject<{query: string; source: string}>({query: '', source: ''});
+  public reload$: BehaviorSubject<{ query: string, source: string }> = new BehaviorSubject<{ query: string; source: string }>({
+    query: '',
+    source: ''
+  });
   /**
    * Configuration to use for the import buttons
    */
@@ -83,6 +86,8 @@ export class SubmissionImportExternalComponent implements OnInit, OnDestroy {
    */
   protected subs: Subscription[] = [];
 
+  private retrieveExternalSourcesSub: Subscription;
+
   /**
    * Initialize the component variables.
    * @param {SearchConfigurationService} searchConfigService
@@ -136,7 +141,10 @@ export class SubmissionImportExternalComponent implements OnInit, OnDestroy {
         queryParams: {source: event.sourceId, query: event.query},
         replaceUrl: true
       }
-    ).then(() => this.reload$.next({source: event.sourceId, query: event.query}));
+    ).then(() => {
+      this.reload$.next({source: event.sourceId, query: event.query});
+      this.retrieveExternalSources();
+    });
   }
 
   /**
@@ -158,6 +166,10 @@ export class SubmissionImportExternalComponent implements OnInit, OnDestroy {
     this.subs
       .filter((sub) => hasValue(sub))
       .forEach((sub) => sub.unsubscribe());
+    if (hasValue(this.retrieveExternalSourcesSub)) {
+      this.retrieveExternalSourcesSub.unsubscribe();
+    }
+
   }
 
   /**
@@ -167,23 +179,24 @@ export class SubmissionImportExternalComponent implements OnInit, OnDestroy {
    * @param query The query string to search
    */
   private retrieveExternalSources(): void {
-    this.reload$.pipe(
+    if (hasValue(this.retrieveExternalSourcesSub)) {
-      switchMap(
+      this.retrieveExternalSourcesSub.unsubscribe();
-        (sourceQueryObject: { source: string, query: string }) => {
+    }
+    this.retrieveExternalSourcesSub = this.reload$.pipe(
+      filter((sourceQueryObject: { source: string, query: string }) => isNotEmpty(sourceQueryObject.source) && isNotEmpty(sourceQueryObject.query)),
+      switchMap((sourceQueryObject: { source: string, query: string }) => {
           const source = sourceQueryObject.source;
           const query = sourceQueryObject.query;
-          if (isNotEmpty(source) && isNotEmpty(query)) {
           this.routeData.sourceId = source;
           this.routeData.query = query;
-            this.isLoading$.next(true);
           return this.searchConfigService.paginatedSearchOptions.pipe(
+            tap((v) => this.isLoading$.next(true)),
             filter((searchOptions) => searchOptions.query === query),
             mergeMap((searchOptions) => this.externalService.getExternalSourceEntries(this.routeData.sourceId, searchOptions).pipe(
               getFinishedRemoteData(),
             )),
           );
         }
-        }
       ),
     ).subscribe((rdData) => {
       this.entriesRD$.next(rdData);