Coreflux MQTT MCP Server
About
An enterprise-grade Model Context Protocol (MCP) server that provides secure, scalable access to Coreflux MQTT brokers and comprehensive automation capabilities for Claude and other MCP-compatible AI assistants.
Details
- License
- Apache-2.0
Explore
- LOT Code Generation - Generate Language-of-Things code from natural language
- Automation Assistance - Get help with Coreflux automation tasks
- Best Practices - Receive guidance on optimal implementations
- Troubleshooting - Get assistance with debugging and optimization
Setting up with Highlight
This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:
- Download and install Highlight from highlightai.com/download
- Navigate to the plugins tab and select "Add Custom Plugin"
-
Configure the plugin with the settings below
Plugin Name
Coreflux MQTT MCP ServerCommand (node, npx, python, etc.)Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.
- Enable "Start Automatically" if you want the plugin to start when Highlight launches
From the repository
Prerequisites
- Python 3.11 or higher - Docker (optional, for containerized deployment) - Access to a Coreflux MQTT broker - Coreflux Copilot API key (optional, for AI assistance)Interactive Setup Assistant
The server includes a comprehensive setup assistant that guides you through configuration: ``bash
python setup_assistant.py
`
The assistant helps with:
- 🔧 MQTT broker connection settings
- 🔐 TLS certificate configuration
- 🤖 Coreflux Copilot API integration
- 📝 Logging and monitoring setup
- ✅ Configuration validation and testing
Use the setup assistant when:
- Creating initial configuration
- Updating existing settings
- Troubleshooting connection issues
- Setting up TLS certificates
- Migrating between environments
Environment Configuration
Copy .env.example to .env and configure:
``bashget_connection_status
Get detailed connection status with troubleshooting guidance
setup_mqtt_connection
Configure a new MQTT broker connection dynamically
mqtt_connect
Connect to a specific MQTT broker with custom parameters
check_broker_health
Test broker connectivity and attempt reconnection
reconnect_mqtt
Force reconnection to the configured broker
- get_connection_status: Get detailed connection status with troubleshooting guidance
- setup_mqtt_connection: Configure a new MQTT broker connection dynamically
- mqtt_connect: Connect to a specific MQTT broker with custom parameters
- check_broker_health: Test broker connectivity and attempt reconnection
- reconnect_mqtt: Force reconnection to the configured broker
Claude Desktop / Cursor
Paste into your MCP client config file to install this server.
{
"mcpServers": {
"coreflux mqtt mcp server": {
"Coreflux-MQTT-MCP-Server": {
"command": "python",
"args": [
"setup_assistant.py",
"#",
"Interactive",
"configuration"
]
}
}
}
}McpServers
{
"Coreflux-MQTT-MCP-Server": {
"command": "python",
"args": [
"setup_assistant.py",
"#",
"Interactive",
"configuration"
]
}
}
An enterprise-grade Model Context Protocol (MCP) server that provides secure, scalable access to Coreflux MQTT brokers and comprehensive automation capabilities for Claude and other MCP-compatible AI assistants.
🚀 Features
Core Functionality
- 🔌 MQTT Integration: Seamless connection to Coreflux MQTT brokers with full TLS support - 🛠️ Complete Coreflux API: Full access to models, actions, rules, and routes - 🤖 AI Code Generation: LOT (Language-of-Things) code generation via Coreflux Copilot API - 🔍 Dynamic Discovery: Automatic discovery and listing of available actions - 🏥 Health Monitoring: Comprehensive system health checks and monitoringEnterprise Features
- 🔒 Production Security: Comprehensive log sanitization, input validation, and security features - ⚡ Async Processing: Non-blocking message processing with rate limiting and queue management - � Enhanced Logging: Structured logging with rotation, filtering, and security sanitization - ✅ Configuration Validation: Comprehensive environment and file validation system - 🧪 Testing Framework: Complete unit testing suite with mocking and coverage reportingDevOps & Deployment
- 🐳 Container Ready: Full Docker and Kubernetes deployment support with health checks - 🔄 CI/CD Pipeline: GitHub Actions with automated testing, security scanning, and quality checks - 📦 Development Tools: Pre-commit hooks, code formatting, linting, and documentation generation - ⚙️ Easy Setup: Interactive setup assistant with validation and testing - 📚 Rich Documentation: API documentation, security guides, and deployment instructionsQuick Start
Docker Deployment (Recommended)
1. Clone and configure: ``bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
cp .env.example .env
# Edit .env with your configuration
`
2. Deploy with Docker:
`bash
docker-compose up -d
`
🚀 Quick Start
Prerequisites
- Python 3.11 or higher
- Docker (optional, for containerized deployment)
- Access to a Coreflux MQTT broker
- Coreflux Copilot API key (optional, for AI assistance)
Option 1: Docker Deployment (Recommended)
1. Clone and configure:
`bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
cp .env.example .env
# Edit .env with your configuration
`
2. Deploy with Docker:
`bash
docker-compose up -d
`
3. Verify deployment:
`bash
docker-compose logs -f coreflux-mcp-server
`
Option 2: Development Installation
1. Clone and setup:
`bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
`
2. Install dependencies:
`bash
pip install -r requirements.txt
# For development
pip install -r requirements-dev.txt
`
3. Configure environment:
`bash
python setup_assistant.py # Interactive configuration
# OR
cp .env.example .env && nano .env # Manual configuration
`
4. Validate and test:
`bash
make validate # Validate configuration
make test # Run tests
`
5. Start the server:
`bash
python server.py
# OR
make run
`
For detailed deployment instructions, see DEPLOYMENT.md.
⚙️ Configuration
Interactive Setup Assistant
The server includes a comprehensive setup assistant that guides you through configuration:
`bash
python setup_assistant.py
`
The assistant helps with:
- 🔧 MQTT broker connection settings
- 🔐 TLS certificate configuration
- 🤖 Coreflux Copilot API integration
- 📝 Logging and monitoring setup
- ✅ Configuration validation and testing
Use the setup assistant when:
- Creating initial configuration
- Updating existing settings
- Troubleshooting connection issues
- Setting up TLS certificates
- Migrating between environments
Environment Configuration
Copy .env.example to .env and configure:
``bashSign in to leave a review
Use Google, GitHub, or an email account so ratings stay tied to real people.
No reviews posted yet.
