Formatting timestamps in local timezone & auto detect datatype support (#343)

Author: balaji-jr

src/api/constants.ts

@@ -35,6 +35,7 @@ export const LOG_STREAMS_RETRNTION_URL = (streamName: string) => `${LOG_STREAM_L
 export const LOG_STREAMS_STATS_URL = (streamName: string) => `${LOG_STREAM_LIST_URL}/${streamName}/stats`;
 export const LOG_STREAMS_INFO_URL = (streamName: string) => `${LOG_STREAM_LIST_URL}/${streamName}/info`;
 export const DELETE_STREAMS_URL = (streamName: string) => `${LOG_STREAM_LIST_URL}/${streamName}`;
+export const DETECT_LOG_STREAM_SCHEMA_URL = `${LOG_STREAM_LIST_URL}/schema/detect`;
 export const CREATE_STREAM_URL = (streamName: string) => `${LOG_STREAM_LIST_URL}/${streamName}`;
 export const LOG_STREAM_HOT_TIER = (streamName: string) => `${LOG_STREAM_LIST_URL}/${streamName}/hottier`;
 

src/api/logStream.ts

@@ -14,6 +14,7 @@ import {
 	DELETE_SAVED_FILTERS_URL,
 	CREATE_SAVED_FILTERS_URL,
 	LOG_STREAM_HOT_TIER,
+	DETECT_LOG_STREAM_SCHEMA_URL,
 } from './constants';
 import { HotTierConfig, LogStreamData, LogStreamSchemaData } from '@/@types/parseable/api/stream';
 
@@ -65,6 +66,10 @@ export const deleteLogStream = (streamName: string) => {
 	return Axios().delete(DELETE_STREAMS_URL(streamName));
 };
 
+export const detectLogStreamSchema = (data: any) => {
+	return Axios().post(DETECT_LOG_STREAM_SCHEMA_URL, data);
+};
+
 export const createLogStream = (streamName: string, data: any, headers: any) => {
 	return Axios().put(CREATE_STREAM_URL(streamName), data, { headers });
 };

src/hooks/useLogStream.tsx

@@ -1,7 +1,14 @@
 import { useMutation, useQuery } from 'react-query';
-import { deleteLogStream, getLogStreamList, createLogStream, updateLogStream } from '@/api/logStream';
+import {
+	deleteLogStream,
+	getLogStreamList,
+	createLogStream,
+	updateLogStream,
+	detectLogStreamSchema,
+} from '@/api/logStream';
 import { AxiosError, isAxiosError } from 'axios';
 import { notifyError, notifySuccess } from '@/utils/notification';
+import { LogStreamSchemaData } from '@/@types/parseable/api/stream';
 
 type CreateStreamOpts = {
 	streamName: string;
@@ -24,6 +31,27 @@ export const useLogStream = () => {
 		},
 	});
 
+	const {
+		mutate: detectLogStreamSchemaMutation,
+		isSuccess: detectLogStreamSchemaIsSuccess,
+		isError: detectLogStreamSchemaIsError,
+		isLoading: detectLogStreamSchemaIsLoading,
+	} = useMutation(
+		(data: { sampleLogs: any[]; onSuccess: (data: LogStreamSchemaData) => void }) =>
+			detectLogStreamSchema(data.sampleLogs),
+		{
+			onSuccess: (data, variables) => {
+				variables.onSuccess && variables.onSuccess(data.data);
+				notifySuccess({ message: `Detected schema successfully` });
+			},
+			onError: (data: AxiosError) => {
+				if (isAxiosError(data) && typeof data.message === 'string') {
+					notifyError({ message: data.message });
+				}
+			},
+		},
+	);
+
 	const {
 		mutate: createLogStreamMutation,
 		isSuccess: createLogStreamIsSuccess,
@@ -109,5 +137,9 @@ export const useLogStream = () => {
 		updateLogStreamIsSuccess,
 		updateLogStreamIsError,
 		updateLogStreamIsLoading,
+		detectLogStreamSchemaMutation,
+		detectLogStreamSchemaIsSuccess,
+		detectLogStreamSchemaIsError,
+		detectLogStreamSchemaIsLoading,
 	};
 };