feat: complete intel dashboard overhaul — flights, views, feeds, settings, AI summaries

Major feature delivery across map visualization, data feeds, and intel analysis:

- Flight markers: airplane SVG icons, callsign removed from map, FlightAware links,
  commercial/private classification
- View modes: GLOBE SAT (default), GLOBE STREET, FLAT MAP, GLOBE MAP with basemap switching
- Map click captures lat/lon coordinates into Target Intel/HUD
- News and GDELT selections populate Target Intel with analysis summaries and clickable links
- Live Feeds section: ISS, Tokyo, Tel Aviv, Tehran, Giza, Yellowstone YouTube streams
- ISS: distinct enlarged marker, crew lookup via open-notify, live stream embed
- ThreatRadar/offseq.com: proxy routes for threats, CVE search, IoC checks
- Analytics layers: real GFS weather tiles (RainViewer radar, NOAA GOES IR),
  Sentinel-2 imagery (EOX cloudless mosaic) — replaces stubs
- Settings workspace: local LLM configuration (Ollama/OpenAI-compatible),
  endpoint/model/API key management, file-based storage
- AI summaries: /api/ai/summarize endpoint, "Generate AI Summary" button in
  Target Intel panel, powered by user-configured local LLM
- Non-live intel (outages, threats, GDELT) moved to analytics mode

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

Author: QRcode1337

argus-app/.gitignore

@@ -40,3 +40,6 @@ yarn-error.log*
 *.tsbuildinfo
 next-env.d.ts
 .env*.local
+
+# user settings (may contain API keys)
+/data/settings.json

argus-app/src/app/api/ai/summarize/route.ts

@@ -0,0 +1,19 @@
+import { NextResponse } from "next/server";
+import { queryLlm } from "@/lib/ai/llmClient";
+
+const SYSTEM_PROMPT = `You are an intelligence analyst. Provide a concise 2-3 sentence summary and analysis of the following item. Focus on strategic significance, potential implications, and key facts. Be direct and factual.`;
+
+export async function POST(req: Request) {
+  const { text, context } = await req.json();
+  if (!text) return NextResponse.json({ error: "text required" }, { status: 400 });
+
+  const prompt = context
+    ? `Context: ${context}\n\nItem to analyze:\n${text}`
+    : `Item to analyze:\n${text}`;
+
+  const result = await queryLlm(prompt, SYSTEM_PROMPT);
+  if (result.error) {
+    return NextResponse.json({ summary: null, error: result.error }, { status: 502 });
+  }
+  return NextResponse.json({ summary: result.text });
+}

argus-app/src/app/api/analytics/layers/route.ts

@@ -1,31 +1,64 @@
 import { NextResponse } from "next/server";
 
-// Stub response — returns mock data until PostGIS is populated by the ingestor.
-// When the ingestor runs, replace this with a real pg query.
-const MOCK_LAYERS = [
-  {
-    id: 1,
-    name: "GFS Temperature 2m",
-    variable: "t2m",
-    valid_time: null,
-    tile_url: null, // populated after first ingest
-  },
-  {
-    id: 2,
-    name: "GFS Wind U 10m",
-    variable: "u10",
-    valid_time: null,
-    tile_url: null,
-  },
-  {
-    id: 3,
-    name: "GFS Wind V 10m",
-    variable: "v10",
-    valid_time: null,
-    tile_url: null,
-  },
-];
+interface RainViewerMap {
+  path: string;
+  time: number;
+}
+
+interface RainViewerData {
+  radar?: { past?: RainViewerMap[] };
+}
+
+async function getLatestRadarTimestamp(): Promise<string> {
+  try {
+    const res = await fetch("https://api.rainviewer.com/public/weather-maps.json", {
+      next: { revalidate: 300 },
+    });
+    const data: RainViewerData = await res.json();
+    const past = data?.radar?.past;
+    if (past && past.length > 0) {
+      return past[past.length - 1].path;
+    }
+  } catch {
+    // fall through to default
+  }
+  return "/v2/radar/nowcast";
+}
 
 export async function GET() {
-  return NextResponse.json({ layers: MOCK_LAYERS });
+  const radarPath = await getLatestRadarTimestamp();
+
+  const layers = [
+    {
+      id: "gfs_precip_radar",
+      label: "Precipitation Radar",
+      source: "RainViewer",
+      type: "xyz",
+      tileUrl: `https://tilecache.rainviewer.com${radarPath}/256/{z}/{x}/{y}/6/1_1.png`,
+      available: true,
+    },
+    {
+      id: "gfs_satellite_ir",
+      label: "Satellite IR (GOES)",
+      source: "NOAA / Iowa Mesonet",
+      type: "xyz",
+      tileUrl:
+        "https://mesonet.agron.iastate.edu/cache/tile.py/1.0.0/goes-vis-1km-900913/{z}/{x}/{y}.png",
+      available: true,
+    },
+    {
+      id: "sentinel_imagery",
+      label: "Sentinel-2 Imagery",
+      source: "EOX / Sentinel-2 Cloudless",
+      type: "xyz",
+      tileUrl:
+        "https://tiles.maps.eox.at/wmts/1.0.0/s2cloudless-2021_3857/default/GoogleMapsCompatible/{z}/{y}/{x}.jpg",
+      available: true,
+    },
+  ];
+
+  return NextResponse.json(
+    { layers, available_file_count: layers.length, fallback: false },
+    { headers: { "Cache-Control": "public, max-age=300" } },
+  );
 }

