Skip to main content
Glama
Coreflux MQTT MCP Server

Coreflux MQTT MCP Server

Coreflux plugins for Cursor

CI Release License: MIT

Cursor Marketplace plugins for the Coreflux MQTT broker and LoT (Language of Things) — the DSL that defines actions, models, routes, rules, panels and themes on a Coreflux broker.

Plugin

What it gives the agent

plugins/coreflux

The full broker command surface over MQTT ($SYS/Coreflux/Command), live topic publish/subscribe, LoT lint + ordered deployment of .lot/.lotnb files, project upload/export, route templates, action tracing, docs search, the Coreflux LoT/broker skills (synced from coreflux-skills), two agents, six slash-commands and safety hooks for destructive operations.

Install

From the Cursor Marketplace, or add this repository as a plugin source. Then set the plugin variables (Cursor → Plugins → Coreflux):

Variable

Purpose

COREFLUX_MQTT_URL

mqtt://host:1883 or mqtts://host:8883 (default mqtt://localhost:1883)

COREFLUX_MQTT_USERNAME / COREFLUX_MQTT_PASSWORD

A user with CommandCall (root, admin, or AllowedSystemConfiguration)

COREFLUX_MQTT_CLIENT_ID

Optional fixed client id

COREFLUX_MQTT_TLS_INSECURE

"true" to accept self-signed certs (dev only)

Alternatively drop a .broker file in the workspace root:

mqtt://192.168.1.10:1883
username=root
password=coreflux

The MCP server needs Node.js ≥ 20 on the machine running Cursor. It has no npm dependencies — the MQTT client is bundled.

Related MCP server: AgentGo

What you can ask

  • "Is the broker healthy?" → /coreflux-status

  • "Deploy this notebook and prove it works" → /coreflux-deploy

  • "Add a Modbus route for the PLC at 10.0.0.5, poll every second" → /coreflux-new-route

  • "Why does AlertOnOverheat never publish?" → /coreflux-debug-action

  • "Lock down devices/# so each gateway only publishes its own topics" → /coreflux-secure

  • "Scaffold a project for the packaging line" → /coreflux-new-project

  • Anything else: "list projects", "show me $SYS/Coreflux/Routes/+/status", "set secret PG_PASSWORD", "publish {"v":1} to test/a", "what does -lotDiagnostic return"…

Repository layout

.cursor-plugin/marketplace.json   marketplace manifest
plugins/coreflux/                 the plugin (see its README); tests in plugins/coreflux/test
scripts/                          validate, check, package and release tooling
.github/workflows/                CI (validate → unit matrix → broker e2e → package), release
docs/add-a-plugin.md              how to add another plugin to this repo

Development

npm run validate   # manifest + frontmatter checks
npm run check      # version sync, hook/MCP wiring, docs ↔ tool names, line endings
npm test           # unit + offline end-to-end tests (in-process fake broker)
npm run smoke      # read-only checks against COREFLUX_MQTT_URL
npm run e2e        # full round-trip against a real broker (creates and removes test entities)

The MCP server is plugins/coreflux/scripts/mcp/coreflux-mqtt-mcp.mjs (stdio JSON-RPC). Run it directly and paste JSON-RPC lines to experiment.

Every push and pull request runs the validators, the unit suite on Linux/macOS/Windows with Node 20 and 22, and the end-to-end suite against coreflux/coreflux-mqtt-broker:latest. Tags vX.Y.Z publish a GitHub release with the packaged plugin and its checksum.

Contributing

Issues and PRs welcome — see CONTRIBUTING.md for the checks to run, how to update the synced skills, and the release process. SECURITY.md covers vulnerability reports. Changes are tracked in CHANGELOG.md.

License

MIT — see LICENSE.

Tool Schema Changelog

Recent tool additions, removals, and schema changes observed during successful MCP inspections.

Loading tool schema changelog…

    Related MCP Connectors

    Related MCP Servers

    • A
      license
      B
      quality
      B
      maintenance
      Local AI ops broker that keeps SSH secrets on your machine, exposes intent-level MCP tools to agents, and requires approval via a loopback Web UI for dangerous writes.
      14
      1 npm
      MIT
    • A
      license
      Not graded
      quality
      B
      maintenance
      Enables an AI assistant to delegate coding tasks to local Codex or Claude Code CLIs, monitor their progress, read results, continue sessions, and browse the files in user-approved project workspaces. It exposes these capabilities over Streamable HTTP through a Cloudflare tunnel or locally over stdio, so a remote or cloud client can drive agents running on the user's own machine.
      76 npm
      1
      MIT
    • A
      license
      Not graded
      quality
      B
      maintenance
      Enables any MCP-speaking AI agent to use a curated toolset over the node CLI for relay health, fleet and capability discovery, task submission and result polling, artifact downloads, and live documentation, without handling credentials directly.
      MIT
    • A
      license
      Not graded
      quality
      C
      maintenance
      Enables an AI agent to drive a remote Linux machine over the LAN through a single TCP connection, exposing tools for shell commands, jobs, interactive PTYs, file read/write/search/transfer, process and service management, networking, packages, and power control, with optional multi-host switching. Operates without SSH or any Linux-side installation beyond one stdlib-only Python daemon, using a state-free binary protocol.
      MIT