Merge pull request #18 from redb0/fix-toml

Update format pyproject.toml and fix code stule

Author: redb0

.gitignore

@@ -30,8 +30,5 @@ workspace.code-workspace
 # Jupyter Notebook
 .ipynb_checkpoints/
 
-# Poetry
-poetry.lock
-
 # Build
 dist

fastapi_structlog/base.py

@@ -10,6 +10,7 @@
 
 class BaseSettingsModel(BaseSettings):
     """Basic model of the settings."""
+
     model_config = SettingsConfigDict(
         arbitrary_types_allowed=True,
         env_ignore_empty=True,

fastapi_structlog/custom_processors.py

@@ -16,6 +16,7 @@ def hide_query_param(
     replace_pattern: str,
 ) -> Callable[[WrappedLogger, str, EventDict], ProcessorReturnValue]:
     """Hide the password query parameter."""
+
     def hide(
         _: WrappedLogger,
         __: str,
@@ -24,6 +25,7 @@ def hide(
         for _ in find_by_value(event_dict, value_pattern, replace=replace_pattern):
             pass
         return event_dict
+
     return hide
 
 
@@ -72,6 +74,7 @@ class CallsiteParameterAdderInKey(structlog.processors.CallsiteParameterAdder):
     logging parameters. An additional nesting level for this key
     will be created in `event_dict`.
     """
+
     def __init__(
         self,
         parameters: Collection[CallsiteParameter] = set(CallsiteParameter),
@@ -111,8 +114,12 @@ class ORJSONRenderer(structlog.processors.JSONRenderer):
 
     Decodes a string of bytes received after serialization.
     """
+
     def __call__(  # noqa: D102
-        self, _: WrappedLogger, __: str, event_dict: EventDict,
+        self,
+        _: WrappedLogger,
+        __: str,
+        event_dict: EventDict,
     ) -> Union[str, bytes]:
         result = self._dumps(event_dict, **self._dumps_kw)
         if isinstance(result, bytes):

fastapi_structlog/db_handler/handler.py

@@ -31,6 +31,7 @@ class QueueHandler(logging.handlers.QueueHandler):
 
     Removes the conversion to a string in the base class.
     """
+
     def emit(self, record: logging.LogRecord) -> None:  # noqa: D102
         if structlog is not None:
             context = structlog.contextvars.get_contextvars()
@@ -46,6 +47,7 @@ def emit(self, record: logging.LogRecord) -> None:  # noqa: D102
 
 class BaseDatabaseHandler(logging.Handler, Generic[T_]):
     """Base class of the handler for logging into the database."""
+
     def __init__(  # noqa: PLR0913
         self,
         db_url: Union[str, URL],

fastapi_structlog/db_handler/model.py

@@ -11,6 +11,7 @@
 
 class LogModel(SQLModel):
     """Basic model of logging into a database."""
+
     id: Optional[int] = Field(
         title='ID',
         default=None,

fastapi_structlog/exceptions.py

@@ -1,7 +1,9 @@
 """Exception module."""
 
+
 class LogError(Exception):
     """Basic exception."""
 
+
 class SysLogConnectionError(LogError):
     """Syslog connection error."""

fastapi_structlog/factory.py

@@ -1,4 +1,5 @@
 """Logger factory module."""
+
 from logging import Logger, getLogger
 from typing import Any, Optional, Union
 
@@ -9,9 +10,12 @@
 
 class LoggerFactory(structlog.stdlib.LoggerFactory):
     """Logger factory."""
-    def __init__(self,
-                 logger: Union[Logger, str],
-                 ignore_frame_names: Optional[list[str]] = None) -> None:
+
+    def __init__(
+        self,
+        logger: Union[Logger, str],
+        ignore_frame_names: Optional[list[str]] = None,
+    ) -> None:
         self.logger = logger
         super().__init__(ignore_frame_names=ignore_frame_names)
 

fastapi_structlog/log.py

@@ -1,4 +1,5 @@
 """Logger configuration module via structlog."""
+
 import logging
 import logging.handlers
 import sys
@@ -22,12 +23,14 @@
 
 try:
     from structlog_sentry import SentryProcessor
+
     find_structlog_sentry = True
 except ImportError:
     find_structlog_sentry = False
 
 try:
     import orjson
+
     find_orjson = True
 except ImportError:
     find_orjson = False
@@ -221,6 +224,7 @@ def base_formatter(settings: LogSettings) -> structlog.stdlib.ProcessorFormatter
 
 class HandlerFactory(Generic[T2_]):
     """An abstract factory for creating logging handlers."""
+
     def __init__(
         self,
         handler: type[T2_],
@@ -246,6 +250,7 @@ def create(self, **kwargs: Any) -> T2_:  # noqa: ANN401, D102
 
 class SyslogHandlerFactory(HandlerFactory[logging.handlers.SysLogHandler]):
     """Factory of handlers for syslog."""
+
     def __init__(
         self,
         formatter: Optional[structlog.stdlib.ProcessorFormatter] = None,
@@ -277,6 +282,7 @@ def create_handler(
 
 class StreamHandlerFactory(HandlerFactory['logging.StreamHandler[TextIO]']):
     """Factory of handlers for console."""
+
     def __init__(
         self,
         formatter: Optional[structlog.stdlib.ProcessorFormatter] = None,
@@ -293,6 +299,7 @@ def create_handler(
 
 class FileHandlerFactory(HandlerFactory[TimedRotatingFileHandler]):
     """Factory of handlers for file."""
+
     def __init__(
         self,
         formatter: Optional[structlog.stdlib.ProcessorFormatter] = None,
@@ -327,12 +334,15 @@ def create_handler(
         path.parent.mkdir(parents=True, exist_ok=True)
 
         return TimedRotatingFileHandler(
-            filename=path, when=when, backupCount=backup_count,
+            filename=path,
+            when=when,
+            backupCount=backup_count,
         )
 
 
 class DatabaseHandlerFactory(HandlerFactory[DatabaseHandler[T_]]):
     """Factory of handlers for database."""
+
     def __init__(
         self,
         formatter: Optional[structlog.stdlib.ProcessorFormatter] = None,
@@ -381,6 +391,7 @@ def create_handler(  # noqa: PLR0913
 
 class LoggerConfigurator:
     """Logger configuration class."""
+
     def __init__(self, settings: LogSettings) -> None:
         self.settings = settings
 

fastapi_structlog/middleware/__init__.py

@@ -1,4 +1,5 @@
 """Middleware for logging package."""
+
 from .access_log import AccessLogMiddleware
 from .current_scope import CurrentScopeSetMiddleware
 from .structlog import StructlogMiddleware

fastapi_structlog/middleware/access_log.py

@@ -1,4 +1,5 @@
 """Access logging middleware module."""
+
 import http
 import logging
 import os
@@ -26,13 +27,15 @@
 
 class AccessInfo(TypedDict, total=False):
     """Access information with timestamps."""
+
     response: Message
     start_time: float
     end_time: float
 
 
 class AccessLogMiddleware:
     """Access logging middleware."""
+
     DEFAULT_FORMAT = '%(client_addr)s - "%(request_line)s" %(status)s %(L)ss - "%(a)s"'
 
     def __init__(  # noqa: PLR0913
@@ -91,9 +94,9 @@ async def send_wrapper(response: Message) -> None:
             info['start_time'] = time.perf_counter()
             await self.app(scope, receive, send_wrapper)
             return
-        except Exception as exc:
+        except Exception:
             info['response']['status'] = 500
-            raise exc
+            raise
         finally:
             info['end_time'] = time.perf_counter()
 
@@ -110,6 +113,7 @@ async def send_wrapper(response: Message) -> None:
 
 class AccessLogAtoms(dict[str, Any]):
     """Logging attributes."""
+
     def __init__(self, scope: Scope, info: AccessInfo) -> None:
         for name, value in scope['headers']:
             self[f"{{{name.decode('latin1').lower()}}}i"] = value.decode('latin1')
@@ -180,7 +184,7 @@ def __getitem__(self, key: str) -> Any:  # noqa: D105, ANN401
             return '-'
 
     @staticmethod
-    def _human_size(size: int, decimal_places: int=2) -> bytes:
+    def _human_size(size: int, decimal_places: int = 2) -> bytes:
         _suffixes = ('bytes', 'KiB', 'MiB', 'GiB', 'TiB', 'PiB', 'EiB', 'ZiB', 'YiB')
         order = int(log2(size) / 10) if size else 0
         human_size = f'{size / (1 << (order * 10)):.{decimal_places}f} {_suffixes[order]}'