Purge old expired sessions

helpers/jobs.go

@@ -0,0 +1,30 @@
+package helpers
+
+import (
+	"time"
+)
+
+func RegisterJob(interval time.Duration, name string, job func(string) error) {
+	log := GetLogger()
+	log.Info(
+		"registering job",
+		"name", name,
+		"interval", interval,
+	)
+
+	for {
+		go func(job func(string) error, name string) {
+			log := GetLogger()
+			log.Info("starting job", "name", name)
+
+			err := job(name)
+			if err != nil {
+				log.Error(err, "job", name)
+			}
+
+			log.Info("job finished", "name", name)
+		}(job, name)
+
+		time.Sleep(interval)
+	}
+}