3diy
/
moonraker
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mqtt: allow internal access to API endpoints 

Signed-off-by:  Eric Callahan <arksine.code@gmail.com>
This commit is contained in:
Eric Callahan 2022-01-10 06:28:38 -05:00
parent 2025332e6f
commit 4c087612d8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
moonraker/components/mqtt.py
View File

@ -192,11 +192,11 @@ class MQTTClient(APITransport, Subscribable):
self.server.register_endpoint( self.server.register_endpoint(
"/server/mqtt/publish", ["POST"], "/server/mqtt/publish", ["POST"],
self._handle_publish_request, self._handle_publish_request,
transports=["http", "websocket"]) transports=["http", "websocket", "internal"])
self.server.register_endpoint( self.server.register_endpoint(
"/server/mqtt/subscribe", ["POST"], "/server/mqtt/subscribe", ["POST"],
self._handle_subscription_request, self._handle_subscription_request,
transports=["http", "websocket"]) transports=["http", "websocket", "internal"])
# Subscribe to API requests # Subscribe to API requests
self.json_rpc = JsonRPC(transport="MQTT") self.json_rpc = JsonRPC(transport="MQTT")