fix(sanctions): pass timeRange filter to sanctions pressure API

proto/worldmonitor/sanctions/v1/list_sanctions_pressure.proto

@@ -10,6 +10,10 @@ import "worldmonitor/sanctions/v1/sanctions_entry.proto";
 // ListSanctionsPressureRequest retrieves recent OFAC sanctions pressure state.
 message ListSanctionsPressureRequest {
   int32 max_items = 1 [(sebuf.http.query) = { name: "max_items" }];
+  // Optional time range filter (e.g. "1h", "6h", "24h", "48h", "7d").
+  // When set, entries are filtered to those with effective_at within
+  // the window and counts are recomputed accordingly.
+  string time_range = 2 [(sebuf.http.query) = { name: "time_range" }];
 }
 
 // ListSanctionsPressureResponse contains normalized OFAC pressure summaries and recent entries.

server/worldmonitor/sanctions/v1/list-sanctions-pressure.ts

@@ -2,6 +2,9 @@ import type {
   ListSanctionsPressureRequest,
   ListSanctionsPressureResponse,
   SanctionsServiceHandler,
+  SanctionsEntry,
+  CountrySanctionsPressure,
+  ProgramSanctionsPressure,
   ServerContext,
 } from '../../../../src/generated/server/worldmonitor/sanctions/v1/service_server';
 
@@ -11,6 +14,14 @@ const REDIS_CACHE_KEY = 'sanctions:pressure:v1';
 const DEFAULT_MAX_ITEMS = 25;
 const MAX_ITEMS_LIMIT = 60;
 
+const TIME_RANGE_MS: Record<string, number> = {
+  '1h': 60 * 60 * 1000,
+  '6h': 6 * 60 * 60 * 1000,
+  '24h': 24 * 60 * 60 * 1000,
+  '48h': 48 * 60 * 60 * 1000,
+  '7d': 7 * 24 * 60 * 60 * 1000,
+};
+
 // All fetch/parse/scoring logic lives in the Railway seed script
 // (scripts/seed-sanctions-pressure.mjs). This handler reads pre-built
 // data from Redis only (gold standard: Vercel reads, Railway writes).
@@ -36,6 +47,85 @@ function emptyResponse(): ListSanctionsPressureResponse {
   };
 }
 
