From adbd7ab4c311f8b2743dcf0f2c7b16d0e96c03ab Mon Sep 17 00:00:00 2001 From: pascal Date: Fri, 6 Feb 2026 17:03:18 +0100 Subject: [PATCH] send account updates on proxy change --- .../modules/reverseproxy/manager/manager.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/management/internals/modules/reverseproxy/manager/manager.go b/management/internals/modules/reverseproxy/manager/manager.go index 4afcd0123..9a17b65de 100644 --- a/management/internals/modules/reverseproxy/manager/manager.go +++ b/management/internals/modules/reverseproxy/manager/manager.go @@ -131,6 +131,8 @@ func (m *managerImpl) CreateReverseProxy(ctx context.Context, accountID, userID m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Create, token, m.proxyGRPCServer.GetOIDCValidationConfig()), reverseProxy.ProxyCluster) + m.accountManager.UpdateAccountPeers(ctx, accountID) + return reverseProxy, nil } @@ -191,12 +193,17 @@ func (m *managerImpl) UpdateReverseProxy(ctx context.Context, accountID, userID m.accountManager.StoreEvent(ctx, userID, reverseProxy.ID, accountID, activity.ReverseProxyUpdated, reverseProxy.EventMeta()) - if domainChanged && oldCluster != reverseProxy.ProxyCluster { + switch { + case domainChanged && oldCluster != reverseProxy.ProxyCluster: m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Delete, "", m.proxyGRPCServer.GetOIDCValidationConfig()), oldCluster) m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Create, "", m.proxyGRPCServer.GetOIDCValidationConfig()), reverseProxy.ProxyCluster) - } else { + case !reverseProxy.Enabled: + m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Delete, "", m.proxyGRPCServer.GetOIDCValidationConfig()), reverseProxy.ProxyCluster) + default: m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Update, "", m.proxyGRPCServer.GetOIDCValidationConfig()), reverseProxy.ProxyCluster) + } + m.accountManager.UpdateAccountPeers(ctx, accountID) return reverseProxy, nil } @@ -232,6 +239,8 @@ func (m *managerImpl) DeleteReverseProxy(ctx context.Context, accountID, userID, m.proxyGRPCServer.SendReverseProxyUpdateToCluster(reverseProxy.ToProtoMapping(reverseproxy.Delete, "", m.proxyGRPCServer.GetOIDCValidationConfig()), reverseProxy.ProxyCluster) + m.accountManager.UpdateAccountPeers(ctx, accountID) + return nil }