remove 7-day cap on historical query window

Author: dangaiden

internal/infra/mcp/tools/README.md

@@ -57,13 +57,12 @@ evaluated at `end`:
 | HTTP / network errors | `sum_over_time(metric[Ns]) / N` (rate per second) |
 | Inventory tools (clusters, nodes, workloads, pod_containers, cronjobs) | `max_over_time(metric[Ns]) > 0` (workloads with status=ready/desired/running drop the `> 0` guard) |
 
-Validation rules (helper: `time_window.go`):
+Validation rules (helper: `utils.go`):
 
 - `end` without `start` → error.
 - `start` without `end` → `end` defaults to now.
+- `end` in the future → clamped to now.
 - `end <= start` → error.
-- `end > now + 60s` → error (60 s grace for client clock skew).
-- `end - start > SYSDIG_MCP_MAX_INTERVAL` (default **168 h / 7 d**) → error.
 
 Windowed queries carry a 60 s client-side PromQL `Timeout` to fail fast before the
 Sysdig edge proxy's own 80–90 s cut-off.

internal/infra/mcp/tools/utils.go

@@ -3,7 +3,6 @@ package tools
 import (
 	"fmt"
 	"log/slog"
-	"os"
 	"time"
 
 	"github.com/mark3labs/mcp-go/mcp"
@@ -61,8 +60,6 @@ func RequiredPermissionsFromTool(tool mcp.Tool) []string {
 // --- Time-window support for k8s_list_* Monitor tools --------------------
 
 const (
-	maxIntervalEnvVar     = "SYSDIG_MCP_MAX_INTERVAL"
-	defaultMaxInterval    = 168 * time.Hour // 7 days
 	windowedQueryTimeout  = "60s"
 	timeParamStart        = "start"
 	timeParamEnd          = "end"
@@ -115,12 +112,11 @@ func WithTimeWindowParams() mcp.ToolOption {
 // ParseTimeWindow reads "start" and "end" from the request, validates them, and returns
 // the resolved TimeWindow.
 //
-//   - Both absent:                  returns zero-value TimeWindow, nil error.
-//   - end without start:            error ("end requires start").
-//   - start without end:            end = clk.Now().
-//   - invalid RFC3339:              error naming the bad field.
-//   - end <= start:                 error.
-//   - end - start > maxInterval():  error referencing SYSDIG_MCP_MAX_INTERVAL.
+//   - Both absent:       returns zero-value TimeWindow, nil error.
+//   - end without start: error ("end requires start").
+//   - start without end: end = clk.Now().
+//   - invalid RFC3339:   error naming the bad field.
+//   - end <= start:      error.
 func ParseTimeWindow(request mcp.CallToolRequest, clk clock.Clock) (TimeWindow, error) {
 	startStr := mcp.ParseString(request, timeParamStart, "")
 	endStr := mcp.ParseString(request, timeParamEnd, "")
@@ -158,26 +154,9 @@ func ParseTimeWindow(request mcp.CallToolRequest, clk clock.Clock) (TimeWindow,
 		return TimeWindow{}, fmt.Errorf("end (%s) must be after start (%s)", end.Format(time.RFC3339), start.Format(time.RFC3339))
 	}
 
-	window := end.Sub(start)
-	if max := maxInterval(); window > max {
-		return TimeWindow{}, fmt.Errorf("requested window (%s) exceeds maximum allowed (%s); set %s to raise the cap", window, max, maxIntervalEnvVar)
-	}
-
 	return TimeWindow{Start: start, End: end}, nil
 }
 
-// maxInterval returns the configured maximum window duration. The SYSDIG_MCP_MAX_INTERVAL
-// env var is read on every call (not cached) so tests can override it via t.Setenv without
-// bumping into sync.Once-style staleness.
-func maxInterval() time.Duration {
-	if v := os.Getenv(maxIntervalEnvVar); v != "" {
-		if d, err := time.ParseDuration(v); err == nil && d > 0 {
-			return d
-		}
-	}
-	return defaultMaxInterval
-}
-
 // requestHasArg reports whether the caller explicitly supplied the named argument
 // (distinguishes "user passed empty string" from "user didn't pass the key at all").
 func requestHasArg(request mcp.CallToolRequest, name string) bool {