feat(mysql): check-instance-info-file-mtime #14259

Author: xfwduke

dbm-services/mysql/db-tools/mysql-monitor/pkg/itemscollect/update_monitor_config/init.go

@@ -6,12 +6,14 @@ import (
 	acst "dbm-services/mysql/db-tools/dbactuator/pkg/core/cst"
 	"dbm-services/mysql/db-tools/mysql-monitor/pkg/config"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"io"
 	"log/slog"
 	"os"
 	"path/filepath"
 	"slices"
+	"time"
 
 	"github.com/gofrs/flock"
 	"github.com/spf13/viper"
@@ -24,6 +26,12 @@ type Checker struct {
 }
 
 func (c *Checker) Run() (msg string, err error) {
+	err = checkOutOfDate()
+	if err != nil {
+		slog.Error("check out of date", slog.String("err", err.Error()))
+		return "", err
+	}
+
 	sii, err := c.getSelfInfo()
 	if err != nil {
 		slog.Error("get self info failed", slog.String("err", err.Error()))
@@ -39,6 +47,25 @@ func (c *Checker) Run() (msg string, err error) {
 	return "", nil
 }
 
+func checkOutOfDate() (err error) {
+	for _, fn := range []string{
+		define.DefaultInstanceInfoFileName,
+		define.DefaultNginxProxyAddrsFileName,
+	} {
+		fp := filepath.Join(define.DefaultCommonConfigDir, fn)
+		st, e := os.Stat(fp)
+		if e != nil {
+			errors.Join(err, e)
+		}
+
+		mtime := st.ModTime()
+		if mtime.Before(time.Now().Add(-24 * time.Hour)) {
+			errors.Join(err, fmt.Errorf("%s is out of date", fn))
+		}
+	}
+	return
+}
+
 func (c *Checker) updateConfigFile(sii *mysql.StorageInstanceInfo) (err error) {
 	configFilePath := viper.GetString("hard-run-config")
 	if !filepath.IsAbs(configFilePath) {
@@ -87,7 +114,6 @@ func (c *Checker) updateConfigFile(sii *mysql.StorageInstanceInfo) (err error) {
 	slog.Info(name, slog.Any("monitor config before", config.MonitorConfig))
 	config.MonitorConfig.Role = &sii.InstanceInnerRole
 	slog.Info(name, slog.Any("monitor config after", config.MonitorConfig))
-	//config.MonitorConfig.ImmuteDomain = sii.ImmuteDomain
 
 	b, err := yaml.Marshal(config.MonitorConfig)
 	if err != nil {
@@ -148,9 +174,11 @@ func (c *Checker) getSelfInfo() (sii *mysql.StorageInstanceInfo, err error) {
 		return nil, err
 	}
 
-	idx := slices.IndexFunc(siis, func(ele mysql.StorageInstanceInfo) bool {
-		return ele.Ip == config.MonitorConfig.Ip && ele.Port == config.MonitorConfig.Port
-	})
+	idx := slices.IndexFunc(
+		siis, func(ele mysql.StorageInstanceInfo) bool {
+			return ele.Ip == config.MonitorConfig.Ip && ele.Port == config.MonitorConfig.Port
+		},
+	)
 	if idx < 0 {
 		err := fmt.Errorf("can't find %s:%d in %v", config.MonitorConfig.Ip, config.MonitorConfig.Port, siis)
 		slog.Error(