From 4f84fbe09cd0b4e654a15f1dc70ba487f51fac24 Mon Sep 17 00:00:00 2001
From: "adel.ka" <rikardofik@gmail.com>
Date: Tue, 1 Jul 2025 11:07:41 +0300
Subject: [PATCH] =?UTF-8?q?=D0=BF=D0=BE=D0=BC=D0=B5=D0=BD=D1=8F=D0=BB=20?=
 =?UTF-8?q?=D0=B8=D0=BD=D1=84=D1=83=20=D0=B2=20=D0=BB=D0=BE=D0=B3=D0=B3?=
 =?UTF-8?q?=D0=B5=D1=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/SessionResponseHolder.java                    | 6 +++---
 .../ervu_business_metrics/service/SessionService.java     | 8 ++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/backend/src/main/java/ervu_business_metrics/service/SessionResponseHolder.java b/backend/src/main/java/ervu_business_metrics/service/SessionResponseHolder.java
index c43f2e2..44d496d 100644
--- a/backend/src/main/java/ervu_business_metrics/service/SessionResponseHolder.java
+++ b/backend/src/main/java/ervu_business_metrics/service/SessionResponseHolder.java
@@ -42,16 +42,16 @@ public class SessionResponseHolder {
     SessionAccumulator acc = sessionsMap.get(requestKey);
 
     long startTime = System.nanoTime();
-    LOGGER.info("Начало ожидания сессий для requestKey = {}", requestKey);
+    LOGGER.info("Starting to await sessions for requestKey = {}", requestKey);
 
     while (acc == null && (System.nanoTime() - startTime) < unit.toNanos(timeout)) {
-      LOGGER.debug("Аккумулятор для requestKey = {} еще не найден, повторная проверка", requestKey);
+      LOGGER.debug("Accumulator for requestKey = {} not found yet, retrying", requestKey);
       TimeUnit.MILLISECONDS.sleep(50);
       acc = sessionsMap.get(requestKey);
     }
 
     if (acc == null) {
-      LOGGER.error("Аккумулятор для requestKey: {} не был инициализирован за время ожидания.", requestKey);
+      LOGGER.error("Accumulator for requestKey: {} was not initialized within the timeout period.", requestKey);
       return List.of();
     }
 
diff --git a/backend/src/main/java/ervu_business_metrics/service/SessionService.java b/backend/src/main/java/ervu_business_metrics/service/SessionService.java
index be1beac..00e3cea 100644
--- a/backend/src/main/java/ervu_business_metrics/service/SessionService.java
+++ b/backend/src/main/java/ervu_business_metrics/service/SessionService.java
@@ -43,23 +43,23 @@ public class SessionService {
     List<UserSessionInfo> sessions = fetchSessions();
     if (!sessions.isEmpty()) {
       activeSessionDao.saveAll(sessions);
-      LOGGER.info("Синхронизировано {} сессий", sessions.size());
+      LOGGER.info("Synchronized {} sessions", sessions.size());
     }
     else {
-      LOGGER.info("Нет сессий для синхронизации");
+      LOGGER.info("No sessions to synchronize");
     }
   }
 
   private List<UserSessionInfo> fetchSessions() {
     String requestKey = UUID.randomUUID().toString();
-    LOGGER.info("Отправка запроса с requestKey = {}", requestKey);
+    LOGGER.info("Sending request with requestKey = {}", requestKey);
     kafkaTemplate.send(sessionTopic, requestKey, "{}");
 
     try {
       return holder.awaitSessions(requestKey, timeout, TimeUnit.SECONDS);
     }
     catch (Exception e) {
-      LOGGER.error("Ошибка при получении сессий по ключу {}", requestKey, e);
+      LOGGER.error("Error while fetching sessions for key {}", requestKey, e);
       return List.of();
     }
     finally {