🌊 AQUA-AI

AI-Powered Water Quality Monitoring Platform for India

🤖 Real-time Environmental Intelligence | 🏛️ Government Data Integration | 📊 Predictive Analytics

⭐ Help Us Protect India's Water - Star This Repository!

If you find this project useful or support water security in India, please give us a ⭐ on GitHub. It helps more people discover and contribute to this mission!

🚀 AI-Powered Water Quality Monitoring Platform for India

Real-time insights • Government data integration • Predictive analytics • Public health protection

🌟 Why Star This Project?

🧪 Social Impact: Directly addresses a water crisis affecting 600M+ people in India.
🤖 Cutting-Edge Tech: High-tier AI/ML integration with React and Node.js.
🏛️ Open Data: Bridges the gap between government data and public awareness.
💼 Professional Quality: Built to production standards, making it a great reference for recruiters.

🌟 Project Highlights

🎯 What Makes This Special

🤖 AI-Powered Predictions - Machine learning models forecast pollution events
🗺️ Interactive Visualization - Real-time India water quality map
🏛️ Government Data Integration - Official CPCB and Ministry data sources
📱 Full-Stack Solution - React frontend + Node.js backend + Python ML
🌐 Public Impact - Serves 1.4 billion people's water safety needs

💡 Key Features

✅ Real-time monitoring across Indian water bodies
✅ Risk level assessment with color-coded alerts
✅ Historical trend analysis and pattern recognition
✅ Pollution event forecasting using AI models
✅ Public health alerts and safety recommendations
✅ Mobile-responsive design for universal access

📊 Data Sources & Integration

🏛️ Official Government Data Sources

🏢 **National Water Quality Database**
🌊 River Water Quality Monitoring
🔗 jal.gov.in

🏦 **Water Quality Monitoring Network**
🏭 Industrial Pollution Data
🔗 cpcb.nic.in

📊 **Various Water Quality Datasets**
🌐 Open Government Platform
🔗 data.gov.in

💧 **Groundwater Quality Data**
🌊 Surface Water Monitoring
🔗 Research Institute

🧪 Water Quality Parameters Monitored

Parameter	📊 Indicator	🎯 Purpose	⚠️ Risk Level
BOD	Biochemical Oxygen Demand	🌿 Organic pollution	High
TDS	Total Dissolved Solids	💧 Water purity	Medium
Heavy Metals	Lead, Mercury, Cadmium, Arsenic	☠️ Toxic contamination	Critical
pH Level	Acidity/Alkalinity	⚖️ Chemical balance	Medium
Dissolved Oxygen	Aquatic life indicator	🐟 Ecosystem health	High
Coliform	Bacterial contamination	🦀 Biological safety	Critical
Nitrates/Phosphates	Agricultural runoff	🌾 Nutrient pollution	Medium

🚀 Technology Stack

🎨 Modern Tech Stack Powering Water Intelligence

🌐 Frontend Excellence

📱 React 18 + TypeScript for type-safe, responsive UI
🗺️ Leaflet/Mapbox for interactive geographical visualization
🎨 Modern CSS3 + Responsive Design for universal access

⚙️ Backend Powerhouse

🚀 Node.js + Express.js for scalable API architecture
🐍 Python FastAPI for high-performance ML model serving
🔒 JWT Authentication + Bcrypt password hashing
✅ Input Validation + CORS + Rate Limiting security
📝 Winston Logger for structured logging

🗄️ Database & Storage

🗺️ PostgreSQL + PostGIS for spatial data operations
⚡ Redis for caching and session management
📋 SQLite for development and testing environments

🤖 AI/ML Pipeline

🤖 TensorFlow + Scikit-Learn for predictive modeling
📊 Pandas + NumPy for data processing and analysis
🎨 Matplotlib + Plotly for data visualization

🐳 DevOps & Deployment

🐳 Docker containerization for consistent deployments
🌐 AWS/Cloud hosting with auto-scaling capabilities
🔄 CI/CD Pipeline with automated testing and deployment

