Skip to content

Commit

Permalink
optimize the code
Browse files Browse the repository at this point in the history
Signed-off-by: yubonluo <[email protected]>
  • Loading branch information
yubonluo committed Aug 26, 2024
1 parent 0e6ad2f commit 0ef40b6
Show file tree
Hide file tree
Showing 3 changed files with 88 additions and 63 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
* SPDX-License-Identifier: Apache-2.0
*/

import React, { useCallback, useMemo, useState } from 'react';
import React, { useCallback, useEffect, useMemo, useState } from 'react';
import {
EuiSpacer,
EuiInMemoryTable,
Expand Down Expand Up @@ -44,6 +44,11 @@ export const OpenSearchConnectionTable = ({
const [modalVisible, setModalVisible] = useState(false);
const [popoversState, setPopoversState] = useState<Record<string, boolean>>({});

useEffect(() => {
// Reset selected items when connectionType changes
setSelectedItems([]);
}, [connectionType, setSelectedItems]);

const filteredDataSources = useMemo(() => {
// Reset the item when switching connectionType.
setSelectedItems([]);
Expand Down Expand Up @@ -180,7 +185,11 @@ export const OpenSearchConnectionTable = ({
</EuiButtonEmpty>
}
>
<EuiPopoverTitle>RELATED CONNECTIONS</EuiPopoverTitle>
<EuiPopoverTitle>
{i18n.translate('workspace.detail.dataSources.recentConnections.title', {
defaultMessage: 'RELATED CONNECTIONS',
})}
</EuiPopoverTitle>
<EuiListGroup
flush
maxWidth={200}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ import { AssociationDataSourceModal } from './association_data_source_modal';
import { useOpenSearchDashboards } from '../../../../opensearch_dashboards_react/public';
import { CoreStart, SavedObjectsStart, WorkspaceObject } from '../../../../../core/public';
import { convertPermissionSettingsToPermissions, useWorkspaceFormContext } from '../workspace_form';
import { getDirectQueryConnections, mergeDataSourcesWithConnections } from '../../utils';
import { useFetchDQC } from '../../hooks';

export interface SelectDataSourcePanelProps {
savedObjects: SavedObjectsStart;
Expand All @@ -52,31 +52,14 @@ export const SelectDataSourceDetailPanel = ({
const [isVisible, setIsVisible] = useState(false);
const [dataSourceConnections, setDataSourceConnections] = useState<DataSourceConnection[]>([]);
const [toggleIdSelected, setToggleIdSelected] = useState('all');
const fetchDQC = useFetchDQC(assignedDataSources, http, notifications);

const fetchDQC = useCallback(async () => {
useEffect(() => {
setIsLoading(true);
try {
const directQueryConnectionsPromises = assignedDataSources.map((ds) =>
getDirectQueryConnections(ds.id, http!)
);
const directQueryConnectionsResult = await Promise.all(directQueryConnectionsPromises);
const directQueryConnections = directQueryConnectionsResult.flat();
setDataSourceConnections(
mergeDataSourcesWithConnections(assignedDataSources, directQueryConnections)
);
} catch (error) {
notifications?.toasts.addDanger(
i18n.translate('workspace.detail.dataSources.error.message', {
defaultMessage: 'Can not fetch direct query connections',
})
);
} finally {
fetchDQC().then((res) => {
setDataSourceConnections(res);
setIsLoading(false);
}
}, [assignedDataSources, http, notifications?.toasts]);

useEffect(() => {
fetchDQC();
});
}, [fetchDQC]);

const toggleButtons = [
Expand All @@ -100,10 +83,6 @@ export const SelectDataSourceDetailPanel = ({
},
];

const onChange = (optionId: string) => {
setToggleIdSelected(optionId);
};

const handleAssignDataSources = async (dataSources: DataSource[]) => {
try {
setIsLoading(true);
Expand Down Expand Up @@ -139,41 +118,44 @@ export const SelectDataSourceDetailPanel = ({
}
};

const handleUnassignDataSources = async (dataSources: DataSourceConnection[]) => {
try {
setIsLoading(true);
const { permissionSettings, selectedDataSources, useCase, ...attributes } = formData;
const savedDataSources = (selectedDataSources ?? [])?.filter(
({ id }: DataSource) => !dataSources.some((item) => item.id === id)
);
const handleUnassignDataSources = useCallback(
async (dataSources: DataSourceConnection[]) => {
try {
setIsLoading(true);
const { permissionSettings, selectedDataSources, useCase, ...attributes } = formData;

Check warning on line 125 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L123-L125

Added lines #L123 - L125 were not covered by tests
const savedDataSources = (selectedDataSources ?? [])?.filter(
({ id }: DataSource) => !dataSources.some((item) => item.id === id)

Check warning on line 127 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L127

Added line #L127 was not covered by tests
);

const result = await workspaceClient.update(currentWorkspace.id, attributes, {
dataSources: savedDataSources.map(({ id }: DataSource) => id),
permissions: convertPermissionSettingsToPermissions(permissionSettings),
});
if (result?.success) {
notifications?.toasts.addSuccess({
title: i18n.translate('workspace.detail.dataSources.unassign.success', {
defaultMessage: 'Remove associated OpenSearch connections successfully',
const result = await workspaceClient.update(currentWorkspace.id, attributes, {
dataSources: savedDataSources.map(({ id }: DataSource) => id),

Check warning on line 131 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L130-L131

Added lines #L130 - L131 were not covered by tests
permissions: convertPermissionSettingsToPermissions(permissionSettings),
});
if (result?.success) {
notifications?.toasts.addSuccess({

Check warning on line 135 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L135

Added line #L135 was not covered by tests
title: i18n.translate('workspace.detail.dataSources.unassign.success', {
defaultMessage: 'Remove associated OpenSearch connections successfully',
}),
});
setSelectedDataSources(savedDataSources);

Check warning on line 140 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L140

Added line #L140 was not covered by tests
} else {
throw new Error(

Check warning on line 142 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L142

Added line #L142 was not covered by tests
result?.error ? result?.error : 'Remove associated OpenSearch connections failed'
);
}
} catch (error) {
notifications?.toasts.addDanger({

Check warning on line 147 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L147

Added line #L147 was not covered by tests
title: i18n.translate('workspace.detail.dataSources.unassign.failed', {
defaultMessage: 'Failed to remove associated OpenSearch connections',
}),
text: error instanceof Error ? error.message : JSON.stringify(error),
});
setSelectedDataSources(savedDataSources);
} else {
throw new Error(
result?.error ? result?.error : 'Remove associated OpenSearch connections failed'
);
} finally {
setIsLoading(false);

Check warning on line 154 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L154

Added line #L154 was not covered by tests
}
} catch (error) {
notifications?.toasts.addDanger({
title: i18n.translate('workspace.detail.dataSources.unassign.failed', {
defaultMessage: 'Failed to remove associated OpenSearch connections',
}),
text: error instanceof Error ? error.message : JSON.stringify(error),
});
} finally {
setIsLoading(false);
}
};
},
[currentWorkspace.id, formData, notifications?.toasts, setSelectedDataSources, workspaceClient]
);

const associationButton = (
<EuiSmallButton
Expand Down Expand Up @@ -267,7 +249,7 @@ export const SelectDataSourceDetailPanel = ({
legend="dataSourceGroup"
options={toggleButtons}
idSelected={toggleIdSelected}
onChange={(id) => onChange(id)}
onChange={(id) => setToggleIdSelected(id)}

Check warning on line 252 in src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx

View check run for this annotation

Codecov / codecov/patch

src/plugins/workspace/public/components/workspace_detail/select_data_source_panel.tsx#L252

Added line #L252 was not covered by tests
isFullWidth
/>
</EuiFlexItem>
Expand Down
38 changes: 36 additions & 2 deletions src/plugins/workspace/public/hooks.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,17 @@
* SPDX-License-Identifier: Apache-2.0
*/

import { ApplicationStart, PublicAppInfo } from 'opensearch-dashboards/public';
import {
ApplicationStart,
HttpSetup,
NotificationsStart,
PublicAppInfo,
} from 'opensearch-dashboards/public';
import { useObservable } from 'react-use';
import { useMemo } from 'react';
import { useCallback, useMemo } from 'react';
import { i18n } from '@osd/i18n';
import { getDirectQueryConnections, mergeDataSourcesWithConnections } from './utils';
import { DataSource } from '../common/types';

export function useApplications(applicationInstance: ApplicationStart) {
const applications = useObservable(applicationInstance.applications$);
Expand All @@ -17,3 +25,29 @@ export function useApplications(applicationInstance: ApplicationStart) {
return apps;
}, [applications]);
}

export const useFetchDQC = (
assignedDataSources: DataSource[],
http: HttpSetup | undefined,
notifications: NotificationsStart | undefined
) => {
const fetchDQC = useCallback(async () => {
try {
const directQueryConnectionsPromises = assignedDataSources.map((ds) =>
getDirectQueryConnections(ds.id, http!)
);
const directQueryConnectionsResult = await Promise.all(directQueryConnectionsPromises);
const directQueryConnections = directQueryConnectionsResult.flat();
return mergeDataSourcesWithConnections(assignedDataSources, directQueryConnections);
} catch (error) {
notifications?.toasts.addDanger(
i18n.translate('workspace.detail.dataSources.error.message', {
defaultMessage: 'Cannot fetch direct query connections',
})
);
return [];
}
}, [assignedDataSources, http, notifications?.toasts]);

return fetchDQC;
};

0 comments on commit 0ef40b6

Please sign in to comment.