feat: removed deprecated identifiers.

Also support warpped errors in ToExceptionCode, and fixed some lint warnings

Author: xiegeo

.golangci.yml

@@ -55,7 +55,12 @@ issues:
       linters:
         - maintidx
         - unused
-
+        
+    - path: "(.+)_test.go"
+      linters:
+        - govet
+      text: "declaration of \"t\" shadows declaration"
+      
   exclude:
     - "G104: Errors unhandled." # turn off errcheck
     - "declaration of \"[a-z]\" shadows declaration at .*_test.go" # ignore shadowing a single character variables in tests

README.md

@@ -1,4 +1,4 @@
-# ModbusOne [![GoDoc](https://godoc.org/github.com/xiegeo/modbusone?status.svg)](https://godoc.org/github.com/xiegeo/modbusone)
+# ModbusOne [![Go Reference](https://pkg.go.dev/badge/github.com/xiegeo/modbusone?utm_source=godoc#section-documentation.svg)](https://pkg.go.dev/github.com/xiegeo/modbusone?utm_source=godoc#section-documentation)
 A Modbus library for Go, with unified client and server APIs.
 One implementation to rule them all.
 <details>
@@ -14,13 +14,13 @@ func handlerGenerator(name string) modbusone.ProtocolHandler {
             fmt.Printf("%v ReadHoldingRegisters from %v, quantity %v\n",
                 name, address, quantity)
             r := make([]uint16, quantity)
-            // application code that fills in r here
+            // Application code that fills in r here.
             return r, nil
         },
         WriteHoldingRegisters: func(address uint16, values []uint16) error {
             fmt.Printf("%v WriteHoldingRegisters from %v, quantity %v\n",
                 name, address, len(values))
-            // application code here
+            // Application code here.
             return nil
         },
         OnErrorImp: func(req modbusone.PDU, errRep modbusone.PDU) {
@@ -29,7 +29,7 @@ func handlerGenerator(name string) modbusone.ProtocolHandler {
     }
 }
 
