Deprecate Trino Support (#410)

Koustavd18 · web-flow · commit 43b4f30dcfaa · 2025-01-08T16:14:19.000+05:30
diff --git a/src/@types/parseable/api/about.ts b/src/@types/parseable/api/about.ts
@@ -1,5 +1,3 @@
-export type QueryEngineType = 'Trino' | 'Parseable' | undefined;
-
 export type AboutData = {
 	commit: string;
 	deploymentId: string;
@@ -18,5 +16,4 @@ export type AboutData = {
 	analytics: {
 		clarityTag: string;
 	};
-	queryEngine: QueryEngineType;
 };
diff --git a/src/@types/parseable/api/query.ts b/src/@types/parseable/api/query.ts
@@ -1,6 +1,4 @@
-import { QueryEngineType } from '@/@types/parseable/api/about';
 export type LogsQuery = {
-	queryEngine?: QueryEngineType;
 	streamName: string;
 	startTime: Date;
 	endTime: Date;
diff --git a/src/api/query.ts b/src/api/query.ts
@@ -1,14 +1,11 @@
 import { Axios } from './axios';
 import { LOG_QUERY_URL } from './constants';
 import { Log, LogsQuery, LogsResponseWithHeaders } from '@/@types/parseable/api/query';
-import { QueryEngineType } from '@/@types/parseable/api/about';
 import timeRangeUtils from '@/utils/timeRangeUtils';
 import { QueryBuilder } from '@/utils/queryBuilder';
 
 const { formatDateAsCastType } = timeRangeUtils;
-type QueryEngine = QueryEngineType;
 type QueryLogs = {
-	queryEngine: QueryEngine;
 	streamName: string;
 	startTime: Date;
 	endTime: Date;
diff --git a/src/hooks/useQueryLogs.ts b/src/hooks/useQueryLogs.ts
@@ -43,7 +43,6 @@ export const useQueryLogs = () => {
 			order: SortOrder.DESCENDING,
 		},
 	});
-	const [queryEngine] = useAppStore((store) => store.instanceConfig?.queryEngine);
 	const [streamInfo] = useStreamStore((store) => store.info);
 	const [currentStream] = useAppStore((store) => store.currentStream);
 	const timePartitionColumn = _.get(streamInfo, 'time_partition', 'p_timestamp');
@@ -82,7 +81,6 @@ export const useQueryLogs = () => {
 
 	// refactor
 	const defaultQueryOpts = {
-		queryEngine,
 		streamName: currentStream || '',
 		startTime: timeRange.startTime,
 		endTime: timeRange.endTime,
@@ -101,7 +99,7 @@ export const useQueryLogs = () => {
 			refetchSchema();
 			if (isQuerySearchActive) {
 				if (activeMode === 'filters' && isQueryFromParams === false) {
-					const { parsedQuery } = parseQuery(queryEngine, appliedQuery, currentStream || '', {
+					const { parsedQuery } = parseQuery(appliedQuery, currentStream || '', {
 						startTime: timeRange.startTime,
 						endTime: timeRange.endTime,
 						timePartitionColumn,
diff --git a/src/hooks/useQueryResult.tsx b/src/hooks/useQueryResult.tsx
@@ -9,16 +9,13 @@ import { useFilterStore, filterStoreReducers } from '@/pages/Stream/providers/Fi
 import _ from 'lodash';
 import { useAppStore } from '@/layouts/MainLayout/providers/AppProvider';
 import { notifyError } from '@/utils/notification';
-import { QueryEngineType } from '@/@types/parseable/api/about';
 
 const { parseQuery } = filterStoreReducers;
 
 type QueryData = {
-	queryEngine: QueryEngineType;
 	logsQuery: LogsQuery;
 	query: string;
 	onSuccess?: () => void;
-	useTrino?: boolean;
 };
 
 export const useQueryResult = () => {
@@ -71,7 +68,7 @@ export const useFetchCount = () => {
 			const finalQuery = `WITH user_query_count as ( ${custSearchQuery} )SELECT count(*) as count from user_query_count`;
 
 			if (activeMode === 'filters') {
-				const { where } = parseQuery('Parseable', appliedQuery, '');
+				const { where } = parseQuery(appliedQuery, '');
 				const finalQuery = defaultQuery + ' ' + 'where' + ' ' + where;
 				return finalQuery;
 			} else {
diff --git a/src/pages/Stream/components/EventTimeLineGraph.tsx b/src/pages/Stream/components/EventTimeLineGraph.tsx
@@ -266,7 +266,6 @@ function ChartTooltip({ payload }: ChartTooltipProps) {
 const EventTimeLineGraph = () => {
 	const { fetchQueryMutation } = useQueryResult();
 	const [currentStream] = useAppStore((store) => store.currentStream);
-	const [queryEngine] = useAppStore((store) => store.instanceConfig?.queryEngine);
 	const [appliedQuery] = useFilterStore((store) => store.appliedQuery);
 	const [{ activeMode, custSearchQuery }, setLogStore] = useLogsStore((store) => store.custQuerySearchState);
 	const [{ interval, startTime, endTime }] = useAppStore((store) => store.timeRange);
@@ -289,13 +288,10 @@ const EventTimeLineGraph = () => {
 			access: [],
 		};
 		const whereClause =
-			activeMode === 'sql'
-				? extractWhereClause(custSearchQuery)
-				: parseQuery(queryEngine, appliedQuery, localStream).where;
+			activeMode === 'sql' ? extractWhereClause(custSearchQuery) : parseQuery(appliedQuery, localStream).where;
 		const query = generateCountQuery(localStream, modifiedStartTime, modifiedEndTime, compactType, whereClause);
 		const graphQuery = removeOffsetFromQuery(query);
 		fetchQueryMutation.mutate({
-			queryEngine: 'Parseable', // query for graph should always hit the endpoint for parseable query
 			logsQuery,
 			query: graphQuery,
 		});
diff --git a/src/pages/Stream/components/Querier/QueryCodeEditor.tsx b/src/pages/Stream/components/Querier/QueryCodeEditor.tsx
@@ -1,7 +1,6 @@
 import React, { FC, MutableRefObject, useCallback, useEffect, useState, useRef } from 'react';
 import Editor from '@monaco-editor/react';
 import { Box, Button, Flex, ScrollArea, Stack, Text, TextInput } from '@mantine/core';
-import { QueryEngineType } from '@/@types/parseable/api/about';
 import { ErrorMarker, errChecker } from '../ErrorMarker';
 import useMountedState from '@/hooks/useMountedState';
 import { notify } from '@/utils/notification';
@@ -33,15 +32,13 @@ const genColumnConfig = (fields: Field[]) => {
 };
 
 export const defaultCustSQLQuery = (
-	queryEngine: QueryEngineType,
 	streamName: string | null,
 	startTime: Date,
 	endTime: Date,
 	timePartitionColumn: string,
 ) => {
 	if (streamName && streamName.length > 0) {
 		const { query } = formQueryOpts({
-			queryEngine,
 			streamName: streamName || '',
 			limit: LOAD_LIMIT,
 			startTime,
@@ -62,7 +59,6 @@ const QueryCodeEditor: FC<{
 }> = (props) => {
 	const [instanceConfig] = useAppStore((store) => store.instanceConfig);
 	const llmActive = _.get(instanceConfig, 'llmActive', false);
-	const queryEngine = _.get(instanceConfig, 'queryEngine', 'Parseable');
 	const [streamInfo] = useStreamStore((store) => store.info);
 	const timePartitionColumn = _.get(streamInfo, 'time_partition', 'p_timestamp');
 	const [{ isQuerySearchActive, activeMode, savedFilterId, custSearchQuery }] = useLogsStore(
@@ -85,7 +81,6 @@ const QueryCodeEditor: FC<{
 	useEffect(() => {
 		if (props.queryCodeEditorRef.current === '' || currentStream !== localStreamName) {
 			props.queryCodeEditorRef.current = defaultCustSQLQuery(
-				queryEngine,
 				currentStream,
 				timeRange.startTime,
 				timeRange.endTime,
diff --git a/src/pages/Stream/components/Querier/SavedFiltersModal.tsx b/src/pages/Stream/components/Querier/SavedFiltersModal.tsx
@@ -44,7 +44,6 @@ const SavedFilterItem = (props: {
 	onSqlSearchApply: (query: string, id: string, time_filter: null | { from: string; to: string }) => void;
 	onFilterBuilderQueryApply: (query: QueryType, id: string) => void;
 	currentStream: string;
-	queryEngine: 'Parseable' | 'Trino' | undefined;
 	savedFilterId: string | null;
 	isStoredAndCurrentTimeRangeAreSame: (from: string, to: string) => boolean;
 	hardRefresh: () => void;
@@ -89,10 +88,7 @@ const SavedFilterItem = (props: {
 				setFilterStore((store) => setAppliedFilterQuery(store, query.filter_query));
 			} else if (query.filter_builder) {
 				setFilterStore((store) =>
-					setAppliedFilterQuery(
-						store,
-						parseQuery(props.queryEngine, query.filter_builder as QueryType, stream_name).parsedQuery,
-					),
+					setAppliedFilterQuery(store, parseQuery(query.filter_builder as QueryType, stream_name).parsedQuery),
 				);
 			}
 			setFilterStore((store) => toggleSavedFiltersModal(store, false));
@@ -171,7 +167,7 @@ const SavedFilterItem = (props: {
 							_.isString(query.filter_query)
 								? query.filter_query
 								: query.filter_builder
-								? parseQuery(props.queryEngine, query.filter_builder, stream_name).parsedQuery
+								? parseQuery(query.filter_builder, stream_name).parsedQuery
 								: ''
 						}
 						language="sql"
@@ -197,7 +193,6 @@ const SavedFiltersModal = () => {
 	const [savedFilters] = useAppStore((store) => store.savedFilters);
 	const [activeSavedFilters] = useAppStore((store) => store.activeSavedFilters);
 	const [currentStream] = useAppStore((store) => store.currentStream);
-	const [queryEngine] = useAppStore((store) => store.instanceConfig?.queryEngine);
 	const { isLoading, refetch, isError } = useSavedFiltersQuery();
 	const onSqlSearchApply = useCallback(
 		(query: string, id: string, time_filter: null | { from: string; to: string }) => {
@@ -281,7 +276,6 @@ const SavedFiltersModal = () => {
 									onSqlSearchApply={onSqlSearchApply}
 									onFilterBuilderQueryApply={onFilterBuilderQueryApply}
 									currentStream={currentStream || ''}
-									queryEngine={queryEngine}
 									savedFilterId={savedFilterId}
 									isStoredAndCurrentTimeRangeAreSame={isStoredAndCurrentTimeRangeAreSame}
 									hardRefresh={hardRefresh}
diff --git a/src/pages/Stream/components/Querier/index.tsx b/src/pages/Stream/components/Querier/index.tsx
@@ -75,7 +75,6 @@ const QuerierModal = (props: {
 	onFiltersApply: () => void;
 }) => {
 	const [currentStream] = useAppStore((store) => store.currentStream);
-	const [queryEngine] = useAppStore((store) => store.instanceConfig?.queryEngine);
 	const [{ showQueryBuilder, viewMode }, setLogsStore] = useLogsStore((store) => store.custQuerySearchState);
 	const [streamInfo] = useStreamStore((store) => store.info);
 	const [timeRange] = useAppStore((store) => store.timeRange);
@@ -87,13 +86,12 @@ const QuerierModal = (props: {
 
 	useEffect(() => {
 		queryCodeEditorRef.current = defaultCustSQLQuery(
-			queryEngine,
 			currentStream,
 			timeRange.startTime,
 			timeRange.endTime,
 			timePartitionColumn,
 		);
-	}, [queryEngine, currentStream, timeRange.endTime, timeRange.startTime, timePartitionColumn]);
+	}, [currentStream, timeRange.endTime, timeRange.startTime, timePartitionColumn]);
 
 	return (
 		<Modal
@@ -126,7 +124,6 @@ const Querier = () => {
 	const [{ startTime, endTime }, setAppStore] = useAppStore((store) => store.timeRange);
 	const { isQuerySearchActive, viewMode, showQueryBuilder, activeMode, savedFilterId } = custQuerySearchState;
 	const [currentStream] = useAppStore((store) => store.currentStream);
-	const [queryEngine] = useAppStore((store) => store.instanceConfig?.queryEngine);
 	const [activeSavedFilters] = useAppStore((store) => store.activeSavedFilters);
 	const openBuilderModal = useCallback(() => {
 		setLogsStore((store) => toggleQueryBuilder(store));
@@ -160,7 +157,7 @@ const Querier = () => {
 			if (!currentStream) return;
 
 			const { isUncontrolled } = opts || {};
-			const { parsedQuery } = parseQuery(queryEngine, query, currentStream, {
+			const { parsedQuery } = parseQuery(query, currentStream, {
 				startTime,
 				endTime,
 				timePartitionColumn,
diff --git a/src/pages/Stream/index.tsx b/src/pages/Stream/index.tsx
@@ -44,7 +44,6 @@ const Stream: FC = () => {
 	const { isStoreSynced } = useParamsController();
 	const [maximized] = useAppStore((store) => store.maximized);
 	const [instanceConfig] = useAppStore((store) => store.instanceConfig);
-	const queryEngine = instanceConfig?.queryEngine;
 	const [, setStreamStore] = useStreamStore((store) => store.sideBarOpen);
 	const { getStreamInfoRefetch, getStreamInfoLoading, getStreamInfoRefetching } = useGetStreamInfo(
 		currentStream || '',
@@ -70,7 +69,7 @@ const Stream: FC = () => {
 	useEffect(() => {
 		if (isStoreSynced) {
 			if (!_.isEmpty(currentStream)) {
-				if (view === 'explore' && queryEngine && queryEngine !== 'Parseable') {
+				if (view === 'explore') {
 					setStreamStore(streamChangeCleanup);
 					getStreamInfoRefetch();
 				} else {
diff --git a/src/pages/Stream/providers/FilterProvider.tsx b/src/pages/Stream/providers/FilterProvider.tsx
@@ -5,7 +5,6 @@ import { FilterQueryBuilder } from '@/utils/queryBuilder';
 import { Field, RuleGroupType, RuleType, formatQuery } from 'react-querybuilder';
 import { LOAD_LIMIT } from './LogsProvider';
 import { timeRangeSQLCondition } from '@/api/query';
-import { QueryEngineType } from '@/@types/parseable/api/about';
 
 // write transformer (for saved filters) if you are updating the operators below
 export const textFieldOperators = [
@@ -136,7 +135,6 @@ type FilterStoreReducers = {
 	updateRule: (store: FilterStore, groupId: string, ruleId: string, updateOpts: RuleUpdateOpts) => ReducerOutput;
 	updateQuery: (store: FilterStore, query: QueryType) => ReducerOutput;
 	parseQuery: (
-		queryEngine: 'Parseable' | 'Trino' | undefined,
 		query: QueryType,
 		currentStream: string,
 		timeRangeOpts?: { startTime: Date; endTime: Date; timePartitionColumn: string },
@@ -275,7 +273,6 @@ const toggleSubmitBtn = (_store: FilterStore, val: boolean) => {
 
 // todo - custom rule processor to prevent converting number strings into numbers for text fields
 const parseQuery = (
-	queryEngine: QueryEngineType,
 	query: QueryType,
 	currentStream: string,
 	timeRangeOpts?: { startTime: Date; endTime: Date; timePartitionColumn: string },
@@ -287,7 +284,6 @@ const parseQuery = (
 		: '(1=1)';
 
 	const filterQueryBuilder = new FilterQueryBuilder({
-		queryEngine,
 		streamName: currentStream,
 		whereClause: where,
 		timeRangeCondition,
diff --git a/src/utils/queryBuilder.ts b/src/utils/queryBuilder.ts
