commit 2021-12-16]17:46:11

cli.go

@@ -27,7 +27,7 @@ func init() {
 		devicesWithUUID:  devWithUUID,
 		devicesWithIface: devWithIface,
 		chanForSync:      chanForSync,
-		SyncListener:     &SyncHandler{devices: devWithUUID, chanForSync: chanForSync, mutex: &sync.Mutex{}},
+		SyncListener:     &SyncHandler{devices: devWithUUID, chanForSync: chanForSync, mutex: &sync.Mutex{}, states: map[string]map[string]interface{}{}},
 		RecvListener:     &RecvHandler{devices: devWithIface, chanForSync: chanForSync},
 	}
 
@@ -65,14 +65,13 @@ func AddRecvListener(h EventHandler) {
 // }
 
 func Run() error {
-	iface, err := puserial.InitDevice()
+	ifaces, err := puserial.InitDevice()
 	if err != nil {
-		if err.Error() != "USB Not found" {
-			return err
-		}
-	} else {
-		// _managerObj.onAdd(iface)
-		_managerObj.onAdded(iface)
+		return err
+	}
+
+	for _, e := range ifaces {
+		go _managerObj.onAdded(e)
 	}
 
 	go puserial.WatchNewDevice(ctx, ch_discover)
@@ -85,7 +84,7 @@ func Run() error {
 		}
 		switch e.Event() {
 		case notify.Create:
-			_managerObj.onAdded(e.Path())
+			go _managerObj.onAdded(e.Path())
 			// case notify.Remove:
 			// 	log.Println("USB Disconnected!!")
 			// 	_managerObj.onAdded(e.Path())

listener.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"log"
+	"reflect"
 	"sync"
 )
 
@@ -11,6 +12,7 @@ type SyncHandler struct {
 	devices     map[string]*_device
 	mutex       *sync.Mutex
 	chanForSync map[string]chan map[string]interface{}
+	states      map[string]map[string]interface{}
 }
 
 func compareMap(src map[string]interface{}, dst map[string]interface{}) bool {
@@ -19,14 +21,23 @@ func compareMap(src map[string]interface{}, dst map[string]interface{}) bool {
 		if key == "code" {
 			continue
 		}
-		srcV, ok := value.(int)
-		if !ok {
-			srcV = int(value.(float64))
+
+		if reflect.TypeOf(value).String() == "string" {
+			dstV, ok := dst[key].(string)
+			if !ok || value != dstV {
+				return false
+			}
+			continue
 		}
 
-		dstV, ok := dst[key].(int)
+		srcV, ok := value.(float64)
 		if !ok {
-			dstV = int(dst[key].(float64))
+			srcV = float64(value.(int))
+		}
+
+		dstV, ok := dst[key].(float64)
+		if !ok {
+			dstV = float64(dst[key].(int))
 		}
 
 		if srcV != dstV {
@@ -59,6 +70,7 @@ func (sh *SyncHandler) Handle(e Event) {
 			origin[key] = value
 		}
 
+		sh.states[device.UUID] = origin
 		// props := []string{"fan", "light", "servo"}
 
 		err := encoder.Encode(origin)
@@ -80,7 +92,7 @@ func (sh *SyncHandler) Handle(e Event) {
 		sh.mutex.Unlock()
 
 		for state := range chanForSync {
-			if compareMap(origin, state) {
+			if compareMap(sh.states[device.UUID], state) {
 				sh.mutex.Lock()
 				close(sh.chanForSync[device.IfaceName])
 				delete(sh.chanForSync, device.IfaceName)
@@ -88,8 +100,8 @@ func (sh *SyncHandler) Handle(e Event) {
 				return
 			}
 			log.Println("wrong: ", state)
-			log.Println("resend: ", origin)
-			err := encoder.Encode(origin)
+			log.Println("resend: ", sh.states[device.UUID])
+			err := encoder.Encode(sh.states[device.UUID])
 			if err != nil {
 				return
 			}

puserial/serial.go

@@ -2,7 +2,6 @@ package puserial
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"io/ioutil"
 	"path/filepath"
@@ -11,19 +10,20 @@ import (
 	"github.com/rjeczalik/notify"
 )
 
-func InitDevice() (string, error) {
+func InitDevice() ([]string, error) {
 	fs, err := ioutil.ReadDir("/dev")
 	if err != nil {
-		return "", err
+		return nil, err
 	}
 
+	var result []string = nil
 	for _, f := range fs {
 		if strings.Contains(f.Name(), "ttyACM") {
-			return filepath.Join("/dev", f.Name()), nil
+			result = append(result, filepath.Join("/dev", f.Name()))
 		}
 	}
 
-	return "", errors.New("USB Not found")
+	return result, nil
 }
 
 func WatchNewDevice(ctx context.Context, ch_discover chan<- notify.EventInfo) error {