📁 Project Architecture

🌊 aqua-ai-project/
┊
├── 🌐 frontend/              # React + TypeScript Application
│   ├── 🎨 src/components/    # Reusable UI components
│   ├── 🗺️ src/pages/        # Route-based page components
│   ├── 🔧 src/hooks/        # Custom React hooks
│   ├── 📊 src/contexts/     # State management contexts
│   └── 🌍 public/          # Static assets and PWA config
┊
├── ⚙️ backend/               # Node.js + Express API Server
│   ├── 🛣️ src/routes/       # API endpoint definitions (auth)
│   ├── �️ routes/           # API routes (water quality, locations, etc.)
│   ├── �💾 src/models/       # Database models (User, etc.)
│   ├── 🔒 src/middleware/   # Auth, validation, error handling
│   ├── 🗄️ src/db/          # Database connection and queries
│   └── � src/utils/        # Logger and utilities
┊
├── 🤖 ai-models/             # Python ML/AI Pipeline
│   ├── 📊 models/          # Trained ML models (.pkl files)
│   ├── 🔬 training/        # Model training scripts
│   ├── 🔍 evaluation/      # Model performance metrics
│   └── 📝 preprocessing/   # Data cleaning and feature engineering
┊
├── 📦 data-pipeline/         # Government Data Integration
│   ├── 📊 collectors/      # API data fetching modules
│   ├── 🧹 cleaners/         # Data validation and cleaning
│   ├── 🔄 schedulers/       # Automated data sync jobs
│   └── 📊 transformers/    # Data format standardization
┊
├── 🗄️ database/             # Database Schema & Migrations
│   ├── 🏗️ migrations/       # Database version control
│   ├── 🌱 seeds/            # Sample data for development
│   └── 📄 schema.sql        # PostgreSQL + PostGIS schema
┊
├── 🐳 docker-compose.yml    # Multi-container orchestration
├── 📚 docs/                 # Comprehensive documentation
├── 🛠️ .github/workflows/    # CI/CD automation
└── 📝 README.md             # This beautiful documentation!

🚀 Quick Start Guide

⚡ Lightning Fast Setup

1️⃣ Clone & Navigate

git clone https://github.com/Kuldeep2822k/aqua-ai.git
cd aqua-ai

2️⃣ Install Dependencies

# Install all dependencies at once
npm install
cd frontend && npm install && cd ..
cd backend && npm install && cd ..
pip install -r requirements.txt

2.5️⃣ Configure Environment

# Copy environment template
cp .env.example .env.development

# Edit .env.development with your settings:
# - Database connection (PostgreSQL)
# - JWT secret key
# - API keys (optional)

2.6️⃣ Setup Database

# Run database migrations
npm run db:migrate

# (Optional) Seed sample data
npm run db:seed

3️⃣ Launch Application

# Start entire stack with one command
npm run dev

4️⃣ Access Your Dashboard

🌐 Frontend: http://localhost:3000
⚙️ Backend API: http://localhost:5000
📊 Interactive Map: Ready to explore!

🐳 Docker One-Click Deploy

# Complete stack deployment with Docker
docker-compose up -d

# 🎉 That's it! Your Aqua-AI platform is live!

📚 Documentation Links

🎯 Live Demo & Features

🌐 Experience India's Water Quality Intelligence

🗺️ Interactive Map Dashboard

• Pan & zoom across India
• Click markers for detailed data
• Filter by parameters & risk levels
• Color-coded safety assessment

• Live WQI scores
• Safety threshold indicators
• Historical trend analysis
• Government data attribution

• ML-powered forecasting
• Pollution event prediction
• Confidence score metrics
• Hotspot identification

• Threshold violation detection
• Risk escalation notifications
• Public health advisories
• Email/SMS capabilities

🌈 Risk Level Color Coding

🏗️ System Architecture

