Merge branch 'dev' to define v3.0.0

Author: janiversen

CHANGELOG.rst

@@ -1,3 +1,12 @@
+version 3.0.0
+----------------------------------------------------------
+* Solve multiple incomming frames. (#1107)
+* Up coverage, tests are 100%. (#1098)
+* Prepare for rc1. (#1097)
+* Prepare 3.0.0dev5 (#1095)
+* Adapt serial tests. (#1094)
+* Allow windows. (#1093)
+
 version 3.0.0dev5
 ----------------------------------------------------------
 * Remove server sync code and combine with async code. (#1092)

README.rst

@@ -19,7 +19,7 @@ Supported versions
 
 Version `2.5.3 <https://github.com/riptideio/pymodbus/releases/tag/v2.5.3>`_ is the last 2.x release (Supports python 2.7.x - 3.7).
 
-Version `3.0.0dev5 <https://github.com/riptideio/pymodbus/releases/tag/v3.0.0dev5>`_ is the current prerelease of 3.0.0 (Supports Python >=3.8).
+Version `3.0.0 <https://github.com/riptideio/pymodbus/releases/tag/v3.0.0>`_ is the latest release of 3.0.0 (Supports Python >=3.8).
 
 Remark: "Supports" means that we only test with those versions, lower versions (e.g. 3.7) might work depending on the functionality used.
 
@@ -135,6 +135,8 @@ If you think, that something in the code is broken/not running well, please `ope
 Pymodbus REPL (Read Evaluate Print Loop)
 ------------------------------------------------------------
 
+**Warning** The Pymodbus REPL documentation is not updated.
+
 ~~~~~~~~~~~~~~~~~~~~~
 Pymodbus REPL Client
 ~~~~~~~~~~~~~~~~~~~~~

pymodbus/exceptions.py

@@ -106,18 +106,6 @@ def __init__(self, string=""):
         ModbusException.__init__(self, message)
 
 
-class TimeOutException(ModbusException):
-    """Error resulting from modbus response timeout."""
-
-    def __init__(self, string=""):
-        """Initialize the exception.
-
-        :param string: The message to append to the error
-        """
-        message = f"[Timeout] {string}"
-        ModbusException.__init__(self, message)
-
-
 # --------------------------------------------------------------------------- #
 # Exported symbols
 # --------------------------------------------------------------------------- #
@@ -130,5 +118,4 @@ def __init__(self, string=""):
     "NoSuchSlaveException",
     "InvalidMessageReceivedException",
     "MessageRegisterException",
-    "TimeOutException",
 ]

pymodbus/framer/rtu_framer.py

@@ -232,21 +232,25 @@ def processIncomingPacket(
             unit = [unit]
         self.addToFrame(data)
         single = kwargs.get("single", False)
-        if self.isFrameReady():
-            if self.checkFrame():
-                if self._validate_unit_id(unit, single):
-                    self._process(callback)
+        while True:
+            if self.isFrameReady():
+                if self.checkFrame():
+                    if self._validate_unit_id(unit, single):
+                        self._process(callback)
+                    else:
+                        header_txt = self._header["uid"]
+                        txt = f"Not a valid unit id - {header_txt}, ignoring!!"
+                        _logger.debug(txt)
+                        self.resetFrame()
+                        break
                 else:
-                    header_txt = self._header["uid"]
-                    txt = f"Not a valid unit id - {header_txt}, ignoring!!"
-                    _logger.debug(txt)
+                    _logger.debug("Frame check failed, ignoring!!")
                     self.resetFrame()
+                    break
             else:
-                _logger.debug("Frame check failed, ignoring!!")
-                self.resetFrame()
-        else:
-            txt = f"Frame - [{data}] not ready"
-            _logger.debug(txt)
+                txt = f"Frame - [{data}] not ready"
+                _logger.debug(txt)
+                break
 
     def buildPacket(self, message):
         """Create a ready to send modbus packet.

pymodbus/repl/server/main.py

@@ -12,7 +12,7 @@
 
 from pymodbus.framer.socket_framer import ModbusSocketFramer
 from pymodbus.repl.server.cli import run_repl
-from pymodbus.server.reactive.default_config import DEFUALT_CONFIG
+from pymodbus.server.reactive.default_config import DEFAULT_CONFIG
 from pymodbus.server.reactive.main import (
     DEFAULT_FRAMER,
     DEFUALT_HANDLERS,
@@ -161,7 +161,7 @@ def run(
         with open(modbus_config) as my_file:  # pylint: disable=unspecified-encoding
             modbus_config = json.load(my_file)
     else:
-        modbus_config = DEFUALT_CONFIG
+        modbus_config = DEFAULT_CONFIG
 
     modbus_config = modbus_config.get(modbus_server, {})
 

pymodbus/server/reactive/default_config.py

@@ -1,6 +1,6 @@
 """Configuration for Pymodbus REPL Reactive Module."""
 
-DEFUALT_CONFIG = {  # pylint: disable=consider-using-namedtuple-or-dataclass
+DEFAULT_CONFIG = {  # pylint: disable=consider-using-namedtuple-or-dataclass
     "tcp": {
         "handler": "ModbusConnectedRequestHandler",
         "allow_reuse_address": True,

pymodbus/version.py

@@ -24,9 +24,10 @@ def __init__(self, package, major, minor, micro, pre=None):
 
     def short(self):
         """Return a string in canonical short version format: <major>.<minor>.<micro>.<pre>."""
+        pre = ""
         if self.pre:
-            return f"{self.major}.{self.minor}.{self.micro}.{self.pre}"
-        return f"{self.major}.{self.minor}.{self.micro}"
+            pre = f".{self.pre}"
+        return f"{self.major}.{self.minor}.{self.micro}{pre}"
 
     def __str__(self):
         """Return a string representation of the object.
@@ -36,13 +37,16 @@ def __str__(self):
         return f"[{self.package}, version {self.short()}]"
 
 
-version = Version("pymodbus", 3, 0, 0, "dev5")
+version = Version("pymodbus", 3, 0, 0, "rc1")
 version.__name__ = (  # fix epydoc error # pylint: disable=attribute-defined-outside-init
     "pymodbus"
 )
 
+
 # --------------------------------------------------------------------------- #
 # Exported symbols
 # --------------------------------------------------------------------------- #
 
-__all__ = ["version"]
+__all__ = [
+    "version"
+]

setup.cfg

@@ -13,7 +13,6 @@ url              = https://github.com/riptideio/pymodbus/
 classifiers      =
     Development Status :: 4 - Beta
     Environment :: Console
-    Framework :: Twisted
     Framework :: AsyncIO
     Intended Audience :: Developers
     License :: OSI Approved :: BSD License

test/conftest.py

@@ -2,7 +2,6 @@
 import functools
 import platform
 
-from pkg_resources import parse_version
 import pytest
 
 from pymodbus.interfaces import IModbusSlaveContext
@@ -13,15 +12,6 @@ def pytest_configure():
     pytest.IS_DARWIN = platform.system().lower() == "darwin"
     pytest.IS_WINDOWS = platform.system().lower() == "windows"
 
-    if pytest.IS_DARWIN:
-        # check for SIERRA
-        if parse_version("10.12") < parse_version(platform.mac_ver()[0]):
-            pytest.SERIAL_PORT = "/dev/ptyp0"
-        else:
-            pytest.SERIAL_PORT = "/dev/ttyp0"
-    else:
-        pytest.SERIAL_PORT = "/dev/ptmx"
-
 
 # -----------------------------------------------------------------------#
 # Generic fixtures
@@ -81,9 +71,8 @@ def __len__(self):
         """Get length."""
         return self.size
 
-    def __iter__(self):  # pylint: disable=non-iterator-returned
+    def __iter__(self):
         """Iterate."""
-        return []
 
 
 class mockSocket:  # pylint: disable=invalid-name
@@ -110,10 +99,6 @@ def mock_retrieve(self, size):
         self.data = None
         return retval
 
-    def fileno(self):
-        """File number."""
-        return 0
-
     def close(self):
         """Close."""
         return True
@@ -131,11 +116,6 @@ def send(self, msg):
         self.mock_store(msg)
         return len(msg)
 
-    def write(self, msg):
-        """Write."""
-        self.mock_store(msg)
-        return len(msg)
-
     def recvfrom(self, size):
         """Receive from."""
         return [self.mock_retrieve(size)]
@@ -149,10 +129,6 @@ def setblocking(self, flag):  # pylint: disable=unused-argument
         """Set blocking."""
         return None
 
-    def in_waiting(self):
-        """Do in waiting."""
-        return None
-
 
 def run_coroutine(coro):
     """Run a coroutine as top-level task by iterating through all yielded steps."""
@@ -164,8 +140,6 @@ def run_coroutine(coro):
     except StopIteration as exc:
         # coro reached end pass on its return value:
         return exc.value
-    except:  # noqa: E722 pylint: disable=try-except-raise
-        raise
 
 
 def _yielded_return(return_value, *args):  # pylint: disable=unused-argument
@@ -174,7 +148,6 @@ def _yielded_return(return_value, *args):  # pylint: disable=unused-argument
     async def _():
         """Actual generator producing value."""
         # yield
-        return return_value
 
     # return new generator each time this function is called:
     return _()

test/test_all_messages.py

@@ -1,4 +1,3 @@
-#!/usr/bin/env python3
 """Test all messages."""
 import unittest