Доработка Пагинации в логи

2026-06-18 11:01:39 +03:00
parent 0cea7d5e9d
commit 35caa2bb72
4 changed files with 745 additions and 243 deletions
--- a/cmd/server/main.go
+++ b/cmd/server/main.go
@@ -106,58 +106,112 @@ func (a *API) HandleLogFiles(w http.ResponseWriter, r *http.Request) {

 // HandleLogEvents - чтение событий
 func (a *API) HandleLogEvents(w http.ResponseWriter, r *http.Request) {
-	limit := 100
-	if l := r.URL.Query().Get("limit"); l != "" {
-		if parsed, err := strconv.Atoi(l); err == nil {
-			limit = parsed
-		}
-	}
+    // Параметры пагинации
+    page := 1
+    if p := r.URL.Query().Get("page"); p != "" {
+        if parsed, err := strconv.Atoi(p); err == nil && parsed > 0 {
+            page = parsed
+        }
+    }

-	eventsPath, err := logger.GetEventHumanLogPath()
-	if err != nil {
-		http.Error(w, err.Error(), 500)
-		return
-	}
+    pageSize := 100
+    if ps := r.URL.Query().Get("page_size"); ps != "" {
+        if parsed, err := strconv.Atoi(ps); err == nil && parsed > 0 {
+            pageSize = parsed
+        }
+    }

-	content, err := os.ReadFile(eventsPath)
-	if err != nil {
-		http.Error(w, err.Error(), 500)
-		return
-	}
+    eventsPath, err := logger.GetEventHumanLogPath()
+    if err != nil {
+        http.Error(w, err.Error(), 500)
+        return
+    }

-	lines := strings.Split(string(content), "\n")
-	// Берем последние N строк
-	if len(lines) > limit+1 {
-		lines = lines[len(lines)-limit-1:]
-	}
+    content, err := os.ReadFile(eventsPath)
+    if err != nil {
+        http.Error(w, err.Error(), 500)
+        return
+    }

-	// Парсим строки для JSON
-	type Event struct {
-		Time  string `json:"time"`
-		Event string `json:"event"`
-	}
+    // Разбиваем на строки
+    lines := strings.Split(string(content), "\n")

-	var events []Event
-	for _, line := range lines {
-		if line == "" {
-			continue
-		}
-		// Формат: [2026-06-16 11:23:45.123] EVENT: СЕРВЕР_ЗАПУЩЕН
-		parts := strings.SplitN(line, "] EVENT: ", 2)
-		if len(parts) == 2 {
-			events = append(events, Event{
-				Time:  strings.TrimPrefix(parts[0], "["),
-				Event: parts[1],
-			})
-		}
-	}
+    // Удаляем пустые строки
+    var nonEmptyLines []string
+    for _, line := range lines {
+        if line != "" {
+            nonEmptyLines = append(nonEmptyLines, line)
+        }
+    }
+    lines = nonEmptyLines

-	writeJSON(w, map[string]any{
-		"events": events,
-		"total":  len(events),
-	})
+    total := len(lines)
+    totalPages := (total + pageSize - 1) / pageSize
+
+    if totalPages == 0 {
+        totalPages = 1
+    }
+
+    // Корректируем номер страницы
+    if page > totalPages {
+        page = totalPages
+    }
+    if page < 1 {
+        page = 1
+    }
+
+    // Вычисляем смещение (нумерация страниц с 1)
+    // Страница 1 → самые ранние записи (начало файла)
+    // Страница N → самые поздние записи (конец файла)
+    start := (page - 1) * pageSize
+    end := start + pageSize
+    if end > total {
+        end = total
+    }
+
+    // Получаем строки для текущей страницы
+    var resultLines []string
+    if start < total {
+        resultLines = lines[start:end]
+    } else {
+        resultLines = []string{}
+    }
+
+    // Парсим строки для JSON
+    type Event struct {
+        Time  string `json:"time"`
+        Event string `json:"event"`
+    }
+
+    var events []Event
+    for _, line := range resultLines {
+        if line == "" {
+            continue
+        }
+        parts := strings.SplitN(line, "] EVENT: ", 2)
+        if len(parts) == 2 {
+            events = append(events, Event{
+                Time:  strings.TrimPrefix(parts[0], "["),
+                Event: parts[1],
+            })
+        }
+    }
+
+    writeJSON(w, map[string]any{
+        "events":        events,
+        "total":         total,
+        "page":          page,
+        "page_size":     pageSize,
+        "total_pages":   totalPages,
+        "has_previous":  page > 1,
+        "has_next":      page < totalPages,
+        "returned":      len(events),
+        "start_index":   start + 1,
+        "end_index":     end,
+    })
 }

+
 // HandleLogData - чтение данных из конкретного bin файла
 func (a *API) HandleLogData(w http.ResponseWriter, r *http.Request) {
 	filename := r.URL.Query().Get("file")