Extending stateful URLS with node filters and Expanding/collapsing modular pipelines flag

RELEASE.md

@@ -9,6 +9,7 @@ Please follow the established format:
 
 ## Major features and improvements
 
+- Extending stateful URLs with node filters and expand/collapse modular pipelines. (#1799)
 - Introduce `--include-hooks` option and remove `--ignore-plugins` from cli commands. (#1818)
 - Add Dataset Factory Patterns to Experiment Tracking. (#1824)
 

cypress/tests/ui/experiment-tracking/experiment-tracking.cy.js

@@ -198,10 +198,7 @@ describe('Experiment Tracking', () => {
       cy.get('.accordion__title--hyperlink').first().click();
 
       // Assert after action
-      cy.location('search').should(
-        'eq',
-        `?pipeline_id=__default__&selected_name=${plotNameText}`
-      );
+      cy.location('search').should('contain', `?pid=__default__&sn=${plotNameText}`);
       cy.__checkForText__(
         '.pipeline-node--selected > .pipeline-node__text',
         prettifyName(stripNamespace(plotNameText))

cypress/tests/ui/flowchart/flowchart.cy.js

@@ -190,7 +190,7 @@ describe('Flowchart DAG', () => {
     // Assert after action
     cy.get('.pipeline-warning__title')
       .should('exist')
-      .and('have.text', `Oops, there's nothing to see here`);
+      .and('include.text', `Oops, there's nothing to see here`);
   });
 
   it('verifies that users can open and see the dataset statistics in the metadata panel for datasets. #TC-51', () => {

cypress/tests/ui/flowchart/menu.cy.js

@@ -31,7 +31,7 @@ describe('Flowchart Menu', () => {
 
       cy.location('search').should((queryParams) => {
         expect(decodeURIComponent(queryParams).toLowerCase()).to.contain(
-          menuOptionValue.toLowerCase()
+          menuOptionValue.toLowerCase().replace(/ /g, '+')
         );
       });
 
@@ -170,4 +170,48 @@ describe('Flowchart Menu', () => {
       .should('have.class', 'pipeline-nodelist__row__label--faded')
       .should('have.class', 'pipeline-nodelist__row__label--disabled');
   });
+
+  it('verifies that after checking node type URL should be updated with correct query params', () => {
+    const nodeToToggleText = 'Parameters';
+
+    // Alias
+    cy.get(`.pipeline-nodelist__row__checkbox[name=${nodeToToggleText}]`).as(
+      'nodeToToggle'
+    );
+
+    // Assert before action
+    cy.get('@nodeToToggle').should('not.be.checked');
+
+    // Action
+    cy.get('@nodeToToggle').check({ force: true });
+
+    // Assert after action
+    cy.url().should('include', 'parameters');
+  });
+
+  it('Verify that if the URL contains the nodeTag query parameter, the same parameter should be reflected on the UI.', () => {
+    const visibleRowLabel = 'Companies';
+    cy.visit(`/?tags=${visibleRowLabel}`);
+
+    // Alias
+    cy.get(`.pipeline-nodelist__row__checkbox[name=${visibleRowLabel}]`).as(
+      'nodeToToggle'
+    );
+
+    // Assert
+    cy.get('@nodeToToggle').should('be.checked');
+  });
+
+  it('Verify that if the URL contains the nodeType query parameter, the same parameter should be reflected on the UI.', () => {
+    const visibleRowLabel = 'Datasets';
+    cy.visit('/?types=data');
+
+    // Alias
+    cy.get(`.pipeline-nodelist__row__checkbox[name=${visibleRowLabel}]`).as(
+      'nodeToToggle'
+    );
+
+    // Assert
+    cy.get('@nodeToToggle').should('be.checked');
+  });
 });

src/components/flowchart-wrapper/flowchart-wrapper.js

@@ -30,11 +30,13 @@ import {
   errorMessages,
   linkToFlowchartInitialVal,
   localStorageFlowchartLink,
+  localStorageName,
   params,
 } from '../../config';
 import { findMatchedPath } from '../../utils/match-path';
-import { getKeyByValue } from '../../utils/get-key-by-value';
+import { getKeyByValue, getKeysByValue } from '../../utils/object-utils';
 import { isRunningLocally } from '../../utils';
+import { useGeneratePathname } from '../../utils/hooks/use-generate-pathname';
 import './flowchart-wrapper.scss';
 
 /**
@@ -55,10 +57,12 @@ export const FlowChartWrapper = ({
   onUpdateActivePipeline,
   pipelines,
   sidebarVisible,
+  activePipeline,
 }) => {
   const history = useHistory();
   const { pathname, search } = useLocation();
   const searchParams = new URLSearchParams(search);
+  const { toSetQueryParam } = useGeneratePathname();
 
   const [errorMessage, setErrorMessage] = useState({});
   const [isInvalidUrl, setIsInvalidUrl] = useState(false);
@@ -78,6 +82,52 @@ export const FlowChartWrapper = ({
     matchedFocusedNode,
   } = findMatchedPath(pathname, search);
 
+  /**
+   * On initial load & when user switch active pipeline,
+   * sets the query params from local storage based on NodeType, tag, expandAllPipelines and active pipeline.
+   * @param {string} activePipeline - The active pipeline.
+   */
+  const setParamsFromLocalStorage = (activePipeline) => {
+    const localStorageParams = loadLocalStorage(localStorageName);
+    if (localStorageParams) {
+      const paramActions = {
+        pipeline: (value) => {
+          if (!searchParams.has(params.pipeline) && activePipeline) {
+            toSetQueryParam(params.pipeline, value.active || activePipeline);
+          }
+        },
+        tag: (value) => {
+          if (!searchParams.has(params.tags)) {
+            const enabledKeys = getKeysByValue(value.enabled, true);
+            enabledKeys && toSetQueryParam(params.tags, enabledKeys);
+          }
+        },
+        nodeType: (value) => {
+          if (!searchParams.has(params.types)) {
+            const disabledKeys = getKeysByValue(value.disabled, false);
+            disabledKeys && toSetQueryParam(params.types, disabledKeys);
+          }
+        },
+        flags: (value) => {
+          if (!searchParams.has(params.expandAll)) {
+            toSetQueryParam(params.expandAll, value.expandAllPipelines);
+          }
+        },
+      };
+
+      for (const [key, value] of Object.entries(localStorageParams)) {
+        if (paramActions[key]) {
+          paramActions[key](value);
+        }
+      }
+    }
+  };
+
+  useEffect(() => {
+    setParamsFromLocalStorage(activePipeline);
+    // eslint-disable-next-line react-hooks/exhaustive-deps
+  }, [activePipeline]);
+
   const resetErrorMessage = () => {
     setErrorMessage({});
     setIsInvalidUrl(false);
@@ -199,17 +249,17 @@ export const FlowChartWrapper = ({
         resetErrorMessage();
       }
 
-      if (matchedSelectedPipeline) {
+      if (matchedSelectedPipeline()) {
         // Redirecting to a different pipeline is also handled at `preparePipelineState`
         // to ensure the data is ready before being passed to here
         redirectSelectedPipeline();
       }
 
-      if (matchedSelectedNodeName || matchedSelectedNodeId) {
+      if (matchedSelectedNodeName() || matchedSelectedNodeId()) {
         redirectToSelectedNode();
       }
 
-      if (matchedFocusedNode) {
+      if (matchedFocusedNode()) {
         redirectToFocusedNode();
       }
 
@@ -312,6 +362,7 @@ export const mapStateToProps = (state) => ({
   modularPipelinesTree: getModularPipelinesTree(state),
   nodes: state.node.modularPipelines,
   pipelines: state.pipeline.ids,
+  activePipeline: state.pipeline.active,
   sidebarVisible: state.visible.sidebar,
 });
 

src/components/node-list/index.js

@@ -39,6 +39,7 @@ import {
 } from '../../actions/nodes';
 import { useGeneratePathname } from '../../utils/hooks/use-generate-pathname';
 import './styles/node-list.scss';
+import { params, NODE_TYPES } from '../../config';
 
 /**
  * Provides data from the store to populate a NodeList component.
@@ -68,9 +69,15 @@ const NodeListProvider = ({
   inputOutputDataNodes,
 }) => {
   const [searchValue, updateSearchValue] = useState('');
+  const [isResetFilterActive, setIsResetFilterActive] = useState(false);
 
-  const { toSelectedPipeline, toSelectedNode, toFocusedModularPipeline } =
-    useGeneratePathname();
+  const {
+    toSelectedPipeline,
+    toSelectedNode,
+    toFocusedModularPipeline,
+    toUpdateUrlParamsOnResetFilter,
+    toUpdateUrlParamsOnFilter,
+  } = useGeneratePathname();
 
   const items = getFilteredItems({
     nodes,
@@ -105,10 +112,32 @@ const NodeListProvider = ({
     }
   };
 
+  // To get existing values from URL query parameters
+  const getExistingValuesFromUrlQueryParams = (paramName, searchParams) => {
+    const paramValues = searchParams.get(paramName);
+    return new Set(paramValues ? paramValues.split(',') : []);
+  };
+
+  const handleUrlParamsUpdateOnFilter = (item) => {
+    const searchParams = new URLSearchParams(window.location.search);
+    const paramName = isElementType(item.type) ? params.types : params.tags;
+    const existingValues = getExistingValuesFromUrlQueryParams(
+      paramName,
+      searchParams
+    );
+
+    toUpdateUrlParamsOnFilter(item, paramName, existingValues);
+  };
+
   const onItemChange = (item, checked, clickedIconType) => {
     if (isGroupType(item.type) || isModularPipelineType(item.type)) {
       onGroupItemChange(item, checked);
 
+      // Update URL query parameters when a filter item is clicked
+      if (!clickedIconType) {
+        handleUrlParamsUpdateOnFilter(item);
+      }
+
       if (isModularPipelineType(item.type)) {
         if (clickedIconType === 'focus') {
           if (focusMode === null) {
@@ -169,6 +198,11 @@ const NodeListProvider = ({
       (groupItem) => !groupItem.checked
     );
 
+    // Update URL query parameters when a filter group is clicked
+    groupItems.forEach((item) => {
+      handleUrlParamsUpdateOnFilter(item);
+    });
+
     if (isTagType(groupType)) {
       onToggleTagFilter(
         groupItems.map((item) => item.id),
@@ -207,6 +241,32 @@ const NodeListProvider = ({
       onToggleNodeSelected(null);
     }
   };
+
+  // Reset applied filters to default
+  const onResetFilter = () => {
+    onToggleTypeDisabled({ task: false, data: false, parameters: true });
+    onToggleTagFilter(
+      tags.map((item) => item.id),
+      false
+    );
+
+    toUpdateUrlParamsOnResetFilter();
+  };
+
+  // Helper function to check if NodeTypes is modified
+  const hasModifiedNodeTypes = (nodeTypes) => {
+    return nodeTypes.some(
+      (item) => NODE_TYPES[item.id]?.defaultState !== item.disabled
+    );
+  };
+
+  // Updates the reset filter button status based on the node types and tags.
+  useEffect(() => {
+    const isNodeTypeModified = hasModifiedNodeTypes(nodeTypes);
+    const isNodeTagModified = tags.some((tag) => tag.enabled);
+    setIsResetFilterActive(isNodeTypeModified || isNodeTagModified);
+  }, [tags, nodeTypes]);
+
   useEffect(() => {
     window.addEventListener('keydown', handleKeyDown);
     return () => window.removeEventListener('keydown', handleKeyDown);
@@ -230,6 +290,8 @@ const NodeListProvider = ({
       onItemChange={onItemChange}
       focusMode={focusMode}
       disabledModularPipeline={disabledModularPipeline}
+      onResetFilter={onResetFilter}
+      isResetFilterActive={isResetFilterActive}
     />
   );
 };

src/components/node-list/node-list.js

@@ -28,6 +28,8 @@ const NodeList = ({
   onModularPipelineToggleExpanded,
   focusMode,
   disabledModularPipeline,
+  onResetFilter,
+  isResetFilterActive,
 }) => {
   return (
     <div
@@ -79,9 +81,18 @@ const NodeList = ({
                 autoHide
                 hideTracksWhenNotNeeded
               >
-                <h2 className="pipeline-nodelist-section__title">
-                  <span>Filters</span>
-                </h2>
+                <div className="pipeline-nodelist-section__filters">
+                  <h2 className="pipeline-nodelist-section__title">
+                    <span>Filters</span>
+                  </h2>
+                  <button
+                    disabled={!isResetFilterActive}
+                    onClick={onResetFilter}
+                    className="pipeline-nodelist-section__reset-filter"
+                  >
+                    Reset
+                  </button>
+                </div>
                 <NodeListGroups
                   items={items}
                   groups={groups}