feat: add git garbage collector cronjob

Author: linsein

cmd/soft/serve/server.go

@@ -59,7 +59,11 @@ func NewServer(ctx context.Context) (*Server, error) {
 	// Add cron jobs.
 	sched := cron.NewScheduler(ctx)
 	for n, j := range jobs.List() {
-		id, err := sched.AddFunc(j.Runner.Spec(ctx), j.Runner.Func(ctx))
+		spec := j.Runner.Spec(ctx)
+		if spec == "" {
+			continue
+		}
+		id, err := sched.AddFunc(spec, j.Runner.Func(ctx))
 		if err != nil {
 			logger.Warn("error adding cron job", "job", n, "err", err)
 		}
@@ -183,7 +187,10 @@ func (s *Server) Shutdown(ctx context.Context) error {
 	})
 	errg.Go(func() error {
 		for _, j := range jobs.List() {
-			s.Cron.Remove(j.ID)
+			// jobID from github.com/robfig/cron/v2 starts from 1
+			if j.ID != 0 {
+				s.Cron.Remove(j.ID)
+			}
 		}
 		s.Cron.Stop()
 		return nil

pkg/config/config.go

@@ -137,6 +137,7 @@ type LFSConfig struct {
 // JobsConfig is the configuration for cron jobs.
 type JobsConfig struct {
 	MirrorPull string `env:"MIRROR_PULL" yaml:"mirror_pull"`
+	GitGC      string `env:"GIT_GC" yaml:"git_gc"`
 }
 
 // Config is the configuration for Soft Serve.

pkg/jobs/garbage_collector.go

@@ -0,0 +1,63 @@
+package jobs
+
+import (
+	"context"
+	"runtime"
+
+	"charm.land/log/v2"
+	"github.com/charmbracelet/soft-serve/git"
+	"github.com/charmbracelet/soft-serve/pkg/backend"
+	"github.com/charmbracelet/soft-serve/pkg/config"
+	"github.com/charmbracelet/soft-serve/pkg/sync"
+)
+
+func init() {
+	Register("git-gc", gitGC{})
+}
+
+type gitGC struct{}
+
+func (g gitGC) Spec(ctx context.Context) string {
+	cfg := config.FromContext(ctx)
+	if cfg.Jobs.GitGC != "" {
+		return cfg.Jobs.GitGC
+	}
+	return ""
+}
+
+func (g gitGC) Func(ctx context.Context) func() {
+	b := backend.FromContext(ctx)
+	logger := log.FromContext(ctx).WithPrefix("jobs.gitgc")
+	return func() {
+		repos, err := b.Repositories(ctx)
+		if err != nil {
+			logger.Error("error getting repositories", "err", err)
+			return
+		}
+
+		wq := sync.NewWorkPool(ctx, runtime.GOMAXPROCS(0),
+			sync.WithWorkPoolLogger(logger.Errorf),
+		)
+
+		logger.Debug("cleaning git garbage")
+		for _, repo := range repos {
+			r, err := repo.Open()
+			if err != nil {
+				logger.Error("error opening repository", "repo", repo.Name(), "err", err)
+				continue
+			}
+
+			name := repo.Name()
+			wq.Add(name, func() {
+				cmd := git.NewCommand("gc").WithContext(ctx)
+				if _, err := cmd.RunInDir(r.Path); err != nil {
+					logger.Error("error running git remote update", "repo", name, "err", err)
+				}
+
+			})
+
+			// TODO: clean up lfs
+		}
+
+	}
+}