๐Ÿ›๏ธ System Architecture

Complete data flow from ingestion to output across all GMIIE subsystems

Data Pipeline

๐Ÿ“ฅ

1 โ€” Ingestion

Raw data from central banks, BIS, SWIFT, regulatory bodies, financial institutions, and open-source intelligence. Normalised into structured events with confidence scores.

6 Source ScrapersEvent normaliserConfidence scorerPostgreSQL writerNeo4j graph builder
๐Ÿงฎ

2 โ€” Analysis Engines

NLP-driven analysis layer extracting narrative clusters, measuring divergence between official statements and reality, scoring propaganda probability.

Narrative Cluster EngineDivergence DetectorPropaganda ScorerPolicy Acceleration Index
๐Ÿ”ฌ

3 โ€” 5-Ring Sovereign Engine

Five concentric analytical rings, each measuring a different dimension of sovereign monetary infrastructure evolution. The NIG score synthesises rhetoric vs. reality.

Ring 1 โ€” Structural Signal MonitorRing 2 โ€” Language Drift AnalyserRing 3 โ€” Deployment TrackerRing 4 โ€” Fragility MapperRing 5 โ€” Fracture DetectorNIG โ€” Narrative-Infrastructure Gap
๐Ÿ”ฎ

4 โ€” Prediction Engine

Forward-looking engine combining all ring outputs to generate probabilistic scenarios, what-if simulations, and multi-dimensional societal impact assessments.

Scenario GeneratorProbability EngineWhat-If SimulatorSocietal Impact Observatory
๐Ÿ›ก๏ธ

5 โ€” Stabilization Layer

Calibration layer ensuring analytical integrity. Detects contradictory ring signals, dampens overconfident scores, enforces alert cooldown, enables human-in-the-loop review, and validates against historical crises.

Cross-Ring Conflict DetectorConfidence DampeningSignal Cooldown LogicAnalyst Review LayerHistorical BacktestingFull Audit Trail
๐Ÿ“ก

6 โ€” Output & Distribution

Multi-channel output layer delivering intelligence through interactive dashboards, real-time alerts, automated daily briefs, and a comprehensive REST API.

Real-time Dashboard (22 views)WebSocket Alert StreamDaily Intelligence BriefsREST API (19 router groups)

Data Stores

๐Ÿ˜

PostgreSQL 16

Primary relational store โ€” 29 model classes, events, ring scores, stabilization state

๐Ÿ”—

Neo4j 5

Graph database โ€” 7 node labels, 15 edge types, infrastructure topology, dependency mapping

โšก

Redis 7

Cache & pub/sub โ€” alert streaming, session cache, rate limiting, Celery broker

โฐ Celery Beat โ€” 16 Scheduled Tasks

Ingestion

every 4 hours
scrape_all_sources
ingest_events
build_graph
generate_brief

Analysis

every 2 hours
run_narrative_analysis
compute_divergence
detect_propaganda

Ring Computation

every 1 hour
compute_stress_index
analyse_language_drift
track_deployments
map_fragility
detect_fractures
compute_nig_scores

Stabilization

every 30 min
cross_ring_conflict_detection
confidence_dampening
cleanup_expired_cooldowns

๐ŸŒ API Surface โ€” 19 Router Groups

GET /api/events/
GET /api/dashboard/
GET /api/alerts/
GET /api/graph/
GET /api/briefs/
GET /api/analysis/
GET /api/signals/
GET /api/drift/
GET /api/deployments/
GET /api/fragility/
GET /api/fractures/
GET /api/nig/
GET /api/predictions/
GET /api/conflicts/
GET /api/confidence/
GET /api/cooldown/
GET /api/backtest/
GET /api/reviews/
GET /api/audit/

๐Ÿ“ Data Model โ€” 29 SQLAlchemy Classes

Core

InfrastructureEvent
EventSource
Alert
NarrativeCluster
IntelligenceBrief
AuditLog

Ring 1โ€“3

StructuralSignal
StressIndex
LanguageDrift
CoordinatedShift
DeploymentTracker
DeploymentMilestone

Ring 4โ€“5 + NIG

FragilityNode
DependencyEdge
FractureEvent
FractureIndex
NIGScore

Predictions

Scenario
Prediction
WhatIfSimulation
SocietalImpactScore

Stabilization

ConfidenceScore
AlertCooldown
CrossRingConflict
AnalystReview

Backtesting

BacktestScenario
BacktestResult
GMIIE โ€” Global Monetary Infrastructure Intelligence Engine โ€” All systems operational