-// serial is a fake serial port
+// serial is a fake serial port.
 type serial struct {
     io.ReadCloser
     io.WriteCloser
@@ -241,6 +241,17 @@ Development tools:
 
 ## Breaking Changes
 
+2022-09-09 v1.0.0
+
+V1 released with the following depreciated identifiers removed:
+
+- The `Server` interface is removed, use `ServerCloser` instead.
+- Public global variable `DebugOut` is changed to private. Use `SetDebugOut(w io.Writer)` instead for thread safety.
+- Type alias `type ProtocalHandler = ProtocolHandler` removed.
+- Function redirect from `GetRTUBidirectionSizeFromHeader` to `GetRTUBidirectionalSizeFromHeader` removed.
+- Function redirect from `NewRTUCLient` to `NewRTUClient` removed.
+
+
 2018-09-27 v0.2.0
 
 - NewRTUPacketReader returns PacketReader interface instead of io.Reader. When a new RTU server or client receives a SerialContext, it will test if it is also a PacketReader, and only create a new NewRTUPacketReader if not.

data.go

@@ -62,16 +62,20 @@ func BoolsToData(values []bool, fc FunctionCode) ([]byte, error) {
 
 	for v := 0; v < count; v++ {
 		if values[v] {
+			// set bit in byte to true
 			byteVal |= 1 << bitNr
 		}
-		if bitNr == 7 {
+		switch {
+		case bitNr == 7:
+			// last bit in byte, set data value and go to the next byte
 			data[byteNr] = byteVal
 			byteVal = 0
 			bitNr = 0
 			byteNr++
-		} else if v+1 == count {
+		case v+1 == count:
+			// last bit, set byte value and exit loop
 			data[byteNr] = byteVal
-		} else {
+		default:
 			bitNr++
 		}
 	}

examples/memory/client.go

@@ -7,9 +7,8 @@ import (
 	"strconv"
 	"strings"
 
-	"github.com/xiegeo/modbusone"
-
 	"github.com/fatih/color"
+	"github.com/xiegeo/modbusone"
 )
 
 func runClient(c *modbusone.RTUClient) {

examples/memory/main.go

@@ -71,7 +71,7 @@ func main() {
 	if *fillData == "am3" {
 		fillAm3()
 	}
-	var device modbusone.Server
+	var device modbusone.ServerCloser
 	if *isClient {
 		if *writeSizeLimit > modbusone.MaxRTUSize || *readSizeLimit > modbusone.MaxRTUSize {
 			fmt.Fprintf(os.Stderr, "write/read size limit is too big")

examples_test.go

@@ -20,13 +20,13 @@ func handlerGenerator(name string) modbusone.ProtocolHandler {
 			fmt.Printf("%v ReadHoldingRegisters from %v, quantity %v\n",
 				name, address, quantity)
 			r := make([]uint16, quantity)
-			// application code that fills in r here
+			// Application code that fills in r here.
 			return r, nil
 		},
 		WriteHoldingRegisters: func(address uint16, values []uint16) error {
 			fmt.Printf("%v WriteHoldingRegisters from %v, quantity %v\n",
 				name, address, len(values))
-			// application code here
+			// Application code here.
 			return nil
 		},
 		OnErrorImp: func(req modbusone.PDU, errRep modbusone.PDU) {
@@ -35,7 +35,7 @@ func handlerGenerator(name string) modbusone.ProtocolHandler {
 	}
 }
 
-// serial is a fake serial port
+// serial is a fake serial port.
 type serial struct {
 	io.ReadCloser
 	io.WriteCloser

failover_rtu_client.go

@@ -3,6 +3,7 @@ package modbusone
 import (
 	"bytes"
 	"encoding/hex"
+	"errors"
 	"fmt"
 	"sync/atomic"
 	"time"
@@ -18,8 +19,8 @@ type FailoverRTUClient struct {
 	actions              chan rtuAction
 }
 
-// FailoverRTUClient is also a Server.
-var _ Server = &FailoverRTUClient{}
+// FailoverRTUClient is also a ServerCloser.
+var _ ServerCloser = &FailoverRTUClient{}
 
 // NewFailoverRTUClient create a new client with failover function communicating over SerialContext with the
 // give slaveID as default.
@@ -199,7 +200,7 @@ func (c *FailoverRTUClient) Serve(handler ProtocolHandler) error {
 				}
 				rp, err := react.data.GetPDU()
 				if err != nil {
-					if err == ErrorCrc {
+					if errors.Is(err, ErrorCrc) {
 						atomic.AddInt64(&c.com.Stats().CrcErrors, 1)
 					} else {
 						atomic.AddInt64(&c.com.Stats().OtherErrors, 1)

handler2serial_test.go

@@ -65,7 +65,7 @@ func (s *mockSerial) BytesDelay(n int) time.Duration { return 0 }
 func (s *mockSerial) Stats() *Stats                  { return &s.s }
 
 // TestHandler runs through each of simplymodbus.ca's samples, conforms both
-// end-to-end behavior and wire format
+// end-to-end behavior and wire format.
 func TestHandler(t *testing.T) {
 	// DebugOut = os.Stdout
 	slaveID := byte(0x11)

modbus.go

@@ -5,27 +5,17 @@
 package modbusone
 
 import (
+	"errors"
 	"fmt"
 	"io"
 )
 
-// Server is a common interface for all Clients and Servers that use ProtocolHandlers.
-// Deprecated: added Closer in ServerCloser.
-type Server interface {
-	Serve(handler ProtocolHandler) error
-}
-
 // ServerCloser is the common interface for all Clients and Servers that use ProtocolHandlers.
 type ServerCloser interface {
-	Server
+	Serve(handler ProtocolHandler) error
 	io.Closer
 }
 
-// ProtocalHandler is a misspelling of ProtocolHandler.
-//
-// Deprecated: misspelling.
-type ProtocalHandler = ProtocolHandler
-
 // ProtocolHandler handles PDUs based on if it is a write or read from the local
 // perspective.
 type ProtocolHandler interface {
@@ -257,11 +247,12 @@ func ToExceptionCode(err error) ExceptionCode {
 	if err == nil {
 		debugf("ToExceptionCode: unexpected covert nil error to ExceptionCode")
 	}
-	e, ok := err.(ExceptionCode)
+	var e ExceptionCode
+	ok := errors.As(err, &e)
 	if ok {
 		return e
 	}
-	if err == ErrFcNotSupported {
+	if errors.Is(err, ErrFcNotSupported) {
 		return EcIllegalFunction
 	}
 	return EcServerDeviceFailure

modbus_test.go

@@ -0,0 +1,30 @@
+package modbusone
+
+import (
+	"errors"
+	"fmt"
+	"reflect"
+	"testing"
+)
+
+func TestToExceptionCode(t *testing.T) {
+	tests := []struct {
+		err  error
+		want ExceptionCode
+	}{
+		{err: EcIllegalDataAddress, want: EcIllegalDataAddress},
+		{err: ErrFcNotSupported, want: EcIllegalFunction},
+		{err: errors.New("other errors"), want: EcServerDeviceFailure},
+	}
+	for _, tt := range tests {
+		t.Run(tt.err.Error(), func(t *testing.T) {
+			if got := ToExceptionCode(tt.err); !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("ToExceptionCode() = %v, want %v", got, tt.want)
+			}
+			errWarped := fmt.Errorf("warped error for %w", tt.err)
+			if got := ToExceptionCode(errWarped); !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("ToExceptionCode() = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}