📍 NearMe OSINT — Mapa de eventos en tiempo real

¿Qué está pasando a mi alrededor ahora mismo?

🔥 Incendios · 🚧 Tráfico · 🌡️ Meteorología · 🌫️ Calidad del aire · 🚆 Trenes · 🏚️ Terremotos · ⚡ Energía · 🏖️ Playas

---

Un agregador OSINT geográfico en tiempo real que une 15 fuentes de datos públicos y oficiales en un solo mapa interactivo con niveles de severidad, mediciones continuas y alertas personalizables. Funciona como una PWA instalable y offline.

💡 ¿Qué es esto en la práctica? En vez de revisar cinco apps distintas para saber si hay un incendio cerca, un retraso de tren, una alerta meteorológica o un corte de tráfico, NearMe lo agrupa todo en un flujo único de eventos geolocalizados.

---

🚀 Prueba la demo

→ Abrir NearMe OSINT en vivo

• 📍 Busca una ubicación por texto, haz clic en el mapa o usa tu GPS
• 🔥 Explora incendios reales detectados por satélite (NASA FIRMS)
• 🚆 Consulta retrasos de tren (RENFE) e incidencias de tráfico (DGT)
• 🔔 Activa alertas: "avísame si hay incendios a <15 km"
• 📱 Instálala como app (PWA con soporte offline)

✨ Características

📊 Pipeline de datos

[15 colectores async] → [Pipeline (asyncio.gather)] → [PostgreSQL + PostGIS] → [FastAPI] → [Frontend Leaflet]

Cada ciclo de 15 minutos procesa ~6.000+ eventos:

Ciclo de vida de un evento

1. Creación — el colector obtiene datos y hace upsert por (source, source_id)
2. Actualización — si el evento sigue en la fuente, se renueva su expires_at
3. Resolución — si deja de aparecer, resolve_events() lo marca como resolved
4. Expiración por TTL — si no hay fin explícito, se limpia al superar su TTL (incendios 24 h, tráfico 12 h, …)
5. Expiración explícita — se respeta el end_time de la fuente (p. ej. DGT overallEndTime)

Niveles de severidad

Frescura

Cada evento lleva un badge según su updated_at: 🟢 <30 min · 🟠 30 min–2 h · 🔴 >2 h. El sidebar muestra un semáforo por fuente (🟢🟡🔴) actualizado cada 60 s desde /api/status.

📈 Análisis transversal

Además del mapa en vivo, NearMe genera analítica agregada nocturna:

• zone_metrics — tabla diaria por CCAA: volumen de eventos, niveles de severidad, diversidad de fuentes, persistencia media e índice de convergencia (coincidencias espaciales <50 km y temporales <6 h entre fuentes distintas). Colector: scripts/compute_zone_metrics.py (cron 23:40, transacción por día).
• Incendios × meteorología — página editorial estática que cruza detecciones FIRMS con temperatura/viento diarios (Open-Meteo) por CCAA y día, con metodología y límites visibles: https://radar.viajeinteligencia.com/incendios-meteorologia.html (regeneración diaria 07:20).

🛠️ Stack

• Backend: FastAPI + uvicorn · async Python (httpx, asyncio.gather)
• Base de datos: PostgreSQL + PostGIS con connection pooling (psycopg2)
• Pipeline: cron */15 * * * * + monitoreo persistente en collector_runs
• Frontend: Leaflet + Leaflet.markerCluster + Leaflet.heat + vanilla JS (PWA con Service Worker)
• Auth: JWT + bcrypt (passlib)
• Infra: Nginx + SSL Let's Encrypt · PM2 (nearme-api) · rsync

📁 Estructura del proyecto

