[Manual Backport 2.x] [MD] Able to hide "Local Cluster" option

CHANGELOG.md

@@ -36,6 +36,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 - [Multiple Datasource] Add datasource picker component and use it in devtools and tutorial page when multiple datasource is enabled ([#5756](https://github.com/opensearch-project/OpenSearch-Dashboards/pull/5756))
 - [Multiple Datasource] Add datasource picker to import saved object flyout when multiple data source is enabled ([#5781](https://github.com/opensearch-project/OpenSearch-Dashboards/pull/5781))
 - [Multiple Datasource] Add interfaces to register add-on authentication method from plug-in module ([#5851](https://github.com/opensearch-project/OpenSearch-Dashboards/pull/5851)) 
+- [Multiple Datasource] Able to Hide "Local Cluster" option from datasource DropDown ([#5827](https://github.com/opensearch-project/OpenSearch-Dashboards/pull/5827))
 
 ### 🐛 Bug Fixes
 

config/opensearch_dashboards.yml

@@ -237,8 +237,8 @@
 
 # Set the value of this setting to true to enable multiple data source feature.
 #data_source.enabled: false
-# Set the value of this setting to false to disable default cluster in data source feature.
-#data_source.defaultCluster: true
+# Set the value of this setting to true to hide local cluster in data source feature.
+#data_source.hideLocalCluster: false
 # Set the value of these settings to customize crypto materials to encryption saved credentials
 # in data sources.
 #data_source.encryption.wrappingKeyName: 'changeme'

src/plugins/console/public/application/containers/editor/legacy/console_editor/editor.test.tsx

@@ -53,7 +53,7 @@ import { getEndpointFromPosition } from '../../../../../lib/autocomplete/get_end
 import * as consoleMenuActions from '../console_menu_actions';
 import { Editor } from './editor';
 
-describe('Legacy (Ace) Console Editor Component Smoke Test', () => {
+describe('Legacy (Ace) Console Editor Component Smoke Test with dataSourceId', () => {
   let mockedAppContextValue: ContextValue;
   const sandbox = sinon.createSandbox();
 
@@ -63,7 +63,70 @@ describe('Legacy (Ace) Console Editor Component Smoke Test', () => {
         <ServicesContextProvider value={mockedAppContextValue}>
           <RequestContextProvider>
             <EditorContextProvider settings={{} as any}>
-              <Editor initialTextValue="" />
+              <Editor initialTextValue="" dataSourceId="Some dataSource Id" />
+            </EditorContextProvider>
+          </RequestContextProvider>
+        </ServicesContextProvider>
+      </I18nProvider>
+    );
+
+  beforeEach(() => {
+    document.queryCommandSupported = sinon.fake(() => true);
+    mockedAppContextValue = serviceContextMock.create();
+  });
+
+  afterEach(() => {
+    jest.clearAllMocks();
+    sandbox.restore();
+  });
+
+  it('calls send current request to OpenSearch', async () => {
+    (getEndpointFromPosition as jest.Mock).mockReturnValue({ patterns: [] });
+    (sendRequestToOpenSearch as jest.Mock).mockRejectedValue({});
+    const editor = doMount();
+    act(() => {
+      editor.find('[data-test-subj~="sendRequestButton"]').simulate('click');
+    });
+    await nextTick();
+    expect(sendRequestToOpenSearch).toBeCalledTimes(1);
+  });
+
+  it('opens docs', () => {
+    const stub = sandbox.stub(consoleMenuActions, 'getDocumentation');
+    const editor = doMount();
+    const consoleMenuToggle = editor.find('[data-test-subj~="toggleConsoleMenu"]').last();
+    consoleMenuToggle.simulate('click');
+
+    const docsButton = editor.find('[data-test-subj~="consoleMenuOpenDocs"]').last();
+    docsButton.simulate('click');
+
+    expect(stub.callCount).toBe(1);
+  });
+
+  it('prompts auto-indent', () => {
+    const stub = sandbox.stub(consoleMenuActions, 'autoIndent');
+    const editor = doMount();
+    const consoleMenuToggle = editor.find('[data-test-subj~="toggleConsoleMenu"]').last();
+    consoleMenuToggle.simulate('click');
+
+    const autoIndentButton = editor.find('[data-test-subj~="consoleMenuAutoIndent"]').last();
+    autoIndentButton.simulate('click');
+
+    expect(stub.callCount).toBe(1);
+  });
+});
+
+describe('Legacy (Ace) Console Editor Component Smoke Test with empty dataSourceId (Local Cluster)', () => {
+  let mockedAppContextValue: ContextValue;
+  const sandbox = sinon.createSandbox();
+
+  const doMount = () =>
+    mount(
+      <I18nProvider>
+        <ServicesContextProvider value={mockedAppContextValue}>
+          <RequestContextProvider>
+            <EditorContextProvider settings={{} as any}>
+              <Editor initialTextValue="" dataSourceId="" />
             </EditorContextProvider>
           </RequestContextProvider>
         </ServicesContextProvider>
@@ -115,3 +178,73 @@ describe('Legacy (Ace) Console Editor Component Smoke Test', () => {
     expect(stub.callCount).toBe(1);
   });
 });
+
+describe('Legacy (Ace) Console Editor Component Smoke Test with dataSouceId undefined', () => {
+  let mockedAppContextValue: ContextValue;
+  const sandbox = sinon.createSandbox();
+
+  const doMount = () =>
+    mount(
+      <I18nProvider>
+        <ServicesContextProvider value={mockedAppContextValue}>
+          <RequestContextProvider>
+            <EditorContextProvider settings={{} as any}>
+              <Editor initialTextValue="" />
+            </EditorContextProvider>
+          </RequestContextProvider>
+        </ServicesContextProvider>
+      </I18nProvider>
+    );
+
+  beforeEach(() => {
+    document.queryCommandSupported = sinon.fake(() => true);
+    mockedAppContextValue = serviceContextMock.create();
+  });
+
+  afterEach(() => {
+    jest.clearAllMocks();
+    sandbox.restore();
+  });
+
+  it('diasbles send request button', async () => {
+    (getEndpointFromPosition as jest.Mock).mockReturnValue({ patterns: [] });
+    (sendRequestToOpenSearch as jest.Mock).mockRejectedValue({});
+    const editor = doMount();
+    expect(editor.find('[data-test-subj~="sendRequestButton"]').get(0).props.disabled);
+  });
+
+  it('not able to send current request to OpenSearch', async () => {
+    (getEndpointFromPosition as jest.Mock).mockReturnValue({ patterns: [] });
+    (sendRequestToOpenSearch as jest.Mock).mockRejectedValue({});
+    const editor = doMount();
+    act(() => {
+      editor.find('[data-test-subj~="sendRequestButton"]').simulate('click');
+    });
+    await nextTick();
+    expect(sendRequestToOpenSearch).toBeCalledTimes(0);
+  });
+
+  it('opens docs', () => {
+    const stub = sandbox.stub(consoleMenuActions, 'getDocumentation');
+    const editor = doMount();
+    const consoleMenuToggle = editor.find('[data-test-subj~="toggleConsoleMenu"]').last();
+    consoleMenuToggle.simulate('click');
+
+    const docsButton = editor.find('[data-test-subj~="consoleMenuOpenDocs"]').last();
+    docsButton.simulate('click');
+
+    expect(stub.callCount).toBe(1);
+  });
+
+  it('prompts auto-indent', () => {
+    const stub = sandbox.stub(consoleMenuActions, 'autoIndent');
+    const editor = doMount();
+    const consoleMenuToggle = editor.find('[data-test-subj~="toggleConsoleMenu"]').last();
+    consoleMenuToggle.simulate('click');
+
+    const autoIndentButton = editor.find('[data-test-subj~="consoleMenuAutoIndent"]').last();
+    autoIndentButton.simulate('click');
+
+    expect(stub.callCount).toBe(1);
+  });
+});

src/plugins/console/public/application/containers/editor/legacy/console_editor/editor.tsx

@@ -228,6 +228,11 @@ function EditorUI({ initialTextValue, dataSourceId }: EditorProps) {
     });
   }, [sendCurrentRequestToOpenSearch, openDocumentation]);
 
+  const tooltipDefaultMessage =
+    dataSourceId === undefined ? `Select a data source` : `Click to send request`;
+
+  const toolTipButtonDiasbled = dataSourceId === undefined;
+
   return (
     <div style={abs} className="conApp">
       <div className="conApp__editor">
@@ -241,16 +246,17 @@ function EditorUI({ initialTextValue, dataSourceId }: EditorProps) {
           <EuiFlexItem>
             <EuiToolTip
               content={i18n.translate('console.sendRequestButtonTooltip', {
-                defaultMessage: 'Click to send request',
+                defaultMessage: tooltipDefaultMessage,
               })}
             >
               <button
                 onClick={sendCurrentRequestToOpenSearch}
                 data-test-subj="sendRequestButton"
                 aria-label={i18n.translate('console.sendRequestButtonTooltip', {
-                  defaultMessage: 'Click to send request',
+                  defaultMessage: tooltipDefaultMessage,
                 })}
                 className="conApp__editorActionButton conApp__editorActionButton--success"
+                disabled={toolTipButtonDiasbled}
               >
                 <EuiIcon type="play" />
               </button>

src/plugins/data/server/search/opensearch_search/decide_client.ts

@@ -9,14 +9,14 @@ import { IOpenSearchSearchRequest } from '..';
 export const decideClient = async (
   context: RequestHandlerContext,
   request: IOpenSearchSearchRequest,
-  withDataSourceEnabled: boolean = false,
   withLongNumeralsSupport: boolean = false
 ): Promise<OpenSearchClient> => {
-  const defaultOpenSearchClient = withLongNumeralsSupport
-    ? context.core.opensearch.client.asCurrentUserWithLongNumeralsSupport
-    : context.core.opensearch.client.asCurrentUser;
-
-  return withDataSourceEnabled && request.dataSourceId && context.dataSource
-    ? await context.dataSource.opensearch.getClient(request.dataSourceId)
-    : defaultOpenSearchClient;
+  // if data source feature is disabled, return default opensearch client of current user
+  const client =
+    request.dataSourceId && context.dataSource
+      ? await context.dataSource.opensearch.getClient(request.dataSourceId)
+      : withLongNumeralsSupport
+      ? context.core.opensearch.client.asCurrentUserWithLongNumeralsSupport
+      : context.core.opensearch.client.asCurrentUser;
+  return client;
 };

src/plugins/data/server/search/opensearch_search/opensearch_search_strategy.test.ts

@@ -33,20 +33,11 @@ import { pluginInitializerContextConfigMock } from '../../../../../core/server/m
 import { opensearchSearchStrategyProvider } from './opensearch_search_strategy';
 import { DataSourceError } from '../../../../data_source/server/lib/error';
 import { DataSourcePluginSetup } from '../../../../data_source/server';
-import { SearchUsage } from '../collectors';
 
 describe('OpenSearch search strategy', () => {
   const mockLogger: any = {
     debug: () => {},
   };
-  const mockSearchUsage: SearchUsage = {
-    trackError(): Promise<void> {
-      return Promise.resolve(undefined);
-    },
-    trackSuccess(duration: number): Promise<void> {
-      return Promise.resolve(undefined);
-    },
-  };
   const body = {
     body: {
       _shards: {
@@ -140,21 +131,8 @@ describe('OpenSearch search strategy', () => {
     expect(response).toHaveProperty('rawResponse');
   });
 
-  it('dataSource enabled and default cluster disabled, send request with dataSourceId get data source client', async () => {
-    const mockDataSourcePluginSetupWithDataSourceEnabled: DataSourcePluginSetup = {
-      createDataSourceError(err: any): DataSourceError {
-        return new DataSourceError({});
-      },
-      dataSourceEnabled: jest.fn(() => true),
-      defaultClusterEnabled: jest.fn(() => false),
-    };
-
-    const opensearchSearch = await opensearchSearchStrategyProvider(
-      mockConfig$,
-      mockLogger,
-      mockSearchUsage,
-      mockDataSourcePluginSetupWithDataSourceEnabled
-    );
+  it('dataSource enabled, send request with dataSourceId get data source client', async () => {
+    const opensearchSearch = await opensearchSearchStrategyProvider(mockConfig$, mockLogger);
 
     await opensearchSearch.search(
       (mockDataSourceEnabledContext as unknown) as RequestHandlerContext,
@@ -166,35 +144,6 @@ describe('OpenSearch search strategy', () => {
     expect(mockOpenSearchApiCaller).not.toBeCalled();
   });
 
-  it('dataSource enabled and default cluster disabled, send request with empty dataSourceId should throw exception', async () => {
-    const mockDataSourcePluginSetupWithDataSourceEnabled: DataSourcePluginSetup = {
-      createDataSourceError(err: any): DataSourceError {
-        return new DataSourceError({});
-      },
-      dataSourceEnabled: jest.fn(() => true),
-      defaultClusterEnabled: jest.fn(() => false),
-    };
-
-    try {
-      const opensearchSearch = opensearchSearchStrategyProvider(
-        mockConfig$,
-        mockLogger,
-        mockSearchUsage,
-        mockDataSourcePluginSetupWithDataSourceEnabled
-      );
-
-      await opensearchSearch.search(
-        (mockDataSourceEnabledContext as unknown) as RequestHandlerContext,
-        {
-          dataSourceId: '',
-        }
-      );
-    } catch (e) {
-      expect(e).toBeTruthy();
-      expect(e).toBeInstanceOf(DataSourceError);
-    }
-  });
-
   it('dataSource disabled, send request with dataSourceId get default client', async () => {
     const opensearchSearch = await opensearchSearchStrategyProvider(mockConfig$, mockLogger);
 
@@ -205,47 +154,8 @@ describe('OpenSearch search strategy', () => {
     expect(mockDataSourceApiCaller).not.toBeCalled();
   });
 
-  it('dataSource enabled and default cluster enabled, send request with dataSourceId get datasource client', async () => {
-    const mockDataSourcePluginSetupWithDataSourceEnabled: DataSourcePluginSetup = {
-      createDataSourceError(err: any): DataSourceError {
-        return new DataSourceError({});
-      },
-      dataSourceEnabled: jest.fn(() => true),
-      defaultClusterEnabled: jest.fn(() => true),
-    };
-
-    const opensearchSearch = await opensearchSearchStrategyProvider(
-      mockConfig$,
-      mockLogger,
-      mockSearchUsage,
-      mockDataSourcePluginSetupWithDataSourceEnabled
-    );
-
-    await opensearchSearch.search(
-      (mockDataSourceEnabledContext as unknown) as RequestHandlerContext,
-      {
-        dataSourceId,
-      }
-    );
-    expect(mockDataSourceApiCaller).toBeCalled();
-    expect(mockOpenSearchApiCaller).not.toBeCalled();
-  });
-
-  it('dataSource enabled and default cluster enabled, send request without dataSourceId get default client', async () => {
-    const mockDataSourcePluginSetupWithDataSourceEnabled: DataSourcePluginSetup = {
-      createDataSourceError(err: any): DataSourceError {
-        return new DataSourceError({});
-      },
-      dataSourceEnabled: jest.fn(() => true),
-      defaultClusterEnabled: jest.fn(() => true),
-    };
-
-    const opensearchSearch = await opensearchSearchStrategyProvider(
-      mockConfig$,
-      mockLogger,
-      mockSearchUsage,
-      mockDataSourcePluginSetupWithDataSourceEnabled
-    );
+  it('dataSource enabled, send request without dataSourceId get default client', async () => {
+    const opensearchSearch = await opensearchSearchStrategyProvider(mockConfig$, mockLogger);
 
     await opensearchSearch.search((mockContext as unknown) as RequestHandlerContext, {});
     expect(mockOpenSearchApiCaller).toBeCalled();

src/plugins/data/server/search/opensearch_search/opensearch_search_strategy.ts

@@ -73,20 +73,7 @@ export const opensearchSearchStrategyProvider = (
       });
 
       try {
-        if (
-          dataSource?.dataSourceEnabled() &&
-          !dataSource?.defaultClusterEnabled() &&
-          !request.dataSourceId
-        ) {
-          throw new Error(`Data source id is required when no openseach hosts config provided`);
-        }
-
-        const client = await decideClient(
-          context,
-          request,
-          dataSource?.dataSourceEnabled(),
-          withLongNumeralsSupport
-        );
+        const client = await decideClient(context, request, withLongNumeralsSupport);
         const promise = shimAbortSignal(client.search(params), options?.abortSignal);
 
         const { body: rawResponse } = (await promise) as ApiResponse<SearchResponse<any>>;
@@ -105,7 +92,7 @@ export const opensearchSearchStrategyProvider = (
       } catch (e) {
         if (usage) usage.trackError();
 
-        if (dataSource?.dataSourceEnabled()) {
+        if (dataSource && request.dataSourceId) {
           throw dataSource.createDataSourceError(e);
         }
         throw e;

src/plugins/data_source/config.ts

@@ -13,7 +13,7 @@ const WRAPPING_KEY_SIZE: number = 32;
 
 export const configSchema = schema.object({
   enabled: schema.boolean({ defaultValue: false }),
-  defaultCluster: schema.boolean({ defaultValue: false }),
+  hideLocalCluster: schema.boolean({ defaultValue: false }),
   encryption: schema.object({
     wrappingKeyName: schema.string({
       minLength: KEY_NAME_MIN_LENGTH,