Frontier Overhaul

api/bootstrap.py

@@ -112,10 +112,14 @@ async def bootstrap_db():
                 ADD COLUMN IF NOT EXISTS location_raw TEXT,
                 ADD COLUMN IF NOT EXISTS location_admin1 VARCHAR(100),
                 ADD COLUMN IF NOT EXISTS geo_validation_flags TEXT[],
-                ADD COLUMN IF NOT EXISTS ai_analysis TEXT;
+                ADD COLUMN IF NOT EXISTS ai_analysis TEXT,
+                ADD COLUMN IF NOT EXISTS verification_count INTEGER DEFAULT 1,
+                ADD COLUMN IF NOT EXISTS source_urls TEXT[] DEFAULT '{}',
+                ADD COLUMN IF NOT EXISTS strategic_relevance VARCHAR(15) DEFAULT 'LOW';
                 
                 CREATE INDEX IF NOT EXISTS idx_geo_confidence ON conflict_events(geo_confidence);
                 CREATE INDEX IF NOT EXISTS idx_ai_analysis ON conflict_events USING GIN(to_tsvector('english', COALESCE(ai_analysis, '')));
+                CREATE INDEX IF NOT EXISTS idx_verification ON conflict_events(verification_count DESC);
             """)
             
             log.info("[Bootstrap] Database schema validation and initialization complete.")

api/routes/conflicts.py

@@ -7,6 +7,20 @@ from fastapi.encoders import jsonable_encoder
 
 router = APIRouter(prefix="/conflicts", tags=["Conflicts"])
 
+def serialize_event(d: dict) -> dict:
+    """Standardized event serialization for all API responses."""
+    d["event_time"] = d["event_time"].isoformat() + "Z" if d.get("event_time") else None
+    d["event_date"] = d["event_date"].isoformat() if d.get("event_date") else None
+    d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
+    d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
+    d["is_approximate"] = d.get("geo_precision", 3) >= 3
+    d["ai_analysis"] = d.get("ai_analysis")
+    d["verification_count"] = d.get("verification_count", 1)
+    d["source_urls"] = d.get("source_urls") or []
+    d["strategic_relevance"] = d.get("strategic_relevance", "LOW")
+    if d.get("geom"): del d["geom"]
+    return d
+
 async def check_cache(request: Request, cache_key: str):
     if db.redis:
         cached = await db.redis.get(cache_key)
@@ -76,15 +90,7 @@ async def get_conflicts(
         
     data = [dict(r) for r in records]
     for d in data:
-        # asyncpg returns dates and datetime as objects
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["event_date"] = d["event_date"].isoformat() if d["event_date"] else None
-        d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
-        # New Precision Metadata
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        d["ai_analysis"] = d.get("ai_analysis")
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
 
     response = {
         "status": 200,
@@ -117,13 +123,7 @@ async def get_recent_conflicts(request: Request, days: int = 7, limit: int = 100
         
     data = [dict(r) for r in records]
     for d in data:
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["event_date"] = d["event_date"].isoformat() if d["event_date"] else None
-        d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        d["ai_analysis"] = d.get("ai_analysis")
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
 
     response = {
         "status": 200,
@@ -152,10 +152,7 @@ async def get_ongoing_conflicts(request: Request, limit: int = 50):
     
     data = [dict(r) for r in records]
     for d in data:
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
     
     res = {"status": 200, "success": True, "count": len(data), "data": data}
     await set_cache(cache_key, res, ttl=60) # Short TTL for live data
@@ -181,10 +178,7 @@ async def get_historical_conflicts(request: Request, days_ago: int = 2, limit: i
 
     data = [dict(r) for r in records]
     for d in data:
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
 
     res = {"status": 200, "success": True, "count": len(data), "data": data}
     await set_cache(cache_key, res, ttl=3600) # Long TTL for history
@@ -218,12 +212,7 @@ async def get_conflicts_near(
         
     data = [dict(r) for r in records]
     for d in data:
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["event_date"] = d["event_date"].isoformat() if d["event_date"] else None
-        d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
 
     response = {
         "status": 200,
@@ -251,12 +240,7 @@ async def get_conflicts_country(request: Request, iso3: str, days: int = 30, lim
         
     data = [dict(r) for r in records]
     for d in data:
-        d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-        d["event_date"] = d["event_date"].isoformat() if d["event_date"] else None
-        d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
-        d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-        d["is_approximate"] = d.get("geo_precision", 3) >= 3
-        if d.get("geom"): del d["geom"]
+        serialize_event(d)
 
     response = {
         "status": 200,
@@ -278,13 +262,7 @@ async def get_conflict_detail(event_id: str):
         raise HTTPException(status_code=404, detail="Event not found")
         
     d = dict(record)
-    d["event_time"] = d["event_time"].isoformat() + "Z" if d["event_time"] else None
-    d["event_date"] = d["event_date"].isoformat() if d["event_date"] else None
-    d["ingested_at"] = d["ingested_at"].isoformat() + "Z" if d.get("ingested_at") else None
-    d["geo_confidence"] = float(d.get("geo_confidence") or 0.0)
-    d["is_approximate"] = d.get("geo_precision", 3) >= 3
-    d["ai_analysis"] = d.get("ai_analysis")
-    if d.get("geom"): del d["geom"]
+    serialize_event(d)
 
     return {
         "status": 200,

frontend/src/Dashboard.jsx

@@ -216,10 +216,6 @@ const Dashboard = () => {
           <IncidentIntelligenceCard 
             event={activeIntelEvent} 
             onClose={() => setActiveIntelEvent(null)}
-            onRequestLiveAnalysis={(ev) => {
-               // Optional: trigger manual live re-analysis if ever needed
-               console.log("Live analysis requested for", ev.event_id);
-            }}
           />
         )}
 

frontend/src/components/IncidentIntelligenceCard.jsx

@@ -1,14 +1,28 @@
-import React, { useState } from 'react';
+import React from 'react';
 import { 
   X, ShieldAlert, Target, Users, MapPin, ExternalLink, 
-  Clock, Zap, FileText, ChevronRight, Activity, TrendingUp 
+  Clock, Zap, ChevronRight, AlertTriangle,
+  CheckCircle
 } from 'lucide-react';
 
-const IncidentIntelligenceCard = ({ event, onClose, onRequestLiveAnalysis }) => {
-  const [activeTab, setActiveTab] = useState('sitrep');
-
+const IncidentIntelligenceCard = ({ event, onClose }) => {
   if (!event) return null;
 
+  const isVerified = (event.verification_count || 1) > 1;
+  const relevance = event.strategic_relevance || 'LOW';
+  const relevanceColors = { CRITICAL: 'var(--accent-red)', HIGH: 'var(--accent-amber)', MEDIUM: 'var(--accent-cyan)', LOW: 'var(--text-dim)' };
+
+  // Safe URL parsing
+  const getSourceUrls = () => {
+    const urls = event.source_urls?.length ? event.source_urls : [event.source_url];
+    return urls.filter(u => u && u.startsWith('http'));
+  };
+
+  const safeDomain = (url) => {
+    try { return new URL(url).hostname.replace('www.', ''); }
+    catch { return 'source'; }
+  };
+
   return (
     <div className="incident-intel-card glass-panel shadow-tactical animate-fade-in" style={{
       position: 'absolute',
@@ -16,29 +30,42 @@ const IncidentIntelligenceCard = ({ event, onClose, onRequestLiveAnalysis }) =>
       left: '20px',
       width: '420px',
       maxHeight: 'calc(100vh - 120px)',
-      background: 'rgba(5, 7, 12, 0.95)',
+      background: 'rgba(5, 7, 12, 0.97)',
       borderRadius: '12px',
-      border: '1px solid var(--border-glass)',
+      border: `1px solid ${isVerified ? 'rgba(16, 185, 129, 0.3)' : 'var(--border-glass)'}`,
       zIndex: 1000,
       display: 'flex',
       flexDirection: 'column',
       overflow: 'hidden',
-      color: 'var(--text-primary)'
+      color: 'var(--text-primary)',
+      overflowY: 'auto'
     }}>
       {/* HEADER */}
       <div style={{
         padding: '15px 20px',
-        background: 'rgba(255,255,255,0.03)',
+        background: isVerified ? 'rgba(16, 185, 129, 0.05)' : 'rgba(255,255,255,0.03)',
         borderBottom: '1px solid var(--border-glass)',
         display: 'flex',
         justifyContent: 'space-between',
         alignItems: 'center'
       }}>
-        <div style={{ display: 'flex', alignItems: 'center', gap: '10px' }}>
-          <ShieldAlert size={14} color="var(--accent-red)" />
-          <span style={{ fontSize: '10px', fontWeight: 900, letterSpacing: '2px', color: 'var(--text-dim)' }}>
-            INTEL CASE: {event.event_id?.slice(0, 8)}
+        <div style={{ display: 'flex', alignItems: 'center', gap: '8px', flexWrap: 'wrap' }}>
+          {isVerified ? (
+            <CheckCircle size={14} color="var(--accent-green)" />
+          ) : (
+            <ShieldAlert size={14} color="var(--accent-red)" />
+          )}
+          <span style={{ fontSize: '10px', fontWeight: 900, letterSpacing: '2px', color: isVerified ? 'var(--accent-green)' : 'var(--text-dim)' }}>
+            {isVerified ? `VERIFIED × ${event.verification_count} SOURCES` : `INTEL CASE: ${event.event_id?.slice(0, 8)}`}
           </span>
+          <div style={{ 
+            background: `${relevanceColors[relevance]}20`, 
+            color: relevanceColors[relevance], 
+            padding: '2px 6px', borderRadius: '4px', fontSize: '8px', fontWeight: 900,
+            border: `1px solid ${relevanceColors[relevance]}40`
+          }}>
+            {relevance}
+          </div>
         </div>
         <button 
           onClick={onClose}
@@ -50,100 +77,79 @@ const IncidentIntelligenceCard = ({ event, onClose, onRequestLiveAnalysis }) =>
 
       {/* EVENT CORE INFO */}
       <div style={{ padding: '20px' }}>
-        <h2 style={{ fontSize: '18px', fontWeight: 900, margin: '0 0 10px 0', lineHeight: '1.3' }}>
+        <h2 style={{ fontSize: '16px', fontWeight: 900, margin: '0 0 12px 0', lineHeight: '1.35' }}>
           {event.title}
         </h2>
-        <div style={{ display: 'flex', flexWrap: 'wrap', gap: '12px', marginBottom: '20px' }}>
-          <div style={{ display: 'flex', alignItems: 'center', gap: '6px', fontSize: '11px', color: 'var(--text-secondary)' }}>
-            <MapPin size={12} /> {event.city || 'Sector'}, {event.country}
+        
+        {/* META ROW */}
+        <div style={{ display: 'flex', flexWrap: 'wrap', gap: '10px', marginBottom: '20px' }}>
+          <div style={{ display: 'flex', alignItems: 'center', gap: '5px', fontSize: '11px', color: 'var(--text-secondary)' }}>
+            <MapPin size={12} /> {event.location_raw || event.city || 'Sector'}, {event.country}
+          </div>
+          <div style={{ display: 'flex', alignItems: 'center', gap: '5px', fontSize: '11px', color: 'var(--text-secondary)' }}>
+            <Clock size={12} /> {event.event_time ? new Date(event.event_time).toLocaleString() : 'Unknown'}
           </div>
-          <div style={{ display: 'flex', alignItems: 'center', gap: '6px', fontSize: '11px', color: 'var(--text-secondary)' }}>
-            <Clock size={12} /> {new Date(event.event_time).toLocaleDateString()}
+          <div style={{ display: 'flex', alignItems: 'center', gap: '5px', fontSize: '11px', color: 'var(--text-secondary)' }}>
+            <Zap size={12} /> {event.event_type || 'Unknown'}
           </div>
-          <a 
-            href={event.source_url} target="_blank" rel="noreferrer"
-            style={{ display: 'flex', alignItems: 'center', gap: '6px', fontSize: '11px', color: 'var(--accent-cyan)', textDecoration: 'none' }}
-          >
-            <ExternalLink size={12} /> VERIFY SOURCE
-          </a>
         </div>
 
-        {/* TABS */}
-        <div style={{ display: 'flex', borderBottom: '1px solid var(--border-glass)', marginBottom: '20px' }}>
-          <TabItem active={activeTab === 'sitrep'} label="SITREP" onClick={() => setActiveTab('sitrep')} />
-          <TabItem active={activeTab === 'details'} label="ENTITIES" onClick={() => setActiveTab('details')} />
+        {/* ENTITY GRID */}
+        <div style={{ display: 'grid', gridTemplateColumns: '1fr 1fr', gap: '10px', marginBottom: '20px' }}>
+          <DetailBox label="PRIMARY ACTOR" value={event.actor1 || 'UNKNOWN'} icon={<Users size={14}/>} />
+          <DetailBox label="SECONDARY ACTOR" value={event.actor2 || 'N/A'} icon={<Target size={14}/>} />
+          <DetailBox label="FATALITIES" value={event.fatalities || 0} color="var(--accent-red)" icon={<AlertTriangle size={14}/>} />
+          <DetailBox label="WEAPON SYSTEM" value={event.weapon || 'NOT SPECIFIED'} icon={<Zap size={14}/>} />
+          <DetailBox label="GEO ACCURACY" value={`${Math.round((event.geo_confidence || 0) * 100)}%`} color="var(--accent-cyan)" />
+          <DetailBox label="PRECISION" value={event.geo_precision === 1 ? 'EXACT' : event.geo_precision === 2 ? 'ADMIN' : 'BROAD'} color={event.geo_precision === 1 ? 'var(--accent-green)' : 'var(--accent-amber)'} />
         </div>
-
-        {/* TAB CONTENT: SITREP */}
-        {activeTab === 'sitrep' && (
-          <div className="tab-content animate-fade-in">
-            {event.ai_analysis ? (
-              <div style={{ fontSize: '14px', lineHeight: '1.7', color: '#cbd5e1', whiteSpace: 'pre-wrap' }}>
-                {event.ai_analysis}
-              </div>
-            ) : (
-              <div style={{ textAlign: 'center', padding: '30px 0', opacity: 0.5 }}>
-                <Activity size={32} style={{ marginBottom: '15px' }} />
-                <div style={{ fontSize: '11px', fontWeight: 800 }}>NO PRE-STORED ANALYSIS FOUND</div>
-                <button 
-                  onClick={() => onRequestLiveAnalysis(event)}
-                  style={{ 
-                    marginTop: '20px', padding: '10px 20px', background: 'var(--accent-cyan)', 
-                    color: 'black', border: 'none', borderRadius: '4px', fontSize: '10px', fontWeight: 900,
-                    cursor: 'pointer'
-                  }}
-                >
-                  REQUEST LIVE SITREP
-                </button>
-              </div>
-            )}
+        
+        {/* TACTICAL NOTES */}
+        {event.notes && (
+          <div style={{ padding: '12px', background: 'rgba(0,0,0,0.2)', borderRadius: '8px', border: '1px solid var(--border-glass)', marginBottom: '20px' }}>
+            <div style={{ fontSize: '8px', fontWeight: 900, color: 'var(--text-dim)', letterSpacing: '1px', marginBottom: '6px' }}>TACTICAL NOTES</div>
+            <div style={{ fontSize: '12px', lineHeight: '1.6', color: 'var(--text-secondary)' }}>
+              {event.notes}
+            </div>
           </div>
         )}
 
-        {/* TAB CONTENT: DETAILS */}
-        {activeTab === 'details' && (
-          <div className="tab-content animate-fade-in" style={{ display: 'flex', flexDirection: 'column', gap: '15px' }}>
-            <div style={{ display: 'grid', gridTemplateColumns: '1fr 1fr', gap: '15px' }}>
-              <DetailBox label="PRIMARY ACTOR" value={event.actor1 || 'UNKNOWN'} icon={<Users size={14}/>} />
-              <DetailBox label="FATALITIES" value={event.fatalities} color="var(--accent-red)" icon={<Target size={14}/>} />
-              <DetailBox label="EQP / WEAPON" value={event.weapon || 'KINETIC'} icon={<Zap size={14}/>} />
-              <DetailBox label="ACCURACY" value={`${Math.round(event.geo_confidence * 100)}%`} color="var(--accent-cyan)" />
-            </div>
-            
-            <div className="glass-panel" style={{ padding: '15px', borderRadius: '8px', background: 'rgba(0,0,0,0.2)' }}>
-              <div style={{ fontSize: '8px', fontWeight: 900, color: 'var(--text-dim)', letterSpacing: '1px', marginBottom: '8px' }}>TACTICAL NOTES</div>
-              <div style={{ fontSize: '12px', lineHeight: '1.6', color: 'var(--text-secondary)' }}>
-                {event.notes || 'No specialized tactical descriptors extracted for this event.'}
-              </div>
+        {/* EVIDENCE TRAIN */}
+        {getSourceUrls().length > 0 && (
+          <div style={{ display: 'flex', flexDirection: 'column', gap: '6px', padding: '12px', background: 'rgba(0,0,0,0.3)', borderRadius: '8px', border: '1px solid var(--border-glass)' }}>
+            <div style={{ fontSize: '8px', fontWeight: 900, color: isVerified ? 'var(--accent-green)' : 'var(--text-dim)', letterSpacing: '1px' }}>
+              {isVerified ? '✓ MULTI-SOURCE VERIFIED' : 'SOURCE'}
             </div>
+            {getSourceUrls().map((url, idx) => (
+              <a 
+                key={idx}
+                href={url} target="_blank" rel="noreferrer"
+                style={{ display: 'flex', alignItems: 'center', gap: '8px', fontSize: '10px', color: 'var(--accent-cyan)', textDecoration: 'none', opacity: 0.85 }}
+              >
+                <ExternalLink size={10} /> SOURCE {idx + 1}: {safeDomain(url)}
+              </a>
+            ))}
           </div>
         )}
       </div>
 
-      {/* FOOTER ACTION */}
+      {/* FOOTER */}
       <div style={{ 
-        padding: '15px 20px', background: 'rgba(0,0,0,0.3)', borderTop: '1px solid var(--border-glass)',
+        padding: '12px 20px', background: 'rgba(0,0,0,0.3)', borderTop: '1px solid var(--border-glass)',
         display: 'flex', justifyContent: 'space-between', alignItems: 'center'
       }}>
          <div style={{ display: 'flex', alignItems: 'center', gap: '6px' }}>
-            <div style={{ width: '6px', height: '6px', borderRadius: '50%', background: 'var(--accent-green)' }}></div>
-            <span style={{ fontSize: '9px', fontWeight: 900, color: 'var(--text-dim)' }}>STORED INTEL ACTIVE</span>
+            <div style={{ width: '6px', height: '6px', borderRadius: '50%', background: event.ai_classified !== false ? 'var(--accent-green)' : 'var(--accent-amber)' }}></div>
+            <span style={{ fontSize: '9px', fontWeight: 900, color: 'var(--text-dim)' }}>
+              {event.ai_classified !== false ? 'AI CLASSIFIED' : 'REGEX FALLBACK'}
+            </span>
+         </div>
+         <div style={{ fontSize: '9px', fontWeight: 800, color: 'var(--text-dim)', fontFamily: 'var(--font-mono)' }}>
+           {event.source || 'SRC'} // {event.event_id?.slice(0, 12)}
          </div>
-         {event.ai_analysis && (
-           <button 
-             onClick={() => onRequestLiveAnalysis(event)}
-             style={{ 
-               background: 'none', border: 'none', color: 'var(--accent-cyan)', fontSize: '9px', fontWeight: 900, 
-               cursor: 'pointer', display: 'flex', alignItems: 'center', gap: '4px'
-             }}
-           >
-             REFRESH ANALYSIS <ChevronRight size={10} />
-           </button>
-         )}
       </div>
 
       <style dangerouslySetInnerHTML={{ __html: `
-        .tab-content { transition: all 0.3s ease; }
         @keyframes fade-in { from { opacity: 0; transform: translateY(10px); } to { opacity: 1; transform: translateY(0); } }
         .animate-fade-in { animation: fade-in 0.3s ease-out; }
       `}} />
@@ -151,30 +157,13 @@ const IncidentIntelligenceCard = ({ event, onClose, onRequestLiveAnalysis }) =>
   );
 };
 
-const TabItem = ({ active, label, onClick }) => (
-  <div 
-    onClick={onClick}
-    style={{
-      padding: '10px 15px',
-      fontSize: '11px',
-      fontWeight: 900,
-      cursor: 'pointer',
-      color: active ? 'white' : 'var(--text-dim)',
-      borderBottom: active ? '2px solid var(--accent-cyan)' : '2px solid transparent',
-      transition: 'all 0.2s'
-    }}
-  >
-    {label}
-  </div>
-);
-
 const DetailBox = ({ label, value, color, icon }) => (
   <div style={{ background: 'rgba(255,255,255,0.02)', padding: '12px', borderRadius: '8px', border: '1px solid var(--border-glass)' }}>
     <div style={{ fontSize: '8px', fontWeight: 900, color: 'var(--text-dim)', letterSpacing: '1px', marginBottom: '6px', display: 'flex', alignItems: 'center', gap: '6px' }}>
       {icon} {label}
     </div>
-    <div style={{ fontSize: '13px', fontWeight: 900, color: color || 'white', textTransform: 'uppercase' }}>
-      {value}
+    <div style={{ fontSize: '12px', fontWeight: 900, color: color || 'white', textTransform: 'uppercase', wordBreak: 'break-word' }}>
+      {value ?? 'N/A'}
     </div>
   </div>
 );

frontend/src/components/TacticalFeed.jsx

@@ -69,6 +69,16 @@ const TacticalFeed = ({ events, selectedId, onSelectEvent }) => {
                         <span style={{ fontSize: '9px', fontWeight: 900, color: ev.severity_score >= 8 ? 'var(--accent-red)' : 'var(--text-secondary)', letterSpacing: '1px' }}>
                           {ev.event_type?.toUpperCase() || 'GENERAL'}
                         </span>
+                        {(ev.verification_count || 1) > 1 && (
+                          <span style={{ fontSize: '8px', fontWeight: 900, color: 'var(--accent-green)', background: 'rgba(16,185,129,0.1)', padding: '1px 5px', borderRadius: '3px', border: '1px solid rgba(16,185,129,0.3)' }}>
+                            ✓ {ev.verification_count}
+                          </span>
+                        )}
+                        {(ev.strategic_relevance === 'CRITICAL' || ev.strategic_relevance === 'HIGH') && (
+                          <span style={{ fontSize: '8px', fontWeight: 900, color: ev.strategic_relevance === 'CRITICAL' ? 'var(--accent-red)' : 'var(--accent-amber)', background: ev.strategic_relevance === 'CRITICAL' ? 'rgba(244,63,94,0.1)' : 'rgba(245,158,11,0.1)', padding: '1px 5px', borderRadius: '3px', border: `1px solid ${ev.strategic_relevance === 'CRITICAL' ? 'rgba(244,63,94,0.3)' : 'rgba(245,158,11,0.3)'}` }}>
+                            {ev.strategic_relevance}
+                          </span>
+                        )}
                       </div>
                       <span style={{ fontSize: '9px', color: 'var(--text-dim)', fontWeight: 700, fontFamily: 'var(--font-mono)' }}>
                         {getTimeAgo(ev.event_time)}

frontend/src/components/TacticalMap.jsx

@@ -1,5 +1,5 @@
 import React, { useState, useEffect, useMemo } from 'react';
-import { MapContainer, TileLayer, Marker, Popup, Circle, useMap } from 'react-leaflet';
+import { MapContainer, TileLayer, Marker, Popup, Circle, Polyline, useMap } from 'react-leaflet';
 import L from 'leaflet';
 import 'leaflet/dist/leaflet.css';
 import { Target, Shield, Zap, MapPin, Activity, AlertTriangle, Users } from 'lucide-react';
@@ -128,6 +128,30 @@ const TacticalMap = ({ events, layerData, selectedEvent, onDeepAnalyze, layers }
            </Circle>
         ))}
 
+        {/* STRATEGIC TENSION VECTORS (Frontier Intelligence) */}
+        {useMemo(() => {
+          const highIntensity = (events || []).filter(e => e.severity_score > 7.5);
+          const vectors = [];
+          for (let i = 0; i < highIntensity.length; i++) {
+            for (let j = i + 1; j < highIntensity.length; j++) {
+              const e1 = highIntensity[i];
+              const e2 = highIntensity[j];
+              // Connect if same country or same actor (Strategic Handshake)
+              if (e1.country_iso3 === e2.country_iso3 || (e1.actor1 && e1.actor1 === e2.actor1)) {
+                vectors.push({ id: `${e1.id}-${e2.id}`, coords: [[e1.lat, e1.lon], [e2.lat, e2.lon]] });
+              }
+            }
+          }
+          return vectors.slice(0, 8); // Performance limit
+        }, [events]).map(v => (
+          <Polyline 
+            key={`vector-${v.id}`} 
+            positions={v.coords} 
+            className="tension-vector"
+            pathOptions={{ color: 'var(--accent-red)', weight: 1, opacity: 0.3 }}
+          />
+        ))}
+
         {/* CIVILIAN RISK VECTOR */}
         {layers.civilians.active && (events || []).filter(e => e.fatalities_civilians > 0).map(ev => (
           <Marker key={`civ-${ev.event_id}`} position={[ev.lat, ev.lon]} icon={createCivilianIcon()}>
@@ -149,6 +173,16 @@ const TacticalMap = ({ events, layerData, selectedEvent, onDeepAnalyze, layers }
           
           return (
             <React.Fragment key={ev.event_id}>
+              {/* Verified Incident Halo (Frontier Intelligence) */}
+              {ev.verification_count > 1 && (
+                <Circle 
+                  center={[ev.lat, ev.lon]}
+                  radius={8000}
+                  className="verified-pulse"
+                  pathOptions={{ color: 'var(--accent-green)', fillColor: 'var(--accent-green)', fillOpacity: 0.2, weight: 1 }}
+                />
+              )}
+
               {/* Uncertainty Zone for non-exact points */}
               {!isExact && (
                 <Circle 
@@ -170,47 +204,117 @@ const TacticalMap = ({ events, layerData, selectedEvent, onDeepAnalyze, layers }
                 zIndexOffset={isExact ? 1000 : 500}
               >
                 <Popup className="tactical-popup">
-                  <div className="popup-grid">
-                    <div className="popup-specs" style={{ borderLeft: `4px solid ${ev.severity_score > 8 ? 'var(--accent-red)' : 'var(--accent-amber)'}` }}>
-                      <div style={{ fontSize: '9px', fontWeight: 900, color: ev.severity_score > 8 ? 'var(--accent-red)' : 'var(--accent-amber)', letterSpacing: '1.5px' }}>
-                        {isExact ? (ev.severity_score > 8 ? 'KINETIC' : 'TACTICAL') : 'APPROXIMATE'}
+                  <div style={{ minWidth: '340px', maxWidth: '380px' }}>
+                    {/* THREAT BANNER */}
+                    <div style={{ 
+                      padding: '12px 16px', 
+                      background: `linear-gradient(135deg, ${eventColor}15, transparent)`,
+                      borderBottom: `1px solid ${eventColor}30`,
+                      display: 'flex', justifyContent: 'space-between', alignItems: 'center'
+                    }}>
+                      <div style={{ display: 'flex', alignItems: 'center', gap: '8px' }}>
+                        <div style={{ width: '8px', height: '8px', borderRadius: '50%', background: eventColor, boxShadow: `0 0 8px ${eventColor}` }}></div>
+                        <span style={{ fontSize: '9px', fontWeight: 900, letterSpacing: '2px', color: eventColor }}>
+                          {ev.event_type?.toUpperCase() || 'ENGAGEMENT'}
+                        </span>
                       </div>
-                      
-                      {/* ACCURACY BADGE */}
-                      <div style={{ 
-                        marginTop: '8px', padding: '2px 4px', background: 'rgba(255,255,255,0.05)', 
-                        borderRadius: '3px', fontSize: '8px', fontWeight: 900, textAlign: 'center',
-                        color: isExact ? 'var(--accent-cyan)' : 'var(--text-dim)',
-                        border: `1px solid ${isExact ? 'var(--accent-cyan)' : 'var(--border-glass)'}`
-                      }}>
-                        {ev.geo_precision === 1 ? 'EXACT' : ev.geo_precision === 2 ? 'ADMIN-LEVEL' : 'COUNTRY-LEVEL'}
+                      <div style={{ display: 'flex', gap: '5px', alignItems: 'center' }}>
+                        {(ev.verification_count || 1) > 1 && (
+                          <span style={{ fontSize: '8px', fontWeight: 900, color: '#10b981', background: 'rgba(16,185,129,0.12)', padding: '2px 7px', borderRadius: '3px', border: '1px solid rgba(16,185,129,0.25)' }}>
+                            ✓ {ev.verification_count}
+                          </span>
+                        )}
+                        <span style={{ 
+                          fontSize: '8px', fontWeight: 900, padding: '2px 7px', borderRadius: '3px',
+                          color: isExact ? '#06b6d4' : '#64748b',
+                          border: `1px solid ${isExact ? 'rgba(6,182,212,0.3)' : 'rgba(255,255,255,0.08)'}`,
+                          background: isExact ? 'rgba(6,182,212,0.08)' : 'rgba(255,255,255,0.03)'
+                        }}>
+                          {ev.geo_precision === 1 ? 'EXACT' : ev.geo_precision === 2 ? 'ADMIN' : 'APPROX'}
+                        </span>
                       </div>
+                    </div>
 
-                      <div style={{ fontSize: '11px', fontWeight: 800, marginTop: '10px', color: 'var(--text-secondary)' }}>SEVERITY</div>
-                      <div style={{ fontSize: '20px', fontWeight: 900, color: 'white' }}>{ev.severity_score}</div>
-                      
-                      <div style={{ fontSize: '11px', fontWeight: 800, marginTop: '15px', color: 'var(--text-secondary)' }}>CONFIDENCE</div>
-                      <div style={{ fontSize: '12px', fontWeight: 900, color: 'var(--accent-cyan)' }}>{Math.round(ev.geo_confidence * 100)}%</div>
-                      
-                      <div style={{ fontSize: '11px', fontWeight: 800, marginTop: '15px', color: 'var(--text-secondary)' }}>LOC</div>
-                      <div style={{ fontSize: '11px', fontWeight: 800 }}>{ev.country_iso3}</div>
+                    {/* TITLE + LOCATION */}
+                    <div style={{ padding: '14px 16px 10px' }}>
+                      <div style={{ fontSize: '14px', fontWeight: 800, color: 'white', lineHeight: '1.35', marginBottom: '8px' }}>
+                        {ev.title}
+                      </div>
+                      <div style={{ display: 'flex', alignItems: 'center', gap: '5px', fontSize: '10px', color: '#94a3b8' }}>
+                        <MapPin size={10} style={{ opacity: 0.5 }} />
+                        {ev.location_raw || ev.admin1 || ev.country_iso3}
+                        <span style={{ opacity: 0.3 }}>•</span>
+                        {ev.country}
+                      </div>
                     </div>
-                    <div className="popup-intel">
-                        <div style={{ fontSize: '10px', fontWeight: 800, color: 'var(--accent-cyan)', marginBottom: '8px' }}>[SITREP: ENCRYPTED]</div>
-                        <div style={{ fontSize: '14px', fontWeight: 800, color: 'white', lineHeight: '1.3', marginBottom: '12px' }}>{ev.title}</div>
-                        
-                        {/* ENRICHED TACTICAL DATA */}
-                        <div style={{ display: 'flex', flexDirection: 'column', gap: '8px', marginBottom: '15px', padding: '10px', background: 'rgba(255,255,255,0.03)', borderRadius: '6px', border: '1px solid var(--border-glass)' }}>
-                          {ev.actor1 && <div style={{ fontSize: '9px', fontWeight: 800 }}><span style={{ color: 'var(--accent-cyan)' }}>ACTOR:</span> {ev.actor1.toUpperCase()}</div>}
-                          {ev.weapon && <div style={{ fontSize: '9px', fontWeight: 800 }}><span style={{ color: 'var(--text-dim)' }}>EQP:</span> {ev.weapon.toUpperCase()}</div>}
-                          {ev.fatalities > 0 && <div style={{ fontSize: '9px', fontWeight: 800 }}><span style={{ color: 'var(--accent-red)' }}>KIA:</span> {ev.fatalities}</div>}
-                          {ev.notes && <div style={{ fontSize: '9px', fontWeight: 700, color: 'var(--text-dim)', fontStyle: 'italic', borderTop: '1px solid var(--border-glass)', paddingTop: '6px' }}>{ev.notes}</div>}
-                          {ev.location_raw && <div style={{ fontSize: '8px', color: 'var(--text-dim)', marginTop: '4px' }}>Extracted: "{ev.location_raw}"</div>}
+
+                    {/* SEVERITY + STATS ROW */}
+                    <div style={{ padding: '0 16px 14px', display: 'flex', gap: '8px' }}>
+                      {/* Severity Gauge */}
+                      <div style={{ 
+                        flex: 1, padding: '10px', borderRadius: '8px', 
+                        background: `linear-gradient(135deg, ${eventColor}08, ${eventColor}03)`,
+                        border: `1px solid ${eventColor}20`, textAlign: 'center'
+                      }}>
+                        <div style={{ fontSize: '22px', fontWeight: 900, color: eventColor, lineHeight: 1 }}>{ev.severity_score}</div>
+                        <div style={{ fontSize: '7px', fontWeight: 800, color: '#64748b', letterSpacing: '1.5px', marginTop: '4px' }}>SEVERITY</div>
+                      </div>
+                      {/* Confidence */}
+                      <div style={{ 
+                        flex: 1, padding: '10px', borderRadius: '8px', 
+                        background: 'rgba(6,182,212,0.04)', border: '1px solid rgba(6,182,212,0.12)', textAlign: 'center'
+                      }}>
+                        <div style={{ fontSize: '22px', fontWeight: 900, color: '#06b6d4', lineHeight: 1 }}>{Math.round((ev.geo_confidence||0) * 100)}%</div>
+                        <div style={{ fontSize: '7px', fontWeight: 800, color: '#64748b', letterSpacing: '1.5px', marginTop: '4px' }}>CONFIDENCE</div>
+                      </div>
+                      {/* Fatalities */}
+                      {ev.fatalities > 0 && (
+                        <div style={{ 
+                          flex: 1, padding: '10px', borderRadius: '8px', 
+                          background: 'rgba(244,63,94,0.05)', border: '1px solid rgba(244,63,94,0.15)', textAlign: 'center'
+                        }}>
+                          <div style={{ fontSize: '22px', fontWeight: 900, color: '#f43f5e', lineHeight: 1 }}>{ev.fatalities}</div>
+                          <div style={{ fontSize: '7px', fontWeight: 800, color: '#64748b', letterSpacing: '1.5px', marginTop: '4px' }}>KIA</div>
                         </div>
+                      )}
+                    </div>
+
+                    {/* ENTITY PILLS */}
+                    {(ev.actor1 || ev.weapon || ev.actor2) && (
+                      <div style={{ padding: '0 16px 14px', display: 'flex', flexWrap: 'wrap', gap: '6px' }}>
+                        {ev.actor1 && (
+                          <div style={{ fontSize: '9px', fontWeight: 800, color: '#06b6d4', background: 'rgba(6,182,212,0.08)', padding: '4px 10px', borderRadius: '20px', border: '1px solid rgba(6,182,212,0.2)' }}>
+                            ⚔ {ev.actor1}
+                          </div>
+                        )}
+                        {ev.actor2 && (
+                          <div style={{ fontSize: '9px', fontWeight: 800, color: '#94a3b8', background: 'rgba(255,255,255,0.04)', padding: '4px 10px', borderRadius: '20px', border: '1px solid rgba(255,255,255,0.08)' }}>
+                            ⛨ {ev.actor2}
+                          </div>
+                        )}
+                        {ev.weapon && (
+                          <div style={{ fontSize: '9px', fontWeight: 800, color: '#fbbf24', background: 'rgba(251,191,36,0.08)', padding: '4px 10px', borderRadius: '20px', border: '1px solid rgba(251,191,36,0.2)' }}>
+                            ◈ {ev.weapon}
+                          </div>
+                        )}
+                      </div>
+                    )}
 
-                        <button className="nav-command-btn active" style={{ width: '100%', justifyContent: 'center' }} onClick={() => onDeepAnalyze(ev)}>
-                          DEEP ANALYZE SECTOR
-                        </button>
+                    {/* FOOTER: ANALYZE + META */}
+                    <div style={{ 
+                      padding: '10px 16px', background: 'rgba(0,0,0,0.25)', borderTop: '1px solid rgba(255,255,255,0.04)',
+                      display: 'flex', justifyContent: 'space-between', alignItems: 'center'
+                    }}>
+                      <button 
+                        className="nav-command-btn active" 
+                        style={{ padding: '6px 14px', fontSize: '9px' }} 
+                        onClick={() => onDeepAnalyze(ev)}
+                      >
+                        INTEL REPORT
+                      </button>
+                      <span style={{ fontSize: '8px', color: '#475569', fontFamily: 'var(--font-mono)' }}>
+                        {ev.source || 'SRC'} • {ev.country_iso3}
+                      </span>
                     </div>
                   </div>
                 </Popup>

frontend/src/index.css

@@ -310,3 +310,33 @@ body {
   0%, 100% { opacity: 1; transform: scale(1); }
   50% { opacity: 0.3; transform: scale(0.8); }
 }
+
+/* --- FRONTIER COMMAND VISUALS --- */
+.tension-vector {
+  stroke-dasharray: 10, 10;
+  animation: dash-flow 20s linear infinite;
+  filter: drop-shadow(0 0 5px var(--accent-red));
+}
+
+@keyframes dash-flow {
+  to { stroke-dashoffset: -1000; }
+}
+
+.theater-haze {
+  filter: blur(10px);
+  animation: heat-haze 8s infinite alternate ease-in-out;
+}
+
+@keyframes heat-haze {
+  0% { transform: scale(1) skew(0deg); opacity: 0.3; }
+  100% { transform: scale(1.1) skew(2deg); opacity: 0.5; }
+}
+
+.verified-pulse {
+  animation: verified-glow 2s infinite alternate;
+}
+
+@keyframes verified-glow {
+  0% { filter: drop-shadow(0 0 2px var(--accent-green)); }
+  100% { filter: drop-shadow(0 0 12px var(--accent-green)); }
+}

poller/classifier.py

@@ -153,27 +153,31 @@ async def classify_event_llm(title: str, summary: str = "") -> Dict[str, Any]:
     Resilient Multi-Engine Classification Gateway.
     Tries Groq -> Gemini -> HF -> Regex Fallback.
     """
