gemma: pkg/controllers/system.go comparison

If the settings for sounding diffs are changed in a way that they need recalculation, flush the cache.

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Thu, 11 Jul 2019 18:54:22 +0200
parents	3fcc4e11fc00
children	49564382ffff

comparison

equal deleted inserted replaced

-:90496300311d
+:45be361f2d48
 package controllers
 import (
 	"bytes"
+	"context"
 	"database/sql"
 	"fmt"
 	"io/ioutil"
 	"log"
 	"net/http"
 	"strings"
 	"sync"
 	"github.com/gorilla/mux"
+	"gemma.intevation.de/gemma/pkg/auth"
 	"gemma.intevation.de/gemma/pkg/config"
 	"gemma.intevation.de/gemma/pkg/geoserver"
 	"gemma.intevation.de/gemma/pkg/models"
 )
 	updateSettingSQL = `
 INSERT INTO sys_admin.system_config (config_key, config_val)
 VALUES ($1, $2)
 ON CONFLICT (config_key) DO UPDATE SET config_val = $2`
+	deleteSoundingDiffsSQL = `
+DELETE FROM caching.sounding_differences`
 )
 // System status end points
 func showSystemLog(
 	registerReconfigureFunc("morphology_classbreaks_compare",
 		func(old sql.NullString, curr string) (func(), error) {
 			return reconfigureClassBreaks(
 				old, curr,
 				"sounding_differences",
-				func() {
+				func() { go deleteSoundingDiffs() })
-					log.Println(
-						"todo: Trigger expensive recalculation of sounding differences contours.")
-				})
 		})
+}
+func deleteSoundingDiffs() {
+	// TODO: Better do that in import queue?
+	ctx := context.Background()
+	if err := auth.RunAs(ctx, "sys_admin",
+		func(conn *sql.Conn) error {
+			_, err := conn.ExecContext(ctx, deleteSoundingDiffsSQL)
+			return err
+		},
+	); err != nil {
+		log.Printf("error: Cleaning sounding diffs cache failed: %v\n", err)
+	}
 }
 func setSystemSettings(
 	input interface{},
 	req *http.Request,

Mercurial > gemma