feat(history): add pagination to history list

- Add count query to history
- Update manager to return paginated history

Author: maniac-en

db/queries/history.sql

@@ -17,6 +17,10 @@ WHERE collection_id = ?
 ORDER BY executed_at DESC
 LIMIT ? OFFSET ?;
 
+-- name: CountHistoryByCollection :one
+SELECT COUNT(*) FROM history
+WHERE collection_id = ?;
+
 -- name: DeleteHistoryEntry :exec
 DELETE FROM history
 WHERE id = ?;

internal/database/history.sql.go

@@ -58,51 +58,61 @@ func (h *HistoryManager) List(ctx context.Context) ([]HistoryEntity, error) {
 	return nil, fmt.Errorf("use ListByCollection to list history entries")
 }
 
-func (h *HistoryManager) ListByCollection(ctx context.Context, collectionID int64, limit, offset int) ([]HistoryEntity, error) {
+func (h *HistoryManager) ListByCollection(ctx context.Context, collectionID int64, limit, offset int) (PaginatedHistory, error) {
 	if err := crud.ValidateID(collectionID); err != nil {
-		return nil, err
+		return PaginatedHistory{}, err
 	}
 
+	// Get total count
+	total, err := h.DB.CountHistoryByCollection(ctx, sql.NullInt64{Int64: collectionID, Valid: true})
+	if err != nil {
+		log.Error("failed to count history by collection", "collection_id", collectionID, "error", err)
+		return PaginatedHistory{}, err
+	}
+
+	// Get paginated results
 	summaries, err := h.DB.GetHistoryByCollection(ctx, database.GetHistoryByCollectionParams{
 		CollectionID: sql.NullInt64{Int64: collectionID, Valid: true},
 		Limit:        int64(limit),
 		Offset:       int64(offset),
 	})
 	if err != nil {
 		log.Error("failed to list history by collection", "collection_id", collectionID, "error", err)
-		return nil, err
+		return PaginatedHistory{}, err
 	}
 
+	// Convert to entities
 	entities := make([]HistoryEntity, len(summaries))
 	for i, summary := range summaries {
 		entities[i] = HistoryEntity{History: database.History{
-			ID:         summary.ID,
-			Method:     summary.Method,
-			Url:        summary.Url,
-			StatusCode: summary.StatusCode,
-			ExecutedAt: summary.ExecutedAt,
+			ID:           summary.ID,
+			Method:       summary.Method,
+			Url:          summary.Url,
+			StatusCode:   summary.StatusCode,
+			ExecutedAt:   summary.ExecutedAt,
 			EndpointName: summary.EndpointName,
 		}}
 	}
 
-	log.Info("listed history by collection", "collection_id", collectionID, "count", len(entities), "limit", limit, "offset", offset)
-	return entities, nil
-}
+	// Calculate pagination metadata
+	totalPages := int((total + int64(limit) - 1) / int64(limit))
+	currentPage := (offset / limit) + 1
+	hasNext := (offset + limit) < int(total)
+	hasPrev := offset > 0
+
+	result := PaginatedHistory{
+		Items:       entities,
+		Total:       total,
+		HasNext:     hasNext,
+		HasPrev:     hasPrev,
+		Limit:       limit,
+		Offset:      offset,
+		TotalPages:  totalPages,
+		CurrentPage: currentPage,
+	}
 
-type ExecutionData struct {
-	CollectionID   int64
-	CollectionName string
-	EndpointName   string
-	Method         string
-	URL            string
-	Headers        map[string]string
-	QueryParams    map[string]string
-	RequestBody    string
-	StatusCode     int
-	ResponseBody   string
-	ResponseHeaders map[string][]string
-	Duration       time.Duration
-	ResponseSize   int64
+	log.Info("listed history by collection", "collection_id", collectionID, "count", len(entities), "total", total, "page", currentPage, "total_pages", totalPages)
+	return result, nil
 }
 
 func (h *HistoryManager) RecordExecution(ctx context.Context, data ExecutionData) (HistoryEntity, error) {
@@ -158,4 +168,5 @@ func validateExecutionData(data ExecutionData) error {
 	}
 
 	return nil
-}
+}
+

internal/history/manager.go

@@ -29,4 +29,31 @@ func (h HistoryEntity) GetCreatedAt() time.Time {
 
 func (h HistoryEntity) GetUpdatedAt() time.Time {
 	return h.GetCreatedAt()
-}
+}
+
+type PaginatedHistory struct {
+	Items       []HistoryEntity
+	Total       int64
+	HasNext     bool
+	HasPrev     bool
+	Limit       int
+	Offset      int
+	TotalPages  int
+	CurrentPage int
+}
+
+type ExecutionData struct {
+	CollectionID    int64
+	CollectionName  string
+	EndpointName    string
+	Method          string
+	URL             string
+	Headers         map[string]string
+	QueryParams     map[string]string
+	RequestBody     string
+	StatusCode      int
+	ResponseBody    string
+	ResponseHeaders map[string][]string
+	Duration        time.Duration
+	ResponseSize    int64
+}