Skip to content
salvatore-ardisi edited this page Mar 17, 2026 · 132 revisions

NotifyEngine


NotifyEngine Logo

NotifyEngine

ML-Powered Notification Delivery Service with Adaptive Channel Routing

Website


Project Description

NotifyEngine is an intelligent notification routing service that learns from user behavior to automatically choose the best delivery channel (email, SMS, push, or in‑app) for every message. Designed for developers and product teams sending high‑volume notifications, it replaces static routing rules with an XGBoost ML model that adapts per‑user in real time.

Unlike developer tools like Courier, Knock, or Novu that rely on fixed priority rules, and enterprise platforms like Braze or MoEngage that cost $50K+/year and aren't developer-first, NotifyEngine offers a simple API with per‑user ML routing that continuously improves with every notification sent.

Key outcomes: Higher engagement rates, lower SMS spending, circuit breaker during provider outages, and no manual routing logic to maintain.

Project Description as PDF | Download Project Description as DOCX


Team Members


Zeeya Ramani
Data Analyst / Developer

Salvatore Ardisi
AI Engineer / Developer

Rhythm Patel
AI Engineer / Developer

Dhawalshree Mengane
Data Analyst / Developer

Mohammed Nazir Yusif
Security Engineer / Project Manager

Krish Dhorajiya
AI Engineer / Tester

Architecture at a Glance

                                         ┌───────────────────┐
                                         │   React Dashboard │
                                         │  (Vite + Tailwind)│
                                         └────────┬──────────┘
                                                  │ HTTP + WebSocket
                                                  ▼
┌──────────┐    POST notifications       ┌──────────────────┐     ┌──────────────┐
│ Developer│ ──────────────────────────► │  API Server      │────►│ PostgreSQL   │
│  Client  │ ◄── 202 Accepted            │  Express + TS    │     │ (Multi-tenant│
└──────────┘                             └────────┬─────────┘     │  + RLS)      │
                                                  │ Enqueue       └──────────────┘
                                                  ▼                      ▲
                                         ┌─────────────────┐             │
                                         │  Redis + BullMQ │             │
                                         │  (Job Queue)    │             │
                                         └────────┬────────┘             │
                                                  │ Dequeue              │
                                                  ▼                      │
                                         ┌────────────────┐              │
                                         │   Worker       │──────────────┘
                                         │  (Delivery +   │
                                         │ Feature Ext.)  │
                                         └───┬────────┬───┘
                                             │        │
                              ┌──────────────┘        └──────────────────┐
                              ▼                                          ▼
                     ┌───────────────────┐                    ┌─────────────────────┐
                     │  ML Service       │                    │  Delivery Channels  │
                     │  FastAPI + XGBoost│                    │  Email              │
                     │  Epsilon-Greedy   │                    │  Push               │
                     └───────────────────┘                    │  SMS                │
                                                              │  In-App             │
                                                              └─────────────────────┘
Component Technology Purpose
API Server Node.js, Express, TypeScript Request handling, auth, validation, enqueuing
Worker Node.js, BullMQ, TypeScript Feature extraction, ML routing, delivery execution
ML Service Python, FastAPI, XGBoost Engagement prediction, epsilon-greedy exploration
Database PostgreSQL 16 Multi-tenant storage with row-level security
Cache/Queue Redis + BullMQ Async job processing, rate limiting, caching
Dashboard React, Vite, Tailwind, shadcn/ui Real-time analytics, routing intelligence, notification explorer
Real-time Socket.IO In-app delivery channel + live dashboard updates
Observability Prometheus, Grafana, Pino Metrics, dashboards, structured JSON logging
CI/CD Docker, GitHub Actions Containerized deployment, automated testing, secret scanning

Core Algorithms

Algorithm Role How It Works
XGBoost Channel Prediction Decision trees trained on delivery outcomes. Each tree corrects the previous tree's errors. Outputs per-channel engagement probability-highest wins.
Epsilon-Greedy Exploration Strategy 90% exploit (use model's best prediction), 10% explore (try alternative channels). Prevents the model from getting stuck on old data.
Circuit Breaker Reliability Monitors provider failure rates in real-time. Opens on threshold -> reroutes to next-best channel -> auto-recovers utilizing a half-open test after cooldown.

Diagrams

Architecture Diagram

See Architecture at a Glance above.

ER Diagram

Context Diagram

Sequence Diagram


Languages and Tools

Languages & Frameworks

TypeScript Node.js Express React Vite Python FastAPI

ML & Data Science

XGBoost scikit--learn pandas

Databases & Infrastructure

PostgreSQL Redis Socket.IO BullMQ

UI

Tailwind CSS shadcn/ui

Validation

Zod Pydantic

Observability

Prometheus Grafana Pino

Testing

Jest pytest

DevOps & CI/CD

Docker GitHub Actions

Tools

GitHub Jira Slack VS Code Claude ChatGPT


CS691 - Spring 2026 Deliverables


Presentations (Sprint Reviews)

Sprint 0

  1. Watch Sprint 0 Presentation Video | Click here to download mp4 File
    0a. View Sprint 0 Presentation Slides as PDF
    0b. Download Sprint 0 Presentation Slides as PowerPoint

Sprint 1

  1. Watch Sprint 1 Presentation Video | Click here to download mp4 File
    1a. View Sprint 1 Presentation Slides as PDF
    1b. Download Sprint 1 Presentation Slides as PowerPoint
    1c. Prototype
    1d. Watch Sprint 1 Demo Video | Click here to download mp4 File
    1e. Sprint 1 Source Code

Sprint Burndown Charts and Completed Tasks

  1. Sprint 0 Completed Tasks
  2. Sprint 1 Burndown Chart and Completed Tasks

Sprint Planning

  1. Watch Sprint 1 Planning Recording | Click here to download mp4 File
  2. Watch Sprint 2 Planning Recording | Click here to download mp4 File

Retrospectives

  1. Watch Sprint 0 Retrospective Video | Click here to download mp4 File
  2. Watch Sprint 1 Retrospective Video | Click here to download mp4 File

Team Working Agreement

Team Working Agreement as PDF | Download Team Working Agreement as DOCX


Architecture Diagrams


Additional Project Artifacts


Product Personas

Sarah Kim Daniel Ross Amanda Lopez
Backend Developer Persona PDF Product Manager Persona PDF Growth Lead Persona PDF

User Stories w/ Acceptance Criteria


Acceptance Criteria


Application Test Cases


Monorepo Structure

notifyengine/
├── apps/
│   ├── api/              # Node.js Express API server (TypeScript)
│   ├── worker/           # BullMQ queue workers (TypeScript)
│   ├── ml-service/       # Python FastAPI ML prediction + training
│   └── dashboard/        # React admin dashboard (Vite + Tailwind)
├── packages/
│   └── shared/           # Shared TypeScript types + constants
├── infra/
│   ├── docker-compose.yml
│   ├── prometheus.yml
│   ├── grafana/dashboards/
│   └── migrations/       # PostgreSQL migrations
├── models/               # XGBoost model artifacts
├── .github/workflows/    # CI/CD + TruffleHog secret scanning
├── turbo.json
├── package.json
└── CLAUDE.md             # Project config with coding standards + security rules

Clone this wiki locally