diff --git a/internal/module/serial-client.go b/internal/module/serial-client.go index a1cc9e1..27d9090 100644 --- a/internal/module/serial-client.go +++ b/internal/module/serial-client.go @@ -42,18 +42,20 @@ func init() { return nil, fmt.Errorf("misc.serial.client port must be a string") } - framingMethod, ok := params["framing"] - if !ok { - return nil, fmt.Errorf("misc.serial.client requires a framing method") + framingMethod := "RAW" + + framingMethodRaw, ok := params["framing"] + + if ok { + framingMethodString, ok := framingMethodRaw.(string) + + if !ok { + return nil, fmt.Errorf("misc.serial.client framing method must be a string") + } + framingMethod = framingMethodString } - framingMethodString, ok := framingMethod.(string) - - if !ok { - return nil, fmt.Errorf("misc.serial.client framing method must be a string") - } - - framer, err := framer.GetFramer(framingMethodString) + framer, err := framer.GetFramer(framingMethod) if err != nil { return nil, err diff --git a/internal/module/tcp-client.go b/internal/module/tcp-client.go index 2f26724..bb1d885 100644 --- a/internal/module/tcp-client.go +++ b/internal/module/tcp-client.go @@ -54,18 +54,20 @@ func init() { return nil, err } - framingMethod, ok := params["framing"] - if !ok { - return nil, fmt.Errorf("net.tcp.client requires a framing method") + framingMethod := "RAW" + + framingMethodRaw, ok := params["framing"] + + if ok { + framingMethodString, ok := framingMethodRaw.(string) + + if !ok { + return nil, fmt.Errorf("misc.serial.client framing method must be a string") + } + framingMethod = framingMethodString } - framingMethodString, ok := framingMethod.(string) - - if !ok { - return nil, fmt.Errorf("net.tcp.client framing method must be a string") - } - - framer, err := framer.GetFramer(framingMethodString) + framer, err := framer.GetFramer(framingMethod) if err != nil { return nil, err diff --git a/internal/module/tcp-server.go b/internal/module/tcp-server.go index a752bb3..65867e5 100644 --- a/internal/module/tcp-server.go +++ b/internal/module/tcp-server.go @@ -44,18 +44,20 @@ func init() { return nil, fmt.Errorf("net.tcp.server port must be a number") } - framingMethod, ok := params["framing"] - if !ok { - return nil, fmt.Errorf("net.tcp.server requires a framing method") + framingMethod := "RAW" + + framingMethodRaw, ok := params["framing"] + + if ok { + framingMethodString, ok := framingMethodRaw.(string) + + if !ok { + return nil, fmt.Errorf("misc.serial.client framing method must be a string") + } + framingMethod = framingMethodString } - framingMethodString, ok := framingMethod.(string) - - if !ok { - return nil, fmt.Errorf("net.tcp.server framing method must be a string") - } - - framer, err := framer.GetFramer(framingMethodString) + framer, err := framer.GetFramer(framingMethod) if err != nil { return nil, err