fix: 잘못들어간 셀프 참조 코드 제거

Author: Hyeonjun0527

src/main/java/kr/it/pullit/modules/learningsource/source/service/SourceService.java

@@ -43,7 +43,6 @@ public class SourceService implements SourcePublicApi {
   private final MemberPublicApi memberPublicApi;
   private final SourceFolderPublicApi sourceFolderPublicApi;
   private final ApplicationEventPublisher eventPublisher;
-  private final SourceService self;
 
   @Override
   public SourceUploadResponse generateUploadUrl(
@@ -121,7 +120,7 @@ public InputStream getContentStream(Long sourceId, Long memberId) {
     try {
       return s3PublicApi.downloadFileAsStream(source.getFilePath());
     } catch (NoSuchKeyException e) {
-      self.markSourceAsError(source.getId());
+      markSourceAsNotExist(source.getId());
       throw S3FileNotFoundForSourceException.bySourceIdAndFilePath(sourceId, source.getFilePath());
     }
   }
@@ -136,7 +135,7 @@ public Path downloadFileToTemp(long sourceId, long memberId) throws IOException
     try {
       return s3PublicApi.downloadFileToTemp(source.getFilePath());
     } catch (NoSuchKeyException e) {
-      self.markSourceAsError(source.getId());
+      markSourceAsNotExist(source.getId());
       throw S3FileNotFoundForSourceException.bySourceIdAndFilePath(sourceId, source.getFilePath());
     }
   }
@@ -178,6 +177,17 @@ public void markSourceAsError(Long sourceId) {
             });
   }
 
+  @Transactional(propagation = Propagation.REQUIRES_NEW)
+  public void markSourceAsNotExist(Long sourceId) {
+    sourceRepository
+        .findById(sourceId)
+        .ifPresent(
+            source -> {
+              source.markAsNotExist();
+              log.warn("Source ID {}의 상태를 NOT_EXIST로 변경했습니다.", sourceId);
+            });
+  }
+
   @Transactional
   public void synchronizeS3Files() {
     log.info("DB에 READY 상태이지만 S3에 존재하지 않는 Source 데이터 정리를 시작합니다.");
@@ -207,15 +217,14 @@ public void synchronizeS3Files() {
   @Transactional
   public void migrateUploadedSourcesToReady() {
     log.info("기존 UPLOADED 상태의 소스 데이터 마이그레이션을 시작합니다.");
-    List<Source> uploadedSources = findUploadedSources();
+    List<Source> uploadedSources = sourceRepository.findByStatus(SourceStatus.UPLOADED);
 
     int successCount = processMigrationForSources(uploadedSources);
 
-    logMigrationSummary(uploadedSources.size(), successCount);
-  }
-
-  private List<Source> findUploadedSources() {
-    return sourceRepository.findByStatus(SourceStatus.UPLOADED);
+    log.info(
+        "소스 데이터 마이그레이션을 완료했습니다. 총 {}개의 소스 중 {}개의 상태를 READY로 변경했습니다.",
+        uploadedSources.size(),
+        successCount);
   }
 
   private int processMigrationForSources(List<Source> sources) {
@@ -232,44 +241,25 @@ private boolean tryMigrateSingleSource(Source source) {
     try {
       return migrateSourceIfFileExists(source);
     } catch (Exception e) {
-      logMigrationError(source, e);
+      log.error(
+          "마이그레이션 중 Source ID {} 처리 오류 발생. 파일 경로: {}", source.getId(), source.getFilePath(), e);
       return false;
     }
   }
 
   private boolean migrateSourceIfFileExists(Source source) {
     if (s3PublicApi.fileExists(source.getFilePath())) {
-      updateSourceStatusToReady(source);
-      logMigrationSuccess(source);
+      source.markAsReady();
+      sourceRepository.save(source);
+      log.info("Source ID {}의 상태를 READY로 변경했습니다. 파일 경로: {}", source.getId(), source.getFilePath());
       return true;
     }
 
-    logS3FileNotFound(source);
-    return false;
-  }
-
-  private void updateSourceStatusToReady(Source source) {
-    source.markAsReady();
-    sourceRepository.save(source);
-  }
-
-  private void logMigrationSuccess(Source source) {
-    log.info("Source ID {}의 상태를 READY로 변경했습니다. 파일 경로: {}", source.getId(), source.getFilePath());
-  }
-
-  private void logS3FileNotFound(Source source) {
     log.warn(
         "S3에 파일이 존재하지 않아 Source ID {}의 상태를 변경하지 않았습니다. 파일 경로: {}",
         source.getId(),
         source.getFilePath());
-  }
-
-  private void logMigrationError(Source source, Exception e) {
-    log.error("마이그레이션 중 Source ID {} 처리 오류 발생. 파일 경로: {}", source.getId(), source.getFilePath(), e);
-  }
-
-  private void logMigrationSummary(int total, int success) {
-    log.info("소스 데이터 마이그레이션을 완료했습니다. 총 {}개의 소스 중 {}개의 상태를 READY로 변경했습니다.", total, success);
+    return false;
   }
 
   private Source getOrElseThrow(Long sourceId, Long memberId) {

src/main/java/kr/it/pullit/modules/notification/service/NotificationEventService.java

@@ -39,7 +39,7 @@ public void publishQuestionSetCreationComplete(
     publishAndSend(userId, SseEventType.QUESTION_SET_CREATION_COMPLETE, data);
   }
 
-  @Scheduled(fixedRate = HEARTBEAT_INTERVAL_MS, zone = "Asia/Seoul")
+  @Scheduled(fixedRate = HEARTBEAT_INTERVAL_MS)
   public void sendHeartbeat() {
     Map<Long, NotificationChannel> channels = notificationChannelRepository.findAll();
     if (channels.isEmpty()) {