From 1c4471a327f6271a95faac887b157d67b5b51a60 Mon Sep 17 00:00:00 2001
From: Marco Pedone <m.pedone98@gmail.com>
Date: Tue, 18 Nov 2025 16:36:08 +0100
Subject: [PATCH] refactor: enhance video processing logic to include
 additional checks and logging for better debugging

---
 apps/backend/miogest_handler.go |  1 +
 apps/backend/video.go           | 21 ++++++++++++++++++++-
 2 files changed, 21 insertions(+), 1 deletion(-)

diff --git a/apps/backend/miogest_handler.go b/apps/backend/miogest_handler.go
index 6d3590c..4c56fe6 100644
--- a/apps/backend/miogest_handler.go
+++ b/apps/backend/miogest_handler.go
@@ -166,6 +166,7 @@ func (m *MiogestHandler) ParseAnnunci(codFilter string, imgPool *[]typesdefs.Med
 			}
 
 		} else {
+
 			// process only new or updated videos
 			video_codes_to_process, err = CodiciToProcessVideos(&annunci)
 			if err != nil {
diff --git a/apps/backend/video.go b/apps/backend/video.go
index dd4d78e..bfbb1ee 100644
--- a/apps/backend/video.go
+++ b/apps/backend/video.go
@@ -307,6 +307,10 @@ func CodiciToProcessVideos(annunci *typesdefs.AnnunciXML) ([]string, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to list bucket: %w", err)
 	}
+	fmt.Println("Current bucket state items:", len(currentBucketState))
+	for _, item := range currentBucketState {
+		fmt.Println(" - ", item.OriginalName, " (ID:", item.ID+")")
+	}
 	//make a list of bucket ids
 	bucketIdsMap := make(map[string]bool)
 	for _, item := range currentBucketState {
@@ -317,6 +321,10 @@ func CodiciToProcessVideos(annunci *typesdefs.AnnunciXML) ([]string, error) {
 	if err != nil {
 		return nil, err
 	}
+	fmt.Println("DB videos items:", len(db_videos))
+	for _, item := range db_videos {
+		fmt.Println(" - ", item.Video, " (Codice:", item.Codice+")")
+	}
 
 	dbVideosMap := make(map[string][]videRef) // Convert slice to map for faster lookup
 	for _, ref := range db_videos {
@@ -330,7 +338,18 @@ func CodiciToProcessVideos(annunci *typesdefs.AnnunciXML) ([]string, error) {
 	var codiciToProcess []string
 	for _, annuncio := range annunci.Annuncio {
 
-		if annuncio.Codice != nil && annuncio.AMMedias != nil {
+		if annuncio.Codice != nil && annuncio.AMMedias != nil && len(*annuncio.AMMedias) > 0 {
+			mediaUrls := []string{}
+			for _, media := range *annuncio.AMMedias {
+				if media.AMVideo != nil && media.AMVideo.Url != nil {
+					if strings.Contains(*media.AMVideo.Url, "video.miogest") {
+						mediaUrls = append(mediaUrls, *media.AMVideo.Url)
+					}
+				}
+			}
+			if len(mediaUrls) == 0 {
+				continue
+			}
 
 			refVideos, existsInDb := dbVideosMap[*annuncio.Codice]
 			if !existsInDb {