Fix: Address flake8 linting/formatting issues

src/bgsexception.py

@@ -10,6 +10,7 @@ def __init__(self, message, original_exception=None):
         super().__init__(message)
         self.original_exception = original_exception
 
+
 class BgsNotFoundException(BgsException):
     """
     Not Found Exception

src/middleware.py

@@ -17,6 +17,7 @@
 HEADER_CORRELATION_ID = "OSC-DM-Correlation-ID"
 USERNAME_UNKNOWN = "unknown"
 
+
 class LoggingMiddleware(BaseHTTPMiddleware):
     """
     FastAPI middleware is used to add processing to
@@ -157,6 +158,7 @@ async def stream_response(self, send: Send):
     def body(self):
         return b"".join(self.body_chunks).decode("utf-8")
 
+
 def _safe_decode(data):
     try:
         return data.decode('utf-8')

src/server.py

@@ -13,7 +13,7 @@
 
 import uvicorn as uvicorn
 import yaml
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI
 
 import state
 
@@ -55,6 +55,7 @@
 app = FastAPI()
 app.add_middleware(LoggingMiddleware)
 
+
 @app.on_event("startup")
 async def startup_event():
     """
@@ -191,8 +192,6 @@ async def _repeat_every(interval_sec, func, *args):
         await asyncio.sleep(interval_sec)
 
 
-
-
 #####
 # MAINLINE
 #####
@@ -250,4 +249,4 @@ async def _repeat_every(interval_sec, func, *args):
     except Exception as e:
         logger.info(f"Stopping service, exception:{e}")
     finally:
-        logger.info(f"Terminating service")
+        logger.info("Terminating service")

src/state.py

@@ -12,7 +12,8 @@
 """
 global_state = {}
 
-def gstate(name: str, value: any=None):
+
+def gstate(name: str, value: any = None):
     """
     Global state manager for registration state
 

src/utilities.py

@@ -7,19 +7,20 @@
 # Created:  2024-04-15 by [email protected]
 
 import logging
-from typing import Any, Dict, List, Optional
+from typing import Any, Dict, Optional
 
 import httpx
 
-from bgsexception import BgsException, BgsNotFoundException
+from bgsexception import BgsException
 
 LOGGING_FORMAT = "%(asctime)s - %(levelname)s - %(message)s"
 logging.basicConfig(level=logging.INFO, format=LOGGING_FORMAT)
 logger = logging.getLogger(__name__)
 
+
 async def httprequest(host: str, port: int, service: str, method: str,
-             data: Optional[Any]=None, obj: Optional[Dict]=None,
-             files: Optional[Any]=None, headers: Optional[Dict]=None) -> Any:
+                      data: Optional[Any] = None, obj: Optional[Dict] = None,
+                      files: Optional[Any] = None, headers: Optional[Dict] = None) -> Any:
     """
     Generic request function using the ASYNC httpx library.
 
@@ -79,9 +80,10 @@ async def httprequest(host: str, port: int, service: str, method: str,
         logger.error(msg)
         raise BgsException(msg)
 
+
 def shttprequest(host: str, port: int, service: str, method: str,
-             data: Optional[Any]=None, obj: Optional[Dict]=None,
-             files: Optional[Any]=None, headers: Optional[Dict]=None) -> Any:
+                 data: Optional[Any] = None, obj: Optional[Dict] = None,
+                 files: Optional[Any] = None, headers: Optional[Dict] = None) -> Any:
     """
     Generic request function using the SYNCHRONOUS requests library.