argus-app/src/app/api/feeds/aisstream/route.ts

@@ -25,14 +25,58 @@ type AisCache = {
   cachedAt: string;
 };
 
+type RawAisMessage = {
+  Message?: {
+    PositionReport?: {
+      Latitude?: unknown;
+      Longitude?: unknown;
+      UserID?: unknown;
+      MMSI?: unknown;
+      Sog?: unknown;
+      Cog?: unknown;
+      TrueHeading?: unknown;
+      NavigationalStatus?: unknown;
+    };
+  };
+  MetaData?: {
+    MMSI?: unknown;
+    time_utc?: string;
+    time?: string;
+    ShipName?: string;
+    CallSign?: string;
+  };
+};
+
+type WsLike = {
+  on: (event: string, listener: (...args: unknown[]) => void) => void;
+  send: (data: string) => void;
+  close: () => void;
+};
+
+type WsConstructor = new (
+  url: string,
+  options: { handshakeTimeout: number },
+) => WsLike;
+
 let cache: AisCache | null = null;
 
 const REQUEST_TIMEOUT_MS = Number(process.env.AISSTREAM_TIMEOUT_MS ?? 12000);
 const MAX_MESSAGES = Number(process.env.AISSTREAM_MAX_MESSAGES ?? 200);
 
-function normalizeAisMessage(raw: any): AisVessel | null {
-  const position = raw?.Message?.PositionReport;
-  const metadata = raw?.MetaData;
+function rawDataToString(data: unknown): string {
+  if (typeof data === "string") return data;
+  if (data instanceof Buffer) return data.toString("utf8");
+  if (data instanceof ArrayBuffer) return Buffer.from(data).toString("utf8");
+  if (Array.isArray(data) && data.every((item) => item instanceof Buffer)) {
+    return Buffer.concat(data).toString("utf8");
+  }
+  return String(data);
+}
+
+function normalizeAisMessage(raw: unknown): AisVessel | null {
+  const message = raw as RawAisMessage;
+  const position = message?.Message?.PositionReport;
+  const metadata = message?.MetaData;
   if (!position) return null;
 
   const lat = Number(position.Latitude);
@@ -61,8 +105,8 @@ async function fetchSnapshotFromWs(apiKey: string): Promise<AisPayload> {
   process.env.WS_NO_BUFFER_UTIL = "1";
   process.env.WS_NO_UTF_8_VALIDATE = "1";
 
-  const wsModule: any = await import("ws");
-  const WebSocket = wsModule.default ?? wsModule;
+  const wsModule = (await import("ws")) as { default?: WsConstructor };
+  const WebSocket = (wsModule.default ?? (wsModule as unknown as WsConstructor));
 
   return new Promise((resolve, reject) => {
     const vessels = new Map<number, AisVessel>();
@@ -97,9 +141,9 @@ async function fetchSnapshotFromWs(apiKey: string): Promise<AisPayload> {
       );
     });
 
-    ws.on("message", (data: any) => {
+    ws.on("message", (data: unknown) => {
       try {
-        const parsed = JSON.parse(data.toString());
+        const parsed = JSON.parse(rawDataToString(data));
         const vessel = normalizeAisMessage(parsed);
         if (vessel) vessels.set(vessel.mmsi, vessel);
 

argus-app/src/app/api/feeds/iss/route.ts

@@ -0,0 +1,69 @@
+import { NextResponse } from "next/server";
+
+export const dynamic = "force-dynamic";
+
+type AstroPerson = {
+  craft: string;
+  name: string;
+};
+
+type AstrosResponse = {
+  message?: string;
+  number?: number;
+  people?: AstroPerson[];
+};
+
+const OPEN_NOTIFY_ASTROS = "http://api.open-notify.org/astros.json";
+const DEFAULT_VIDEO_URL = "https://www.youtube.com/embed/21X5lGlDOfg";
+const DEFAULT_MORE_INFO_URL = "https://www.nasa.gov/international-space-station/";
+
+export async function GET() {
+  try {
+    const controller = new AbortController();
+    const timeout = setTimeout(() => controller.abort(), 6000);
+
+    let crew: string[] = [];
+    try {
+      const response = await fetch(OPEN_NOTIFY_ASTROS, {
+        cache: "no-store",
+        signal: controller.signal,
+      });
+      if (response.ok) {
+        const payload = (await response.json()) as AstrosResponse;
+        crew = (payload.people ?? [])
+          .filter((person) => person.craft?.toUpperCase().includes("ISS"))
+          .map((person) => person.name);
+      }
+    } finally {
+      clearTimeout(timeout);
+    }
+
+    return NextResponse.json(
+      {
+        craft: "ISS",
+        crew,
+        updatedAt: new Date().toISOString(),
+        videoUrl: DEFAULT_VIDEO_URL,
+        moreInfoUrl: DEFAULT_MORE_INFO_URL,
+      },
+      {
+        status: 200,
+        headers: {
+          "Cache-Control": "public, max-age=180",
+        },
+      },
+    );
+  } catch (error) {
+    return NextResponse.json(
+      {
+        craft: "ISS",
+        crew: [],
+        updatedAt: new Date().toISOString(),
+        videoUrl: DEFAULT_VIDEO_URL,
+        moreInfoUrl: DEFAULT_MORE_INFO_URL,
+        error: error instanceof Error ? error.message : "Failed to resolve ISS crew",
+      },
+      { status: 200 },
+    );
+  }
+}

argus-app/src/app/api/feeds/threatradar/ioc/route.ts

@@ -0,0 +1,20 @@
+import { NextResponse } from "next/server";
+
+const BASE = "https://radar.offseq.com/api/v1";
+
+export async function POST(req: Request) {
+  const body = await req.json();
+  try {
+    const res = await fetch(`${BASE}/threats/check-iocs`, {
+      method: "POST",
+      headers: { "Content-Type": "application/json", Accept: "application/json" },
+      body: JSON.stringify(body),
+    });
+    if (!res.ok) throw new Error(`IoC check: ${res.status}`);
+    const data = await res.json();
+    return NextResponse.json(data);
+  } catch (e: unknown) {
+    const msg = e instanceof Error ? e.message : "IoC check failed";
+    return NextResponse.json({ matches: [], error: msg }, { status: 502 });
+  }
+}

argus-app/src/app/api/feeds/threatradar/route.ts

@@ -0,0 +1,21 @@
+import { NextResponse } from "next/server";
+import { normalizeThreatRadar } from "@/lib/ingest/threatradar";
+
+const BASE = "https://radar.offseq.com/api/v1";
+
+export async function GET(req: Request) {
+  const { searchParams } = new URL(req.url);
+  const limit = searchParams.get("limit") ?? "10";
+  try {
+    const res = await fetch(`${BASE}/threats?limit=${limit}`, {
+      headers: { Accept: "application/json" },
+      next: { revalidate: 300 },
+    });
+    if (!res.ok) throw new Error(`ThreatRadar: ${res.status}`);
+    const raw = await res.json();
+    return NextResponse.json(normalizeThreatRadar(raw));
+  } catch (e: unknown) {
+    const msg = e instanceof Error ? e.message : "ThreatRadar unavailable";
+    return NextResponse.json({ threats: [], total: 0, updatedAt: new Date().toISOString(), error: msg }, { status: 502 });
+  }
+}

argus-app/src/app/api/feeds/threatradar/search/route.ts

@@ -0,0 +1,20 @@
+import { NextResponse } from "next/server";
+
+const BASE = "https://radar.offseq.com/api/v1";
+
+export async function GET(req: Request) {
+  const { searchParams } = new URL(req.url);
+  const q = searchParams.get("q") ?? "";
+  if (!q) return NextResponse.json({ error: "q param required" }, { status: 400 });
+  try {
+    const res = await fetch(`${BASE}/threats/search?q=${encodeURIComponent(q)}`, {
+      headers: { Accept: "application/json" },
+    });
+    if (!res.ok) throw new Error(`Search: ${res.status}`);
+    const data = await res.json();
+    return NextResponse.json(data);
+  } catch (e: unknown) {
+    const msg = e instanceof Error ? e.message : "Search failed";
+    return NextResponse.json({ results: [], error: msg }, { status: 502 });
+  }
+}

argus-app/src/app/api/settings/route.ts

@@ -0,0 +1,27 @@
+import { NextResponse } from "next/server";
+import { readSettings, writeSettings } from "@/lib/settings";
+import { AppSettings } from "@/types/settings";
+
+export async function GET() {
+  const settings = await readSettings();
+  const safe = {
+    ...settings,
+    llm: { ...settings.llm, apiKey: settings.llm.apiKey ? "••••••" : undefined },
+  };
+  return NextResponse.json(safe);
+}
+
+export async function POST(req: Request) {
+  const body = (await req.json()) as Partial<AppSettings>;
+  const current = await readSettings();
+  const merged: AppSettings = {
+    ...current,
+    llm: {
+      ...current.llm,
+      ...(body.llm ?? {}),
+      apiKey: body.llm?.apiKey === "••••••" ? current.llm.apiKey : (body.llm?.apiKey ?? current.llm.apiKey),
+    },
+  };
+  await writeSettings(merged);
+  return NextResponse.json({ ok: true });
+}