From d78e7bfce2f0599c45ee09eae31606570796263b Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Wed, 25 Dec 2024 13:05:00 +0700
Subject: [PATCH] fix

---
 src/controllers/log-controller.ts    |  1 +
 src/controllers/report-controller.ts | 17 ++++++++++++++++-
 2 files changed, 17 insertions(+), 1 deletion(-)

diff --git a/src/controllers/log-controller.ts b/src/controllers/log-controller.ts
index 7cb247a..c7a8ffc 100644
--- a/src/controllers/log-controller.ts
+++ b/src/controllers/log-controller.ts
@@ -64,6 +64,7 @@ export class LogController extends Controller {
                           "host",
                           "responseCode",
                           "output",
+                          "userName",
                           "rootId",
                         ].map((v) => ({
                           wildcard: { [`${v}.keyword`]: `*${search}*` },
diff --git a/src/controllers/report-controller.ts b/src/controllers/report-controller.ts
index 33dd915..b974496 100644
--- a/src/controllers/report-controller.ts
+++ b/src/controllers/report-controller.ts
@@ -52,6 +52,8 @@ export class ReportController extends Controller {
 
     const queryData = await elasticsearch.search({
       index: ELASTICSEARCH_INDEX,
+      scroll: '1m', // เวลาที่ scroll session จะคงอยู่
+      size: 10000, 
       query: {
         bool: {
           must: [
@@ -68,6 +70,7 @@ export class ReportController extends Controller {
                           "host",
                           "responseCode",
                           "output",
+                          "userName",
                           "rootId",
                         ].map((v) => ({
                           wildcard: { [`${v}.keyword`]: `*${search}*` },
@@ -118,6 +121,18 @@ export class ReportController extends Controller {
       },
       sort: [{ startTimeStamp: sort }],
     });
+    let scrollId = queryData._scroll_id;
+    let results = queryData.hits.hits;
+
+    // ดึงข้อมูลถัดไป
+    const nextBatch = await elasticsearch.scroll({
+      scroll_id: scrollId,
+      scroll: '1m',
+    });
+
+    // เก็บข้อมูลทั้งหมดใน results
+    results = results.concat(nextBatch.hits.hits);
+    
     interface DocumentSource {
       startTimeStamp: Date;
       userName: string;
@@ -128,7 +143,7 @@ export class ReportController extends Controller {
       logType: string;
       responseDescription: string;
     }
-    const raw_data = queryData.hits.hits.map((x) => {
+    const raw_data = results.map((x) => {
       const source = x._source as DocumentSource;
       return {
         id: x._id,