add stop mechanism for bad connection

Author: dariusstefan

docs/event.md

@@ -44,6 +44,8 @@ except OpenSIPSEventException as e:
     # handle the exception
 ```
 
+If `callback` function is called with `None` as a parameter, it means that there was an error while receiving the event and no JSON object could be parsed from the received data after 10 retries.
+
 ## Subscribing
 
 By default, the subscription will be permanent. If you want to set a timeout, you can use the `expires` parameter. The value should be an integer representing the number of seconds the subscription will be active.

opensips/event/__main__.py

@@ -107,6 +107,10 @@ def main():
 
     def event_handler(message):
         """ Event handler callback """
+        if message is None:
+            ev.unsubscribe()
+            sys.exit(1)
+
         try:
             print(json.dumps(message, indent=4))
         except json.JSONDecodeError as e:

opensips/event/event.py

@@ -40,6 +40,7 @@ def __init__(self, handler, name: str, callback, expire=None):
         self.thread_stop.clear()
         self.buf = b""
         self.json_queue = []
+        self.retries = 0
 
         try:
             self.socket = self._handler.__new_socket__()
@@ -63,7 +64,16 @@ def handle(self, callback):
 
             self.buf += data
             self.json_queue, self.buf = extract_json(self.json_queue, self.buf)
+
+            if not self.json_queue:
+                self.retries += 1
+
+            if self.retries > 10:
+                callback(None)
+                break
+
             while self.json_queue:
+                self.retries = 0
                 json_obj = self.json_queue.pop(0)
                 callback(json_obj)