This commit is contained in:
Pranita 2025-10-03 13:19:06 +05:30
parent 39c4461d03
commit 42695b3154
3 changed files with 37 additions and 40 deletions

View File

@ -183,9 +183,14 @@ export const selectDataProductFromTab = async (
page: Page,
dataProduct: DataProduct['data']
) => {
const dpRes = page.waitForResponse(
'/api/v1/search/query?*&from=0&size=50&index=data_product_search_index*'
);
const dpRes = page.waitForResponse((response) => {
const url = response.url();
return (
url.includes('/api/v1/search/query') &&
url.includes('index=data_product_search_index')
);
});
await page
.locator('.domain-details-page-tabs')
.getByText('Data Products')

View File

@ -50,7 +50,6 @@ import {
getAddServicePath,
getServiceDetailsPath,
} from '../../../utils/RouterUtils';
import { getTermQuery } from '../../../utils/SearchUtils';
import {
getOptionalFields,
getResourceEntityFromServiceCategory,
@ -101,9 +100,11 @@ const Services = ({ serviceName }: ServicesProps) => {
const [deleted, setDeleted] = useState<boolean>(false);
const { permissions } = usePermissionProvider();
const serviceTypeQueryFilter = useMemo(() => {
const filterString = useMemo(() => {
return serviceTypeFilter?.length
? getTermQuery({ 'serviceType.keyword': serviceTypeFilter }, 'should', 1)
? `(${serviceTypeFilter
.map((type) => `serviceType:${type}`)
.join(' OR ')})`
: undefined;
}, [serviceTypeFilter]);
@ -141,19 +142,19 @@ const Services = ({ serviceName }: ServicesProps) => {
currentPage,
after,
before,
queryFilter,
filters,
}: {
search?: string;
limit?: number;
currentPage?: number;
after?: string;
before?: string;
queryFilter?: Record<string, unknown>;
filters?: string;
}) => {
setIsLoading(true);
try {
let services = [];
if (search || queryFilter) {
if (search || !isEmpty(filters)) {
const {
hits: { hits, total },
} = await searchService({
@ -161,7 +162,7 @@ const Services = ({ serviceName }: ServicesProps) => {
searchIndex,
limit: pageSize,
currentPage,
queryFilter,
filters,
deleted,
});
@ -205,23 +206,23 @@ const Services = ({ serviceName }: ServicesProps) => {
const handleServicePageChange = useCallback(
({ cursorType, currentPage }: PagingHandlerParams) => {
if (searchTerm || serviceTypeQueryFilter) {
if (searchTerm || filterString) {
handlePageChange(currentPage);
getServiceDetails({
currentPage,
search: searchTerm,
limit: pageSize,
queryFilter: serviceTypeQueryFilter,
filters: filterString,
});
} else if (cursorType) {
handlePageChange(currentPage);
getServiceDetails({
[cursorType]: paging[cursorType],
queryFilter: serviceTypeQueryFilter,
filters: filterString,
});
}
},
[getServiceDetails, searchTerm, serviceTypeQueryFilter, paging, pageSize]
[getServiceDetails, searchTerm, filterString, paging, pageSize]
);
const addServicePermission = useMemo(
@ -270,11 +271,7 @@ const Services = ({ serviceName }: ServicesProps) => {
}, [serviceName]);
const noDataPlaceholder = useMemo(() => {
if (
addServicePermission &&
isEmpty(searchTerm) &&
!serviceTypeQueryFilter
) {
if (addServicePermission && isEmpty(searchTerm) && !filterString) {
return (
<ErrorPlaceHolder
className="p-lg border-none"
@ -301,7 +298,7 @@ const Services = ({ serviceName }: ServicesProps) => {
servicesDisplayName,
serviceName,
searchTerm,
serviceTypeQueryFilter,
filterString,
addServicePermission,
handleAddServiceClick,
]);
@ -466,16 +463,9 @@ const Services = ({ serviceName }: ServicesProps) => {
getServiceDetails({
search: searchTerm,
limit: pageSize,
queryFilter: serviceTypeQueryFilter,
filters: filterString,
});
}, [
searchIndex,
pageSize,
serviceName,
searchTerm,
serviceTypeQueryFilter,
deleted,
]);
}, [searchIndex, pageSize, serviceName, searchTerm, filterString, deleted]);
const handleTableChange: TableProps<ServicesType>['onChange'] = (
_pagination,

View File

@ -31,7 +31,7 @@ import {
} from '../interface/service.interface';
import { getEncodedFqn } from '../utils/StringsUtils';
import APIClient from './index';
import { searchQuery } from './searchAPI';
import { searchData } from './miscAPI';
interface ServiceRequestParams {
limit?: number;
@ -183,26 +183,28 @@ export const searchService = async ({
searchIndex,
currentPage = 1,
limit = PAGE_SIZE,
queryFilter,
filters,
deleted = false,
}: {
search?: string;
searchIndex: SearchIndex | SearchIndex[];
limit?: number;
currentPage?: number;
queryFilter?: Record<string, unknown>;
filters?: string;
deleted?: boolean;
}) => {
const response = await searchQuery({
query: search ?? WILD_CARD_CHAR,
pageNumber: currentPage,
pageSize: limit,
queryFilter,
const response = await searchData(
search ?? WILD_CARD_CHAR,
currentPage,
limit,
filters ?? '',
'',
'',
searchIndex,
includeDeleted: deleted,
});
deleted
);
return response;
return response.data;
};
export const restoreService = async (serviceCategory: string, id: string) => {