Add Marstek MQTT responder to answer CT002/CT003 polls locally

[tomquist]

Summary

Adds a Marstek MQTT responder feature to the MQTT Insights service that allows AstraMeter to answer Marstek CT002/CT003 poll requests on the local MQTT broker. When combined with hame-relay bridging to the Marstek cloud, this surfaces the emulator in the Marstek mobile app as if it were a real device.

Key Changes

• New marstek_mqtt.py module: Pure helper functions and dataclass for the Marstek MQTT protocol

  • MarstekMqttBinding: Dataclass holding per-device registration (device_id, ct_type, MAC, get_values callback, wifi_rssi, ver_v)
  • Topic helpers: app_topics_for(), device_topics_for(), parse_app_topic()
  • Payload helpers: is_poll_payload(), build_response(), normalize_mac()
  • Comprehensive unit tests in marstek_mqtt_test.py

• Extended MqttInsightsService:

  • Added marstek_mqtt_enabled config option (default: true)
  • New public API: register_marstek() and unregister_marstek() for device lifecycle management
  • Message handler _handle_marstek_message() that dispatches polls quickly
  • Poll responder _serve_marstek_poll() that offloads to async tasks to prevent slow powermeters from blocking the listener loop
  • Tracks in-flight tasks and failed get_values calls per device with rate-limited logging

• Integration in main.py:

  • Wires up Marstek MQTT responder for CT002 devices when Marstek credentials yield a managed MAC
  • Passes marstek_mac through device lifecycle
  • Registers/unregisters bindings on device start/stop

• Configuration:

  • Added MARSTEK_MQTT_ENABLED config option to [MQTT_INSIGHTS] section
  • Updated config loader to parse the new boolean setting
  • Updated example config and README

Implementation Details

• Non-blocking poll handling: Poll requests are dispatched to background tasks so a slow powermeter can't stall the MQTT listener loop
• Dual-topic support: Responds on both hame_energy/ and marstek_energy/ topic prefixes for compatibility
• Graceful failure handling: Suppresses repeated get_values errors per device with recovery logging
• Live subscription: Supports registering bindings before or after service start; live-subscribes if already connected
• Comprehensive test coverage: 10+ integration tests with real MQTT broker, covering poll dispatch, error handling, unregistration, and concurrent handler scenarios

https://claude.ai/code/session_01K5ypPxYASWXJewf7Lk9a1e

[coderabbitai]

Important

Review skipped

Draft detected.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Pro

Run ID: bba97618-6a69-4c7a-bfae-881eba17f7fc

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

• 🔍 Trigger review

✨ Finishing Touches

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Commit unit tests in branch claude/ct002-mqtt-support-BjFKJ

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}