🛰️ Vigil · Real-Time Streaming Anomaly Platform
Kafka Flink QLoRA Qwen2.5-7B ClickHouse Iceberg PyTorch

Production-shaped streaming platform with provable exactly-once processing (Kafka + Flink), crash-tested via TaskManager SIGKILL with zero duplicates on recovery and zero reconciliation drift over 5.7M readings / 4 hours. Pairs a zero-shot foundation-model detector with a QLoRA-fine-tuned Qwen2.5-7B planner (97.7% exact-match on held-out hard cases vs 20% rules baseline) behind a deterministic safety gate. 76,556 events/sec, p99 detection 0.493 ms, 697 tests, CI-gated.

🪐 PersonaCR · Multi-Agent Code Review
FastAPI React TypeScript Groq Jina ChromaDB MCP

6-agent system that learns your coding fingerprint and reviews code against your own patterns, not generic rules. Research-grounded in 9 papers (EMNLP, NAACL, ACL). Parallel agent execution (~48% latency savings), CRScore-inspired ML quality gate (~69ms validation). Exposes the full pipeline via an MCP server (SSE transport) for direct Cursor / VS Code integration. ~8.5s end-to-end.

📡 Streaming Density Monitor · Sublinear KDE Sketch (C++17)
C++17 pybind11 Kafka Prometheus Grafana MCP

Re-implemented a 2025 sliding-window Approximate-KDE sketch (RACE + exponential histograms) as a tested package, catching and fixing 7 defects (2 in the paper's own pseudocode), each pinned by a regression test. Grew the suite to 130 tests validated against brute-force ground truth. Ported the hot path to C++17 behind pybind11 for ~10-20x faster updates, taking a 1.5M-reading pass from 23.9 min to 1.1 min, held bit-for-bit identical to the Python oracle.

🧠 Dory.md · Memory-Aware Notes (RAG + Spaced Repetition)
React TypeScript FastAPI ChromaDB RAG FSRS-4

Full-stack notes app that scores how fast you're forgetting each note (Ebbinghaus forgetting curve) and uses that decay signal to re-rank semantic search, schedule FSRS-4 reviews, and generate quizzes from your weakest material. FastAPI + dual SQLite/ChromaDB store with MiniLM embeddings, 43 API routes, an 11-page React SPA (8,170 lines TS/TSX), 92 tests, JWT auth with rotation, per-user isolation, and GDPR export.

⚙️ OULAD Analytics Engine · Distributed Data Pipeline (gRPC)
Java gRPC Multithreading JUnit 5

Processes a 10.65M-row / 433 MB dataset three ways (sequential, single-node concurrent, and a gRPC distributed system), each proven to produce the same SHA-256 checksum. Byte-range shard planner, worker- and coordinator-failure recovery with exactly-once re-queueing, and a PySpark equivalence check. 122 tests, 84% instruction / 76% branch coverage, plus a chaos harness that force-kills workers mid-run.

🌍 Third-Place-Finder · AI Recommendation Engine
React TypeScript Node.js Groq Leaflet · Live Demo

Multi-stage RAG pipeline mapping natural language to structured categories, ranking the top 10 with LLM rationale. Fault-tolerant integration with exponential backoff and anti-hallucination prompting. Deployed on Vercel + Render + Aiven.