From 2f3d6432788936b7da529066760dfa4cdb87863d Mon Sep 17 00:00:00 2001
From: John Costa <johncosta027@gmail.com>
Date: Sat, 10 May 2025 15:12:25 +0100
Subject: [PATCH] feat: not deleting images to process

---
 backend/models/image.go | 32 +++++++++++++++++++++++++-------
 1 file changed, 25 insertions(+), 7 deletions(-)

diff --git a/backend/models/image.go b/backend/models/image.go
index 8ca72bb..2fe300f 100644
--- a/backend/models/image.go
+++ b/backend/models/image.go
@@ -130,14 +130,21 @@ func (m ImageModel) FinishProcessing(ctx context.Context, imageId uuid.UUID) (mo
 		return model.UserImages{}, err
 	}
 
-	removeProcessingStmt := UserImagesToProcess.
-		DELETE().
-		WHERE(UserImagesToProcess.ID.EQ(UUID(imageToProcess.ID)))
+	// TODO:
+	// We cannot delete the image to process because our events rely on it.
+	// This indicates our DB structure with the two tables might need some adjusting.
+	// Or re-doing all together perhaps.
+	// (switching to a one table (user_images) could work)
+	// But for now, we can just not delete the images to process and set them to complete
 
-	_, err = removeProcessingStmt.ExecContext(ctx, tx)
-	if err != nil {
-		return model.UserImages{}, err
-	}
+	// removeProcessingStmt := UserImagesToProcess.
+	// 	DELETE().
+	// 	WHERE(UserImagesToProcess.ID.EQ(UUID(imageToProcess.ID)))
+	//
+	// _, err = removeProcessingStmt.ExecContext(ctx, tx)
+	// if err != nil {
+	// 	return model.UserImages{}, err
+	// }
 
 	err = tx.Commit()
 	return userImage, err
@@ -184,6 +191,17 @@ func GetUserId(dbPool *sql.DB, ctx context.Context, imageId uuid.UUID) (uuid.UUI
 	return userImage.UserID, err
 }
 
+func GetUserIdComplete(dbPool *sql.DB, ctx context.Context, imageId uuid.UUID) (uuid.UUID, error) {
+	getUserIdStmt := UserImages.
+		SELECT(UserImages.UserID).
+		WHERE(UserImages.ID.EQ(UUID(imageId)))
+
+	userImage := model.UserImagesToProcess{}
+	err := getUserIdStmt.QueryContext(ctx, dbPool, &userImage)
+
+	return userImage.UserID, err
+}
+
 func NewImageModel(db *sql.DB) ImageModel {
 	return ImageModel{dbPool: db}
 }