Built for uOttaHack 8 | Solace Agent Mesh + Solace PubSub+ + Django + React
An intelligent email security system that uses multiple AI agents to analyze incoming emails in real-time for spam detection, priority classification, tone analysis, action item extraction, and malicious URL scanning.
- 🚫 Spam Detection - AI-powered spam and phishing classification
- 🎯 Priority Classification - Automatic urgency scoring (Urgent/High/Medium/Low)
- 📝 Smart Summaries - One-line AI summaries for quick scanning
- 😊 Tone Analysis - Sentiment detection (Professional, Friendly, Urgent, etc.)
- ✅ Action Item Extraction - Automatically extracts tasks with due dates
- 🔗 URL Security Scanning - VirusTotal integration for malicious link detection
- 💬 AI Chat Interface - Ask questions about your emails in natural language
- ⚡ Real-time Updates - Server-Sent Events (SSE) for instant UI updates
┌─────────────┐ ┌──────────────────┐ ┌─────────────────────────────────┐
│ React UI │◄───►│ Django Backend │────►│ Solace PubSub+ Broker │
│ (Vite) │ SSE │ (DRF + JWT) │MQTT │ │
└─────────────┘ └──────────────────┘ └───────────────┬─────────────────┘
│ │
│ ▼
┌─────────┴─────────┐ ┌─────────────────────────────────┐
│ PostgreSQL 16 │ │ Solace Agent Mesh (SAM) │
│ + Redis 7 │ │ ┌─────────┐ ┌─────────────────┐│
└───────────────────┘ │ │ Event │ │ AI Agents ││
│ │ Mesh GW │►│ • SpamAgent ││
┌───────────────────┐ │ │ │ │ • PriorityAgent ││
│ Django Consumer │◄────┤ │ │ │ • SummaryAgent ││
│ (MQTT Subscriber)│ │ │ │ │ • ToneAnalyzer ││
└───────────────────┘ │ │ │ │ • ActionItems ││
│ │ │ │ • URLScanner ││
│ └─────────┘ │ • QueryAgent ││
└─────────────────────────────────┘
│
┌───────────────┴───────────────┐
│ External Services │
│ • AWS Bedrock (Claude 3.5) │
│ • VirusTotal API (MCP) │
└───────────────────────────────┘
How it works:
- Django publishes new emails to Solace topics via MQTT
- SAM's Event Mesh Gateway fans out each email to 6+ specialist AI agents in parallel
- Each agent analyzes the email and publishes results to its own topic
- Django Consumer subscribes to all result topics and updates the database
- SSE pushes real-time updates to the React UI
uOttaMail/
├── backend/ # Django REST API + MQTT Consumer
│ ├── api/ # DRF views, models, serializers
│ │ ├── models.py # Email, User, ActionItem models
│ │ ├── views.py # REST endpoints + SSE
│ │ └── solace_mqtt.py # MQTT publisher client
│ ├── inboxfirewall/ # Django project settings
│ └── requirements.txt
├── frontend/ # React + Vite UI
│ ├── src/
│ │ ├── App.jsx # Main application component
│ │ └── index.css # Styling
│ └── package.json
├── sam/ # Solace Agent Mesh configuration
│ ├── configs/
│ │ ├── agents/ # AI agent definitions
│ │ │ ├── spam_agent.yaml
│ │ │ ├── priority_agent.yaml
│ │ │ ├── summary_agent.yaml
│ │ │ ├── email_tone_analyzer.yaml
│ │ │ ├── action_items_agent.yaml
│ │ │ ├── url-scanner.yaml
│ │ │ └── email_query_agent.yaml
│ │ ├── gateways/ # Event Mesh Gateway configs
│ │ └── shared_config.yaml
│ └── src/inbox_agents/ # Custom Python tools
├── docker-compose.yml # Full stack orchestration
├── .env.example # Environment template
└── README.md
- Docker & Docker Compose
- AWS account with Bedrock access (Claude 3.5 Haiku enabled)
- VirusTotal API key (free tier works)
git https://github.com/Divi76h/uOttaMail.git
cd uOttaMail
# Copy environment files
cp .env.example .env
cp sam/.env.example sam/.envEdit sam/.env:
LLM_SERVICE_API_KEY=<your-aws-access-key>
LLM_SERVICE_API_KEY_SECRET=<your-aws-secret-key>
LLM_SERVICE_REGION=us-east-1
VIRUSTOTAL_API_KEY=<your-virustotal-key>docker compose up --buildNote: First run takes a few minutes as SAM installs the Event Mesh Gateway plugin.
| Service | URL | Credentials |
|---|---|---|
| React UI | http://localhost:5173 | Register new user |
| Django API | http://localhost:8001/api/ | JWT Auth |
| Solace Broker Manager | http://localhost:8080 | admin / admin |
- Register two users in the UI (e.g.,
aliceandbob) - Login as Alice and send an email to Bob
- Login as Bob - watch the email appear with AI analysis badges:
- 🟢 Priority badge (Urgent/High/Medium/Low)
- 🛡️ Spam status (Legitimate/Suspicious/Spam)
- 📝 One-line summary
- 😊 Tone indicator
- ✅ Extracted action items
- 🔗 URL safety status
- Try the AI Chat - Ask "What emails mention deadlines?"
solace-broker/
├── email/
│ ├── new/{user_id}/{email_id} # Trigger for all agents
│ ├── chat/{user_id}/{session_id} # AI chat queries
│ ├── priority/{user_id}/{email_id} # Priority results
│ ├── spam/{user_id}/{email_id} # Spam detection results
│ ├── summary/{user_id}/{email_id} # Summary results
│ ├── tone/{user_id}/{email_id} # Tone analysis results
│ ├── action_items/{user_id}/{email_id} # Action items results
│ └── url_scan/{user_id}/{email_id} # URL scan results
| Layer | Technology | Purpose |
|---|---|---|
| Frontend | React 18 + Vite | Modern UI with hot reload |
| Backend | Django 5.1 + DRF | REST API framework |
| Auth | SimpleJWT | Token-based authentication |
| Database | PostgreSQL 16 | Primary data store |
| Cache | Redis 7 | Session management |
| Message Broker | Solace PubSub+ | Event-driven messaging |
| AI Framework | Solace Agent Mesh | Multi-agent orchestration |
| LLM | AWS Bedrock (Claude 3.5 Haiku) | AI inference |
| Security API | VirusTotal (MCP) | Malicious URL detection |
| Orchestration | Docker Compose | Container management |
# Backend only
cd backend && python manage.py runserver
# Frontend only
cd frontend && npm run dev
# View SAM logs
docker logs -f inbox-sam# Restart just SAM (after config changes)
docker compose restart sam
# View all container logs
docker compose logs -f
# Reset database (caution: deletes all data)
docker compose down -v
docker compose up --buildCheck for broker queue limits in Solace Manager (http://localhost:8080):
Queues > Look for queues starting with "#P2P"
If count is ~100, delete old queues and restart SAM
docker compose down
docker compose up -d postgres
# Wait for healthy status, then:
docker compose upVerify AWS credentials and ensure Claude 3.5 Haiku is enabled in your Bedrock region.
MIT License