feat: parse timestamps

api/logs/logs.go

@@ -1,7 +1,9 @@
 package logs
 
 import (
+	"bufio"
 	"fmt"
+	"strings"
 	"time"
 
 	"github.com/flanksource/kommons"
@@ -132,6 +134,23 @@ type Result struct {
 	Labels  map[string]string `json:"labels,omitempty"`
 }
 
+func (r Result) Process() Result {
+	scanner := bufio.NewScanner(strings.NewReader(r.Message))
+	scanner.Split(bufio.ScanWords)
+	if scanner.Scan() {
+		timestamp := scanner.Text()
+		if _, err := time.Parse(time.RFC3339, timestamp); err == nil {
+			r.Time = timestamp
+			r.Message = strings.ReplaceAll(r.Message, timestamp, "")
+			fmt.Println(r.Message)
+		} else {
+			fmt.Printf("error parsing timestamp %s: %v\n", timestamp, err)
+		}
+	}
+	r.Message = strings.TrimSpace(r.Message)
+	return r
+}
+
 type SearchAPI interface {
 	Search(q *SearchParams) (r SearchResults, err error)
 }

pkg/kubernetes/search.go

@@ -77,7 +77,10 @@ func (s *KubernetesSearch) getLogResultsForPods(q *logs.SearchParams, pods *v1.P
 			}
 			for _, line := range containerLogs {
 				line.Labels = labels
-				results = append(results, line)
+				line = line.Process()
+				if line.Message != "" {
+					results = append(results, line)
+				}
 			}
 		}
 	}