Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 5 additions & 14 deletions src/modbus_sniffer/modbus_parser_new.py
Original file line number Diff line number Diff line change
Expand Up @@ -94,8 +94,7 @@ def _handle_trash(self, buffer, index):
self.trashdataf += f" {byte:02x}"
else:
self.trashdata = True
self.trashdataf = f"\033[33mWarning \033[0m: Ignoring data: [{
byte:02x}"
self.trashdataf = f"\033[33mWarning \033[0m: Ignoring data: [{byte:02x}"
self.bufferIndex = index + 1

def _log_raw(self, buffer, start, end):
Expand Down Expand Up @@ -165,8 +164,7 @@ def _handle_read_bits(self, buffer, start, sid, fc):
return None
self._log_raw(buffer, start, self.bufferIndex)
self._log_data(
f"Master\t-> ID: {sid}, FC: 0x{
fc:02x}, Read address: {read_address}, Read Quantity: {read_qty}"
f"Master\t-> ID: {sid}, FC: 0x{fc:02x}, Read address: {read_address}, Read Quantity: {read_qty}"
)
self._log_csv(
datetime.now().isoformat(), sid, "READ", read_address, read_qty, []
Expand Down Expand Up @@ -203,8 +201,7 @@ def _handle_read_registers(self, buffer, start, sid, fc):
)
fname = "Read Holding Registers" if fc == 3 else "Read Input Registers"
self._log_data(
f"Master\t-> ID: {sid}, FC: 0x{
fc:02x}, Read address: {read_address}, Read Quantity: {read_qty}"
f"Master\t-> ID: {sid}, FC: 0x{fc:02x}, Read address: {read_address}, Read Quantity: {read_qty}"
)
self._log_csv(
datetime.now().isoformat(), sid, "READ", read_address, read_qty, []
Expand Down Expand Up @@ -234,10 +231,7 @@ def _handle_write_single(self, buffer, start, sid, fc):
return None
self._log_raw(buffer, start, self.bufferIndex)
self._log_data(
f"Master\t-> ID: {sid}, FC: 0x{
fc:02x}, Write addr: {addr}, Data: {
int.from_bytes(
data, 'big')}"
f"Master\t-> ID: {sid}, FC: 0x{fc:02x}, Write addr: {addr}, Data: {int.from_bytes(data, 'big')}"
)
fname = "Write Single Coil" if fc == 5 else "Write Single Register"
frame = self._common_frame(
Expand Down Expand Up @@ -445,10 +439,7 @@ def _handle_write_single_response(self, buffer, start, sid, fc):
self._log_raw(buffer, start, self.bufferIndex)
fname = "Write Single Coil" if fc == 5 else "Write Single Register"
self._log_data(
f"Slave\t-> ID: {sid}, FC: 0x{
fc:02x}, Echo addr: {addr}, Data: {
int.from_bytes(
data, 'big')}"
f"Slave\t-> ID: {sid}, FC: 0x{fc:02x}, Echo addr: {addr}, Data: {int.from_bytes(data, 'big')}"
)
self._log_csv(
datetime.now().isoformat(),
Expand Down