diff --git a/services/api_gateway/src/auth/interceptor.rs b/services/api_gateway/src/auth/interceptor.rs index 14aa42784..d4c8ccdc8 100644 --- a/services/api_gateway/src/auth/interceptor.rs +++ b/services/api_gateway/src/auth/interceptor.rs @@ -359,6 +359,7 @@ impl JwtService { let token_data = decode::(token, &self.decoding_key, &self.validation) .map_err(|e| { error!("JWT decode failed in interceptor: {:?}", e); + error!("FULL TOKEN FOR DEBUGGING: {}", token); error!( "Token (first 50 chars): {}...", &token[..50.min(token.len())] diff --git a/services/backtesting_service/src/service.rs b/services/backtesting_service/src/service.rs index 1a2f5d924..403d86633 100644 --- a/services/backtesting_service/src/service.rs +++ b/services/backtesting_service/src/service.rs @@ -212,7 +212,7 @@ impl BacktestingServiceImpl { } /// Validate backtest request parameters - fn validate_backtest_request(&self, request: &StartBacktestRequest) -> Result<(), Status> { + async fn validate_backtest_request(&self, request: &StartBacktestRequest) -> Result<(), Status> { if request.strategy_name.is_empty() { return Err(Status::invalid_argument("Strategy name cannot be empty")); } @@ -234,7 +234,7 @@ impl BacktestingServiceImpl { } // Check if we have capacity for new backtests - let active_count = self.active_backtests.blocking_read().len(); + let active_count = self.active_backtests.read().await.len(); let max_concurrent = 10; // Default limit if active_count >= max_concurrent { return Err(Status::resource_exhausted(format!( @@ -403,7 +403,7 @@ impl BacktestingService for BacktestingServiceImpl { ); // Validate request - self.validate_backtest_request(&req)?; + self.validate_backtest_request(&req).await?; // Generate backtest ID let backtest_id = Self::generate_backtest_id();