-    prompt = f"""
-    Analyze this news event for a conflict intelligence database:
-    Title: {title}
-    Summary: {summary}
-
-    Return a JSON object with:
-    - category: (MILITARY, TERRORIST, MILITANT, CIVIL_UNREST, or GENERAL)
-    - event_type: (Armed Clash, Airstrike / Artillery, Terrorist Attack, Arrests / Detainment, Strategic Report, or Other)
-    - location_city: Specific city or town name
-    - location_admin1: Province, state, or oblast name
-    - location_country: The country name
-    - location_text_span: The verbatim phrase from the title/summary referring to the location
-    - location_confidence: Float 0-1 indicating extraction certainty
-    - actor1: The primary group or entity (e.g. 'IDF', 'Wagner Group', 'Protestors')
-    - actor2: The secondary entity or target
-    - weapon: Keywords for weapons used (e.g. 'F-16', 'Drone', 'Rocket')
-    - fatalities: Estimated count if mentioned, else 0
-    - severity_score: 0 to 10 based on tactical impact
-    - summary_short: 1 sentence tactical summary
-    - deep_analysis: 2-3 paragraph professional intelligence SITREP. Include likely strategic intent, immediate escalation risks, and any historical context regarding the actors or location. Use a sober, analytical tone.
-    """
+    prompt = f"""Analyze this news headline for an ELITE conflict intelligence database.
+Your goal is absolute accuracy. Only classify REAL kinetic/military/violent incidents.
+Reject diplomacy, politics, economics, sports, or opinion articles.
+
+Title: {title}
+Summary: {summary}
+
+Return a JSON object with these fields:
+- is_conflict_tactical: Boolean. True ONLY if this is a real kinetic event (explosions, airstrikes, armed clashes, shootings, bombings, military operations). False for diplomacy, sanctions, protests, elections, humanitarian aid, opinion pieces, or general politics.
+- validation_logic: 1 sentence explaining your reasoning.
+- category: MILITARY, TERRORIST, MILITANT, CIVIL_UNREST, or GENERAL
+- strategic_significance: CRITICAL, HIGH, MEDIUM, or LOW
+- event_type: Armed Clash, Airstrike / Artillery, Terrorist Attack, Drone Strike, Naval Engagement, Arrests / Detainment, or Other
+- location_landmark: Specific facility name if mentioned (base, airport, port, checkpoint). null if none.
+- location_city: Specific city or town. null if unclear.
+- location_admin1: Province, state, or oblast name. null if unclear.
+- location_country: Country name. Required.
+- location_text_span: The exact phrase from the title referring to the location.
+- confidence_score: Float 0.0-1.0 indicating overall data reliability.
+- actor1: Primary armed group or military force. Be specific (e.g. "72nd Mechanized Brigade" not just "Ukraine").
+- actor2: Secondary entity or target. null if unknown.
+- weapon: Specific weapon system if mentioned (e.g. "Shahed-136", "HIMARS", "RPG-7"). null if not mentioned.
+- fatalities: Integer count. 0 if not mentioned or unknown.
+- severity_score: Float 0-10 based on tactical impact and scale.
+"""
 
     # ENGINE TIER 1: GROQ
     res = await classify_with_groq(prompt)