nearme-osint/
├── run.py                      # Orquestador del pipeline (colectores async)
├── src/
│   ├── api/server.py           # FastAPI (frontend + API + auth)
│   ├── db.py                   # PostgreSQL/PostGIS con connection pooling
│   ├── config.py               # Constantes centralizadas (umbrales, URLs, TTLs)
│   ├── logging.py              # Logging JSON estructurado
│   ├── metrics.py              # PipelineMetrics (latencia y éxito por colector)
│   ├── models.py               # Event dataclass + EVENT_TYPES
│   └── collectors/
│       ├── aemet/              # Meteorología (observaciones + alertas)
│       ├── dgt/                # Tráfico DATEX II + USGS + NASA FIRMS
│       ├── renfe/              # Retrasos tren (GTFS-RT + CSV estaciones)
│       ├── ree/                # Demanda eléctrica
│       ├── miteco/             # Calidad del aire (ICA)
│       ├── openaq/             # Calidad del aire (fallback, 6 parámetros)
│       ├── proteccion_civil/   # Avisos meteorológicos (CAP)
│       ├── intelhub_bridge.py  # Noticias/incendios RSS (IntelHub)
│       ├── playas/             # Estado de playas Euskadi
│       ├── embalses/           # Nivel de embalses (SAIH + MITECO)
│       ├── ign/                # Sismología española (red 24/7)
│       ├── uv/                 # Índice UV (Open-Meteo)
│       ├── energy/             # Demanda REE + precio PVPC (ESIOS)
│       └── copernicus/         # Incendios GWIS (endpoints 404 — deshabilitado)
├── frontend/                   # Leaflet + MarkerCluster + vanilla JS (PWA)
├── analytics/                  # Reporte GoAccess (basic auth)
├── deploy.sh                   # rsync + PM2 restart
├── setup-server.sh             # Provisionamiento del servidor
├── requirements.txt
├── .env.example                # Template de credenciales (gitignored)
└── WAYAHEAD.md                 # Bitácora de desarrollo y sprints

🔌 API

Panel de operaciones: /admin (protegido con ADMIN_PASSWORD).

🚀 Puesta en marcha local

git clone git@github.com:mcasrom/nearme-osint.git
cd nearme-osint

# 1. Credenciales (AEMET_API_KEY, OPENAQ_API_KEY, DB_*, JWT_SECRET, ADMIN_PASSWORD)
cp .env.example .env

# 2. PostgreSQL con PostGIS
#    (ver setup-server.sh para el aprovisionamiento completo)

# 3. Instalar dependencias
python -m venv venv && source venv/bin/activate
pip install -r requirements.txt

# 4. Ejecutar el pipeline (recolección → PostGIS)
python run.py

# 5. Arrancar la API
uvicorn src.api.server:app --host 0.0.0.0 --port 8100

👥 Contribuir

¿Te interesa el OSINT de código abierto o los datos abiertos de España? Todas las contribuciones son bienvenidas:

• 🐛 Reporta bugs o sugerencias vía Issues
• 📦 Añade un colector: implementa BaseCollector con async collect() → list[Event], regístralo en run.py y añade su config en src/config.py
• 🗺️ Nueva fuente o región: el pipeline es agnóstico a la fuente; añadir otro país es "escribir un colector nuevo"
• 📄 Revisa WAYAHEAD.md para el contexto de desarrollo y sprints

🔒 Privacidad

Sin analytics, sin tracking, sin cookies, sin publicidad. Solo se guardan datos mínimos (usuario, email opcional y hash bcrypt) exclusivamente para el sistema de alertas y las ubicaciones favoritas. Sin IPs, sin geolocalización del usuario. Detalles en la app.

🧭 Roadmap

• Alertas por email
• Soporte multi-región (más países)
• Más fuentes de datos abiertos
• App móvil nativa (Android/iOS)
• API pública documentada para terceros

☕ Apoyar el proyecto

Hecho por un desarrollador independiente en España. Si te resulta útil:

• ⭐ Da una estrella al repositorio
• ☕ Invita un café en Ko-fi
• 📤 Comparte el mapa con quien pueda necesitarlo

Contacto: nearme@viajeinteligencia.com

📄 Licencia

MIT — libre de usar, auditar y modificar. Las fuentes de datos conservan sus propias licencias.

Widget embebible (para acuerdos de backlink)

• /embed.html — mapa en vivo embebible (solo mapa + crédito fijo).
• /incrustar — página howto para el usuario final (zona → código → colocación → ajustes).
• Uso: <iframe src="https://nearme.viajeinteligencia.com/embed.html?lat=..&lon=..&radius=30" width="100%" height="500"></iframe>
• Requisito: mantener el enlace de crédito a nearme.viajeinteligencia.com (backlink).

Navegación cruzada

En el footer: enlaces directos a Radar (emergencias), Noticias, Datos por país y Ecosistema. Los enlaces siguen los journeys reales de los usuarios.