internal/scheduler/scheduler.go

@@ -4,7 +4,6 @@ package scheduler
 import (
 	"context"
 	"fmt"
-	"os"
 	"path/filepath"
 	"sync"
 	"encoding/json"
@@ -463,23 +462,21 @@ func (s *Scheduler) ScheduleBot(bot *models.Bot) error {
 			}
 		}
 		
-		// If posting failed, return without removing the file
+		// If posting failed, return without archiving the file
 		if postErr != nil {
 			return
 		}
 		
-		// Delete the file after successful posting to save space
+		// Move the file to the archive directory
-		if err := os.Remove(contentPath); err != nil {
+		archivePath := filepath.Join(botArchiveDir, filepath.Base(contentPath))
-			s.logger.Error("Failed to delete file after posting",
+		if err := utils.MoveFile(contentPath, archivePath); err != nil {
+			s.logger.Error("Failed to archive file",
 				zap.Int64("bot_id", bot.ID),
 				zap.String("file", contentPath),
+				zap.String("archive", archivePath),
 				zap.Error(err))
 			return
 		}
-
-		s.logger.Info("Successfully deleted file after posting",
-			zap.Int64("bot_id", bot.ID),
-			zap.String("file", contentPath))
 	}
 	
 	// Schedule the job