graph TB
    subgraph "Frontend Layer"
        A[React + TypeScript]
        B[Leaflet Maps]
        C[Real-time Dashboard]
    end

    subgraph "API Gateway"
        D[Node.js + Express]
        E[Authentication]
        F[Rate Limiting]
    end

    subgraph "Data Layer"
        G[PostgreSQL + PostGIS]
        H[Redis Cache]
        I[Government APIs]
    end

    subgraph "AI/ML Pipeline"
        J[Python ML Models]
        K[TensorFlow]
        L[Prediction Engine]
    end

    A --> D
    B --> D
    C --> D
    D --> G
    D --> H
    D --> I
    G --> J
    J --> K
    K --> L
    L --> D

Architecture Diagrams

System Architecture

flowchart TB
  subgraph Frontend[Frontend Layer]
    FE1[React + TypeScript]
    FE2[Leaflet Maps]
    FE3[Real-time Dashboard]
  end

  subgraph API[API Gateway]
    API1[Node.js + Express]
    API2[Authentication]
    API3[Rate Limiting]
  end

  subgraph Data[Data Layer]
    DB1[PostgreSQL + PostGIS]
    DB2[SQLite Dev Storage]
    DB3[Government APIs]
    DB4[Redis Cache]
  end

  subgraph ML[AI/ML Pipeline]
    ML1[Python ML Models]
    ML2[Feature Engineering]
    ML3[Prediction Engine]
  end

  subgraph ETL[ETL + Data Pipeline]
    ETL1[Python ETL]
    ETL2[Validation + Cleaning]
    ETL3[Scheduler]
  end

  subgraph Obs[Observability + Alerts]
    O1[Winston Logs]
    O2[Sentry Errors]
    O3[Performance Monitoring]
    O4[Alerting]
  end

  FE1 --> API1
  FE2 --> API1
  FE3 --> API1
  API1 --> API2
  API1 --> API3
  API1 --> DB1
  API1 --> DB2
  API1 --> DB4
  DB4 --> API1
  DB3 --> ETL1 --> ETL2 --> DB1
  ETL2 --> DB2
  ETL3 --> ETL1
  DB1 --> ML1
  DB2 --> ML1
  ML1 --> ML2 --> ML3 --> DB1
  API1 --> O1
  API1 --> O2
  API1 --> O3
  ML3 --> O4
  DB1 --> O4

Data Flow Architecture

flowchart LR
  subgraph Sources[Data Sources]
    S1[CPCB APIs]
    S2[Jal Shakti Data]
    S3[Open Government Data]
    S4[Community Reports]
  end

  subgraph Ingestion[ETL + Data Pipeline]
    P1[Fetch + Normalize]
    P2[Validation + Cleaning]
    P3[Enrichment + Geocoding]
    P4[Scheduler]
  end

  subgraph Storage[Storage]
    T1[PostgreSQL + PostGIS]
    T2[SQLite Dev DB]
    T3[Redis Cache]
  end

  subgraph Analytics[Analytics + AI]
    A1[Feature Store]
    A2[Model Training]
    A3[Risk Predictions]
  end

  subgraph Alerting[Alerts]
    AL1[Threshold Engine]
    AL2[Alert Store]
    AL3[Notification Service]
  end

  subgraph Delivery[Delivery]
    D1[REST API]
    D2[Realtime Dashboard]
    D3[Map Visualization]
  end

  Sources --> P1 --> P2 --> P3 --> Storage
  P4 --> P1
  T1 --> A1 --> A2 --> A3 --> T1
  T2 --> A1
  T1 --> AL1 --> AL2 --> D1
  D1 --> AL3
  T1 --> D1 --> D2
  T1 --> D3
  D1 --> T3
  T3 --> D1

Security Architecture

