Fix payload generation bug (#126)

bachya · Apr 28, 2022 · 2f3c5b0 · 2f3c5b0
1 parent 0476307
commit 2f3c5b0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ecowitt2mqtt/mqtt.py b/ecowitt2mqtt/mqtt.py
@@ -71,10 +71,10 @@ async def _async_publish_to_topic(
 def _generate_payload(data: Union[Dict[str, Any], float, str]) -> bytes:
     """Generate a binary MQTT payload from input data."""
     if isinstance(data, dict):
-        value = json.dumps(data, default=_json_serial)
+        data = json.dumps(data, default=_json_serial)
     elif not isinstance(data, str):
-        value = str(data)
-    return value.encode("utf-8")
+        data = str(data)
+    return data.encode("utf-8")
 
 
 def _json_serial(obj: Any) -> Any: