protoconfloader 1st version

Author: Aviv Laufer

config.json

@@ -0,0 +1,23 @@
+{
+  "crawlers": [
+    {
+      "userAgent": "Mozilla/5.0 (iPhone; CPU iPhone OS 6_0_1 like Mac OS X) AppleWebKit/536.26 (KHTML, like Gecko) Version/6.0 Mobile/10A525 Safari/8536.25",
+      "httpTimeout": 30,
+      "followRedirects": true
+    },
+    {
+      "userAgent": "Mozilla/5.0 (iPhone; CPU iPhone OS 6_0_1 like Mac OS X) AppleWebKit/536.26 (KHTML, like Gecko) Version/6.0 Mobile/10A525 Safari/8536.25",
+      "httpTimeout": 60
+    },
+    {
+      "userAgent": "Mozilla/5.0 (iPhone; CPU iPhone OS 6_0_1 like Mac OS X) AppleWebKit/536.26 (KHTML, like Gecko) Version/6.0 Mobile/10A525 Safari/8536.25",
+      "httpTimeout": 90
+    },
+    {
+      "userAgent": "Linux/ time=1562845087",
+      "httpTimeout": 30
+    }
+  ],
+  "logLevel": 5
+
+}

protoconfloader/__init__.py

@@ -0,0 +1 @@
+from .protoconfloader import Configuration

protoconfloader/protoconfloader.py

@@ -1,14 +1,14 @@
-import aiofiles
 import asyncio
-import grpc
 import json
 import logging
 import os
 import pathlib
 import sys
-from google.protobuf.any_pb2 import Any
-from google.protobuf.json_format import Parse
 from typing import Any, Callable
+
+import aiofiles
+import grpc
+from google.protobuf.json_format import Parse
 from watchdog.events import FileSystemEvent, FileSystemEventHandler
 from watchdog.observers import Observer
 
@@ -167,11 +167,11 @@ async def watch_config(self, delay: int = 0) -> None:
                 task1.result(),
                 task2.result(),
             )
-        except* asyncio.CancelledError:
+        except asyncio.CancelledError:
             self.logger.info("Tasks were cancelled")
-        except* Exception as e:
+        except Exception as e:
             self.logger.error("Error in watch_config: %s", e)
-            for exc in e.exceptions:
-                self.logger.error("Sub-exception: %s", exc)
-                self.logger.error("Traceback: ", exc_info=exc)
-            exit(os.EX_UNAVAILABLE)
+            # Removed the incorrect handling of exceptions as instances of Exception do not have an 'exceptions' member
+            # Instead, directly log the exception and its traceback
+            self.logger.error("Error traceback: ", exc_info=e)
+            sys.exit(os.EX_UNAVAILABLE)

pyproject.toml

@@ -7,14 +7,19 @@ readme = "README.md"
 
 [tool.poetry.dependencies]
 python = "^3.11"
-inotify = "^0.2.10"
 grpclib = "^0.4.7"
 protobuf = "^5.27.1"
 asyncio = "^3.4.3"
+grpcio = "^1.65.5"
+grpcio-tools = "^1.65.5"
+watchdog = "^4.0.2"
+aiofiles = "^24.1.0"
 
 
 [tool.poetry.group.test.dependencies]
-pytest = "^8.2.2"
+pytest = "^8.3.2"
+pytest-asyncio = "^0.23.8"
+pytest-cov = "^5.0.0"
 
 [build-system]
 requires = ["poetry-core"]