fix5

Author: torchiaf

controller/rpc_client.go

@@ -3,6 +3,7 @@ package main
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"log"
 	"math"
 	"strconv"
@@ -30,7 +31,7 @@ func main() {
 
 	for {
 
-		var temperature float64
+		temperature := ""
 
 		for _, module := range config.Config.Modules {
 			log.Printf(" [x] Requesting on {%s, %s, %s}", module.Name, module.Type, module.RoutingKey)
@@ -46,12 +47,13 @@ func main() {
 
 			if module.Name == "raspberrypi-0" {
 				var obj Dht11
-				err = json.Unmarshal([]byte(res), &obj)
+				jsonString := string(fmt.Sprintf("`%s`", res))
+				err = json.Unmarshal([]byte(jsonString), &obj)
 				if err != nil {
 					log.Fatalf("error: %v", err)
 				}
 
-				temperature = obj.T
+				temperature = strconv.Itoa(int(math.Round(obj.T)))
 			}
 
 			if module.Name == "raspberrypi-1" {
@@ -60,7 +62,7 @@ func main() {
 					"tm1637",
 					[]string{
 						"temperature",
-						strconv.Itoa(int(math.Round(temperature))),
+						temperature,
 					},
 				)
 				failOnError(err, "Failed to handle RPC request: tm1637")

modules/raspberrypi5/devices/dht11/app/main.py

@@ -12,6 +12,7 @@
 dhtDevice = _device(_board)
 
 try:
+
     d = dict();
 
     d['t'] = dhtDevice.temperature