Make stats endpoint respect selected time window instead of hardcoded last hour

P99 latency and active count now use the same from/to parameters as the
timeseries sparklines, so all stat cards are consistent with the user's
selected time range.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

cameleer3-server-app/src/main/java/com/cameleer3/server/app/controller/SearchController.java

@@ -70,8 +70,11 @@ public class SearchController {
 
     @GetMapping("/stats")
     @Operation(summary = "Aggregate execution stats (P99 latency, active count)")
-    public ResponseEntity<ExecutionStats> stats() {
-        return ResponseEntity.ok(searchService.stats());
+    public ResponseEntity<ExecutionStats> stats(
+            @RequestParam Instant from,
+            @RequestParam(required = false) Instant to) {
+        Instant end = to != null ? to : Instant.now();
+        return ResponseEntity.ok(searchService.stats(from, end));
     }
 
     @GetMapping("/stats/timeseries")

cameleer3-server-app/src/main/java/com/cameleer3/server/app/search/ClickHouseSearchEngine.java

@@ -88,11 +88,11 @@ public class ClickHouseSearchEngine implements SearchEngine {
     }
 
     @Override
-    public ExecutionStats stats() {
+    public ExecutionStats stats(Instant from, Instant to) {
         Long p99 = jdbcTemplate.queryForObject(
                 "SELECT quantile(0.99)(duration_ms) FROM route_executions " +
-                "WHERE start_time >= now() - INTERVAL 1 HOUR",
-                Long.class);
+                "WHERE start_time >= ? AND start_time <= ?",
+                Long.class, Timestamp.from(from), Timestamp.from(to));
         Long active = jdbcTemplate.queryForObject(
                 "SELECT count() FROM route_executions WHERE status = 'RUNNING'",
                 Long.class);

cameleer3-server-core/src/main/java/com/cameleer3/server/core/search/ExecutionStats.java

@@ -3,7 +3,7 @@ package com.cameleer3.server.core.search;
 /**
  * Aggregate execution statistics.
  *
- * @param p99LatencyMs 99th percentile duration in milliseconds (last hour)
+ * @param p99LatencyMs 99th percentile duration in milliseconds within the requested time window
  * @param activeCount  number of currently running executions
  */
 public record ExecutionStats(long p99LatencyMs, long activeCount) {}

cameleer3-server-core/src/main/java/com/cameleer3/server/core/search/SearchEngine.java

@@ -28,9 +28,11 @@ public interface SearchEngine {
     /**
      * Compute aggregate stats: P99 latency and count of currently running executions.
      *
+     * @param from start of the time window
+     * @param to   end of the time window
      * @return execution stats
      */
-    ExecutionStats stats();
+    ExecutionStats stats(java.time.Instant from, java.time.Instant to);
 
     /**
      * Compute bucketed time-series stats over a time window.

cameleer3-server-core/src/main/java/com/cameleer3/server/core/search/SearchService.java

@@ -32,8 +32,8 @@ public class SearchService {
     /**
      * Compute aggregate execution stats (P99 latency, active count).
      */
-    public ExecutionStats stats() {
-        return engine.stats();
+    public ExecutionStats stats(java.time.Instant from, java.time.Instant to) {
+        return engine.stats(from, to);
     }
 
     /**

ui/src/api/openapi.json

@@ -664,6 +664,26 @@
         ],
         "summary": "Aggregate execution stats (P99 latency, active count)",
         "operationId": "stats",
+        "parameters": [
+          {
+            "name": "from",
+            "in": "query",
+            "required": true,
+            "schema": {
+              "type": "string",
+              "format": "date-time"
+            }
+          },
+          {
+            "name": "to",
+            "in": "query",
+            "required": false,
+            "schema": {
+              "type": "string",
+              "format": "date-time"
+            }
+          }
+        ],
         "responses": {
           "200": {
             "description": "OK",

ui/src/api/queries/executions.ts

@@ -2,14 +2,23 @@ import { useQuery } from '@tanstack/react-query';
 import { api } from '../client';
 import type { SearchRequest } from '../schema';
 
-export function useExecutionStats() {
+export function useExecutionStats(timeFrom: string | undefined, timeTo: string | undefined) {
   return useQuery({
-    queryKey: ['executions', 'stats'],
+    queryKey: ['executions', 'stats', timeFrom, timeTo],
     queryFn: async () => {
-      const { data, error } = await api.GET('/search/stats');
+      const { data, error } = await api.GET('/search/stats', {
+        params: {
+          query: {
+            from: timeFrom!,
+            to: timeTo || undefined,
+          },
+        },
+      });
       if (error) throw new Error('Failed to load stats');
       return data!;
     },
+    enabled: !!timeFrom,
+    placeholderData: (prev) => prev,
     refetchInterval: 10_000,
   });
 }

ui/src/api/schema.d.ts

@@ -97,6 +97,12 @@ export interface paths {
   };
   '/search/stats': {
     get: {
+      parameters: {
+        query: {
+          from: string;
+          to?: string;
+        };
+      };
       responses: {
         200: {
           content: {

ui/src/pages/executions/ExecutionExplorer.tsx

@@ -10,11 +10,10 @@ export function ExecutionExplorer() {
   const { toSearchRequest, offset, limit, setOffset, live, toggleLive } = useExecutionSearch();
   const searchRequest = toSearchRequest();
   const { data, isLoading, isFetching } = useSearchExecutions(searchRequest, live);
-  const { data: stats } = useExecutionStats();
-  const { data: timeseries } = useStatsTimeseries(
-    searchRequest.timeFrom ?? undefined,
-    searchRequest.timeTo ?? undefined,
-  );
+  const timeFrom = searchRequest.timeFrom ?? undefined;
+  const timeTo = searchRequest.timeTo ?? undefined;
+  const { data: stats } = useExecutionStats(timeFrom, timeTo);
+  const { data: timeseries } = useStatsTimeseries(timeFrom, timeTo);
 
   const sparkTotal = timeseries?.buckets.map((b) => b.totalCount) ?? [];
   const sparkFailed = timeseries?.buckets.map((b) => b.failedCount) ?? [];
@@ -53,7 +52,7 @@ export function ExecutionExplorer() {
         <StatCard label="Total Matches" value={total.toLocaleString()} accent="amber" change={`from current search`} sparkData={sparkTotal} />
         <StatCard label="Avg Duration" value={`${avgDuration}ms`} accent="cyan" sparkData={sparkAvgDuration} />
         <StatCard label="Failed (page)" value={failedCount.toString()} accent="rose" sparkData={sparkFailed} />
-        <StatCard label="P99 Latency" value={stats ? `${stats.p99LatencyMs}ms` : '--'} accent="green" change="last hour" sparkData={sparkP99} />
+        <StatCard label="P99 Latency" value={stats ? `${stats.p99LatencyMs}ms` : '--'} accent="green" sparkData={sparkP99} />
         <StatCard label="In-Flight" value={stats ? stats.activeCount.toString() : '--'} accent="blue" change="running executions" sparkData={sparkActive} />
       </div>