+/**
+ * When a time_range is supplied (e.g. "7d"), recompute newEntryCount and
+ * per-country / per-program counts so they reflect only entries whose
+ * effectiveAt falls within the requested window.
+ */
+function applyTimeRangeFilter(
+  data: ListSanctionsPressureResponse,
+  timeRange: string,
+  maxItems: number,
+): ListSanctionsPressureResponse {
+  const windowMs = TIME_RANGE_MS[timeRange];
+  if (!windowMs) {
+    // Unknown or 'all' — return unfiltered (existing behaviour)
+    return { ...data, entries: (data.entries ?? []).slice(0, maxItems) };
+  }
+
+  const cutoff = Date.now() - windowMs;
+  const allEntries = data.entries ?? [];
+
+  // Mark entries whose effectiveAt falls within the window as "new"
+  // and recompute the global / per-country / per-program counts.
+  const retagged: SanctionsEntry[] = allEntries.map((e) => {
+    const ts = typeof e.effectiveAt === 'string' ? Number(e.effectiveAt) : (e.effectiveAt as unknown as number);
+    const withinWindow = Number.isFinite(ts) && ts > 0 && ts >= cutoff;
+    return { ...e, isNew: withinWindow };
+  });
+
+  const newEntryCount = retagged.filter((e) => e.isNew).length;
+
+  // Rebuild country pressure with recomputed newEntryCount
+  const countryMap = new Map<string, CountrySanctionsPressure>();
+  for (const entry of retagged) {
+    for (const code of (entry.countryCodes ?? [])) {
+      const existing = countryMap.get(code);
+      if (existing) {
+        if (entry.isNew) existing.newEntryCount += 1;
+      } else {
+        // Find matching country from original data
+        const orig = (data.countries ?? []).find((c) => c.countryCode === code);
+        if (orig) {
+          countryMap.set(code, { ...orig, newEntryCount: entry.isNew ? 1 : 0 });
+        }
+      }
+    }
+  }
+  const countries = countryMap.size > 0
+    ? Array.from(countryMap.values())
+    : (data.countries ?? []).map((c) => ({ ...c, newEntryCount: 0 }));
+
+  // Rebuild program pressure with recomputed newEntryCount
+  const programMap = new Map<string, ProgramSanctionsPressure>();
+  for (const entry of retagged) {
+    for (const prog of (entry.programs ?? [])) {
+      const existing = programMap.get(prog);
+      if (existing) {
+        if (entry.isNew) existing.newEntryCount += 1;
+      } else {
+        const orig = (data.programs ?? []).find((p) => p.program === prog);
+        if (orig) {
+          programMap.set(prog, { ...orig, newEntryCount: entry.isNew ? 1 : 0 });
+        }
+      }
+    }
+  }
+  const programs = programMap.size > 0
+    ? Array.from(programMap.values())
+    : (data.programs ?? []).map((p) => ({ ...p, newEntryCount: 0 }));
+
+  return {
+    ...data,
+    entries: retagged.slice(0, maxItems),
+    countries,
+    programs,
+    newEntryCount,
+    vesselCount: data.vesselCount,
+    aircraftCount: data.aircraftCount,
+  };
+}
+
 export const listSanctionsPressure: SanctionsServiceHandler['listSanctionsPressure'] = async (
   _ctx: ServerContext,
   req: ListSanctionsPressureRequest,
@@ -45,6 +135,11 @@ export const listSanctionsPressure: SanctionsServiceHandler['listSanctionsPressu
     const data = await getCachedJson(REDIS_CACHE_KEY, true) as ListSanctionsPressureResponse & { _state?: unknown } | null;
     if (!data?.totalCount) return emptyResponse();
     const { _state: _discarded, ...rest } = data;
+
+    if (req.timeRange) {
+      return applyTimeRangeFilter(rest, req.timeRange, maxItems);
+    }
+
     return {
       ...rest,
       entries: (data.entries ?? []).slice(0, maxItems),

src/App.ts

@@ -690,6 +690,7 @@ export class App {
       loadAllData: () => this.dataLoader.loadAllData(),
       updateMonitorResults: () => this.dataLoader.updateMonitorResults(),
       loadSecurityAdvisories: () => this.dataLoader.loadSecurityAdvisories(),
+      onTimeRangeChanged: () => { void this.dataLoader.loadSanctionsPressure(); },
     });
 
     this.eventHandlers = new EventHandlerManager(this.state, {

src/app/data-loader.ts

@@ -3065,7 +3065,7 @@ export class DataLoaderManager implements AppModule {
 
   async loadSanctionsPressure(): Promise<void> {
     try {
-      const result = await fetchSanctionsPressure();
+      const result = await fetchSanctionsPressure(this.ctx.currentTimeRange);
       this.callPanel('sanctions-pressure', 'setData', result);
       this.ctx.intelligenceCache.sanctions = result;
       signalAggregator.ingestSanctionsPressure(result.countries);

src/app/panel-layout.ts

@@ -112,6 +112,7 @@ export interface PanelLayoutManagerCallbacks {
   loadAllData: () => Promise<void>;
   updateMonitorResults: () => void;
   loadSecurityAdvisories?: () => Promise<void>;
+  onTimeRangeChanged?: (timeRange: string) => void;
 }
 
 export class PanelLayoutManager implements AppModule {
@@ -131,6 +132,7 @@ export class PanelLayoutManager implements AppModule {
     this.callbacks = callbacks;
     this.applyTimeRangeFilterDebounced = debounce(() => {
       this.applyTimeRangeFilterToNewsPanels();
+      this.callbacks.onTimeRangeChanged?.(ctx.currentTimeRange);
     }, 120);
   }
 

src/generated/client/worldmonitor/sanctions/v1/service_client.ts

@@ -4,6 +4,7 @@
 
 export interface ListSanctionsPressureRequest {
   maxItems: number;
+  timeRange: string;
 }
 
 export interface ListSanctionsPressureResponse {
@@ -121,6 +122,7 @@ export class SanctionsServiceClient {
     let path = "/api/sanctions/v1/list-sanctions-pressure";
     const params = new URLSearchParams();
     if (req.maxItems != null && req.maxItems !== 0) params.set("max_items", String(req.maxItems));
+    if (req.timeRange != null && req.timeRange !== "") params.set("time_range", String(req.timeRange));
     const url = this.baseURL + path + (params.toString() ? "?" + params.toString() : "");
 
     const headers: Record<string, string> = {

src/generated/server/worldmonitor/sanctions/v1/service_server.ts

@@ -4,6 +4,7 @@
 
 export interface ListSanctionsPressureRequest {
   maxItems: number;
+  timeRange: string;
 }
 
 export interface ListSanctionsPressureResponse {
@@ -133,6 +134,7 @@ export function createSanctionsServiceRoutes(
           const params = url.searchParams;
           const body: ListSanctionsPressureRequest = {
             maxItems: Number(params.get("max_items") ?? "0"),
+            timeRange: params.get("time_range") ?? "",
           };
           if (options?.validateRequest) {
             const bodyViolations = options.validateRequest("listSanctionsPressure", body);

src/services/sanctions-pressure.ts

@@ -147,7 +147,7 @@ function toResult(response: ListSanctionsPressureResponse): SanctionsPressureRes
   };
 }
 
-export async function fetchSanctionsPressure(): Promise<SanctionsPressureResult> {
+export async function fetchSanctionsPressure(timeRange?: string): Promise<SanctionsPressureResult> {
   const hydrated = getHydratedData('sanctionsPressure') as ListSanctionsPressureResponse | undefined;
   if (hydrated?.entries?.length || hydrated?.countries?.length || hydrated?.programs?.length) {
     const result = toResult(hydrated);
@@ -158,6 +158,7 @@ export async function fetchSanctionsPressure(): Promise<SanctionsPressureResult>
   return breaker.execute(async () => {
     const response = await client.listSanctionsPressure({
       maxItems: 30,
+      timeRange: timeRange ?? '',
     }, {
       signal: AbortSignal.timeout(25_000),
     });