Merge pull request #541 from riptideio/revert-536-use_hexlify_packets

Revert "Refactor/DRY: use `use_hexlify_packets`"

Author: dhoomakethu

pymodbus/client/asynchronous/async_io/__init__.py

@@ -7,7 +7,7 @@
 import ssl
 from pymodbus.exceptions import ConnectionException
 from pymodbus.client.asynchronous.mixins import AsyncModbusClientMixin
-from pymodbus.utilities import hexlify_packets
+from pymodbus.compat import byte2int
 from pymodbus.transaction import FifoTransactionManager
 import logging
 
@@ -137,7 +137,7 @@ def _execute(self, request, **kwargs):
         """
         request.transaction_id = self.transaction.getNextTID()
         packet = self.framer.buildPacket(request)
-        _logger.debug("send: " + hexlify_packets(packet))
+        _logger.debug("send: " + " ".join([hex(byte2int(x)) for x in packet]))
         self.write_transport(packet)
         return self._buildResponse(request.transaction_id)
 
@@ -146,7 +146,7 @@ def _dataReceived(self, data):
 
         :param data: The data returned from the server
         '''
-        _logger.debug("recv: " + hexlify_packets(data))
+        _logger.debug("recv: " + " ".join([hex(byte2int(x)) for x in data]))
         unit = self.framer.decode_data(data).get("unit", 0)
         self.framer.processIncomingPacket(data, self._handleResponse, unit=unit)
 

pymodbus/client/asynchronous/tornado/__init__.py

@@ -18,7 +18,7 @@
 from pymodbus.client.asynchronous.mixins import (AsyncModbusClientMixin,
                                                  AsyncModbusSerialClientMixin)
 from pymodbus.exceptions import ConnectionException
-from pymodbus.utilities import hexlify_packets
+from pymodbus.compat import byte2int
 
 LOGGER = logging.getLogger(__name__)
 
@@ -74,7 +74,7 @@ def on_receive(self, *args):
 
         if not data:
             return
-        LOGGER.debug("recv: " + hexlify_packets(data))
+        LOGGER.debug("recv: " + " ".join([hex(byte2int(x)) for x in data]))
         unit = self.framer.decode_data(data).get("unit", 0)
         self.framer.processIncomingPacket(data, self._handle_response, unit=unit)
 
@@ -86,7 +86,7 @@ def execute(self, request=None):
         """
         request.transaction_id = self.transaction.getNextTID()
         packet = self.framer.buildPacket(request)
-        LOGGER.debug("send: " + hexlify_packets(packet))
+        LOGGER.debug("send: " + " ".join([hex(byte2int(x)) for x in packet]))
         self.stream.write(packet)
         return self._build_response(request.transaction_id)
 
@@ -174,7 +174,7 @@ def callback(*args):
                 if waiting:
                     data = self.stream.connection.read(waiting)
                     LOGGER.debug(
-                        "recv: " + hexlify_packets(data))
+                        "recv: " + " ".join([hex(byte2int(x)) for x in data]))
                     unit = self.framer.decode_data(data).get("uid", 0)
                     self.framer.processIncomingPacket(
                         data,
@@ -185,7 +185,7 @@ def callback(*args):
                     break
 
         packet = self.framer.buildPacket(request)
-        LOGGER.debug("send: " + hexlify_packets(packet))
+        LOGGER.debug("send: " + " ".join([hex(byte2int(x)) for x in packet]))
         self.stream.write(packet, callback=callback)
         f = self._build_response(request.transaction_id)
         return f

pymodbus/client/asynchronous/twisted/__init__.py

@@ -40,7 +40,7 @@ def process():
 from pymodbus.client.asynchronous.mixins import AsyncModbusClientMixin
 from pymodbus.transaction import FifoTransactionManager, DictTransactionManager
 from pymodbus.transaction import ModbusSocketFramer, ModbusRtuFramer
-from pymodbus.utilities import hexlify_packets
+from pymodbus.compat import byte2int
 from twisted.python.failure import Failure
 
 
@@ -109,7 +109,7 @@ def execute(self, request):
         """
         request.transaction_id = self.transaction.getNextTID()
         packet = self.framer.buildPacket(request)
-        _logger.debug("send: " + hexlify_packets(packet))
+        _logger.debug("send: " + " ".join([hex(byte2int(x)) for x in packet]))
         self.transport.write(packet)
         return self._buildResponse(request.transaction_id)