Ìmprove handling of multiple rapid file changes

Makefile

@@ -26,13 +26,9 @@ package:
 	go clean
 	rm -rf ./_out/*
 
-	GOARCH=386   GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-386-static                                      ./cmd/cli  # Linux - 32 bit
+	GOARCH=386   GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-386-static    ./cmd/cli  # Linux - 32 bit
-	GOARCH=amd64 GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-amd64-static                                    ./cmd/cli  # Linux - 64 bit
+	GOARCH=amd64 GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-amd64-static  ./cmd/cli  # Linux - 64 bit
-	GOARCH=arm64 GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-arm64-static                                    ./cmd/cli  # Linux - ARM
+	GOARCH=arm64 GOOS=linux   CGO_ENABLED=0 go build -o _out/kpsync_linux-arm64-static  ./cmd/cli  # Linux - ARM
-	GOARCH=386   GOOS=linux                 go build -o _out/kpsync_linux-386                                             ./cmd/cli  # Linux - 32 bit
+	GOARCH=386   GOOS=linux                 go build -o _out/kpsync_linux-386           ./cmd/cli  # Linux - 32 bit
-	GOARCH=amd64 GOOS=linux                 go build -o _out/kpsync_linux-amd64                                           ./cmd/cli  # Linux - 64 bit
+	GOARCH=amd64 GOOS=linux                 go build -o _out/kpsync_linux-amd64         ./cmd/cli  # Linux - 64 bit
-	GOARCH=arm64 GOOS=linux                 go build -o _out/kpsync_linux-arm64                                           ./cmd/cli  # Linux - ARM
+	GOARCH=arm64 GOOS=linux                 go build -o _out/kpsync_linux-arm64         ./cmd/cli  # Linux - ARM
-	GOARCH=amd64 GOOS=openbsd               go build -o _out/kpsync_openbsd-amd64                                         ./cmd/cli  # OpenBSD - 64 bit
-	GOARCH=arm64 GOOS=openbsd               go build -o _out/kpsync_openbsd-arm64                                         ./cmd/cli  # OpenBSD - ARM
-	GOARCH=amd64 GOOS=freebsd               go build -o _out/kpsync_freebsd-amd64                                         ./cmd/cli  # FreeBSD - 64 bit
-	GOARCH=arm64 GOOS=freebsd               go build -o _out/kpsync_freebsd-arm64                                         ./cmd/cli  # FreeBSD - ARM

README.md

@@ -8,13 +8,14 @@ A small util to launch keepassXC while the database file is on a remote webDAV s
 1. simply start `kpsync`
 2. On first start a example config in `~/.config/kpsync.json` will be created, probably needs to be edited
 3. Afterwards start it again
+4. You can access the logs, functionality, state etc via the tray icon
 
 # Functionality
 
 kpsync starts by downloading the latest db file from the webDAV to the (configured) temp directory  
 (if there already exists a local file, matching with the server version (via ETag), the download will be skipped)
 
-If teh download fails, teh user gets the option to open a local (fallback) file (e.g. if the computer has no network)
+If the download fails, the user gets the option to open a local (fallback) file (e.g. if the computer has no network)
 
 Then KeepassXC is launched.
 
@@ -42,4 +43,8 @@ Needs `keepassxc` to be installed. duh.
     "debounce":          3500,
     "terminal_emulator": "konsole -e"
 }
-```
+```
+
+# Screenshot
+
+<img width="539" height="406" alt="image" src="https://github.com/user-attachments/assets/283ec720-d45d-412a-9be4-b92e9008c9ee" />

app/application.go

@@ -1,6 +1,7 @@
 package app
 
 import (
+	"errors"
 	"fmt"
 	"os"
 	"os/signal"
@@ -11,6 +12,8 @@ import (
 
 	"fyne.io/systray"
 	"git.blackforestbytes.com/BlackForestBytes/goext/dataext"
+	"git.blackforestbytes.com/BlackForestBytes/goext/langext"
+	"git.blackforestbytes.com/BlackForestBytes/goext/mathext"
 	"git.blackforestbytes.com/BlackForestBytes/goext/syncext"
 	"git.blackforestbytes.com/BlackForestBytes/goext/termext"
 	"git.blackforestbytes.com/BlackForestBytes/goext/timeext"
@@ -28,7 +31,8 @@ type Application struct {
 	config Config
 
 	trayReady       *syncext.AtomicBool
-	uploadRunning   *syncext.AtomicBool
+	uploadWaiting   *syncext.AtomicBool
+	uploadActive    *syncext.AtomicBool
 	syncLoopRunning *syncext.AtomicBool
 	keepassRunning  *syncext.AtomicBool
 
@@ -46,6 +50,8 @@ type Application struct {
 
 	currSysTrayTooltip string
 
+	uploadDCI *dataext.DelayedCombiningInvoker
+
 	trayItemChecksum     *systray.MenuItem
 	trayItemETag         *systray.MenuItem
 	trayItemLastModified *systray.MenuItem
@@ -58,7 +64,8 @@ func NewApplication() *Application {
 		logLock:             sync.Mutex{},
 		logList:             make([]LogMessage, 0, 1024),
 		logBroadcaster:      dataext.NewPubSub[string, LogMessage](128),
-		uploadRunning:       syncext.NewAtomicBool(false),
+		uploadWaiting:       syncext.NewAtomicBool(false),
+		uploadActive:        syncext.NewAtomicBool(false),
 		trayReady:           syncext.NewAtomicBool(false),
 		syncLoopRunning:     syncext.NewAtomicBool(false),
 		keepassRunning:      syncext.NewAtomicBool(false),
@@ -89,7 +96,7 @@ func (app *Application) Run() {
 	app.LogDebug(fmt.Sprintf("WebDAVURL     := '%s'", app.config.WebDAVURL))
 	app.LogDebug(fmt.Sprintf("WebDAVUser    := '%s'", app.config.WebDAVUser))
 	app.LogDebug(fmt.Sprintf("WebDAVPass    := '%s'", app.config.WebDAVPass))
-	app.LogDebug(fmt.Sprintf("LocalFallback := '%s'", app.config.LocalFallback))
+	app.LogDebug(fmt.Sprintf("LocalFallback := '%s'", langext.Coalesce(app.config.LocalFallback, "<null>")))
 	app.LogDebug(fmt.Sprintf("WorkDir       := '%s'", app.config.WorkDir))
 	app.LogDebug(fmt.Sprintf("Debounce      := %d ms", app.config.Debounce))
 	app.LogDebug(fmt.Sprintf("ForceColors   := %v", app.config.ForceColors))
@@ -108,6 +115,22 @@ func (app *Application) Run() {
 
 	go func() { app.initTray() }()
 
+	if app.config.LocalFallback != nil {
+		if _, err := os.Stat(*app.config.LocalFallback); errors.Is(err, os.ErrNotExist) {
+			app.config.LocalFallback = nil
+
+			app.LogError(fmt.Sprintf("Configured local-fallback '%s' not found - disabling.", *app.config.LocalFallback), nil)
+
+			app.showErrorNotification("Local fallback database not found", fmt.Sprintf("Configured local-fallback '%s' not found - fallback option won't be available.", *app.config.LocalFallback))
+		}
+	}
+
+	debounce := timeext.FromMilliseconds(app.config.Debounce)
+	app.uploadDCI = dataext.NewDelayedCombiningInvoker(app.runDBUpload, debounce, mathext.Max(45*time.Second, debounce*3))
+
+	app.uploadDCI.RegisterOnRequest(func(_ int, _ bool) { app.uploadWaiting.Set(app.uploadDCI.HasPendingRequests()) })
+	app.uploadDCI.RegisterOnExecutionDone(func() { app.uploadWaiting.Set(app.uploadDCI.HasPendingRequests()) })
+
 	go func() {
 		app.syncLoopRunning.Set(true)
 		defer app.syncLoopRunning.Set(false)
@@ -140,10 +163,10 @@ func (app *Application) Run() {
 				return
 			}
 
-		} else if isr == InitSyncResponseFallback {
+		} else if isr == InitSyncResponseFallback && app.config.LocalFallback != nil {
 
 			app.LogInfo(fmt.Sprintf("Starting KeepassXC with local fallback database (without sync loop!)"))
-			app.LogDebug(fmt.Sprintf("DB-Path := '%s'", app.config.LocalFallback))
+			app.LogDebug(fmt.Sprintf("DB-Path := '%s'", *app.config.LocalFallback))
 
 			go func() {
 				app.keepassRunning.Set(true)
@@ -215,9 +238,14 @@ func (app *Application) stopBackgroundRoutines() {
 	app.trayReady.Wait(false)
 	app.LogDebug("Stopped systray.")
 
-	if app.uploadRunning.Get() {
+	if app.uploadWaiting.Get() {
+		app.LogInfo("Triggering pending upload immediately...")
+		app.uploadDCI.ExecuteNow()
+	}
+
+	if app.uploadActive.Get() {
 		app.LogInfo("Waiting for active upload...")
-		app.uploadRunning.Wait(false)
+		app.uploadActive.Wait(false)
 		app.LogInfo("Upload finished.")
 	}
 

app/config.go

@@ -16,7 +16,7 @@ type Config struct {
 	WebDAVUser string `json:"webdav_user"`
 	WebDAVPass string `json:"webdav_pass"`
 
-	LocalFallback string `json:"local_fallback"`
+	LocalFallback *string `json:"local_fallback"`
 
 	WorkDir string `json:"work_dir"`
 
@@ -85,7 +85,7 @@ func (app *Application) loadConfig() (Config, string) {
 			WebDAVURL:        "https://your-nextcloud-domain.example/remote.php/dav/files/keepass.kdbx",
 			WebDAVUser:       "",
 			WebDAVPass:       "",
-			LocalFallback:    "",
+			LocalFallback:    nil,
 			WorkDir:          "/tmp/kpsync",
 			Debounce:         3500,
 			ForceColors:      false,
@@ -114,7 +114,7 @@ func (app *Application) loadConfig() (Config, string) {
 		cfg.WebDAVPass = webdavPass
 	}
 	if localFallback != "" {
-		cfg.LocalFallback = localFallback
+		cfg.LocalFallback = &localFallback
 	}
 	if workDir != "" {
 		cfg.WorkDir = workDir

app/logger.go

@@ -60,10 +60,12 @@ func (app *Application) LogDebug(msg string) {
 	app.logInternal("[D]", msg, termext.Gray)
 }
 
-func (app *Application) logInternal(pf string, msg string, c func(_ string) string) {
+func (app *Application) logInternal(pf string, msg string, cf func(_ string) string) {
 	app.logLock.Lock()
 	defer app.logLock.Unlock()
 
+	c := cf
+
 	if !termext.SupportsColors() && !app.config.ForceColors {
 		c = func(s string) string { return s }
 	}
@@ -71,24 +73,24 @@ func (app *Application) logInternal(pf string, msg string, c func(_ string) stri
 	for i, s := range strings.Split(msg, "\n") {
 		if i == 0 {
 			println(c(pf + " " + s))
-			app.logList = append(app.logList, LogMessage{i, pf, s, c})
+			app.logList = append(app.logList, LogMessage{i, pf, s, cf})
 			if app.logFile != nil {
 				_, err := app.logFile.WriteString(pf + " " + s + "\n")
 				if err != nil {
 					app.fallbackLog("[!] Failed to write logfile: " + err.Error())
 				}
 			}
-			app.logBroadcaster.Publish("", LogMessage{i, pf, s, c})
+			app.logBroadcaster.Publish("", LogMessage{i, pf, s, cf})
 		} else {
 			println(c(langext.StrRepeat(" ", len(pf)+1) + s))
-			app.logList = append(app.logList, LogMessage{i, pf, s, c})
+			app.logList = append(app.logList, LogMessage{i, pf, s, cf})
 			if app.logFile != nil {
 				_, err := app.logFile.WriteString(langext.StrRepeat(" ", len(pf)+1) + s + "\n")
 				if err != nil {
 					app.fallbackLog("[!] Failed to write logfile: " + err.Error())
 				}
 			}
-			app.logBroadcaster.Publish("", LogMessage{i, pf, s, c})
+			app.logBroadcaster.Publish("", LogMessage{i, pf, s, cf})
 		}
 	}
 

app/sync.go

@@ -11,7 +11,6 @@ import (
 
 	"git.blackforestbytes.com/BlackForestBytes/goext/exerr"
 	"git.blackforestbytes.com/BlackForestBytes/goext/langext"
-	"git.blackforestbytes.com/BlackForestBytes/goext/timeext"
 	"mikescher.com/kpsync/assets"
 )
 
@@ -30,7 +29,18 @@ func (app *Application) initSync() (InitSyncResponse, error) {
 		return "", exerr.Wrap(err, "").Build()
 	}
 
-	app.dbFile = path.Join(app.config.WorkDir, path.Base(app.config.LocalFallback))
+	fn := ""
+	if app.config.LocalFallback != nil {
+		fn = path.Base(*app.config.LocalFallback)
+	}
+	if fn == "" || fn == "." || fn == "/" || fn == "\\" {
+		fn = path.Base(app.config.WebDAVURL)
+	}
+	if fn == "" || fn == "." || fn == "/" || fn == "\\" {
+		fn = "database.kdbx"
+	}
+
+	app.dbFile = path.Join(app.config.WorkDir, fn)
 	app.stateFile = path.Join(app.config.WorkDir, "kpsync.state")
 
 	if app.isKeepassRunning() {
@@ -102,18 +112,27 @@ func (app *Application) initSync() (InitSyncResponse, error) {
 		}()
 		if err != nil {
 
-			r, err := app.showChoiceNotification("KeePassSync", "Failed to download remote database.\nUse local fallback?", map[string]string{"y": "Yes", "n": "Abort"})
+			if app.config.LocalFallback != nil {
-			if err != nil {
+
-				app.LogError("Failed to show choice notification", err)
+				r, err := app.showChoiceNotification("KeePassSync", "Failed to download remote database.\nUse local fallback?", map[string]string{"y": "Yes", "n": "Abort"})
-				return "", exerr.Wrap(err, "Failed to show choice notification").Build()
+				if err != nil {
-			}
+					app.LogError("Failed to show choice notification", err)
+					return "", exerr.Wrap(err, "Failed to show choice notification").Build()
+				}
+
+				if r == "y" {
+					return InitSyncResponseFallback, nil
+				} else if r == "n" {
+					return InitSyncResponseAbort, nil
+				} else {
+					return "", exerr.Wrap(err, "").Build()
+				}
 
-			if r == "y" {
-				return InitSyncResponseFallback, nil
-			} else if r == "n" {
-				return InitSyncResponseAbort, nil
 			} else {
-				return "", exerr.Wrap(err, "").Build()
+
+				app.showErrorNotification("KeePassSync", "Failed to download remote database.")
+				return InitSyncResponseAbort, nil
+
 			}
 
 		}
@@ -133,7 +152,13 @@ func (app *Application) runKeepass(fallback bool) {
 
 	filePath := app.dbFile
 	if fallback {
-		filePath = app.config.LocalFallback
+		if app.config.LocalFallback == nil {
+			app.LogError("No local fallback database configured", nil)
+			app.sigErrChan <- exerr.New(exerr.TypeInternal, "No local fallback database configured").Build()
+			return
+		}
+
+		filePath = *app.config.LocalFallback
 	}
 
 	cmd := exec.Command("keepassxc", filePath)
@@ -199,21 +224,16 @@ func (app *Application) runKeepass(fallback bool) {
 
 }
 
-func (app *Application) onDBFileChanged() {
+func (app *Application) runDBUpload() {
-	app.masterLock.Lock()
+	app.uploadWaiting.Set(false)
-	app.uploadRunning.Wait(false)
-	app.uploadRunning.Set(true)
-	app.masterLock.Unlock()
 
-	defer app.uploadRunning.Set(false)
+	app.uploadActive.Set(true)
+	defer app.uploadActive.Set(false)
 
 	fin1 := app.setTrayState("Uploading database", assets.IconUpload)
 	defer fin1()
 
-	app.LogInfo("Database file was modified")
+	app.LogInfo("Starting upload-check")
-	app.LogInfo(fmt.Sprintf("Sleeping for %d ms", app.config.Debounce))
-
-	time.Sleep(timeext.FromMilliseconds(app.config.Debounce))
 
 	state := app.readState()
 	localCS, err := app.calcLocalChecksum()
@@ -347,12 +367,12 @@ func (app *Application) doDBUpload(state *State, stateClear func(), allowConflic
 
 func (app *Application) runFinalSync() {
 	app.masterLock.Lock()
-	app.uploadRunning.Wait(false)
+	app.uploadDCI.CancelPendingRequests()
-	app.uploadRunning.Set(true)
+	app.uploadActive.Wait(false)
+	app.uploadActive.Set(true)
+	defer app.uploadActive.Set(false)
 	app.masterLock.Unlock()
 
-	defer app.uploadRunning.Set(false)
-
 	fin1 := app.setTrayState("Uploading database", assets.IconUpload)
 	defer fin1()
 
@@ -385,12 +405,12 @@ func (app *Application) runFinalSync() {
 
 func (app *Application) runExplicitSync(force bool) {
 	app.masterLock.Lock()
-	app.uploadRunning.Wait(false)
+	app.uploadDCI.CancelPendingRequests()
-	app.uploadRunning.Set(true)
+	app.uploadActive.Wait(false)
+	app.uploadActive.Set(true)
+	defer app.uploadActive.Set(false)
 	app.masterLock.Unlock()
 
-	defer app.uploadRunning.Set(false)
-
 	state := app.readState()
 
 	if !force {

app/watcher.go

@@ -6,6 +6,7 @@ import (
 
 	"git.blackforestbytes.com/BlackForestBytes/goext/exerr"
 	"github.com/fsnotify/fsnotify"
+	"mikescher.com/kpsync/assets"
 )
 
 func (app *Application) runSyncWatcher() error {
@@ -61,7 +62,10 @@ func (app *Application) runSyncWatcher() error {
 				continue
 			}
 
-			app.onDBFileChanged()
+			app.uploadWaiting.Set(true)
+			app.setTrayStateDirect("Uploading database (waiting)", assets.IconUpload)
+			app.LogInfo(fmt.Sprintf("Database file was modified - requesting upload (currently %d pending requests)", app.uploadDCI.CountPendingRequests()))
+			app.uploadDCI.Request()
 
 		case err := <-watcher.Errors:
 			app.LogError("Filewatcher reported an error", err)

go.mod

@@ -4,23 +4,25 @@ go 1.24.6
 
 require (
 	fyne.io/systray v1.11.0
-	git.blackforestbytes.com/BlackForestBytes/goext v0.0.594
+	git.blackforestbytes.com/BlackForestBytes/goext v0.0.604
 	github.com/fsnotify/fsnotify v1.9.0
 	github.com/shirou/gopsutil/v3 v3.24.5
 )
 
 require (
-	github.com/bytedance/sonic v1.13.3 // indirect
+	github.com/bytedance/gopkg v0.1.3 // indirect
+	github.com/bytedance/sonic v1.14.1 // indirect
 	github.com/bytedance/sonic/loader v0.3.0 // indirect
-	github.com/cloudwego/base64x v0.1.5 // indirect
+	github.com/cloudwego/base64x v0.1.6 // indirect
-	github.com/gabriel-vasile/mimetype v1.4.9 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.10 // indirect
 	github.com/gin-contrib/sse v1.1.0 // indirect
-	github.com/gin-gonic/gin v1.10.1 // indirect
+	github.com/gin-gonic/gin v1.11.0 // indirect
 	github.com/go-ole/go-ole v1.2.6 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/go-playground/validator/v10 v10.27.0 // indirect
 	github.com/goccy/go-json v0.10.5 // indirect
+	github.com/goccy/go-yaml v1.18.0 // indirect
 	github.com/godbus/dbus/v5 v5.1.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
@@ -32,6 +34,8 @@ require (
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/pelletier/go-toml/v2 v2.2.4 // indirect
 	github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c // indirect
+	github.com/quic-go/qpack v0.5.1 // indirect
+	github.com/quic-go/quic-go v0.54.0 // indirect
 	github.com/rs/xid v1.6.0 // indirect
 	github.com/rs/zerolog v1.34.0 // indirect
 	github.com/shoenig/go-m1cpu v0.1.6 // indirect
@@ -41,13 +45,15 @@ require (
 	github.com/ugorji/go/codec v1.3.0 // indirect
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
 	go.mongodb.org/mongo-driver v1.17.4 // indirect
-	golang.org/x/arch v0.19.0 // indirect
+	go.uber.org/mock v0.6.0 // indirect
-	golang.org/x/crypto v0.40.0 // indirect
+	golang.org/x/arch v0.21.0 // indirect
-	golang.org/x/net v0.42.0 // indirect
+	golang.org/x/crypto v0.42.0 // indirect
-	golang.org/x/sync v0.16.0 // indirect
+	golang.org/x/mod v0.28.0 // indirect
-	golang.org/x/sys v0.34.0 // indirect
+	golang.org/x/net v0.44.0 // indirect
-	golang.org/x/term v0.33.0 // indirect
+	golang.org/x/sync v0.17.0 // indirect
-	golang.org/x/text v0.27.0 // indirect
+	golang.org/x/sys v0.36.0 // indirect
-	google.golang.org/protobuf v1.36.6 // indirect
+	golang.org/x/term v0.35.0 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
+	golang.org/x/text v0.29.0 // indirect
+	golang.org/x/tools v0.37.0 // indirect
+	google.golang.org/protobuf v1.36.9 // indirect
 )

go.sum

@@ -1,27 +1,27 @@
 fyne.io/systray v1.11.0 h1:D9HISlxSkx+jHSniMBR6fCFOUjk1x/OOOJLa9lJYAKg=
 fyne.io/systray v1.11.0/go.mod h1:RVwqP9nYMo7h5zViCBHri2FgjXF7H2cub7MAq4NSoLs=
-git.blackforestbytes.com/BlackForestBytes/goext v0.0.594 h1:tFbvEAe7FMvLuW9/RuXXlxsi8/Ve7xVrFxZnk8e/0yU=
+git.blackforestbytes.com/BlackForestBytes/goext v0.0.604 h1:bOiEQtg6Ed3OHr8yd+AapUf7znuYlJxJyt8wpfvyNVg=
-git.blackforestbytes.com/BlackForestBytes/goext v0.0.594/go.mod h1:vczjjViG013HjA5Ka3VTE7axDgqMChn1EsvEVg9LZnU=
+git.blackforestbytes.com/BlackForestBytes/goext v0.0.604/go.mod h1:h2HP/6E8z+Gq+8HGiVk1Qfo86PL6gbpgObUyMoDEFCA=
-github.com/bytedance/sonic v1.13.3 h1:MS8gmaH16Gtirygw7jV91pDCN33NyMrPbN7qiYhEsF0=
+github.com/bytedance/gopkg v0.1.3 h1:TPBSwH8RsouGCBcMBktLt1AymVo2TVsBVCY4b6TnZ/M=
-github.com/bytedance/sonic v1.13.3/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4=
+github.com/bytedance/gopkg v0.1.3/go.mod h1:576VvJ+eJgyCzdjS+c4+77QF3p7ubbtiKARP3TxducM=
-github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
+github.com/bytedance/sonic v1.14.1 h1:FBMC0zVz5XUmE4z9wF4Jey0An5FueFvOsTKKKtwIl7w=
+github.com/bytedance/sonic v1.14.1/go.mod h1:gi6uhQLMbTdeP0muCnrjHLeCUPyb70ujhnNlhOylAFc=
 github.com/bytedance/sonic/loader v0.3.0 h1:dskwH8edlzNMctoruo8FPTJDF3vLtDT0sXZwvZJyqeA=
 github.com/bytedance/sonic/loader v0.3.0/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI=
-github.com/cloudwego/base64x v0.1.5 h1:XPciSp1xaq2VCSt6lF0phncD4koWyULpl5bUxbfCyP4=
+github.com/cloudwego/base64x v0.1.6 h1:t11wG9AECkCDk5fMSoxmufanudBtJ+/HemLstXDLI2M=
-github.com/cloudwego/base64x v0.1.5/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
+github.com/cloudwego/base64x v0.1.6/go.mod h1:OFcloc187FXDaYHvrNIjxSe8ncn0OOM8gEHfghB2IPU=
-github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
 github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=
 github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
-github.com/gabriel-vasile/mimetype v1.4.9 h1:5k+WDwEsD9eTLL8Tz3L0VnmVh9QxGjRmjBvAG7U/oYY=
+github.com/gabriel-vasile/mimetype v1.4.10 h1:zyueNbySn/z8mJZHLt6IPw0KoZsiQNszIpU+bX4+ZK0=
-github.com/gabriel-vasile/mimetype v1.4.9/go.mod h1:WnSQhFKJuBlRyLiKohA/2DtIlPFAbguNaG7QCHcyGok=
+github.com/gabriel-vasile/mimetype v1.4.10/go.mod h1:d+9Oxyo1wTzWdyVUPMmXFvp4F9tea18J8ufA774AB3s=
 github.com/gin-contrib/sse v1.1.0 h1:n0w2GMuUpWDVp7qSpvze6fAu9iRxJY4Hmj6AmBOU05w=
 github.com/gin-contrib/sse v1.1.0/go.mod h1:hxRZ5gVpWMT7Z0B0gSNYqqsSCNIJMjzvm6fqCz9vjwM=
-github.com/gin-gonic/gin v1.10.1 h1:T0ujvqyCSqRopADpgPgiTT63DUQVSfojyME59Ei63pQ=
+github.com/gin-gonic/gin v1.11.0 h1:OW/6PLjyusp2PPXtyxKHU0RbX6I/l28FTdDlae5ueWk=
-github.com/gin-gonic/gin v1.10.1/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
+github.com/gin-gonic/gin v1.11.0/go.mod h1:+iq/FyxlGzII0KHiBGjuNn4UNENUlKbGlNmc+W50Dls=
 github.com/go-ole/go-ole v1.2.6 h1:/Fpf6oFPoeFik9ty7siob0G6Ke8QvQEuVcuChpwXzpY=
 github.com/go-ole/go-ole v1.2.6/go.mod h1:pprOEPIfldk/42T2oK7lQ4v4JSDwmV0As9GaiUsvbm0=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
@@ -34,6 +34,8 @@ github.com/go-playground/validator/v10 v10.27.0 h1:w8+XrWVMhGkxOaaowyKH35gFydVHO
 github.com/go-playground/validator/v10 v10.27.0/go.mod h1:I5QpIEbmr8On7W0TktmJAumgzX4CA1XNl4ZmDuVHKKo=
 github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
 github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
+github.com/goccy/go-yaml v1.18.0 h1:8W7wMFS12Pcas7KU+VVkaiCng+kG8QiFeFwzFb+rwuw=
+github.com/goccy/go-yaml v1.18.0/go.mod h1:XBurs7gK8ATbW4ZPGKgcbrY1Br56PdM69F7LkFRi1kA=
 github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
 github.com/godbus/dbus/v5 v5.1.0 h1:4KLkAxT3aOY8Li4FRJe/KvhoNFFxo0m6fNuFUO8QJUk=
 github.com/godbus/dbus/v5 v5.1.0/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
@@ -47,10 +49,8 @@ github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnr
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
 github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
-github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y=
 github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
-github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
 github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0 h1:6E+4a0GO5zZEnZ81pIr0yLvtUWk2if982qA3F3QD6H4=
@@ -76,6 +76,10 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c h1:ncq/mPwQF4JjgDlrVEn3C11VoGHZN7m8qihwgMEtzYw=
 github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c/go.mod h1:OmDBASR4679mdNQnz2pUhc2G8CO2JrUAVFDRBDP/hJE=
+github.com/quic-go/qpack v0.5.1 h1:giqksBPnT/HDtZ6VhtFKgoLOWmlyo9Ei6u9PqzIMbhI=
+github.com/quic-go/qpack v0.5.1/go.mod h1:+PC4XFrEskIVkcLzpEkbLqq1uCoxPhQuvK5rH1ZgaEg=
+github.com/quic-go/quic-go v0.54.0 h1:6s1YB9QotYI6Ospeiguknbp2Znb/jZYjZLRXn9kMQBg=
+github.com/quic-go/quic-go v0.54.0/go.mod h1:e68ZEaCdyviluZmy44P6Iey98v/Wfz6HCjQEm+l8zTY=
 github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
 github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
 github.com/rs/zerolog v1.34.0 h1:k43nTLIwcTVQAncfCw4KZ2VY6ukYoZaBPNOE8txlOeY=
@@ -90,12 +94,11 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
-github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
 github.com/tklauser/go-sysconf v0.3.12 h1:0QaGUFOdQaIVdPgfITYzaTegZvdCjmYO52cSFAEVmqU=
 github.com/tklauser/go-sysconf v0.3.12/go.mod h1:Ho14jnntGE1fpdOqQEEaiKRpvIavV0hSfmBq8nJbHYI=
 github.com/tklauser/numcpus v0.6.1 h1:ng9scYS7az0Bk4OZLvrNXNSAO2Pxr1XXRAPyjhIx+Fk=
@@ -116,14 +119,18 @@ github.com/yusufpapurcu/wmi v1.2.4 h1:zFUKzehAFReQwLys1b/iSMl+JQGSCSjtVqQn9bBrPo
 github.com/yusufpapurcu/wmi v1.2.4/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
 go.mongodb.org/mongo-driver v1.17.4 h1:jUorfmVzljjr0FLzYQsGP8cgN/qzzxlY9Vh0C9KFXVw=
 go.mongodb.org/mongo-driver v1.17.4/go.mod h1:Hy04i7O2kC4RS06ZrhPRqj/u4DTYkFDAAccj+rVKqgQ=
-golang.org/x/arch v0.19.0 h1:LmbDQUodHThXE+htjrnmVD73M//D9GTH6wFZjyDkjyU=
+go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y=
-golang.org/x/arch v0.19.0/go.mod h1:bdwinDaKcfZUGpH09BB7ZmOfhalA8lQdzl62l8gGWsk=
+go.uber.org/mock v0.6.0/go.mod h1:KiVJ4BqZJaMj4svdfmHM0AUx4NJYO8ZNpPnZn1Z+BBU=
-golang.org/x/crypto v0.40.0 h1:r4x+VvoG5Fm+eJcxMaY8CQM7Lb0l1lsmjGBQ6s8BfKM=
+golang.org/x/arch v0.21.0 h1:iTC9o7+wP6cPWpDWkivCvQFGAHDQ59SrSxsLPcnkArw=
-golang.org/x/crypto v0.40.0/go.mod h1:Qr1vMER5WyS2dfPHAlsOj01wgLbsyWtFn/aY+5+ZdxY=
+golang.org/x/arch v0.21.0/go.mod h1:dNHoOeKiyja7GTvF9NJS1l3Z2yntpQNzgrjh1cU103A=
-golang.org/x/net v0.42.0 h1:jzkYrhi3YQWD6MLBJcsklgQsoAcw89EcZbJw8Z614hs=
+golang.org/x/crypto v0.42.0 h1:chiH31gIWm57EkTXpwnqf8qeuMUi0yekh6mT2AvFlqI=
-golang.org/x/net v0.42.0/go.mod h1:FF1RA5d3u7nAYA4z2TkclSCKh68eSXtiFwcWQpPXdt8=
+golang.org/x/crypto v0.42.0/go.mod h1:4+rDnOTJhQCx2q7/j6rAN5XDw8kPjeaXEUR2eL94ix8=
-golang.org/x/sync v0.16.0 h1:ycBJEhp9p4vXvUZNszeOq0kGTPghopOL8q0fq3vstxw=
+golang.org/x/mod v0.28.0 h1:gQBtGhjxykdjY9YhZpSlZIsbnaE2+PgjfLWUQTnoZ1U=
-golang.org/x/sync v0.16.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
+golang.org/x/mod v0.28.0/go.mod h1:yfB/L0NOf/kmEbXjzCPOx1iK1fRutOydrCMsqRhEBxI=
+golang.org/x/net v0.44.0 h1:evd8IRDyfNBMBTTY5XRF1vaZlD+EmWx6x8PkhR04H/I=
+golang.org/x/net v0.44.0/go.mod h1:ECOoLqd5U3Lhyeyo/QDCEVQ4sNgYsqvCZ722XogGieY=
+golang.org/x/sync v0.17.0 h1:l60nONMj9l5drqw6jlhIELNv9I0A4OFgRsG9k2oT9Ug=
+golang.org/x/sync v0.17.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
 golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201204225414-ed752295db88/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
@@ -131,18 +138,18 @@ golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.34.0 h1:H5Y5sJ2L2JRdyv7ROF1he/lPdvFsd0mJHFw2ThKHxLA=
+golang.org/x/sys v0.36.0 h1:KVRy2GtZBrk1cBYA7MKu5bEZFxQk4NIDV6RLVcC8o0k=
-golang.org/x/sys v0.34.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/sys v0.36.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
-golang.org/x/term v0.33.0 h1:NuFncQrRcaRvVmgRkvM3j/F00gWIAlcmlB8ACEKmGIg=
+golang.org/x/term v0.35.0 h1:bZBVKBudEyhRcajGcNc3jIfWPqV4y/Kt2XcoigOWtDQ=
-golang.org/x/term v0.33.0/go.mod h1:s18+ql9tYWp1IfpV9DmCtQDDSRBUjKaw9M1eAv5UeF0=
+golang.org/x/term v0.35.0/go.mod h1:TPGtkTLesOwf2DE8CgVYiZinHAOuy5AYUYT1lENIZnA=
-golang.org/x/text v0.27.0 h1:4fGWRpyh641NLlecmyl4LOe6yDdfaYNrGb2zdfo4JV4=
+golang.org/x/text v0.29.0 h1:1neNs90w9YzJ9BocxfsQNHKuAT4pkghyXc4nhZ6sJvk=
-golang.org/x/text v0.27.0/go.mod h1:1D28KMCvyooCX9hBiosv5Tz/+YLxj0j7XhWjpSUF7CU=
+golang.org/x/text v0.29.0/go.mod h1:7MhJOA9CD2qZyOKYazxdYMF85OwPdEr9jTtBpO7ydH4=
+golang.org/x/tools v0.37.0 h1:DVSRzp7FwePZW356yEAChSdNcQo6Nsp+fex1SUW09lE=
+golang.org/x/tools v0.37.0/go.mod h1:MBN5QPQtLMHVdvsbtarmTNukZDdgwdwlO5qGacAzF0w=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=
+google.golang.org/protobuf v1.36.9 h1:w2gp2mA27hUeUzj9Ex9FBjsBm40zfaDtEWow293U7Iw=
-google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
+google.golang.org/protobuf v1.36.9/go.mod h1:fuxRtAxBytpl4zzqUh6/eyUujkJdNiuEkXntxiD/uRU=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=