@@ -203,21 +207,36 @@ async def classify_event_llm(title: str, summary: str = "") -> Dict[str, Any]:
     }
 
 def parse_llm_res(res: Dict, provider: str) -> Dict[str, Any]:
+    # World Monitor Noise Gate: Reject non-conflict or low-confidence events
+    is_tactical = res.get("is_conflict_tactical")
+    confidence = 0.0
+    try:
+        confidence = float(res.get("confidence_score", 0))
+    except (ValueError, TypeError):
+        confidence = 0.0
+
+    if not is_tactical or confidence < 0.7:
+        return {"is_noise": True, "logic": res.get("validation_logic", "Rejected by noise gate")}
+
+    significance = res.get("strategic_significance", "LOW")
+
     return {
+        "is_noise": False,
         "category": res.get("category", "GENERAL").upper(),
         "severity_score": float(res.get("severity_score", 3.0)),
-        "location": res.get("location_city"),
+        "strategic_relevance": significance,
+        "location": res.get("location_landmark") or res.get("location_city"),
         "location_admin1": res.get("location_admin1"),
         "country": res.get("location_country"),
         "location_raw": res.get("location_text_span"),
-        "extraction_confidence": float(res.get("location_confidence", 0.5)),
-        "tags": list(set([res.get("actor1"), res.get("weapon")] + (res.get("weapon_list", []) if isinstance(res.get("weapon_list"), list) else []))),
+        "extraction_confidence": confidence,
+        "tags": [t for t in [res.get("actor1"), res.get("weapon")] if t],
         "event_type": res.get("event_type", "Other"),
         "actor1": res.get("actor1"),
         "actor2": res.get("actor2"),
+        "weapon": res.get("weapon"),
         "fatalities": int(res.get("fatalities", 0)),
-        "notes": res.get("summary_short", ""),
-        "ai_analysis": res.get("deep_analysis", ""),
+        "notes": f"[{significance}] {res.get('validation_logic', '')}",
         "ai_classified": True,
         "provider": provider
     }

