fix processes async requests (#475)

GeoNode · Aug 27, 2021 · 437b5eb · 437b5eb
1 parent 4fc5e28
commit 437b5eb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/geonode_mapstore_client/client/js/epics/resourceservice.js b/geonode_mapstore_client/client/js/epics/resourceservice.js
@@ -66,7 +66,8 @@ const processAPI = {
 
 export const gnProcessResources = (action$) =>
     action$.ofType(PROCESS_RESOURCES)
-        .switchMap((action) => {
+        // all the processes must be listened for this reason we should use flatMap instead of switchMap
+        .flatMap((action) => {
             return Observable.defer(() => axios.all(
                 action.resources.map(resource =>
                     processAPI[action.processType](resource)

diff --git a/geonode_mapstore_client/client/js/utils/LocalStorageUtils.js b/geonode_mapstore_client/client/js/utils/LocalStorageUtils.js
@@ -13,7 +13,7 @@ const LOCAL_STORAGE_PROCESSES_KEY = 'gn.reducers.resourceservice.processes';
 export function getLocalStorageProcesses() {
     try {
         const processes = JSON.parse(localStorage.getItem(LOCAL_STORAGE_PROCESSES_KEY)) || [];
-        return processes.filter(({ completed, output }) => !(completed || output?.status === ProcessStatus.FINISHED || output?.status === ProcessStatus.FAILED));
+        return processes.filter(({ completed, output }) => !(completed || !output || output?.status === ProcessStatus.FINISHED || output?.status === ProcessStatus.FAILED));
     } catch (e) {
         return [];
     }