Compare commits

...

2 Commits

Author SHA1 Message Date
c06b046df5 Merge branch 'main' of https://git.sovbit.dev/Enki/nostr-poster 2025-05-12 09:58:27 -07:00
912eaeff7d file nuke on post update 2025-05-12 09:58:04 -07:00

View File

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