fix: Detect schema JSON type fix

parseablehq · Jan 24, 2025 · f9f0337 · f9f0337
1 parent 16e3a8a
commit f9f0337
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 21 deletions.
diff --git a/src/hooks/useLogStream.tsx b/src/hooks/useLogStream.tsx
@@ -1,15 +1,16 @@
+import { appStoreReducers, useAppStore } from '@/layouts/MainLayout/providers/AppProvider';
+import { AxiosError, isAxiosError } from 'axios';
+import { LogStreamSchemaData } from '@/@types/parseable/api/stream';
+import { notifyError, notifySuccess } from '@/utils/notification';
 import { useMutation, useQuery } from 'react-query';
 import {
+	createLogStream,
 	deleteLogStream,
+	detectLogStreamSchema,
 	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';
-import { appStoreReducers, useAppStore } from '@/layouts/MainLayout/providers/AppProvider';
+
 
 type CreateStreamOpts = {
 	streamName: string;
@@ -40,7 +41,7 @@ export const useLogStream = () => {
 		isError: detectLogStreamSchemaIsError,
 		isLoading: detectLogStreamSchemaIsLoading,
 	} = useMutation(
-		(data: { sampleLogs: any[]; onSuccess: (data: LogStreamSchemaData) => void }) =>
+		(data: { sampleLogs: Record<string, any>; onSuccess: (data: LogStreamSchemaData) => void }) =>
 			detectLogStreamSchema(data.sampleLogs),
 		{
 			onSuccess: (data, variables) => {

diff --git a/src/pages/Home/CreateStreamModal.tsx b/src/pages/Home/CreateStreamModal.tsx
@@ -1,3 +1,19 @@
+import _ from 'lodash';
+import styles from './styles/CreateStreamModal.module.css';
+import { appStoreReducers, useAppStore } from '@/layouts/MainLayout/providers/AppProvider';
+import { CreatableSelect } from '@/components/Misc/CreatableSelect';
+import {
+	FC,
+	useCallback,
+	useEffect,
+	useState
+	} from 'react';
+import { GetInputPropsReturnType, UseFormReturnType } from 'node_modules/@mantine/form/lib/types';
+import { IconInfoCircleFilled, IconPlus } from '@tabler/icons-react';
+import { LogStreamSchemaData } from '@/@types/parseable/api/stream';
+import { notifyError } from '@/utils/notification';
+import { useForm } from '@mantine/form';
+import { useLogStream } from '@/hooks/useLogStream';
 import {
 	ActionIcon,
 	Box,
@@ -18,17 +34,7 @@ import {
 	ThemeIcon,
 	Tooltip,
 } from '@mantine/core';
-import { FC, useCallback, useEffect, useState } from 'react';
-import styles from './styles/CreateStreamModal.module.css';
-import { useLogStream } from '@/hooks/useLogStream';
-import { useForm } from '@mantine/form';
-import { IconInfoCircleFilled, IconPlus } from '@tabler/icons-react';
-import _ from 'lodash';
-import { CreatableSelect } from '@/components/Misc/CreatableSelect';
-import { useAppStore, appStoreReducers } from '@/layouts/MainLayout/providers/AppProvider';
-import { GetInputPropsReturnType, UseFormReturnType } from 'node_modules/@mantine/form/lib/types';
-import { notifyError } from '@/utils/notification';
-import { LogStreamSchemaData } from '@/@types/parseable/api/stream';
+
 
 const { toggleCreateStreamModal } = appStoreReducers;
 
@@ -461,9 +467,7 @@ const DetectSchemaSection = (props: { form: StreamFormType }) => {
 		} catch (e) {
 			console.error('Error parsing json', e);
 		}
-		if (!_.isArray(logRecords)) {
-			return notifyError({ message: 'Invalid JSON' });
-		} else if (_.isEmpty(logRecords)) {
+		if (_.isEmpty(logRecords)) {
 			return notifyError({ message: 'No records found' });
 		} else if (_.size(logRecords) > 10) {
 			return notifyError({ message: 'More than 10 records found' });