Compare commits
2 Commits
05cc242ee5
...
c06b046df5
Author | SHA1 | Date | |
---|---|---|---|
c06b046df5 | |||
912eaeff7d |
@ -4,6 +4,7 @@ package scheduler
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"sync"
|
||||
"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 {
|
||||
return
|
||||
}
|
||||
|
||||
// Move the file to the archive directory
|
||||
archivePath := filepath.Join(botArchiveDir, filepath.Base(contentPath))
|
||||
if err := utils.MoveFile(contentPath, archivePath); err != nil {
|
||||
s.logger.Error("Failed to archive file",
|
||||
|
||||
// Delete the file after successful posting to save space
|
||||
if err := os.Remove(contentPath); err != nil {
|
||||
s.logger.Error("Failed to delete file after posting",
|
||||
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
|
||||
|
Loading…
x
Reference in New Issue
Block a user