poller/db_inserter.py

@@ -33,6 +33,11 @@ async def get_pool():
 async def upsert_event(event: Dict[str, Any]):
     pool = await get_pool()
     async with pool.acquire() as conn:
+        # Guard: Reject events that failed geocoding entirely
+        if event.get("lat", 0) == 0.0 and event.get("lon", 0) == 0.0:
+            log.warning(f"Dropping event with (0,0) coordinates: {event.get('title', '')[:60]}")
+            return None
+
         # Use Conflict Tracker to group events
         try:
             conflict_id, conflict_name = await identify_or_create_conflict(conn, event)
@@ -40,6 +45,33 @@ async def upsert_event(event: Dict[str, Any]):
             log.warning(f"Conflict tracking failed: {e}")
             conflict_id, conflict_name = None, None
 
+        # --- WORLD MONITOR TRIANGULATION: Proximity Search ---
+        # Search for an event within 10km and +/- 12 hours
+        search_query = """
+        SELECT event_id, verification_count, source_urls FROM conflict_events 
+        WHERE ST_DWithin(geom, ST_SetSRID(ST_MakePoint($1, $2), 4326), 10000)
+          AND event_time >= $3::timestamp - INTERVAL '12 hours'
+          AND event_time <= $3::timestamp + INTERVAL '12 hours'
+        LIMIT 1;
+        """
+        existing = await conn.fetchrow(search_query, event["lon"], event["lat"], event["event_time"])
+        
+        if existing:
+            # INTERFACE: Update existing event with new source and increment verification
+            log.info(f"Triangulation Successful: Merging {event['event_id']} with existing {existing['event_id']}")
+            update_query = """
+            UPDATE conflict_events SET
+                verification_count = verification_count + 1,
+                source_urls = array_append(source_urls, $2),
+                severity_score = GREATEST(severity_score, $3),
+                notes = notes || '\n[UPDATE] ' || $4,
+                ingested_at = NOW()
+            WHERE event_id = $1;
+            """
+            await conn.execute(update_query, existing["event_id"], event.get("source_url"), event.get("severity_score", 0.0), event.get("notes", ""))
+            return existing["event_id"]
+
+
         query = """
         INSERT INTO conflict_events (
             event_id, source, source_reliability, event_time, event_date,
@@ -51,13 +83,13 @@ async def upsert_event(event: Dict[str, Any]):
             severity, severity_score, title, notes, tags, source_url, category,
             conflict_id, conflict_name,
             geo_confidence, geo_method, geocode_provider, location_raw,
-            ai_analysis
+            ai_analysis, strategic_relevance, source_urls
         ) VALUES (
             $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11,
             $12::double precision, $13::double precision, ST_SetSRID(ST_MakePoint($13::double precision, $12::double precision), 4326), $14,
             $15, $16, $17, $18, $19, $20, $21,
             $22, $23, $24, $25, $26, $27, $28, $29, $30, $31, $32, $33,
-            $34, $35, $36, $37, $38
+            $34, $35, $36, $37, $38, $39, ARRAY[$30]::text[]
         )
         ON CONFLICT (event_id) DO UPDATE SET
             severity_score = EXCLUDED.severity_score,
@@ -70,6 +102,7 @@ async def upsert_event(event: Dict[str, Any]):
             ai_analysis = EXCLUDED.ai_analysis,
             conflict_id = EXCLUDED.conflict_id,
             conflict_name = EXCLUDED.conflict_name,
+            strategic_relevance = EXCLUDED.strategic_relevance,
             ingested_at = NOW();
         """
         
