🔧 RIS Looking Glass Lite - Technical Documentation

graph TB subgraph "🌐 External Systems" RIS[RIPE RIS Live
ris-live.ripe.net/v1/ws] BROWSER[Browser Clients
JavaScript/HTML] FS[File System
Parquet Snapshots] end subgraph "🏗️ RIS Looking Glass Light" subgraph "📡 Data Ingestion" CONSUMER[RIS Live Consumer
WebSocket Client] PROCESSOR[BGP Event Processor
Parse & Validate] end subgraph "⚡ Akka Classic System" ACTOR[Actor System
ris-looking-glass] SCHEDULER[Scheduler
Periodic Tasks] end subgraph "💾 Data Layer" ROUTING[In-Memory Routing Table
ConcurrentHashMap
Thread-Safe] SNAPSHOTS[Snapshot Manager
Parquet Format] end subgraph "🌐 HTTP Layer" HTTP[Akka HTTP Server
Port 8080] ROUTES[REST API Routes
/api/v1/*] STATIC[Static Assets
HTML/JS/CSS] end subgraph "📊 Services" QUERY[Query Service
Route Lookups] LIVE[Live Event Service
Server-Sent Events] MEMORY[Memory Analyzer
Performance Monitoring] end subgraph "🎨 Visualizations" D3[D3.js Topology
SVG Rendering] SIGMA[Sigma.js Topology
WebGL Rendering] TERMINAL[Terminal Interface
Text-based UI] end end %% Data Flow RIS --> CONSUMER CONSUMER --> PROCESSOR PROCESSOR --> ROUTING ROUTING --> QUERY ROUTING --> LIVE %% Akka System ACTOR --> HTTP SCHEDULER --> SNAPSHOTS SNAPSHOTS --> FS FS --> ROUTING %% HTTP Layer HTTP --> ROUTES HTTP --> STATIC ROUTES --> QUERY ROUTES --> LIVE ROUTES --> MEMORY %% Client Connections STATIC --> D3 STATIC --> SIGMA STATIC --> TERMINAL BROWSER --> HTTP %% Live Updates LIVE --> BROWSER PROCESSOR --> LIVE %% Styling classDef external fill:#e1f5fe,stroke:#01579b,stroke-width:2px classDef pekko fill:#f3e5f5,stroke:#4a148c,stroke-width:2px classDef data fill:#e8f5e8,stroke:#1b5e20,stroke-width:2px classDef http fill:#fff3e0,stroke:#e65100,stroke-width:2px classDef viz fill:#fce4ec,stroke:#880e4f,stroke-width:2px class RIS,BROWSER,FS external class ACTOR,SCHEDULER pekko class ROUTING,SNAPSHOTS data class HTTP,ROUTES,STATIC http class D3,SIGMA,TERMINAL viz

sequenceDiagram participant RIS as RIPE RIS Live participant WS as WebSocket Consumer participant BGP as BGP Processor participant RT as Routing Table participant LE as Live Events participant UI as Browser UI participant API as REST API Note over RIS,UI: Real-time BGP Data Pipeline RIS->>WS: BGP Update Stream WS->>BGP: Raw BGP Events BGP->>RT: Processed Routes RT->>LE: Route Changes LE->>UI: Server-Sent Events UI->>UI: Update Visualization Note over API,RT: Query Processing UI->>API: Route Query API->>RT: Lookup Request RT->>API: Route Data API->>UI: JSON Response Note over RT,LE: Periodic Operations loop Every 15 minutes RT->>RT: Create Snapshot end loop Every 2 minutes RT->>LE: Memory Stats LE->>UI: Statistics Update end

flowchart LR subgraph "📡 Input" A[RIS Live WebSocket
BGP Updates] end subgraph "🔄 Processing" B[Event Parser
JSON → BGPEvent] C[Route Processor
Announcements
Withdrawals] D[Routing Table
In-Memory Store] end subgraph "📤 Output" E[Live Events
Server-Sent Events] F[REST API
Query Interface] G[Visualizations
Real-time UI] end A --> B B --> C C --> D D --> E D --> F E --> G F --> G %% Styling classDef input fill:#e3f2fd,stroke:#1976d2,stroke-width:2px classDef process fill:#f1f8e9,stroke:#388e3c,stroke-width:2px classDef output fill:#fce4ec,stroke:#c2185b,stroke-width:2px class A input class B,C,D process class E,F,G output

		// Thread-safe routing table
		class RoutingTable {
		  private val routes = new ConcurrentHashMap[String, BGPRoute]()
		  private val peerStats = new ConcurrentHashMap[String, PeerStatistics]()
		  private val asnRoutes = new ConcurrentHashMap[Int, Set[String]]()
		}

		// BGP Event Processing
		case class BGPEvent(
		  eventType: String,        // "announcement" or "withdrawal"
		  prefix: String,           // "8.8.8.0/24"
		  asPath: String,           // "3356 15169"
		  nextHop: String,          // "192.168.1.1"
		  peer: String,             // "rrc00-peer-123"
		  timestamp: Long           // Unix timestamp
		)