From 7ea6e49001e287169ce597c3f6a59edd9655850f Mon Sep 17 00:00:00 2001 From: Sven van Heugten Date: Sat, 3 Jan 2026 19:37:31 +0100 Subject: [PATCH] Introduce decodeMqttApplicationMessage --- NightLight/Program.fs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/NightLight/Program.fs b/NightLight/Program.fs index 59aed70..0c8d153 100644 --- a/NightLight/Program.fs +++ b/NightLight/Program.fs @@ -47,13 +47,12 @@ let private handleEvent (mqttClient: IMqttClient) (logger: ILogger) (state: Stat logger.LogError("Error {Error} while {Event}", e, event) async.Return state -let private mqttMessageToReceivedZigbeeEvent (message: MqttApplicationMessage) = +let private decodeMqttApplicationMessage (message: MqttApplicationMessage) = let payload = message.Payload let decodedPayload = Encoding.UTF8.GetString(&payload) - ReceivedZigbeeEvent - { Topic = message.Topic - Payload = decodedPayload } + { Topic = message.Topic + Payload = decodedPayload } [] let mainAsync _ = @@ -82,7 +81,7 @@ let mainAsync _ = mqttClient.add_ApplicationMessageReceivedAsync (fun e -> async { - let event = mqttMessageToReceivedZigbeeEvent e.ApplicationMessage + let event = ReceivedZigbeeEvent <| decodeMqttApplicationMessage e.ApplicationMessage do! stateLock.WaitAsync() |> Async.AwaitTask