flowchart TB
  subgraph Clients[Clients]
    C1[Browser App]
    C2[Admin Console]
  end

  subgraph Edge[Ingress Controls]
    E1[HTTPS + TLS]
    E2[CORS Policy]
    E3[Rate Limiting]
  end

  subgraph Auth[Auth + Access]
    A1[JWT Auth]
    A2[RBAC Roles]
    A3[Session Controls]
  end

  subgraph App[Application Security]
    S1[Input Validation]
    S2[Sanitization]
    S3[Security Headers]
    S4[HPP + XSS Protection]
  end

  subgraph DataSec[Data Security]
    D1[Least Privilege DB User]
    D2[Audit Logs]
    D3[Encrypted Secrets]
    D4[Monitoring + Logs]
    D5[Backup + Recovery]
  end

  Clients --> Edge --> Auth --> App --> DataSec

Deployment Architecture

flowchart TB
  subgraph Dev[Developer Workstations]
    D1[Frontend]
    D2[Backend]
    D3[Data Pipeline]
  end

  subgraph CI[CI/CD]
    C1[GitHub Actions]
    C2[Build + Test]
    C3[Deploy]
  end

  subgraph Hosting[Hosting]
    H1[Render Frontend]
    H2[Render Backend]
  end

  subgraph DataInfra[Data Infrastructure]
    I1[Supabase Postgres + PostGIS]
    I2[Scheduled Pipeline]
  end

  D1 --> C1
  D2 --> C1
  D3 --> C1
  C1 --> C2 --> C3
  C3 --> H1
  C3 --> H2
  H2 --> I1
  I2 --> I1

CI/CD Pipeline

flowchart LR
  P1[Push or PR] --> P2[Lint]
  P2 --> P3[Unit Tests]
  P3 --> P4[Build Frontend]
  P4 --> P5[Build Backend]
  P5 --> P6[Deploy to Render]
  P6 --> P7[Schedule Data Pipeline]

Database ER Diagram

