From 9d33c7532afc157594cfaa10f013cf3e592d327b Mon Sep 17 00:00:00 2001
From: vladp <vlad.popovtsevv@gmail.com>
Date: Thu, 2 Apr 2026 12:18:47 +0700
Subject: [PATCH] dev add notification entity

---
 .../nocopy/service/search/GlobalSearchAsyncProcessor.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java
index cb6d7a2..fdc1008 100644
--- a/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java
+++ b/src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java
@@ -48,6 +48,8 @@ public class GlobalSearchAsyncProcessor {
     @Async
     @Transactional
     public void processFilesAsync(String taskId, List<FileEntity> filesToProcess, Long userId) {
+        GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
+
         try {
             for (int i = 0; i < filesToProcess.size(); i++) {
                 FileEntity file = filesToProcess.get(i);
@@ -55,13 +57,11 @@ public class GlobalSearchAsyncProcessor {
                 GlobalSearchResult result = processFile(file, taskId, userId);
                 globalSearchResultRepository.save(result);
 
-                GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
                 task.setProcessedFiles(i + 1);
                 task.setUpdatedAt(LocalDateTime.now());
                 globalSearchTaskRepository.save(task);
             }
 
-            GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
             task.setStatus(SearchStatus.COMPLETED.name());
             task.setUpdatedAt(LocalDateTime.now());
             globalSearchTaskRepository.save(task);
@@ -70,7 +70,6 @@ public class GlobalSearchAsyncProcessor {
         } catch (Exception e) {
             log.error("Global search failed for task: {}", taskId, e);
 
-            GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
             task.setStatus(SearchStatus.FAILED.name());
             task.setUpdatedAt(LocalDateTime.now());
             globalSearchTaskRepository.save(task);