ensure that changed config reloads seeding cap enforcement

Author: FlorianSW

seeding/automod.go

@@ -12,6 +12,7 @@ import (
 	"seeding/internal/crcon"
 	"strconv"
 	"syscall"
+	"time"
 )
 
 var (
@@ -33,6 +34,10 @@ var (
 	horizontalCaps = []string{"A", "B", "C", "D", "E", "F", "G", "H", "I", "J"}
 )
 
+type CRConClient interface {
+	GetAutoModSeedingConfig(ctx context.Context) (*crcon.AutoModSeedingConfig, error)
+}
+
 func main() {
 	level := slog.LevelInfo
 	if _, ok := os.LookupEnv("DEBUG"); ok {
@@ -45,14 +50,52 @@ func main() {
 		rconBackendUrl = "http://backend:8000"
 	}
 
-	ctx := context.Background()
+	ctx, cancel := context.WithCancel(context.Background())
 	a := internal.NewAuthentication(hllPassword, rconWebApiSecret)
-	ac, err := crcon.NewClient(rconBackendUrl, a).GetAutoModSeedingConfig(ctx)
-	if err != nil {
-		logger.Error("find-seeding-automod-config", "error", err)
-		return
+	c := crcon.NewClient(rconBackendUrl, a)
+
+	go scheduleWorker(ctx, logger, c)
+
+	stop := make(chan os.Signal, 1)
+	signal.Notify(stop, os.Interrupt, syscall.SIGTERM)
+	<-stop
+
+	logger.Info("graceful-shutdown")
+	cancel()
+}
+
+func scheduleWorker(ctx context.Context, logger *slog.Logger, c CRConClient) {
+	refreshConfig := time.NewTicker(time.Second * 5)
+
+	var (
+		childCtx, cancelFn = context.WithCancel(ctx)
+		previous           *crcon.AutoModSeedingConfig
+	)
+	for {
+		select {
+		case <-ctx.Done():
+			refreshConfig.Stop()
+			cancelFn()
+			return
+		case <-refreshConfig.C:
+			ac, err := c.GetAutoModSeedingConfig(childCtx)
+			if err != nil {
+				logger.Error("find-seeding-automod-config", "error", err)
+				continue
+			}
+			if ac.Equals(previous) {
+				continue
+			}
+			logger.Info("config-updated-restart")
+			cancelFn()
+			previous = ac
+			childCtx, cancelFn = context.WithCancel(ctx)
+			initialize(childCtx, logger, ac)
+		}
 	}
+}
 
+func initialize(ctx context.Context, logger *slog.Logger, ac *crcon.AutoModSeedingConfig) {
 	// Prefilling fences for first-spawners on the server. Whenever a player joins a server, they are randomly assigned
 	// a spawn on either side (even before side selection). To not give them a warning that they are outside of the spawns
 	// during seeding, the HQ lines for each team opponent are allowlisted as well.
@@ -241,10 +284,4 @@ func main() {
 		go w.Run(ctx)
 		logger.Info("started-worker")
 	}
-
-	stop := make(chan os.Signal, 1)
-	signal.Notify(stop, os.Interrupt, syscall.SIGTERM)
-	<-stop
-
-	logger.Info("graceful-shutdown")
 }

seeding/go.mod

@@ -4,7 +4,7 @@ go 1.24.1
 
 require (
 	github.com/floriansw/go-hll-rcon v0.0.0-20250421114312-973708b529c4
-	github.com/floriansw/hll-geofences v0.0.0-20250424221049-a62713ee5a0c
+	github.com/floriansw/hll-geofences v0.0.0-20250425215853-4c30cf65a19f
 )
 
 require gopkg.in/yaml.v3 v3.0.1 // indirect

seeding/go.sum

@@ -1,7 +1,7 @@
 github.com/floriansw/go-hll-rcon v0.0.0-20250421114312-973708b529c4 h1:GVl9QM8D0XVfACR9yoPr1fjSF3A/j58i5W8BIFOIW2M=
 github.com/floriansw/go-hll-rcon v0.0.0-20250421114312-973708b529c4/go.mod h1:ICGqIYtkRM6GJv6oBwbskUIWq5Ar4C1SNxXBPdGYgDw=
-github.com/floriansw/hll-geofences v0.0.0-20250424221049-a62713ee5a0c h1:8F3PjoYJU9ZKO+OvioJxNip26oqu7EYldtM8orDn6JQ=
-github.com/floriansw/hll-geofences v0.0.0-20250424221049-a62713ee5a0c/go.mod h1:dZb6SSJb0bL4ijBW7TYYS0YUK42haOGgwXyWxcrI45o=
+github.com/floriansw/hll-geofences v0.0.0-20250425215853-4c30cf65a19f h1:MxlhdCkj7X0bA2nQ33OyJV9tDhL5fbm7Tzl46yeVuNs=
+github.com/floriansw/hll-geofences v0.0.0-20250425215853-4c30cf65a19f/go.mod h1:dZb6SSJb0bL4ijBW7TYYS0YUK42haOGgwXyWxcrI45o=
 github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4=
 github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=

seeding/internal/crcon/data.go

@@ -6,10 +6,28 @@ type AutoModSeedingConfig struct {
 	EnforceCapFight EnforceCapFight
 }
 
+func (c *AutoModSeedingConfig) Equals(o *AutoModSeedingConfig) bool {
+	if o == nil {
+		return false
+	}
+	if c.Enabled != o.Enabled || c.DryRun != o.DryRun || !c.EnforceCapFight.Equals(o.EnforceCapFight) {
+		return false
+	}
+	return true
+}
+
 type EnforceCapFight struct {
 	MinPlayers       int
 	MaxPlayers       int
 	MaxCaps          int
 	SkipWarning      bool
 	ViolationMessage string
 }
+
+func (c *EnforceCapFight) Equals(o EnforceCapFight) bool {
+	return c.MinPlayers == o.MinPlayers ||
+		c.MaxPlayers == o.MaxPlayers ||
+		c.MaxCaps == o.MaxCaps ||
+		c.SkipWarning == o.SkipWarning ||
+		c.ViolationMessage == o.ViolationMessage
+}

seeding/vendor/github.com/floriansw/hll-geofences/worker/worker.go

@@ -3,7 +3,7 @@
 github.com/floriansw/go-hll-rcon/rcon
 github.com/floriansw/go-hll-rcon/rconv2
 github.com/floriansw/go-hll-rcon/rconv2/api
-# github.com/floriansw/hll-geofences v0.0.0-20250424221049-a62713ee5a0c
+# github.com/floriansw/hll-geofences v0.0.0-20250425215853-4c30cf65a19f
 ## explicit; go 1.24.1
 github.com/floriansw/hll-geofences/data
 github.com/floriansw/hll-geofences/worker