@@ -111,7 +144,8 @@ async def upsert_event(event: Dict[str, Any]):
             event.get("geo_method"),
             event.get("geocode_provider"),
             event.get("location_raw"),
-            event.get("ai_analysis")
+            event.get("ai_analysis"),
+            event.get("strategic_relevance", "LOW")
         )
         
         try:
@@ -123,6 +157,7 @@ async def upsert_event(event: Dict[str, Any]):
                 "title": event["title"],
                 "city": event.get("city"),
                 "country": event["country"],
+                "country_iso3": event.get("country_iso3"),
                 "lat": event["lat"],
                 "lon": event["lon"],
                 "geo_precision": event.get("geo_precision", 3),
@@ -135,7 +170,11 @@ async def upsert_event(event: Dict[str, Any]):
                 "weapon": event.get("weapon"),
                 "fatalities": event.get("fatalities", 0),
                 "notes": event.get("notes", ""),
-                "ai_analysis": event.get("ai_analysis", "")
+                "ai_analysis": event.get("ai_analysis", ""),
+                "strategic_relevance": event.get("strategic_relevance", "LOW"),
+                "verification_count": 1,
+                "source_urls": [event.get("source_url", "")],
+                "source_url": event.get("source_url", "")
             }
             await conn.execute(f"SELECT pg_notify('new_conflict_event', $1)", json.dumps(payload))
             log.debug(f"Upserted and Enriched Notified event {event['event_id']}")

