AI Agent Backend - IoT Dashboard

A comprehensive Node.js Express backend for IoT device management with AI-powered analytics, real-time streaming, self-healing capabilities, and intelligent suggestions.

Features

🔐 Authentication & Authorization

• JWT-based authentication with Redis session management
• Role-based access control (Admin, Operator, Viewer)
• Password hashing with bcrypt
• Rate limiting for security

📡 Real-time Data Streaming

• Apache StreamPipes integration for IoT data ingestion
• WebSocket support for real-time communication
• Kafka/MQTT support for message queuing
• Redis caching for high-performance data access

🤖 AI Agent Capabilities

• Intelligent anomaly detection
• Predictive maintenance suggestions
• Performance optimization recommendations
• Self-healing automation
• Machine learning model management

🚨 Alert Management

• Real-time alert generation
• Configurable alert rules and thresholds
• Multi-channel notifications (Email, SMS, WebSocket)
• Alert acknowledgment and resolution tracking

🔧 Self-Healing System

• Automated problem detection and resolution
• Device restart and configuration management
• Load balancing and circuit breaker patterns
• Maintenance scheduling

📊 Analytics & Insights

• Real-time dashboard metrics
• Performance analytics
• Device health monitoring
• Historical data analysis

📱 Notification System

• Multi-channel notifications (Email, SMS, In-app)
• Configurable notification preferences
• Notification history and status tracking

Tech Stack

• Runtime: Node.js 16+
• Framework: Express.js
• Database: MySQL 8.0+
• Cache: Redis 6.0+
• Authentication: JWT + bcrypt
• Real-time: Socket.IO
• Streaming: Apache StreamPipes, Kafka, MQTT
• Notifications: Nodemailer, Twilio
• Logging: Winston
• Validation: Express-validator

Prerequisites

• Node.js 16+
• MySQL 8.0+
• Redis 6.0+
• Apache StreamPipes (optional)
• Kafka (optional)
• MQTT Broker (optional)

Installation

1. Clone the repository

   git clone <repository-url>
   cd ai-agent-backend
   

2. Install dependencies

   npm install
   

3. Environment Configuration

   cp env.example .env
   

   Edit .env with your configuration:

   # Database
   DB_HOST=localhost
   DB_PORT=3306
   DB_USER=root
   DB_PASSWORD=your_password
   DB_NAME=ai_agent_iot
   
   # JWT
   JWT_SECRET=your_super_secret_jwt_key_here
   
   # Redis
   REDIS_HOST=localhost
   REDIS_PORT=6379
   
   # StreamPipes
   STREAMPIPES_HOST=localhost
   STREAMPIPES_PORT=8080
   STREAMPIPES_USERNAME=admin
   STREAMPIPES_PASSWORD=admin
   
   # Notifications
   SMTP_HOST=smtp.gmail.com
   SMTP_USER=your_email@gmail.com
   SMTP_PASS=your_app_password
   
   TWILIO_ACCOUNT_SID=your_twilio_account_sid
   TWILIO_AUTH_TOKEN=your_twilio_auth_token
   

4. Database Setup

   # Run migrations
   npm run migrate
   
   # Seed initial data (optional)
   npm run seed
   

5. Start the server

   # Development
   npm run dev
   
   # Production
   npm start
   

API Endpoints

Authentication

• POST /api/auth/register - Register new user
• POST /api/auth/login - User login
• POST /api/auth/logout - User logout
• GET /api/auth/profile - Get user profile
• PUT /api/auth/profile - Update user profile
• POST /api/auth/refresh - Refresh JWT token

Devices

• GET /api/devices - Get all devices
• GET /api/devices/:deviceId - Get device details
• POST /api/devices - Create new device
• PUT /api/devices/:deviceId - Update device
• DELETE /api/devices/:deviceId - Delete device
• GET /api/devices/:deviceId/data - Get device data
• POST /api/devices/:deviceId/command - Send command to device
• GET /api/devices/:deviceId/stats - Get device statistics

Alerts

