Remove twisted (#972)

Remove twisted.

Author: janiversen

.github/workflows/ci.yml

@@ -125,7 +125,6 @@ jobs:
         run: |
           pip install --upgrade pip setuptools wheel
           pip install --upgrade tox
-      - uses: twisted/python-info-action@v1.0.1
       - name: Add PyPy Externals
         if: ${{ matrix.os.matrix == 'windows' && matrix.python.implementation == 'pypy'}}
         env:
@@ -225,7 +224,6 @@ jobs:
         run: |
           pip install --upgrade pip setuptools wheel
           pip install --upgrade tox
-      - uses: twisted/python-info-action@v1.0.1
       - name: Test
         continue-on-error: ${{ matrix.task.continue_on_error == true }}
         run: |
@@ -272,7 +270,6 @@ jobs:
         run: |
           pip install --upgrade pip setuptools wheel
           pip install --upgrade tox
-      - uses: twisted/python-info-action@v1.0.1
       - name: Download Coverage
         if: matrix.task.download_coverage
         uses: actions/download-artifact@v2

README.rst

@@ -30,7 +30,7 @@ Remark: "Supports" means that we only test with those versions, lower versions (
 Summary
 ------------------------------------------------------------
 
-Pymodbus is a full Modbus protocol implementation using a synchronous or asynchronous core. The preferred mode for asynchronous communication is asyncio, however for the moment twisted are also supported (due to be removed or converted to a plugin in a later version).
+Pymodbus is a full Modbus protocol implementation using a synchronous or asynchronous (using asyncio) core.
 
 Supported modbus communication modes: tcp, rtu-over-tcp, udp, serial, tls
 
@@ -53,7 +53,7 @@ Client Features
   * Full read/write protocol on discrete and register
   * Most of the extended protocol (diagnostic/file/pipe/setting/information)
   * TCP, RTU-OVER-TCP, UDP, TLS, Serial ASCII, Serial RTU, and Serial Binary
-  * asynchronous(powered by asyncio/twisted) and synchronous versions
+  * asynchronous(powered by asyncio) and synchronous versions
   * Payload builder/decoder utilities
   * Pymodbus REPL for quick tests
   * Customable framer to allow for custom implementations
@@ -167,8 +167,6 @@ Available options are:
 
 - **datastore**, installs databases (SQLAlchemy and Redit) for datastore.
 
-- **twisted**, installs twisted as alternative to asyncio (will be removed in a future version).
-
 - **documentation**, installs tools to generate documentation.
 
 - **development**, installs development tools needed to enable test/check of pymodbus changes.
@@ -282,6 +280,5 @@ Pymodbus is built on top of code developed from/by:
   * Copyright (c) 2001-2005 S.W.A.C. Bohemia s.r.o., Czech Republic.
 
   * Hynek Petrak, https://github.com/HynekPetrak
-  * Twisted Matrix
 
 Released under the `BSD License <LICENSE>`_

doc/source/library/pymodbus.server.rst

@@ -12,7 +12,7 @@ Submodules
 pymodbus\.server\.asynchronous module
 -------------------------------------
 
-.. automodule:: pymodbus.server.asynchronous
+.. automodule:: pymodbus.server.async_io
     :members:
     :undoc-members:
     :show-inheritance:
@@ -24,5 +24,3 @@ pymodbus\.server\.sync module
     :members:
     :undoc-members:
     :show-inheritance:
-
-

examples/common/asyncio_server.py

@@ -3,8 +3,7 @@
 
 The asyncio server is implemented in pure python without any third
 party libraries (unless you need to use the serial protocols which require
-asyncio-pyserial). This is helpful in constrained or old environments where using
-twisted is just not feasible. What follows is an example of its use:
+asyncio-pyserial). What follows is an example of its use:
 """
 import asyncio
 

examples/common/callback_server.py

@@ -16,7 +16,7 @@
     ModbusSparseDataBlock,
 )
 from pymodbus.device import ModbusDeviceIdentification
-from pymodbus.server.asynchronous import StartTcpServer
+from pymodbus.server.async_io import StartTcpServer
 
 # --------------------------------------------------------------------------- #
 # import the modbus libraries we need

examples/common/custom_datablock.py

@@ -13,7 +13,7 @@
     ModbusSparseDataBlock,
 )
 from pymodbus.device import ModbusDeviceIdentification
-from pymodbus.server.asynchronous import StartTcpServer
+from pymodbus.server.async_io import StartTcpServer
 
 # --------------------------------------------------------------------------- #
 # import the modbus libraries we need

examples/common/dbstore_update_server.py

@@ -15,16 +15,12 @@
 """
 import logging
 import random
-
-# --------------------------------------------------------------------------- #
-# import the twisted libraries we need
-# --------------------------------------------------------------------------- #
-from twisted.internet.task import LoopingCall
+import asyncio
 
 from pymodbus.datastore import ModbusSequentialDataBlock, ModbusServerContext
 from pymodbus.datastore.database import SqlSlaveContext
 from pymodbus.device import ModbusDeviceIdentification
-from pymodbus.server.asynchronous import StartTcpServer
+from pymodbus.server.async_io import StartTcpServer
 
 # --------------------------------------------------------------------------- #
 # import the modbus libraries we need
@@ -100,7 +96,7 @@ def run_dbstore_update_server():
     # run the server you want
     # ----------------------------------------------------------------------- #
     time = 5  # 5 seconds delay
-    loop = LoopingCall(f=updating_writer, a=(context,))
+    loop = asyncio.get_event_loop()
     loop.start(time, now=False)  # initially delay by time
     loop.stop()
     StartTcpServer(context, identity=identity, address=("", 5020))

examples/common/updating_server.py

@@ -10,27 +10,17 @@
     Thread(target=updating_writer, args=(context,)).start()
 """
 import logging
-
-# --------------------------------------------------------------------------- #
-# import the modbus libraries we need
-# --------------------------------------------------------------------------- #
-from twisted.internet.task import LoopingCall
+import asyncio
 
 from pymodbus.datastore import (
     ModbusSequentialDataBlock,
     ModbusServerContext,
     ModbusSlaveContext,
 )
 from pymodbus.device import ModbusDeviceIdentification
-from pymodbus.server.asynchronous import StartTcpServer
+from pymodbus.server.async_io import StartTcpServer
 from pymodbus.version import version
 
-# from pymodbus.transaction import ModbusRtuFramer, ModbusAsciiFramer
-
-# --------------------------------------------------------------------------- #
-# import the twisted libraries we need
-# --------------------------------------------------------------------------- #
-
 # --------------------------------------------------------------------------- #
 # configure the service logging
 # --------------------------------------------------------------------------- #
@@ -94,7 +84,7 @@ def run_updating_server():
     # run the server you want
     # ----------------------------------------------------------------------- #
     time = 5  # 5 seconds delay
-    loop = LoopingCall(f=updating_writer, a=(context,))
+    loop = asyncio.get_event_loop()
     loop.start(time, now=False)  # initially delay by time
     StartTcpServer(context, identity=identity, address=("localhost", 5020))
 

examples/contrib/libmodbus_client.py

@@ -26,7 +26,7 @@
 # -------------------------------------------------------------------------- #
 # import system libraries
 # -------------------------------------------------------------------------- #
-from cffi import FFI
+from cffi import FFI  # pylint: disable=import-error
 
 from pymodbus.bit_read_message import ReadCoilsResponse, ReadDiscreteInputsResponse
 from pymodbus.bit_write_message import (

examples/contrib/modbus_simulator.py

@@ -9,7 +9,7 @@
 import pickle  # nosec
 
 from pymodbus.datastore import ModbusServerContext, ModbusSlaveContext
-from pymodbus.server.asynchronous import StartTcpServer
+from pymodbus.server.async_io import StartTcpServer
 
 # -------------------------------------------------------------------------- #
 # Logging