poller/deduplicator.py

@@ -0,0 +1,29 @@
+import hashlib
+import logging
+from api.database import db
+
+log = logging.getLogger(__name__)
+
+async def is_duplicate_event(title: str, window_days: int = 1) -> bool:
+    """
+    Checks if a similar headline has been processed recently.
+    Uses semantic hashing (normalized title) and Redis/Mem storage.
+    """
+    if not title: return False
+    
+    # Simple normalization for semantic hashing
+    normalized = "".join(filter(str.isalnum, title.lower()))
+    hash_key = hashlib.md5(normalized.encode()).hexdigest()
+    
+    redis_key = f"seen_event:{hash_key}"
+    
+    if db.redis:
+        exists = await db.redis.get(redis_key)
+        if exists:
+            log.debug(f"Token Saved: Skipping duplicate event: {title[:50]}...")
+            return True
+        
+        # Mark as seen for X days
+        await db.redis.setex(redis_key, 86400 * window_days, "1")
+    
+    return False

poller/gdelt_poller.py

@@ -7,38 +7,46 @@ from datetime import datetime, timezone
 from poller.db_inserter import upsert_event
 from poller.geo_utils import geocode_ranked
 from poller.classifier import classify_event_llm
+from poller.deduplicator import is_duplicate_event
 
 log = logging.getLogger(__name__)
 GDELT_URL = 'https://api.gdeltproject.org/api/v2/doc/doc'
 
-# List of keywords that usually indicate non-tactical news or "noise"
+# Expanded noise patterns — historical, editorial, and non-kinetic content
 NOISE_PATTERNS = [
     r"years ago", r"anniversary", r"memorial", r"remembers", r"history of", 
-    r"how to watch", r"commemorate", r"museum", r"exhibition", r"biography"
+    r"how to watch", r"commemorate", r"museum", r"exhibition", r"biography",
+    r"book review", r"opinion:", r"editorial:", r"analysis:", r"podcast",
+    r"interview with", r"what you need to know", r"explained:", r"timeline of",
+    r"trade war", r"war on drugs", r"war on poverty", r"culture war",
+    r"star wars", r"price war", r"bidding war", r"turf war",
+    r"fantasy football", r"world cup", r"olympic", r"nba ", r"nfl ",
+    r"box office", r"movie", r"tv show", r"streaming", r"netflix",
+    r"stock market", r"wall street", r"cryptocurrency", r"bitcoin",
+    r"election results", r"campaign trail", r"poll shows", r"voter",
 ]
 
 def passes_quality_filter(article):
     title = article.get('title', '')
