From da748f012a5299a9ca75928d555566528ed6f72a Mon Sep 17 00:00:00 2001 From: ameen4455 Date: Fri, 2 Sep 2022 18:59:07 +0530 Subject: [PATCH 1/3] Query Bug --- src/page/Dashboard/index.js | 4 +++- src/utils/api/query.js | 20 +++++++++++--------- 2 files changed, 14 insertions(+), 10 deletions(-) diff --git a/src/page/Dashboard/index.js b/src/page/Dashboard/index.js index df8b31f4..2a5ffd2d 100644 --- a/src/page/Dashboard/index.js +++ b/src/page/Dashboard/index.js @@ -181,7 +181,9 @@ const Dashboard = () => { selectedLogStream?.name, moment(startTime).utcOffset("+00:00").format("YYYY-MM-DDTHH:mm:ssZ"), moment(endTime).utcOffset("+00:00").format("YYYY-MM-DDTHH:mm:ssZ"), - selectedLogSchema, + logStreamSchema?.data?.data?.fields?.map((field) => { + return field.name; + }), () => { if (range < 7) { const rangeVal = getRange(); diff --git a/src/utils/api/query.js b/src/utils/api/query.js index 9ff79e6d..f3e18065 100644 --- a/src/utils/api/query.js +++ b/src/utils/api/query.js @@ -8,23 +8,25 @@ const queryLogs = async ( endTime, signal, pageParam, - selectedLogSchema, + logSchema, ) => { let dateStream = null; - for (let index in selectedLogSchema) { + for (let index in logSchema) { if ( - selectedLogSchema[index].includes("date") || - selectedLogSchema[index].includes("time") + logSchema[index].includes("date") || + logSchema[index].includes("time") ) { - dateStream = selectedLogSchema[index]; + dateStream = logSchema[index]; } } return await post( QUERY_URL, { - query: `select * from ${streamName}`, + query: `select * from ${streamName} ${ + dateStream !== null ? `order by ${dateStream}` : "" + } limit 10${pageParam === 1 ? "" : ` offset ${pageParam * 10}`}`, startTime: startTime, endTime: endTime, }, @@ -36,12 +38,12 @@ export const useQueryLogs = ( streamName, startTime, endTime, - selectedLogSchema, + logSchema, fn, option = {}, ) => useInfiniteQuery( - [QUERY, streamName, startTime, endTime], + [QUERY, logSchema, startTime, endTime], async ({ signal, pageParam = 1 }) => { await fn(); return await queryLogs( @@ -50,7 +52,7 @@ export const useQueryLogs = ( endTime, signal, pageParam, - selectedLogSchema, + logSchema, ); }, { From 0e35f4fbcd63dd6e701d7779043dcec45acf640a Mon Sep 17 00:00:00 2001 From: ameen4455 Date: Fri, 2 Sep 2022 20:02:12 +0530 Subject: [PATCH 2/3] Remove tag in table --- src/page/Dashboard/FieldBox.js | 2 +- src/page/Dashboard/index.js | 24 +++++++++++------------- src/utils/api/query.js | 6 +++--- 3 files changed, 15 insertions(+), 17 deletions(-) diff --git a/src/page/Dashboard/FieldBox.js b/src/page/Dashboard/FieldBox.js index fa2c21d6..d21d6d0b 100644 --- a/src/page/Dashboard/FieldBox.js +++ b/src/page/Dashboard/FieldBox.js @@ -7,7 +7,7 @@ const Field = ({ }) => { return (
-
+

Columns

diff --git a/src/page/Dashboard/index.js b/src/page/Dashboard/index.js index 2a5ffd2d..696943f2 100644 --- a/src/page/Dashboard/index.js +++ b/src/page/Dashboard/index.js @@ -197,7 +197,12 @@ const Dashboard = () => { setAvailableTags([]); }, retry: false, - enabled: !!(selectedLogSchema?.length !== 0), + enabled: + !!( + logStreamSchema?.data?.data?.fields?.map((field) => { + return field.name; + })?.length !== 0 + ) && !!(selectedLogStream?.name != null), refetchOnWindowFocus: false, refetchInterval: interval === null || range === 7 ? false : interval * 1000, @@ -682,18 +687,11 @@ const Dashboard = () => { {data[schema] || ""} ))} - - {data.p_tags - ?.split("^") - .map((tag, index) => { - addAvailableTags(tag); - return ( -
- {tag} -
- ); - })} - + {data.p_tags + ?.split("^") + .forEach((tag) => { + addAvailableTags(tag); + })} ), ), diff --git a/src/utils/api/query.js b/src/utils/api/query.js index f3e18065..2244619d 100644 --- a/src/utils/api/query.js +++ b/src/utils/api/query.js @@ -25,8 +25,8 @@ const queryLogs = async ( QUERY_URL, { query: `select * from ${streamName} ${ - dateStream !== null ? `order by ${dateStream}` : "" - } limit 10${pageParam === 1 ? "" : ` offset ${pageParam * 10}`}`, + dateStream !== null ? `order by ${dateStream} ` : "" + }limit 10${pageParam === 1 ? "" : ` offset ${pageParam * 10}`}`, startTime: startTime, endTime: endTime, }, @@ -43,7 +43,7 @@ export const useQueryLogs = ( option = {}, ) => useInfiniteQuery( - [QUERY, logSchema, startTime, endTime], + [QUERY, streamName, logSchema, startTime, endTime], async ({ signal, pageParam = 1 }) => { await fn(); return await queryLogs( From 27a5e5b9799d427f56994d69c1047e27db0efc70 Mon Sep 17 00:00:00 2001 From: ameen4455 Date: Fri, 2 Sep 2022 20:36:46 +0530 Subject: [PATCH 3/3] Fix offset --- src/page/Dashboard/index.js | 6 ------ src/utils/api/query.js | 2 +- 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/src/page/Dashboard/index.js b/src/page/Dashboard/index.js index 696943f2..7341b1ce 100644 --- a/src/page/Dashboard/index.js +++ b/src/page/Dashboard/index.js @@ -630,12 +630,6 @@ const Dashboard = () => { {name} ))} - - Tags - {logQueries.isLoading && diff --git a/src/utils/api/query.js b/src/utils/api/query.js index 2244619d..3a56e075 100644 --- a/src/utils/api/query.js +++ b/src/utils/api/query.js @@ -26,7 +26,7 @@ const queryLogs = async ( { query: `select * from ${streamName} ${ dateStream !== null ? `order by ${dateStream} ` : "" - }limit 10${pageParam === 1 ? "" : ` offset ${pageParam * 10}`}`, + }limit 10${pageParam === 1 ? "" : ` offset ${(pageParam - 1) * 10}`}`, startTime: startTime, endTime: endTime, },