dev add context for notifcations

src/main/java/ru/soune/nocopy/service/search/GlobalSearchAsyncProcessor.java

@@ -54,9 +54,7 @@ public class GlobalSearchAsyncProcessor {
     private final FileEntityRepository fileEntityRepository;
 
     @Async
-    public void processFilesAsync(String taskId, List<String> filesToProcess, Long userId) {
-        GlobalSearchTask task = globalSearchTaskRepository.findById(taskId).orElseThrow();
-
+    public void processFilesAsync(GlobalSearchTask task, List<String> filesToProcess, Long userId) {
         try {
             for (int i = 0; i < filesToProcess.size(); i++) {
                 String uuid = filesToProcess.get(i);
@@ -67,7 +65,7 @@ public class GlobalSearchAsyncProcessor {
 
                 tariffInfoService.writeOffTokens(userId, TariffConstants.TOKEN_VALUE_FOR_SEARCH,
                         OperationType.GLOBAL_SEARCH);
-                GlobalSearchResult result = processFile(file, taskId, userId);
+                GlobalSearchResult result = processFile(file, task.getTaskId(), userId);
                 globalSearchResultRepository.save(result);
 
                 task.setProcessedFiles(i + 1);
@@ -81,8 +79,6 @@ public class GlobalSearchAsyncProcessor {
 
             addSearchResultNotification(save, filesToProcess, userId);
         } catch (Exception e) {
-            log.error("Global search failed for task: {}", taskId, e);
-
             task.setStatus(SearchStatus.FAILED.name());
             task.setUpdatedAt(LocalDateTime.now());
             globalSearchTaskRepository.save(task);

src/main/java/ru/soune/nocopy/service/search/GlobalSearchService.java

@@ -48,7 +48,7 @@ public class GlobalSearchService {
 
         List<String> fileIds = filesToProcess.stream().map(FileEntity::getId).toList();
 
-        asyncProcessor.processFilesAsync(save.getTaskId(), fileIds, userId);
+        asyncProcessor.processFilesAsync(save, fileIds, userId);
 
         return save.getTaskId();
     }