Changes console behavior to streaming by default, adds relative/absol…

…ute time filtering options (#9)

* Changed default behavior in console from fetching all logs to
streaming new data
* Added a selector that allows users to filter logs using relative time
(e.g. 5 minutes ago) or absolute time

Dockerfile

@@ -40,7 +40,7 @@ WORKDIR /frontend
 
 # enable pnpm
 RUN corepack enable
-RUN corepack prepare [email protected].1 --activate
+RUN corepack prepare [email protected].3 --activate
 
 # set up git+ssh for private package download from github
 RUN apk add git openssh-client

backend/graph/helpers.go

@@ -32,7 +32,6 @@ import (
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/utils/ptr"
 
-	"github.com/kubetail-org/kubetail/graph/lib"
 	"github.com/kubetail-org/kubetail/graph/model"
 )
 
@@ -219,17 +218,6 @@ func newLogRecordFromLogLine(logLine string) model.LogRecord {
 	}
 }
 
-func validatePodLogQueryTimeArgs(now time.Time, args ...string) error {
-	for _, arg := range args {
-		if ts, err := time.Parse(time.RFC3339Nano, arg); err == nil {
-			if ts.After(now) {
-				return lib.NewValidationError("custom", "`since` and `until` timestamp values must be in the past")
-			}
-		}
-	}
-	return nil
-}
-
 func tailPodLog(ctx context.Context, clientset kubernetes.Interface, namespace string, name string, container *string, args TailArgs) (<-chan model.LogRecord, error) {
 	// init output channel
 	ch := make(chan model.LogRecord)
@@ -246,7 +234,8 @@ func tailPodLog(ctx context.Context, clientset kubernetes.Interface, namespace s
 	)
 
 	// handle `since`
-	if since := strings.TrimSpace(args.Since); since == "" {
+	since := strings.TrimSpace(args.Since)
+	if strings.ToLower(since) == "beginning" {
 		tailSince = TailSinceBeginning
 	} else if strings.ToLower(since) == "now" {
 		tailSince = TailSinceNow
@@ -270,7 +259,8 @@ func tailPodLog(ctx context.Context, clientset kubernetes.Interface, namespace s
 	}
 
 	// handle `until`
-	if until := strings.TrimSpace(args.Until); until == "" {
+	until := strings.TrimSpace(args.Until)
+	if strings.ToLower(until) == "forever" {
 		tailUntil = TailUntilForever
 	} else if strings.ToLower(until) == "now" {
 		tailUntil = TailUntilTime

backend/graph/schema.graphqls

@@ -618,7 +618,7 @@ type Query {
     name: String!,
     container: String,
     after: String,
-    since: String,
+    since: String = "BEGINNING",
     until: String = "NOW",
     limit: Int @validate(rule: "gt=0", message: "Value must be greater than 0")
   ): [LogRecord!] @nullIfValidationFailed
@@ -678,7 +678,7 @@ type Subscription {
     """
     Returns log records that came until the specified option (e.g. "NOW", "PT1M", "2006-01-03T15:04:05Z07:00")
     """
-    until: String
+    until: String = "FOREVER"
 
     """
     Close the subscription after _n_ records are returned.

backend/internal/ginapp/ginapp_test.go

@@ -280,19 +280,6 @@ func TestHealthz(t *testing.T) {
 	assert.Equal(t, "{\"status\":\"ok\"}", w.Body.String())
 }
 
-func TestGraphQLPlayground(t *testing.T) {
-	app := NewTestApp(nil)
-
-	// check url
-	w := httptest.NewRecorder()
-	r := httptest.NewRequest("GET", "/graphiql", nil)
-	app.ServeHTTP(w, r)
-
-	// check result
-	res := w.Result()
-	assert.Equal(t, http.StatusOK, res.StatusCode)
-}
-
 func TestWraponce(t *testing.T) {
 	app := NewTestApp(nil)
 

frontend/package.json

@@ -18,11 +18,12 @@
     "@heroicons/react": "^2.1.1",
     "async-mutex": "^0.4.1",
     "clsx": "^2.1.0",
-    "date-fns": "^3.3.1",
+    "date-fns": "^2.30.0",
+    "date-fns-tz": "^2.0.0",
     "distinct-colors": "^3.0.0",
     "graphql": "^16.8.1",
     "graphql-ws": "^5.15.0",
-    "kubetail-ui": "github:kubetail-org/kubetail-ui#v0.1.0",
+    "kubetail-ui": "github:kubetail-org/kubetail-ui#v0.1.1",
     "lucide-react": "^0.303.0",
     "react": "^18.2.0",
     "react-day-picker": "^8.10.0",