Fix changes after merge

Author: febus982

pyproject.toml

@@ -2,7 +2,7 @@
 authors = [
     {name = "Federico Busetti", email = "[email protected]"},
 ]
-requires-python = "<3.14,>=3.9"
+requires-python = "<3.14,>=3.11"
 name = "bootstrap-fastapi-service"
 version = "0.1.0"
 description = ""
@@ -14,20 +14,22 @@ dependencies = [
     "cloudevents-pydantic<1.0.0,>=0.0.3",
     "dependency-injector[pydantic]<5.0.0,>=4.41.0",
     "dramatiq[redis,watch]<2.0.0,>=1.17.1",
-    "hiredis<4.0.0,>=3.1.0",  # Recommended by dramatiq
+    "hiredis<4.0.0,>=3.1.0", # Recommended by dramatiq
     "httpx>=0.23.0",
     "opentelemetry-distro[otlp]",
     "opentelemetry-instrumentation",
     "opentelemetry-instrumentation-httpx",
     "opentelemetry-instrumentation-sqlalchemy",
     "opentelemetry-instrumentor-dramatiq",
+    "opentelemetry-instrumentation-faststream",
     "orjson<4.0.0,>=3.10.12",
     "pydantic<3.0.0,>=2.2.1",
     "pydantic-settings<3.0.0,>=2.0.3",
     "rich<14.0.0,>=13.2.0",
     "SQLAlchemy[asyncio,mypy]<3.0.0,>=2.0.0",
     "sqlalchemy-bind-manager",
     "structlog<25.1.1,>=25.1.0",
+    "faststream>=0.5.34",
 ]
 
 [dependency-groups]

src/bootstrap/config.py

@@ -17,11 +17,19 @@ class AuthConfig(BaseModel):
     JWKS_URL: Optional[str] = None
 
 
+class EventConfig(BaseModel):
+    REDIS_BROKER_URL: str = ""
+    TOPIC: Optional[str] = None
+    IS_PUBLISHER: bool = False
+    IS_SUBSCRIBER: bool = False
+
+
 class AppConfig(BaseSettings):
     model_config = SettingsConfigDict(env_nested_delimiter="__")
 
     APP_NAME: str = "bootstrap"
     AUTH: AuthConfig = AuthConfig()
+    EVENTS: EventConfig = EventConfig()
     DRAMATIQ: DramatiqConfig = DramatiqConfig()
     DEBUG: bool = False
     ENVIRONMENT: TYPE_ENVIRONMENT = "local"

src/common/config.py

@@ -10,8 +10,9 @@
 # from faststream.redis.publisher.asyncapi import AsyncAPIPublisher
 from opentelemetry.instrumentation.faststream import RedisOtelMiddleware
 
-from bootstrap.config import EventConfig
+from common.config import EventConfig
 from domains import event_registry
+from event_consumer import register_subscribers
 
 logger = structlog.getLogger(__name__)
 

src/common/faststream.py

@@ -17,7 +17,7 @@
 from opentelemetry.sdk.trace.export import BatchSpanProcessor
 
 from alembic.env import logger
-from bootstrap import AppConfig, application_init
+from common import AppConfig, application_init
 from domains import event_registry
 from domains.books.events import BookCreatedV1, BookCreatedV1Data