Refactor and add routing concept

This scales better when additional receiving routes will be added.

1 files changed, 2 insertions, 2 deletions

diff --git a/shelly.go b/shelly.go
index 7396bbb..5f6f2ad 100644
--- a/shelly.go
+++ b/shelly.go
@@ -7,8 +7,8 @@ import (
 	"strings"
 )
 
-func ShellyRun(config ShellyConfigs, rx chan MQTTMessage) {
-	for message := range rx {
+func ShellyRun(config ShellyConfigs, route Route) {
+	for message := range route.Destination {
 		ip, command, err := parseMessage(config, message)
 		if err != nil {
 			log.Println(err)