erDiagram
  USERS {
    uuid id PK
    string email
    string password_hash
    string role
    timestamp created_at
  }

  LOCATIONS {
    uuid id PK
    string name
    string state
    point geom
  }

  WATER_QUALITY_PARAMETERS {
    uuid id PK
    string name
    string unit
    float safe_threshold
  }

  WATER_QUALITY_READINGS {
    uuid id PK
    uuid location_id FK
    uuid parameter_id FK
    float value
    timestamp recorded_at
  }

  AI_PREDICTIONS {
    uuid id PK
    uuid location_id FK
    string risk_level
    float confidence
    timestamp predicted_at
  }

  ALERTS {
    uuid id PK
    uuid location_id FK
    string alert_status
    timestamp created_at
  }

  LOCATIONS ||--o{ WATER_QUALITY_READINGS : has
  WATER_QUALITY_PARAMETERS ||--o{ WATER_QUALITY_READINGS : defines
  LOCATIONS ||--o{ AI_PREDICTIONS : generates
  LOCATIONS ||--o{ ALERTS : triggers

Runtime Sequence Diagram

sequenceDiagram
  participant User
  participant UI as Frontend UI
  participant API as API Gateway
  participant Auth as Auth Middleware
  participant Valid as Validation
  participant DB as Postgres + PostGIS
  participant Cache as Redis Cache
  participant ML as Prediction Engine
  participant Alerts as Alerting
  participant Obs as Monitoring

  User->>UI: Open dashboard
  UI->>API: GET /api/locations
  API->>Auth: Verify JWT
  Auth-->>API: OK
  API->>Valid: Validate request
  Valid-->>API: OK
  API->>Cache: Read cached locations
  alt Cache hit
    Cache-->>API: Locations
  else Cache miss
    API->>DB: Query locations
    DB-->>API: Locations
    API->>Cache: Store locations
  end
  API->>Obs: Log request metrics
  API-->>UI: Locations response

  UI->>API: GET /api/predictions/risk-map
  API->>Auth: Verify JWT
  Auth-->>API: OK
  API->>DB: Fetch latest readings
  API->>ML: Request predictions
  ML-->>API: Risk scores
  API->>Alerts: Evaluate thresholds
  Alerts-->>API: Active alerts
  API->>Obs: Log prediction latency
  API-->>UI: Risk map payload
  UI-->>User: Render map + alerts

Data Governance Architecture

flowchart LR
  subgraph Governance[Governance + Quality]
    G1[Data Catalog]
    G2[Lineage Tracker]
    G3[Quality Scoring]
    G4[Retention Policies]
    G5[PII Classification]
  end

  subgraph Sources[Data Sources]
    S1[Government APIs]
    S2[Community Inputs]
  end

  subgraph Pipeline[ETL + Storage]
    P1[Ingestion]
    P2[Validation]
    P3[Postgres + PostGIS]
    P4[Archive Storage]
  end

  Sources --> P1 --> P2 --> P3
  P1 --> G2
  P2 --> G3
  P3 --> G1
  P3 --> G4 --> P4
  P1 --> G5

Security Depth Architecture

flowchart TB
  subgraph Edge[Edge Protection]
    E1[WAF]
    E2[DDoS Mitigation]
    E3[TLS Termination]
  end

  subgraph Secrets[Secrets + Keys]
    S1[Secrets Manager]
    S2[KMS]
    S3[Key Rotation]
  end

  subgraph App[Application]
    A1[API Gateway]
    A2[Auth Service]
    A3[Rate Limiting]
  end

  Edge --> App
  Secrets --> App
  S2 --> S3

Operational Resilience Architecture

flowchart TB
  subgraph Primary[Primary Region]
    P1[Frontend]
    P2[Backend]
    P3[Primary DB]
  end

  subgraph Secondary[Secondary Region]
    S1[Standby Backend]
    S2[Read Replica]
    S3[Static Failover Site]
  end

  subgraph Recovery[Recovery]
    R1[Backups + Snapshots]
    R2[Restore Playbooks]
    R3[Failover Runbook]
  end

  P2 --> P3
  P3 --> S2
  S2 --> S1
  P1 --> S3
  P3 --> R1 --> R2
  R2 --> R3
  R3 --> S1

User Journey Diagram

flowchart LR
  U1[User] --> U2[Open Dashboard]
  U2 --> U3[Authenticate]
  U3 --> U4[View Map]
  U4 --> U5[Select Location]
  U5 --> U6[View Analytics]
  U6 --> U7[Receive Alerts]
  U7 --> U8[Download Report]

Threat Model Diagram

flowchart TB
  subgraph Threats[Attack Surface]
    T1[Injection]
    T2[XSS]
    T3[Credential Abuse]
    T4[Rate Abuse]
  end

  subgraph Controls[Controls]
    C1[Validation + Sanitization]
    C2[HPP + XSS Protection]
    C3[JWT + RBAC]
    C4[Rate Limiting + WAF]
  end

  subgraph Outcomes[Outcomes]
    O1[Rejected Requests]
    O2[Blocked Actors]
    O3[Audit Trail]
  end

  Threats --> Controls --> Outcomes

🐍 Detailed Architecture Flow

Layer	Technology	Purpose	Scalability
🌐 Frontend	React + TypeScript	Interactive UI/UX	CDN Distribution
⚙️ Backend	Node.js + Express	API Services	Load Balancing
🗄️ Database	PostgreSQL + PostGIS	Spatial Data	Read Replicas
🤖 AI/ML	Python + TensorFlow	Predictions	Model Serving
📊 Cache	Redis	Performance	Clustering

🏆 Hackathon Impact & Innovation

🌍 Addressing India's Most Critical Environmental Challenge

📊 Problem Scope

🌊 600M+ People affected by water pollution
🏥 70% of Surface Water contaminated
💰 ₹3 Trillion economic impact annually
⚠️ 2M Deaths/year from water-related diseases

🚀 Our Solution Impact

🤖 AI-Powered early warning system
🏛️ Government Data integration
📊 Real-time public access to water data
📈 Predictive Analytics for policy makers

🎆 Innovation Highlights

💰 Business Model & Monetization

💹 Revenue Potential: $9.5M+ by Year 3

🏛️ **State & Municipal**
$200K - $500K per contract
28 states + major cities

🏭 **Industrial Compliance**
$5K - $50K monthly
1000+ facilities target

📊 **Data Access**
$99 - $2,499 monthly
Developers & researchers

🤝 Contributing & Community

👩‍💻 How to Contribute

🍴 Fork the repository
🌱 Create your feature branch (git checkout -b feature/AmazingFeature)
✨ Commit your changes (git commit -m 'Add some AmazingFeature')
🚀 Push to the branch (git push origin feature/AmazingFeature)
🎉 Open a Pull Request

🎆 Built with ❤️ for India's Water Security

⭐ Star this repo if it helped you!

Kuldeep Kumar • 2024 • MIT Licensed

Name		Name	Last commit message	Last commit date
Latest commit History 550 Commits
.devcontainer		.devcontainer
.github		.github
.husky		.husky
.jules		.jules
.planning		.planning
.vs		.vs
ai-models		ai-models
api		api
backend		backend
data-pipeline		data-pipeline
docs		docs
frontend		frontend
.env.development		.env.development
.env.example		.env.example
.flake8		.flake8
.gitignore		.gitignore
.prettierignore		.prettierignore
.prettierrc		.prettierrc
GEMINI.md		GEMINI.md
LICENSE		LICENSE
README.md		README.md
docker-compose.yml		docker-compose.yml
generate_history.py		generate_history.py
index.js		index.js
package-lock.json		package-lock.json
package.json		package.json
pyproject.toml		pyproject.toml
render.yaml		render.yaml
requirements.txt		requirements.txt
vercel.json		vercel.json
verify.ps1		verify.ps1
verify.sh		verify.sh
verify_a11y.py		verify_a11y.py

Folders and files

Latest commit

History

Repository files navigation

🌊 AQUA-AI

AI-Powered Water Quality Monitoring Platform for India

🤖 Real-time Environmental Intelligence | 🏛️ Government Data Integration | 📊 Predictive Analytics

⭐ Help Us Protect India's Water - Star This Repository!

🚀 AI-Powered Water Quality Monitoring Platform for India

🌟 Why Star This Project?

🌟 Project Highlights

🎯 What Makes This Special

💡 Key Features

📊 Data Sources & Integration

🏛️ Official Government Data Sources

🧪 Water Quality Parameters Monitored

🚀 Technology Stack

🎨 Modern Tech Stack Powering Water Intelligence

🌐 Frontend Excellence

⚙️ Backend Powerhouse

🗄️ Database & Storage

🤖 AI/ML Pipeline

🐳 DevOps & Deployment

📁 Project Architecture

🚀 Quick Start Guide

⚡ Lightning Fast Setup

1️⃣ Clone & Navigate

2️⃣ Install Dependencies

2.5️⃣ Configure Environment

2.6️⃣ Setup Database

3️⃣ Launch Application

4️⃣ Access Your Dashboard

🐳 Docker One-Click Deploy

📚 Documentation Links

🎯 Live Demo & Features

🌐 Experience India's Water Quality Intelligence

🗺️ Interactive Map Dashboard

🌈 Risk Level Color Coding

🏗️ System Architecture

Architecture Diagrams

System Architecture

Data Flow Architecture

Security Architecture

Deployment Architecture

CI/CD Pipeline

Database ER Diagram

Runtime Sequence Diagram

Data Governance Architecture

Security Depth Architecture

Operational Resilience Architecture

User Journey Diagram

Threat Model Diagram

🐍 Detailed Architecture Flow

🏆 Hackathon Impact & Innovation

🌍 Addressing India's Most Critical Environmental Challenge

📊 Problem Scope

🚀 Our Solution Impact

🎆 Innovation Highlights

💰 Business Model & Monetization

💹 Revenue Potential: $9.5M+ by Year 3

🤝 Contributing & Community

👩‍💻 How to Contribute

🎆 Built with ❤️ for India's Water Security

⭐ Star this repo if it helped you!

About

Topics

Resources

License

Code of conduct

Uh oh!

Stars

Watchers

Forks

Releases

Packages 0

Uh oh!

Uh oh!

Contributors

Uh oh!

Languages

Packages