fix(saved-pipelines): open pipeline in correct namespace COMPASS-5871 (#3150)

Author: mabaasit

packages/compass-aggregations/src/components/aggregations/aggregations.jsx

@@ -50,7 +50,7 @@ import { setIsModified } from '../../modules/is-modified';
 import {
   newPipelineFromPaste,
   restoreSavedPipeline,
-  getPipelineFromIndexedDB
+  openPipelineById
 } from '../../modules/index';
 import {
   restorePipelineModalToggle,
@@ -206,7 +206,7 @@ const MappedAggregations = connect(
     createNew,
     confirmNew,
     openLink,
-    getPipelineFromIndexedDB,
+    openPipelineById,
     applySettings,
     setIsModified,
     limitChanged,

packages/compass-aggregations/src/components/pipeline/modals/restore-pipeline-modal.jsx

@@ -12,7 +12,7 @@ class RestorePipelineModal extends Component {
 
   static propTypes = {
     restorePipelineModalToggle: PropTypes.func.isRequired,
-    getPipelineFromIndexedDB: PropTypes.func.isRequired,
+    openPipelineById: PropTypes.func.isRequired,
     restorePipeline: PropTypes.object.isRequired
   }
 
@@ -24,7 +24,7 @@ class RestorePipelineModal extends Component {
   openPipeline = () => {
     const id = this.props.restorePipeline.pipelineObjectID;
     track('Aggregation Opened', { id, screen: 'aggregations' });
-    this.props.getPipelineFromIndexedDB(id);
+    this.props.openPipelineById(id);
   }
 
   /**

packages/compass-aggregations/src/components/pipeline/pipeline.jsx

@@ -35,7 +35,7 @@ class Pipeline extends PureComponent {
     allowWrites: PropTypes.bool.isRequired,
     env: PropTypes.string.isRequired,
     isAtlasDeployed: PropTypes.bool.isRequired,
-    getPipelineFromIndexedDB: PropTypes.func.isRequired,
+    openPipelineById: PropTypes.func.isRequired,
     savedPipelinesListToggle: PropTypes.func.isRequired,
     getSavedPipelines: PropTypes.func.isRequired,
     toggleComments: PropTypes.func.isRequired,
@@ -162,7 +162,7 @@ class Pipeline extends PureComponent {
       return (
         <RestorePipelineModal
           restorePipelineModalToggle={this.props.restorePipelineModalToggle}
-          getPipelineFromIndexedDB={this.props.getPipelineFromIndexedDB}
+          openPipelineById={this.props.openPipelineById}
           restorePipeline={this.props.restorePipeline}
         />
       );

packages/compass-aggregations/src/modules/index.ts

@@ -711,28 +711,31 @@ export const deletePipeline = (pipelineId: string): ThunkAction<void, RootState,
 };
 
 /**
- * Get a pipeline from the db.
- *
- * @param {String} pipelineId - The id.
- *
- * @returns {Function} The thunk function.
+ * Restore pipeline by an ID
  */
-export const getPipelineFromIndexedDB = (pipelineId: string): ThunkAction<void, RootState, void, AnyAction> => {
+export const openPipelineById = (id: string): ThunkAction<void, RootState, void, AnyAction> => {
   return async (dispatch) => {
-    const file = path.join(getDirectory(), `${pipelineId}.json`);
+    const file = path.join(getDirectory(), `${id}.json`);
     try {
       const data = await fs.promises.readFile(file, 'utf8')
-      const pipe = JSON.parse(data);
-      dispatch(clearPipeline());
-      dispatch(restoreSavedPipeline(pipe));
-      dispatch(globalAppRegistryEmit('compass:aggregations:pipeline-opened'));
-      dispatch(runStage(0, true /* force execute */));
+      dispatch(openPipeline(JSON.parse(data)));
     } catch (e: unknown) {
       console.log(e);
     }
   };
 };
 
+/**
+ * Restore pipeline
+ */
+export const openPipeline = (pipeline: any): ThunkAction<void, RootState, void, AnyAction> => {
+  return (dispatch) => {
+    dispatch(clearPipeline());
+    dispatch(restoreSavedPipeline(pipeline));
+    dispatch(globalAppRegistryEmit('compass:aggregations:pipeline-opened'));
+    dispatch(runStage(0, true /* force execute */));
+  };
+}
 
 /**
  * Make view pipeline.

packages/compass-aggregations/src/stores/store.js

@@ -1,7 +1,7 @@
 /* eslint complexity: 0 */
 import { createStore, applyMiddleware } from 'redux';
 import thunk from 'redux-thunk';
-import reducer, { getPipelineFromIndexedDB } from '../modules';
+import reducer, { openPipeline } from '../modules';
 import toNS from 'mongodb-ns';
 import { namespaceChanged } from '../modules/namespace';
 import { dataServiceConnected } from '../modules/data-service';
@@ -304,7 +304,7 @@ const configureStore = (options = {}) => {
   }
 
   if (options.aggregation) {
-    getPipelineFromIndexedDB(options.aggregation.id)(store.dispatch);
+    openPipeline(options.aggregation)(store.dispatch);
   }
 
   if (options.isDataLake) {

packages/compass-saved-aggregations-queries/src/stores/open-item.ts

@@ -237,11 +237,22 @@ const openItem =
       }
     );
 
-    appRegistry.emit('open-namespace-in-new-tab', {
+    const emitData = {
       ...metadata,
-      aggregation: item.type === 'aggregation' ? item.aggregation : null,
-      query: item.type === 'query' ? item.query : null,
-    });
+      [item.type]:
+        item.type === 'aggregation'
+          ? {
+              ...item.aggregation,
+              namespace: metadata.namespace,
+            }
+          : {
+              ...item.query,
+              _ns: metadata.namespace,
+              ns: metadata.namespace,
+            },
+    };
+
+    appRegistry.emit('open-namespace-in-new-tab', emitData);
   };
 
 export const openSavedItem =