Browse Source

PublishDeletedClientPeerUpdate when deleting user from RAGW

Max Ma 1 year ago
parent
commit
ec81cc4837
1 changed files with 9 additions and 1 deletions
  1. 9 1
      pro/controllers/users.go

+ 9 - 1
pro/controllers/users.go

@@ -10,6 +10,7 @@ import (
 	"github.com/gravitl/netmaker/logger"
 	"github.com/gravitl/netmaker/logic"
 	"github.com/gravitl/netmaker/models"
+	"github.com/gravitl/netmaker/mq"
 	"github.com/gravitl/netmaker/servercfg"
 	"golang.org/x/exp/slog"
 )
@@ -114,7 +115,14 @@ func removeUserFromRemoteAccessGW(w http.ResponseWriter, r *http.Request) {
 		}
 		for _, extclient := range extclients {
 			if extclient.OwnerID == user.UserName && remoteGwID == extclient.IngressGatewayID {
-				logic.DeleteExtClient(extclient.Network, extclient.ClientID)
+				err = logic.DeleteExtClient(extclient.Network, extclient.ClientID)
+				if err != nil {
+					slog.Error("failed to delete extclient",
+						"id", extclient.ClientID, "owner", user.UserName, "error", err)
+				}
+				if err := mq.PublishDeletedClientPeerUpdate(&extclient); err != nil {
+					logger.Log(1, "error setting ext peers: "+err.Error())
+				}
 			}
 		}
 		if servercfg.IsDNSMode() {