Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

RED-6805: As Operation I want to see why downloads are in an ERROR state

Browse Source 
added errorcause to repository
This commit is contained in:
yhampe 2024-01-15 12:21:00 +01:00
parent 0cfbdb3083
commit 4ccf355dcf
4 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/entity/download/DownloadStatusEntity.java
View File

@ -60,6 +60,8 @@ public class DownloadStatusEntity {
OffsetDateTime lastDownload; OffsetDateTime lastDownload;
@Column @Column
long fileSize; long fileSize;
@Column
String errorCause;
@ManyToOne(fetch = FetchType.EAGER) @ManyToOne(fetch = FetchType.EAGER)
DossierEntity dossier; DossierEntity dossier;

6
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/download/DownloadDLQMessageReceiver.java
View File

@ -68,9 +68,11 @@ public class DownloadDLQMessageReceiver {
private void setDownloadFailed(String userId, String downloadId) { private void setDownloadFailed(String userId, String downloadId) {
String errorCause = "unknown error cause";
retryTemplate.execute(retryContext -> { retryTemplate.execute(retryContext -> {
log.warn("Retrying {} time to set FAILED status for downloadJob userId: {} storageId: {}", retryContext.getRetryCount(), userId, downloadId); log.warn("Retrying {} time to set FAILED status for downloadJob userId: {} storageId: {}", retryContext.getRetryCount(), userId, downloadId);
downloadStatusPersistenceService.updateStatus(downloadId, DownloadStatusValue.FAILED); downloadStatusPersistenceService.updateStatus(downloadId, DownloadStatusValue.FAILED,errorCause);
return null; return null;
}); });
} }
@ -79,7 +81,7 @@ public class DownloadDLQMessageReceiver {
retryTemplate.execute(retryContext -> { retryTemplate.execute(retryContext -> {
log.warn("Retrying {} time to set FAILED status for downloadJob userId: {} storageId: {}", retryContext.getRetryCount(), userId, downloadId); log.warn("Retrying {} time to set FAILED status for downloadJob userId: {} storageId: {}", retryContext.getRetryCount(), userId, downloadId);
downloadStatusPersistenceService.updateStatus(downloadId, DownloadStatusValue.FAILED); downloadStatusPersistenceService.updateStatus(downloadId, DownloadStatusValue.FAILED, errorCause);
return null; return null;
}); });
} }

4
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/DownloadStatusPersistenceService.java
View File

@ -65,9 +65,9 @@ public class DownloadStatusPersistenceService {
@Transactional @Transactional
public void updateStatus(String storageId, DownloadStatusValue status) { public void updateStatus(String storageId, DownloadStatusValue status, String errorCause) {
downloadStatusRepository.updateStatus(storageId, status); downloadStatusRepository.updateStatusAndErrorCause(storageId, status, errorCause);
} }

4
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/repository/DownloadStatusRepository.java
View File

@ -20,6 +20,10 @@ public interface DownloadStatusRepository extends JpaRepository<DownloadStatusEn
@Query("update DownloadStatusEntity ds set ds.status = :status where ds.storageId = :storageId") @Query("update DownloadStatusEntity ds set ds.status = :status where ds.storageId = :storageId")
int updateStatus(@Param("storageId") String storageId, @Param("status") DownloadStatusValue status); int updateStatus(@Param("storageId") String storageId, @Param("status") DownloadStatusValue status);
@Query("update DownloadStatusEntity ds set ds.status = :status, ds.errorCause = :errorCause where ds.storageId = :storageId")
int updateStatusAndErrorCause(@Param("storageId") String storageId, @Param("status") DownloadStatusValue status, @Param("errorCause") String errorCause);
@Modifying @Modifying
@Transactional @Transactional
@Query("update DownloadStatusEntity ds set ds.status = :status where ds.storageId = :storageId and ds.status != :status") @Query("update DownloadStatusEntity ds set ds.status = :status where ds.storageId = :storageId and ds.status != :status")