-    if len(title) < 15:
+    if len(title) < 20:
         return False
     
-    # Filter out historical retrospectives / noise
     title_lower = title.lower()
     for pattern in NOISE_PATTERNS:
         if re.search(pattern, title_lower):
-            log.debug(f"Filtering out noise: {title}")
+            log.debug(f"GDELT noise filter: {title[:60]}")
             return False
             
     return True
 
 async def poll_gdelt():
-    # Stagger startup to avoid simultaneous polling pressure
     await asyncio.sleep(10)
     
+    # Precision query — only actual kinetic/military terms, not broad "war" or "conflict"
     params = {
-        'query': '(conflict OR battle OR airstrike OR war OR "armed clash" OR "suicide bombing") sourcelang:English',
+        'query': '(airstrike OR "armed clash" OR shelling OR artillery OR "drone strike" OR missile OR bombing OR "suicide attack" OR ambush OR mortar OR "killed in" OR "troops deployed" OR "military operation") sourcelang:English',
         'mode': 'artlist',
-        'maxrecords': 100,
+        'maxrecords': 75,
         'format': 'json',
     }
     
@@ -68,23 +76,43 @@ async def poll_gdelt():
     log.info(f"GDELT returned {len(articles)} articles.")
     
     count = 0
+    skipped_noise = 0
+    skipped_dupe = 0
+    skipped_geo = 0
+    
     for article in articles:
         if not passes_quality_filter(article):
              continue
              
         title = article.get("title", "").replace("\n", " ").strip()
         
-        # 1. AI-Powered Insight (Swapped to FIRST for better geography)
+        # Token-saving deduplication
+        if await is_duplicate_event(title):
+            skipped_dupe += 1
+            continue
+
         try:
             ai_res = await classify_event_llm(title)
             
-            # 2. High-Fidelity Geocoding using AI-extracted entities
+            # World Monitor Noise Gate
+            if ai_res.get("is_noise"):
+                log.debug(f"GDELT Skeptic Rejection: {title[:60]}... Reason: {ai_res.get('logic')}")
+                skipped_noise += 1
+                continue
+
+            # High-Fidelity Geocoding
             geo_res = await geocode_ranked(
                 ai_res.get("location"), 
                 ai_res.get("country"),
                 ai_res.get("location_admin1")
             )
             
+            # Drop failed geocodes — don't pollute the map with (0,0)
+            if geo_res.get("confidence", 0) == 0.0 and geo_res.get("method") == "failed":
+                log.warning(f"GDELT: Dropping event with failed geocode: {title[:60]}")
+                skipped_geo += 1
+                continue
+            
             uniq = str(uuid.uuid5(uuid.NAMESPACE_URL, article.get('url', ''))).split('-')[0]
             event_time = datetime.now(timezone.utc).replace(tzinfo=None)
             
@@ -115,16 +143,17 @@ async def poll_gdelt():
                 "actor2": ai_res.get("actor2"),
                 "fatalities": ai_res.get("fatalities", 0),
                 "notes": ai_res.get("notes"),
+                "ai_analysis": ai_res.get("ai_analysis"),
+                "strategic_relevance": ai_res.get("strategic_relevance", "LOW"),
             }
             
             await upsert_event(event)
             count += 1
             
-            # 3. Rate Limit Compliance (2s sleep)
             await asyncio.sleep(2.0)
             
         except Exception as e:
             log.error(f"Error processing GDELT article: {e}")
             await asyncio.sleep(5)
         
-    log.info(f"Successfully processed {count} events from GDELT with AI Intelligence.")
+    log.info(f"GDELT: Processed {count} events. Rejected {skipped_noise} noise, {skipped_dupe} dupes, {skipped_geo} bad geo.")

poller/geo_utils.py

@@ -10,24 +10,68 @@ import json
 log = logging.getLogger(__name__)
 
 # Tactical Centroids for major conflict zones (High precision manual overrides)
-# Rules: Token boundary matching, contextual agreement.
+# These bypass Nominatim entirely for reliable, instant geocoding of known hotspots.
 HOTSPOTS = {
+    # --- UKRAINE FRONTLINE ---
     "gaza": (31.3547, 34.3088, "Palestine", "PSE"),
+    "gaza strip": (31.3547, 34.3088, "Palestine", "PSE"),
+    "rafah": (31.2768, 34.2457, "Palestine", "PSE"),
+    "khan younis": (31.3462, 34.3015, "Palestine", "PSE"),
+    "khan yunis": (31.3462, 34.3015, "Palestine", "PSE"),
+    "jabalia": (31.5281, 34.4831, "Palestine", "PSE"),
+    "deir al-balah": (31.4180, 34.3509, "Palestine", "PSE"),
+    "nuseirat": (31.4416, 34.3963, "Palestine", "PSE"),
     "west bank": (31.9522, 35.2332, "Palestine", "PSE"),
+    "jenin": (32.4610, 35.3008, "Palestine", "PSE"),
+    "tulkarm": (32.3104, 35.0286, "Palestine", "PSE"),
+    # --- UKRAINE ---
     "donbas": (48.0, 37.8, "Ukraine", "UKR"),
     "donetsk": (48.0196, 37.8018, "Ukraine", "UKR"),
     "luhansk": (48.574, 39.307, "Ukraine", "UKR"),
     "kharkiv": (49.9935, 36.2304, "Ukraine", "UKR"),
     "avdiivka": (48.1366, 37.7347, "Ukraine", "UKR"),
+    "bakhmut": (48.5954, 38.0003, "Ukraine", "UKR"),
+    "zaporizhzhia": (47.8388, 35.1396, "Ukraine", "UKR"),
+    "kherson": (46.6354, 32.6169, "Ukraine", "UKR"),
+    "mariupol": (47.0958, 37.5494, "Ukraine", "UKR"),
+    "pokrovsk": (48.2833, 37.1833, "Ukraine", "UKR"),
+    "kursk": (51.7304, 36.1927, "Russia", "RUS"),
+    "crimea": (45.3, 34.1, "Ukraine", "UKR"),
+    "odesa": (46.4825, 30.7233, "Ukraine", "UKR"),
+    "kyiv": (50.4501, 30.5234, "Ukraine", "UKR"),
+    # --- RED SEA / YEMEN ---
     "red sea": (20.0, 38.0, "International Waters", "INT"),
-    "taiwan strait": (24.0, 119.0, "Taiwan", "TWN"),
-    "south china sea": (12.0, 113.0, "International Waters", "INT"),
+    "hodeidah": (14.7980, 42.9540, "Yemen", "YEM"),
+    "sanaa": (15.3694, 44.1910, "Yemen", "YEM"),
+    "aden": (12.7855, 45.0187, "Yemen", "YEM"),
+    # --- SUDAN ---
     "darfur": (13.0, 25.0, "Sudan", "SDN"),
     "khartoum": (15.5007, 32.5599, "Sudan", "SDN"),
+    "el fasher": (13.6300, 25.3500, "Sudan", "SDN"),
+    "port sudan": (19.6158, 37.2164, "Sudan", "SDN"),
+    # --- HORN OF AFRICA ---
     "tigray": (13.5, 39.0, "Ethiopia", "ETH"),
+    "mogadishu": (2.0469, 45.3182, "Somalia", "SOM"),
+    # --- ASIA ---
     "kabul": (34.555, 69.207, "Afghanistan", "AFG"),
+    "kandahar": (31.6133, 65.7101, "Afghanistan", "AFG"),
+    "myanmar": (21.9162, 95.956, "Myanmar", "MMR"),
+    # --- SAHEL ---
     "mali": (17.57, -3.99, "Mali", "MLI"),
+    "burkina faso": (12.3714, -1.5197, "Burkina Faso", "BFA"),
+    # --- MARITIME ---
     "hormuz": (26.5, 56.5, "International Waters", "INT"),
+    "taiwan strait": (24.0, 119.0, "Taiwan", "TWN"),
+    "south china sea": (12.0, 113.0, "International Waters", "INT"),
+    # --- MIDDLE EAST ---
+    "aleppo": (36.2021, 37.1343, "Syria", "SYR"),
+    "idlib": (35.9306, 36.6339, "Syria", "SYR"),
+    "beirut": (33.8938, 35.5018, "Lebanon", "LBN"),
+    "baghdad": (33.3152, 44.3661, "Iraq", "IRQ"),
+    "mosul": (36.3350, 43.1189, "Iraq", "IRQ"),
+    # --- AFRICA ---
+    "goma": (-1.6785, 29.2284, "DR Congo", "COD"),
+    "beni": (0.4900, 29.4700, "DR Congo", "COD"),
 }
 
 COUNTRY_CENTROIDS = {
@@ -64,8 +108,9 @@ def get_geolocator():
 def normalize_location_text(text: str) -> str:
     if not text: return ""
     t = text.lower()
-    # Remove noise patterns
+    # Remove noise patterns but preserve critical infrastructure identifiers
     t = re.sub(r'\b(near|outside|north of|south of|east of|west of|frontline near|region of|area of)\b', '', t)
+    # Be careful not to remove 'base' or 'port' here
     t = re.sub(r'\b(city|province|district|oblast|state)\b', '', t)
     # Simplify whitespace
     return ' '.join(t.split()).strip()
@@ -126,9 +171,14 @@ async def geocode_ranked(place: str, country: str, admin1: str = None) -> Dict:
             if admin1 and (admin1.lower() in str(addr).lower()):
                 score += 0.20
             
-            # Name Similarity (Simple check - 20%)
+            # PINPOINT LANDMARK BOOST (World Monitor Requirement)
+            landmark_kws = ['base', 'airport', 'port', 'checkpoint', 'refinery', 'plant', 'depot', 'harbor', 'dam']
+            if any(kw in clean_place for kw in landmark_kws) and any(kw in cand.address.lower() for kw in landmark_kws):
+                score += 0.25 # High boost for strategic infrastructure
+            
+            # Name Similarity (Simple check - 15%)
             if clean_place in cand.address.lower():
-                score += 0.20
+                score += 0.15
                 
             # Feature Type Preference (10%)
             if addr.get('city') or addr.get('town') or addr.get('village'):

poller/rss_poller.py

@@ -6,6 +6,7 @@ from datetime import datetime, timezone
 from poller.db_inserter import upsert_event
 from poller.geo_utils import geocode_ranked
 from poller.classifier import classify_event_llm
+from poller.deduplicator import is_duplicate_event
 
 log = logging.getLogger(__name__)
 
@@ -19,73 +20,97 @@ RSS_FEEDS = [
 ]
 
 CONFLICT_KEYWORDS = ['battle','strike','attack','shelling','airstrike',
-                     'missile','killed','fatalities','troops','offensive', 'war', 'army']
-
-def build_event(entry, geo_res, ai_res, source='RSS'):
-    event_time = datetime.now(timezone.utc).replace(tzinfo=None)
-    uniq = str(uuid.uuid5(uuid.NAMESPACE_URL, entry.get('link', ''))).split('-')[0]
-    return {
-        "event_id": f"CIQ-{event_time.strftime('%Y%m%d')}-RSS-{uniq}",
-        "source": source,
-        "source_reliability": "MEDIUM",
-        "event_time": event_time,
-        "event_date": event_time.date(),
-        "country": geo_res["country"],  
-        "country_iso3": geo_res["iso3"],
-        "admin1": geo_res.get("admin1"),
-        "lat": geo_res["lat"],           
-        "lon": geo_res["lon"],           
-        "geo_precision": geo_res["precision"],
-        "geo_confidence": geo_res["confidence"],
-        "geo_method": geo_res["method"],
-        "geocode_provider": geo_res["provider"],
-        "location_raw": ai_res.get("location_raw"),
-        "event_type": ai_res.get("event_type", "Other"),
-        "severity": "HIGH" if ai_res["severity_score"] > 7 else "MEDIUM" if ai_res["severity_score"] > 4 else "LOW",
-        "severity_score": ai_res.get("severity_score", 3.0),
-        "category": ai_res.get("category", "GENERAL"),
-        "tags": ai_res.get("tags", []),
-        "title": entry.get("title", "")[:500],
-        "notes": ai_res.get("notes") or entry.get("summary", "")[:1000],
-        "source_url": entry.get("link", ""),
-        "actor1": ai_res.get("actor1"),
-        "actor2": ai_res.get("actor2"),
-        "fatalities": ai_res.get("fatalities", 0)
-    }
+                     'missile','killed','fatalities','troops','offensive', 'war', 'army',
+                     'bombing', 'explosion', 'drone', 'artillery', 'clashes', 'ambush',
+                     'insurgent', 'militant', 'terrorist', 'combat', 'mortar']
 
 async def poll_rss():
     log.info("Polling RSS Feeds with AI Intelligence...")
     count = 0
