From 33d220cbcee7d106d90588562c60601aa4d3d5ba Mon Sep 17 00:00:00 2001 From: HardMax71 Date: Fri, 13 Feb 2026 21:51:05 +0100 Subject: [PATCH] fix: rate limit DI made sync --- backend/app/core/providers.py | 17 ++--------------- 1 file changed, 2 insertions(+), 15 deletions(-) diff --git a/backend/app/core/providers.py b/backend/app/core/providers.py index abab1a2d..d67f3c23 100644 --- a/backend/app/core/providers.py +++ b/backend/app/core/providers.py @@ -46,7 +46,6 @@ from app.dlq.manager import DLQManager from app.dlq.models import RetryPolicy, RetryStrategy from app.domain.enums import KafkaTopic -from app.domain.rate_limit import RateLimitConfig from app.domain.saga import SagaConfig from app.events.core import UnifiedProducer from app.services.admin import AdminEventsService, AdminSettingsService, AdminUserService @@ -144,25 +143,13 @@ async def get_redis_client( await client.aclose() @provide - async def get_rate_limit_service( + def get_rate_limit_service( self, redis_client: redis.Redis, settings: Settings, rate_limit_metrics: RateLimitMetrics, - logger: structlog.stdlib.BoundLogger, ) -> RateLimitService: - service = RateLimitService(redis_client, settings, rate_limit_metrics) - try: - config_key = f"{settings.RATE_LIMIT_REDIS_PREFIX}config" - existing_config = await redis_client.get(config_key) - if not existing_config: - logger.info("Initializing default rate limit configuration in Redis") - default_config = RateLimitConfig.get_default_config() - await service.update_config(default_config) - logger.info(f"Initialized {len(default_config.default_rules)} default rate limit rules") - except Exception as e: - logger.error(f"Failed to initialize rate limits: {e}") - return service + return RateLimitService(redis_client, settings, rate_limit_metrics) class CoreServicesProvider(Provider):