Fix the supabase image storage issue

Author: F0xhopper

backend/cmd/bot/main.go

@@ -33,6 +33,7 @@ func corsMiddleware(next http.Handler) http.Handler {
 
 func main() {
 	cfg, err := config.LoadConfig()
+	
 	if err != nil {
 		log.Fatalf("Error loading config: %v", err)
 	}

backend/internal/content/service.go

@@ -7,11 +7,13 @@ import (
 	"io"
 	"log"
 	"mime/multipart"
+	"strings"
 	"time"
 
 	"novissima/internal/logging"
 
 	"github.com/google/uuid"
+	storage_go "github.com/supabase-community/storage-go"
 	"github.com/supabase-community/supabase-go"
 )
 
@@ -57,13 +59,39 @@ func (s *Service) AddContent(contentEnglish string, contentLatin string, file mu
 	if file != nil && header != nil {
 		defer file.Close()
 
-		filename := fmt.Sprintf("%s/%s", theme, header.Filename)
+			fileExt := ""
+		if idx := strings.LastIndex(header.Filename, "."); idx != -1 {
+			fileExt = header.Filename[idx:]
+		}
+		filename := fmt.Sprintf("%s/%s%s", theme, uuid.New().String(), fileExt)
+		
 		fileBytes, err := io.ReadAll(file)
 		if err != nil {
 			return Content{}, fmt.Errorf("failed to read file: %w", err)
-}
+		}
 
-		_, err = s.dbClient.Storage.UploadFile(s.bucketName, filename, bytes.NewReader(fileBytes))
+		
+		fileReader := bytes.NewReader(fileBytes)
+		
+		
+		contentType := header.Header.Get("Content-Type")
+		if contentType == "" {
+			switch fileExt {
+			case ".jpg", ".jpeg":
+				contentType = "image/jpeg"
+			case ".png":
+				contentType = "image/png"
+			case ".gif":
+				contentType = "image/gif"
+			default:
+				contentType = "application/octet-stream"
+			}
+		}
+		
+		fileOptions := storage_go.FileOptions{
+			ContentType: &contentType,
+		}
+		_, err = s.dbClient.Storage.UploadFile(s.bucketName, filename, fileReader, fileOptions)
 		if err != nil {
 			return Content{}, fmt.Errorf("failed to upload to storage: %w", err)
 		}
@@ -94,7 +122,7 @@ func (s *Service) AddContent(contentEnglish string, contentLatin string, file mu
 }
 
 func (s *Service) GetDailyContent() (*Content, error) {
-	themes := []string{"heaven", "hell", "judgment", "death"}
+	themes := []string{ "death"}
 	startDate := time.Date(2025, 7, 1, 0, 0, 0, 0, time.UTC)
 
 	now := time.Now()
@@ -103,13 +131,11 @@ func (s *Service) GetDailyContent() (*Content, error) {
 
 	currentTheme := themes[cycleDay]
 
-	thirtyDaysAgo := now.AddDate(0, 0, -30)
+	// thirtyDaysAgo := now.AddDate(0, 0, -30)
 
 	content, _, err := s.dbClient.From("content").
 		Select("*", "", false).
 		Eq("theme", currentTheme).
-		Or("last_sent.is.null", "").
-		Or("last_sent.lt."+thirtyDaysAgo.Format("2006-01-02"), "").
 		Limit(1, "").
 		Execute()
 	if err != nil {

backend/internal/scheduler/scheduler.go

@@ -26,7 +26,7 @@ func NewService(contentService *content.Service, twilioService *twilio.Service,
 func (s *Service) Start() {
 	c := cron.New()
 
-	c.AddFunc("0 8 * * *", func() {
+	c.AddFunc("*/2 * * * *", func() {
 		log.Println("Starting daily content distribution...")
 
 		content, err := s.contentService.GetDailyContent()
@@ -37,7 +37,7 @@ func (s *Service) Start() {
 
 		err = s.twilioService.SendMessageToAllUsers(content)
 		if err != nil {
-			log.Printf("Failed to send daily content: %v", err)
+			log.Printf("Failed to send daidly content: %v", err)
 			return
 		}
 		log.Println("Daily content sent to all users successfully")

backend/internal/twilio/service.go

@@ -4,6 +4,7 @@ import (
 	"crypto/hmac"
 	"crypto/sha1"
 	"encoding/base64"
+	"encoding/json"
 	"fmt"
 	"log"
 	"net/http"
@@ -39,10 +40,23 @@ func (s *Service) SendMessageToUser(phoneNumber, message string, mediaUrl string
 	params := &twilioApi.CreateMessageParams{}
 	params.SetTo("whatsapp:" + phoneNumber)
 	params.SetFrom("whatsapp:" + s.client.phoneNumber)
-	params.SetBody(message)
-	params.SetMediaUrl([]string{mediaUrl})
+	params.SetContentSid("HXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX")
+	
+	contentVariables := map[string]string{
+		"1": message,
+		"2": mediaUrl,
+		}
+	
+	variablesJSON, _ := json.Marshal(contentVariables)
+	params.SetContentVariables(string(variablesJSON))
+
+	twilioMessage, err := s.client.twilioClient.Api.CreateMessage(params)
+	if err != nil {
+		return err
+	}
+	jsonMsg, _ := json.MarshalIndent(twilioMessage, "", "  ")
+	log.Printf("Twilio message: %s", jsonMsg)
 
-	_, err := s.client.twilioClient.Api.CreateMessage(params)
 	return err
 }
 

frontend/src/app/upload/page.tsx

@@ -88,8 +88,8 @@ export default function UploadPage() {
   };
 
   return (
-    <div className="min-h-screen p-8">
-      <div className="max-w-2xl mx-auto">
+    <div className="min-h-screen flex justify-center items-center flex-col">
+      <div className="max-w-2xl mx-auto w-full">
         <Card>
           <CardHeader>
             <CardTitle>Upload Content</CardTitle>