Compare commits

...

2 Commits

Author SHA1 Message Date
e9152da3a9 Update 2025-06-27 18:49:14 +02:00
425b5edbcf Ensure command exists before trying to run 2025-06-27 18:42:16 +02:00
2 changed files with 20 additions and 3 deletions

Binary file not shown.

View File

@@ -103,13 +103,29 @@ func loadCronJobs() error {
cronExpr := strings.Join(fields[0:5], " ") cronExpr := strings.Join(fields[0:5], " ")
cmdStr := strings.Join(fields[5:], " ") cmdStr := strings.Join(fields[5:], " ")
cmdStr, err = filepath.Abs(cmdStr)
if err != nil {
logger.Error("Failed to find command: %s", cmdStr)
continue
}
cmdStr = filepath.Clean(cmdStr)
file, err := os.OpenFile(cmdStr, os.O_RDONLY, 0644)
if err != nil {
logger.Error("Failed to find command: %s", cmdStr)
continue
}
file.Close()
logger.Info("Adding cron job: %s -> %s", cronExpr, cmdStr)
job := CronJob{ job := CronJob{
Cron: cronExpr, Cron: cronExpr,
Command: cmdStr, Command: cmdStr,
} }
// Add the job to cron // Add the job to cron
_, err := cronRunner.AddFunc(job.Cron, createJobFunc(job)) _, err = cronRunner.AddFunc(job.Cron, createJobFunc(job))
if err != nil { if err != nil {
logger.Error("Failed to add cron job %+v: %v", job, err) logger.Error("Failed to add cron job %+v: %v", job, err)
continue continue
@@ -124,6 +140,7 @@ func loadCronJobs() error {
func createJobFunc(job CronJob) func() { func createJobFunc(job CronJob) func() {
return func() { return func() {
logger.Info("Executing command: %s", job.Command)
cmd := exec.Command(job.Command) cmd := exec.Command(job.Command)
output, err := cmd.CombinedOutput() output, err := cmd.CombinedOutput()
if err != nil { if err != nil {