run entity collection not on request but on intervals

Author: zachmann

docs/config/federation.md

@@ -286,3 +286,20 @@ It is generally more performant to rely on an external endpoint.
         use_entity_collection_endpoint: true
     ```
 
+
+## `entity_collection_interval`
+<span class="badge badge-purple" title="Value Type">integer</span>
+<span class="badge badge-blue" title="Default Value">5</span>
+<span class="badge badge-green" title="If this option is required or optional">optional</span>
+
+The `entity_collection_interval` option defines in which interval OFFA will 
+query the Entity Collection Endpoint or do entity collection on its own. The 
+time is given in minutes!
+
+??? file "config.yaml"
+
+    ```yaml
+    federation:
+        entity_collection_interval: 60
+    ```
+

internal/config/config.go

@@ -44,6 +44,7 @@ type federationConf struct {
 	TrustMarks                  []*pkg.EntityConfigurationTrustMarkConfig `yaml:"trust_marks"`
 	UseResolveEndpoint          bool                                      `yaml:"use_resolve_endpoint"`
 	UseEntityCollectionEndpoint bool                                      `yaml:"use_entity_collection_endpoint"`
+	EntityCollectionInterval    int64                                     `yaml:"entity_collection_interval"`
 }
 
 type sessionConf struct {
@@ -287,7 +288,10 @@ func MustLoadConfig() {
 			TTL:        3600,
 			CookieName: "offa-session",
 		},
-		Federation: federationConf{ClientName: "OFFA - Openid Federation Forward Auth"},
+		Federation: federationConf{
+			ClientName:               "OFFA - Openid Federation Forward Auth",
+			EntityCollectionInterval: 5,
+		},
 	}
 	if err := yaml.Unmarshal(data, conf); err != nil {
 		log.Fatal(err)

internal/server/login.go

@@ -36,7 +36,21 @@ func addLoginHandlers(s fiber.Router) {
 	s.Get("/redirect", codeExchange)
 }
 
-func showLoginPage(c *fiber.Ctx) error {
+var opOptions string
+
+func scheduleBuildOPOptions() {
+	ticker := time.NewTicker(time.Duration(config.Get().Federation.EntityCollectionInterval) * time.Minute) // Replace 5 with your desired interval
+
+	go buildOPOptions()
+
+	go func() {
+		for range ticker.C {
+			buildOPOptions()
+		}
+	}()
+}
+
+func buildOPOptions() {
 	const opOptionFmt = `<option value="%s">%s</option>`
 	var options string
 	filters := []pkg.EntityCollectionFilter{}
@@ -70,12 +84,16 @@ func showLoginPage(c *fiber.Ctx) error {
 			),
 		)
 	}
+	opOptions = options
+}
+
+func showLoginPage(c *fiber.Ctx) error {
 	var img string
 	if config.Get().Federation.LogoURI != "" {
 		img = fmt.Sprintf(`<img src="%s" alt="%s" class="logo"/>`, config.Get().Federation.LogoURI, "Logo")
 	}
 	c.Set(fiber.HeaderContentType, fiber.MIMETextHTML)
-	return c.SendString(fmt.Sprintf(loginHtml, config.Get().Federation.ClientName, img, options, c.Query("next")))
+	return c.SendString(fmt.Sprintf(loginHtml, config.Get().Federation.ClientName, img, opOptions, c.Query("next")))
 }
 
 type stateData struct {

internal/server/server.go

@@ -34,6 +34,7 @@ var fullLoginPath string
 
 // Init initializes the server
 func Init() {
+	scheduleBuildOPOptions()
 	initHtmls()
 	initFederationEntity()
 	server = fiber.New(serverConfig)