mirrors/ghorg
1
0
Fork 0
mirror of https://github.com/gabrie30/ghorg.git synced 2026-05-05 11:56:09 +02:00
Code Issues Projects Releases Wiki Activity

Update reclone-cron.go (#542)

Browse Source
This commit is contained in:
gabrie30 2025-07-02 07:44:17 -07:00 committed by GitHub
parent f4b6a44386
commit ff25dc27c0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 38 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
cmd/reclone-cron.go
View File

@ -2,16 +2,21 @@ package cmd
import (
_ "embed"
"log"
"os"
"os/exec"
"strconv"
"sync"
"time"
"github.com/gabrie30/ghorg/colorlog"
"github.com/spf13/cobra"
)
var (
recloneRunning bool
recloneMutex sync.Mutex
)
var recloneCronCmd = &cobra.Command{
Use: "reclone-cron",
Short: "Simple cron that will trigger your reclone command at a specified minute intervals indefinitely",
@ -26,27 +31,52 @@ var recloneCronCmd = &cobra.Command{
}
func startReCloneCron() {
if os.Getenv("GHORG_CRON_TIMER_MINUTES") == "" {
cronTimer := os.Getenv("GHORG_CRON_TIMER_MINUTES")
if cronTimer == "" {
colorlog.PrintInfo("GHORG_CRON_TIMER_MINUTES is not set. Cron job will not start.")
return
}
colorlog.PrintInfo("Cron activated and will first run after " + os.Getenv("GHORG_CRON_TIMER_MINUTES") + " minutes ")
minutes, err := strconv.Atoi(os.Getenv("GHORG_CRON_TIMER_MINUTES"))
colorlog.PrintInfo("Cron activated and will first run after " + cronTimer + " minutes ")
minutes, err := strconv.Atoi(cronTimer)
if err != nil {
log.Fatalf("Invalid GHORG_CRON_TIMER_MINUTES: %v", err)
colorlog.PrintError("Invalid GHORG_CRON_TIMER_MINUTES: " + cronTimer)
return
}
ticker := time.NewTicker(time.Duration(minutes) * time.Minute)
defer ticker.Stop()
for range ticker.C {
colorlog.PrintInfo("starting reclone cron, time: " + time.Now().Format(time.RFC1123))
recloneMutex.Lock()
if recloneRunning {
recloneMutex.Unlock()
continue
}
recloneRunning = true
recloneMutex.Unlock()
colorlog.PrintInfo("Starting reclone cron, time: " + time.Now().Format(time.RFC1123))
cmd := exec.Command("ghorg", "reclone")
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
if err := cmd.Run(); err != nil {
log.Printf("Failed to run ghorg reclone: %v", err)
if err := cmd.Start(); err != nil {
colorlog.PrintError("Failed to start ghorg reclone: " + err.Error())
recloneMutex.Lock()
recloneRunning = false
recloneMutex.Unlock()
continue
}
go func() {
if err := cmd.Wait(); err != nil {
colorlog.PrintError("ghorg reclone command failed: " + err.Error())
}
recloneMutex.Lock()
recloneRunning = false
recloneMutex.Unlock()
}()
}
}