+    skipped_noise = 0
+    skipped_dupe = 0
+    
     for url in RSS_FEEDS:
         try:
             feed = feedparser.parse(url)
             for entry in feed.entries:
-                title = entry.get('title','').lower()
-                summary = entry.get('summary', '').lower()
+                title = entry.get('title','')
+                summary = entry.get('summary', '')
+                title_lower = title.lower()
+                summary_lower = summary.lower()
+                
+                # Pre-filter: Only process likely conflict news
+                if not any(kw in title_lower or kw in summary_lower for kw in CONFLICT_KEYWORDS):
+                    continue
                 
-                # Pre-filter to save LLM tokens (Only process likely conflict news)
-                if not any(kw in title or kw in summary for kw in CONFLICT_KEYWORDS):
+                # Token-saving deduplication
+                if await is_duplicate_event(title):
+                    skipped_dupe += 1
                     continue
                 
-                # 1. AI-Powered Insight (Swapped to FIRST so we get high-fidelity location)
-                ai_res = await classify_event_llm(entry.get('title',''), entry.get('summary',''))
+                # AI-Powered Classification
+                ai_res = await classify_event_llm(title, summary)
                 
-                # 2. High-Fidelity Geocoding using AI-extracted entities
+                # World Monitor Noise Gate
+                if ai_res.get("is_noise"):
+                    log.debug(f"RSS Skeptic Rejection: {title[:60]}... Reason: {ai_res.get('logic')}")
+                    skipped_noise += 1
+                    continue
+
+                # High-Fidelity Geocoding
                 geo_res = await geocode_ranked(
                     ai_res.get("location"), 
                     ai_res.get("country"),
                     ai_res.get("location_admin1")
                 )
                 
-                event = build_event(entry, geo_res, ai_res, source='RSS')
+                # Drop failed geocodes — don't pollute the map
+                if geo_res.get("confidence", 0) == 0.0 and geo_res.get("method") == "failed":
+                    log.warning(f"RSS: Dropping event with failed geocode: {title[:60]}")
+                    continue
+
+                event_time = datetime.now(timezone.utc).replace(tzinfo=None)
+                uniq = str(uuid.uuid5(uuid.NAMESPACE_URL, entry.get('link', ''))).split('-')[0]
+                
+                event = {
+                    "event_id": f"CIQ-{event_time.strftime('%Y%m%d')}-RSS-{uniq}",
+                    "source": "RSS",
+                    "source_reliability": "MEDIUM",
+                    "event_time": event_time,
+                    "event_date": event_time.date(),
+                    "country": geo_res["country"],
+                    "country_iso3": geo_res["iso3"],
+                    "admin1": geo_res.get("admin1"),
+                    "lat": geo_res["lat"],
+                    "lon": geo_res["lon"],
+                    "geo_precision": geo_res["precision"],
+                    "geo_confidence": geo_res["confidence"],
+                    "geo_method": geo_res["method"],
+                    "geocode_provider": geo_res["provider"],
+                    "location_raw": ai_res.get("location_raw"),
+                    "event_type": ai_res.get("event_type", "Other"),
+                    "severity": "HIGH" if ai_res.get("severity_score", 0) > 7 else "MEDIUM" if ai_res.get("severity_score", 0) > 4 else "LOW",
+                    "severity_score": ai_res.get("severity_score", 3.0),
+                    "category": ai_res.get("category", "GENERAL"),
+                    "tags": ai_res.get("tags", []),
+                    "title": title[:500],
+                    "notes": ai_res.get("notes"),
+                    "source_url": entry.get("link", ""),
+                    "actor1": ai_res.get("actor1"),
+                    "actor2": ai_res.get("actor2"),
+                    "fatalities": ai_res.get("fatalities", 0),
+                    "ai_analysis": ai_res.get("ai_analysis"),
+                    "strategic_relevance": ai_res.get("strategic_relevance", "LOW"),
+                }
+                
                 await upsert_event(event)
                 count += 1
                 
-                # 3. Throttling: respect Nominatim "1 req/sec" + AI rate limits
+                # Rate limit compliance
                 await asyncio.sleep(2.0)
                 
         except Exception as e:
             log.error(f"Error parsing RSS {url}: {e}")
-            await asyncio.sleep(5) # Cooldown on failure
+            await asyncio.sleep(5)
 
-    log.info(f"Successfully processed {count} events from RSS with AI Intelligence.")
+    log.info(f"RSS: Processed {count} events. Rejected {skipped_noise} noise, {skipped_dupe} duplicates.")