From 04aaf514b1bdd741373bb64b855ebd738f3e79af Mon Sep 17 00:00:00 2001 From: Michael Mayer Date: Sun, 26 Oct 2025 14:48:04 +0100 Subject: [PATCH] Cluster: Persist database credentials in cluster_nodes_register.go Signed-off-by: Michael Mayer --- internal/api/cluster_nodes_register.go | 24 +++++++++++++++++------- 1 file changed, 17 insertions(+), 7 deletions(-) diff --git a/internal/api/cluster_nodes_register.go b/internal/api/cluster_nodes_register.go index e32deac07..ee4dad398 100644 --- a/internal/api/cluster_nodes_register.go +++ b/internal/api/cluster_nodes_register.go @@ -239,14 +239,24 @@ func ClusterNodesRegister(router *gin.RouterGroup) { } haveCreds = true - if req.RotateDatabase { + if n.Database == nil { + n.Database = &cluster.NodeDatabase{} + } + + n.Database.Name = creds.Name + n.Database.User = creds.User + n.Database.Driver = provisioner.DatabaseDriver + if creds.RotatedAt != "" { n.Database.RotatedAt = creds.RotatedAt - n.Database.Driver = provisioner.DatabaseDriver - if putErr := regy.Put(n); putErr != nil { - event.AuditErr([]string{clientIp, string(acl.ResourceCluster), "node", "%s", "persist node", status.Error(putErr)}, clean.Log(name)) - AbortUnexpectedError(c) - return - } + } + + if putErr := regy.Put(n); putErr != nil { + event.AuditErr([]string{clientIp, string(acl.ResourceCluster), "node", "%s", "persist node", status.Error(putErr)}, clean.Log(name)) + AbortUnexpectedError(c) + return + } + + if req.RotateDatabase { event.AuditInfo([]string{clientIp, string(acl.ResourceCluster), "node", "%s", "rotate database", status.Succeeded}, clean.Log(name)) } }