• GET /api/alerts - Get all alerts
• GET /api/alerts/:alertId - Get alert details
• POST /api/alerts/:alertId/acknowledge - Acknowledge alert
• POST /api/alerts/:alertId/resolve - Resolve alert
• GET /api/alerts/stats/overview - Get alert statistics

Analytics

• GET /api/analytics/dashboard - Get dashboard overview
• GET /api/analytics/performance - Get performance metrics

Healing

• GET /api/healing - Get healing actions

Suggestions

• GET /api/suggestions - Get AI suggestions

Notifications

• GET /api/notifications - Get user notifications

StreamPipes

• GET /api/streampipes/health - Check StreamPipes health
• GET /api/streampipes/streams - Get data streams

WebSocket Events

Client to Server

• subscribe_device - Subscribe to device updates
• unsubscribe_device - Unsubscribe from device updates
• subscribe_alerts - Subscribe to alerts
• unsubscribe_alerts - Unsubscribe from alerts
• device_control - Send device control command
• acknowledge_alert - Acknowledge alert

Server to Client

• device_data_update - Device data update
• new_alert - New alert notification
• alert_acknowledged - Alert acknowledged
• healing_approved - Healing action approved
• suggestion_feedback_received - Suggestion feedback
• new_notification - New notification
• dashboard_update - Dashboard update

Database Schema

Core Tables

• users - User accounts and authentication
• devices - IoT device information
• device_data - Raw device data storage
• alerts - Alert records
• notifications - User notifications

AI & Analytics Tables

• ai_suggestions - AI-generated suggestions
• ai_analysis_results - AI analysis results
• healing_actions - Self-healing actions
• device_controls - Device control commands

Services Architecture

Core Services

• StreamPipesService - Handles Apache StreamPipes integration
• AIAgentService - Manages AI analysis and suggestions
• AlertService - Handles alert generation and management
• HealingService - Manages self-healing actions
• NotificationService - Handles multi-channel notifications

Configuration

• Database - MySQL connection and query management
• Redis - Caching and session management
• Logger - Structured logging with Winston

Development

Project Structure

├── config/           # Configuration files
├── middleware/       # Express middleware
├── routes/          # API route handlers
├── services/        # Business logic services
├── socket/          # WebSocket handlers
├── utils/           # Utility functions
├── scripts/         # Database scripts
├── logs/            # Application logs
├── server.js        # Main application file
└── package.json     # Dependencies and scripts

Available Scripts

• npm start - Start production server
• npm run dev - Start development server with nodemon
• npm run migrate - Run database migrations
• npm run seed - Seed database with initial data
• npm test - Run tests

Environment Variables

See env.example for all available configuration options.

Deployment

Production Setup

1. Set NODE_ENV=production
2. Configure production database and Redis
3. Set up SSL certificates
4. Configure reverse proxy (nginx)
5. Set up process manager (PM2)

Docker Deployment

# Build image
docker build -t ai-agent-backend .

# Run container
docker run -p 5000:5000 --env-file .env ai-agent-backend

Monitoring & Logging

Health Checks

• GET /health - Application health status
• Service-specific health checks available

Logging

• Structured JSON logging
• Log rotation and archiving
• Different log levels (error, warn, info, debug)

Metrics

• Request/response metrics
• Database query performance
• Service health metrics
• Custom business metrics

Security

Authentication

• JWT tokens with configurable expiration
• Redis-based session management
• Password hashing with bcrypt

Authorization

• Role-based access control
• Route-level permissions
• Device-level access control

Security Headers

• Helmet.js for security headers
• CORS configuration
• Rate limiting
• Input validation

Contributing

1. Fork the repository
2. Create a feature branch
3. Make your changes
4. Add tests
5. Submit a pull request

License

MIT License - see LICENSE file for details

Support

For support and questions:

• Create an issue in the repository
• Check the documentation
• Review the API examples

Roadmap

• Advanced ML model integration
• GraphQL API support
• Microservices architecture
• Kubernetes deployment
• Advanced analytics dashboard
• Mobile app support
• Multi-tenant support
• Advanced security features