Оновлено interface.py: додано багатопотокову обробку для оновлення індикатора прогресу під час аналізу тексту, зменшено затримки між кроками прогресу, покращено обробку помилок та зупинку фонових потоків. Додано детальніший опис прогресу в залежності від стану аналізу.

src/interface.py

@@ -1,5 +1,6 @@
 import gradio as gr
 import time
+import threading
 import os
 from .analyzer import NPAAnalyzer
 
@@ -61,7 +62,7 @@ def create_interface():
         def analyze_and_format(npa_text, selected_provider, selected_model, enable_thinking, thinking_budget, progress=gr.Progress()):
             if not npa_text.strip():
                 return "### Помилка\nПоле для тексту не може бути порожнім. Введіть текст для аналізу.", "", "Перевірте введені дані"
-                
+                    
             if api_keys_warning:
                 return f"### Помилка\n{api_keys_warning}", "", "Помилка конфігурації API ключів"
 
@@ -69,7 +70,7 @@ def create_interface():
             try:
                 if analyzer.get_provider_name() != selected_provider:
                     analyzer.change_provider(selected_provider)
-                
+                    
                 current_models = analyzer.get_available_models() or []
                 if selected_model in current_models:
                     analyzer.change_model(selected_model)
@@ -90,14 +91,45 @@ def create_interface():
 
             start_time = time.time()
             
-            # Індикатори прогресу
+            # Початкові кроки прогресу
             progress(0, desc="Ініціалізація аналізу...")
-            time.sleep(0.5)
+            time.sleep(0.3)
+            
+            progress(0.05, desc="Підготовка тексту НПА...")
+            time.sleep(0.3)
+            
+            progress(0.1, desc=f"Підготовка запиту до {selected_provider}...")
+            time.sleep(0.3)
             
-            progress(0.1, desc="Підготовка тексту НПА...")
-            time.sleep(0.5)
+            progress(0.15, desc=f"Відправка запиту до {selected_provider}...")
             
-            progress(0.2, desc=f"Відправка запиту до {selected_provider}...")
+            # Змінні для контролю фонового потоку
+            is_analyzing = True
+            current_progress = 0.15
+            
+            def update_progress_bar():
+                nonlocal current_progress
+                while is_analyzing and current_progress < 0.95:
+                    # Поступово збільшуємо значення прогресу
+                    time.sleep(0.5)  # Оновлюємо кожні 0.5 секунди
+                    
+                    # Використовуємо логарифмічну прогресію для повільнішого наростання в кінці
+                    step = max(0.005, (0.95 - current_progress) / 20)
+                    current_progress += step
+                    
+                    # Оновлюємо опис базуючись на поточному прогресі
+                    desc = "Аналіз тексту..."
+                    if current_progress > 0.7:
+                        desc = "Формування відповіді..."
+                    elif current_progress > 0.4:
+                        desc = "Опрацювання результатів..."
+                        
+                    progress(current_progress, desc=desc)
+            
+            # Запускаємо фоновий потік для оновлення прогресу
+            progress_thread = threading.Thread(target=update_progress_bar)
+            progress_thread.daemon = True
+            progress_thread.start()
             
             # Аналіз з поточними налаштуваннями
             try:
@@ -108,9 +140,17 @@ def create_interface():
                     thinking_budget=thinking_budget
                 )
             except Exception as e:
+                # Зупиняємо фоновий потік оновлення прогресу
+                is_analyzing = False
+                progress_thread.join(timeout=1.0)
+                
                 return f"### Помилка при аналізі\n```\n{str(e)}\n```\n\nПеревірте текст та налаштування або спробуйте ще раз.", "", f"Помилка аналізу: {str(e)}"
             
-            progress(0.9, desc="Форматування результатів...")
+            # Зупиняємо фоновий потік оновлення прогресу
+            is_analyzing = False
+            progress_thread.join(timeout=1.0)
+            
+            progress(0.95, desc="Форматування результатів...")
             
             end_time = time.time()
             elapsed_time = end_time - start_time
@@ -128,7 +168,7 @@ def create_interface():
             else:
                 thinking_output = f"## Роздуми моделі недоступні\n{'Режим роздумів вимкнено.' if supports_thinking else f'Провайдер {selected_provider} не підтримує режим роздумів.'}"
             
-            # Додавання інформації про налаштування
+            # Додавання інформації про налаштування та токени
             settings_info = f"\n\n_Провайдер: {selected_provider}, Модель: {selected_model}, "
             if supports_thinking:
                 settings_info += f"режим роздумів {'увімкнено' if enable_thinking else 'вимкнено'}"