Add detailed logging for queue processing in ISO8583Processor and ISO8583Sender

Co-authored-by: Copilot <copilot@github.com>

iso8583_web/iso8583/__init__.py

@@ -179,6 +179,7 @@ class CommonConnection(Log):
         # thread.start()
         # thread.start()
         now = datetime.datetime.now().strftime('%Y%m%d%H%M%S%f')
         now = datetime.datetime.now().strftime('%Y%m%d%H%M%S%f')
         flag = self.conf.get("ip")+":"+str(self.conf.get("port"))+"_" + now
         flag = self.conf.get("ip")+":"+str(self.conf.get("port"))+"_" + now
+        log.info(f"[TIME RECEIVE] Writing to QUEUE {flag} for processing")
         request_queue.put((flag, raw))
         request_queue.put((flag, raw))
 
 
 
 

iso8583_web/iso8583/processor.py

@@ -25,8 +25,12 @@ class ISO8583Processor:
     def start(self):
     def start(self):
         while True:
         while True:
             filename, data = self.request_queue.get()
             filename, data = self.request_queue.get()
+            log.info(f"[TIME PROCESSOR] Received from queue: filename={filename}")
             response = self.process_file(filename, data, self.db_config)
             response = self.process_file(filename, data, self.db_config)
             self.response_queue.put((filename, response))
             self.response_queue.put((filename, response))
+            log.info(
+                f"[TIME PROCESSOR] Writing from queue: filename={filename}")
+
 
 
     def get_bit7(self):
     def get_bit7(self):
         from datetime import datetime
         from datetime import datetime

iso8583_web/iso8583/sender.py

@@ -14,6 +14,8 @@ class ISO8583Sender:
         while True:
         while True:
             
             
             filename, response = self.response_queue.get()
             filename, response = self.response_queue.get()
+            log.info(
+                f"[TIME SENDER] Received from queue: filename={filename}")
             conn_name = filename.rsplit('_', 3)[0]
             conn_name = filename.rsplit('_', 3)[0]
             with self.sender_lock:
             with self.sender_lock:
                 count += 1
                 count += 1
@@ -46,8 +48,11 @@ class ISO8583Sender:
                 length = str(frame_len).zfill(4).encode('ascii')
                 length = str(frame_len).zfill(4).encode('ascii')
                 new_data = length + response_data
                 new_data = length + response_data
                 try:
                 try:
+                    log.info(
+                        f"[TIME SENDER] {filename}")
                     sock.sendall(new_data)
                     sock.sendall(new_data)
-                    log.info(f"[SENDER] Sending response to {conn_name}: {response_data}, frame_len={frame_len}, count={count}")
+                    log.info(
+                        f"[TIME SENDER] {filename} sent successfully")
                 except Exception as send_err:
                 except Exception as send_err:
                     log.error(f"[SENDER ERROR] sendall failed for {conn_name}: {send_err}")
                     log.error(f"[SENDER ERROR] sendall failed for {conn_name}: {send_err}")
             # except Exception as send_err:
             # except Exception as send_err: