import { ResourceKind } from 'models/resource';
import { ContainerRequestResource } from 'models/container-request';
import { progressIndicatorActions } from 'store/progress-indicator/progress-indicator-actions';
+import { dataExplorerActions } from 'store/data-explorer/data-explorer-action';
export class SearchResultsMiddlewareService extends DataExplorerMiddlewareService {
- constructor(private services: ServiceRepository, id: string) {
+ constructor(private services: ServiceRepository, id: string, private responseMap: Record<string, number> = {}) {
super(id);
}
const searchValue = state.searchBar.searchValue;
const { cluster: clusterId } = getAdvancedDataFromQuery(searchValue);
const sessions = getSearchSessions(clusterId, state.auth.sessions);
+ const recentQueries = this.services.searchService.getRecentQueries();
+ //the last query is compared to the current query to check if the value has changed
+ //once the search button is clicked, the value is pushed to the recentQueries array
+ //therefore, the last query is the second to last element in the array
+ const lastQuery = recentQueries[recentQueries.length - 2];
if (searchValue.trim() === '') {
return;
const numberOfSessions = sessions.length;
let numberOfResolvedResponses = 0;
+ let totalNumItemsAvailable = 0;
api.dispatch(progressIndicatorActions.START_WORKING(this.id))
+ api.dispatch(dataExplorerActions.SET_IS_NOT_FOUND({ id: this.id, isNotFound: false }));
+
+ //In SearchResultsPanel, if we don't reset the items available, the items available will
+ //will be added to the previous value every time the 'load more' button is clicked.
+ api.dispatch(resetItemsAvailable());
sessions.forEach(session => {
const params = getParams(dataExplorer, searchValue, session.apiRevision);
this.services.groupsService.contents('', params, session)
.then((response) => {
+ //if items were added or deleted, we ignore them for "load more" button purposes
+ if (lastQuery === searchValue && this.responseMap[session.clusterId] && this.responseMap[session.clusterId] !== response.itemsAvailable) {
+ response.itemsAvailable = this.responseMap[session.clusterId];
+ }
+ this.responseMap[session.clusterId] = response.itemsAvailable;
api.dispatch(updateResources(response.items));
api.dispatch(appendItems(response));
numberOfResolvedResponses++;
+ totalNumItemsAvailable += response.itemsAvailable;
if (numberOfResolvedResponses === numberOfSessions) {
api.dispatch(progressIndicatorActions.STOP_WORKING(this.id))
+ if(totalNumItemsAvailable === 0) api.dispatch(dataExplorerActions.SET_IS_NOT_FOUND({ id: this.id, isNotFound: true }))
}
// Request all containers for process status to be available
const containerRequests = response.items.filter((item) => item.kind === ResourceKind.CONTAINER_REQUEST) as ContainerRequestResource[];
items: listResults.items.map(resource => resource.uuid),
});
+export const resetItemsAvailable = () =>
+ searchResultsPanelActions.RESET_ITEMS_AVAILABLE();
+
export const appendItems = (listResults: ListResults<GroupContentsResource>) =>
searchResultsPanelActions.APPEND_ITEMS({
...listResultsToDataExplorerItemsMeta(listResults),