🐛 Fix schedule deletion will delete referenced file

Solsynth · Aug 18, 2024 · 1cce7c9 · 1cce7c9
1 parent a65b761
commit 1cce7c9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/pkg/internal/services/recycler.go b/pkg/internal/services/recycler.go
@@ -51,7 +51,7 @@ func RunMarkDeletionTask() {
 	for _, pool := range pendingPools {
 		lifecycle := fmt.Sprintf("%d seconds", *pool.Config.Data().ExistLifecycle)
 		tx := database.C.
-			Where("pool_id = ? AND created_at < NOW() - INTERVAL ?", pool.ID, lifecycle).
+			Where("pool_id = ? AND  AND created_at < NOW() - INTERVAL ?", pool.ID, lifecycle).
 			Updates(&models.Attachment{CleanedAt: lo.ToPtr(time.Now())})
 		log.Info().
 			Str("pool", pool.Alias).
@@ -68,6 +68,9 @@ func RunScheduleDeletionTask() {
 	}
 
 	for idx, attachment := range attachments {
+		if attachment.RefID != nil {
+			continue
+		}
 		if err := DeleteFile(attachment); err != nil {
 			log.Error().
 				Uint("id", attachment.ID).