Issue #12: use the nanoseconds instead

quickwit-oss · Nov 23, 2023 · e2264b8 · e2264b8
1 parent 0b9b6a4
commit e2264b8
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/build_and_start.sh b/build_and_start.sh
@@ -3,4 +3,5 @@
 npm install
 npm run build
 mage -v
+go test -v ./pkg/...
 docker-compose up --build --force-recreate
diff --git a/pkg/quickwit/client/client.go b/pkg/quickwit/client/client.go
@@ -166,6 +166,13 @@ func (c *baseClientImpl) ExecuteMultisearch(r *MultiSearchRequest) (*MultiSearch
 
 	c.logger.Debug("Received multisearch response", "code", res.StatusCode, "status", res.Status, "content-length", res.ContentLength)
 
+	if res.StatusCode >= 400 {
+		jsonResponseBody, _ := json.Marshal(res.Body)
+		jsonQueryParam, _ := json.Marshal(queryParams)
+		jsonRequestBody, _ := json.Marshal(r.Requests)
+		c.logger.Error("Error on multisearch: statusCode = " + strconv.Itoa(res.StatusCode) + ", responseBody = " + string(jsonResponseBody) + ", queryParam = " + string(jsonQueryParam) + ", requestBody = " + string(jsonRequestBody))
+	}
+
 	start := time.Now()
 	c.logger.Debug("Decoding multisearch json response")
 

diff --git a/src/datasource.ts b/src/datasource.ts
@@ -434,8 +434,7 @@ export class QuickwitDataSource
 
   private makeLogContextDataRequest = (row: LogRowModel, options?: LogRowContextOptions) => {
     const direction = options?.direction || LogRowContextQueryDirection.Backward;
-    const searchAfterNs = row.dataFrame.fields.find((f) => f.name === 'sort')?.values.get(row.rowIndex) ?? [row.timeEpochNs]
-    const searchAfterMs = [Math.round(searchAfterNs[0]/1000000)]
+    const searchAfter = row.dataFrame.fields.find((f) => f.name === 'sort')?.values.get(row.rowIndex) ?? [row.timeEpochNs]
 
     const logQuery: Logs = {
       type: 'logs',
@@ -445,7 +444,7 @@ export class QuickwitDataSource
         // Sorting of results in the context query
         sortDirection: direction === LogRowContextQueryDirection.Backward ? 'desc' : 'asc',
         // Used to get the next log lines before/after the current log line using sort field of selected log line
-        searchAfter: searchAfterMs,
+        searchAfter: searchAfter,
       },
     };