瀏覽代碼

publish peer update on user group updates

abhishek9686 3 周之前
父節點
當前提交
7cb2938199
共有 2 個文件被更改,包括 4 次插入2 次删除
  1. 2 0
      pro/controllers/users.go
  2. 2 2
      pro/logic/user_mgmt.go

+ 2 - 0
pro/controllers/users.go

@@ -528,6 +528,7 @@ func createUserGroup(w http.ResponseWriter, r *http.Request) {
 		},
 		Origin: models.Dashboard,
 	})
+	go mq.PublishPeerUpdate(false)
 	logic.ReturnSuccessResponseWithJson(w, r, userGroupReq.Group, "created user group")
 }
 
@@ -656,6 +657,7 @@ func deleteUserGroup(w http.ResponseWriter, r *http.Request) {
 	})
 
 	go proLogic.UpdatesUserGwAccessOnGrpUpdates(userG.NetworkRoles, make(map[models.NetworkID]map[models.UserRoleID]struct{}))
+	go mq.PublishPeerUpdate(false)
 	logic.ReturnSuccessResponseWithJson(w, r, nil, "deleted user group")
 }
 

+ 2 - 2
pro/logic/user_mgmt.go

@@ -586,7 +586,7 @@ func CreateUserGroup(g *models.UserGroup) error {
 		return err
 	}
 	// create default network gateway policies
-	go CreateDefaultUserGroupNetworkPolicies(*g)
+	CreateDefaultUserGroupNetworkPolicies(*g)
 	return nil
 }
 
@@ -674,7 +674,7 @@ func DeleteUserGroup(gid models.UserGroupID) error {
 		logic.UpsertUser(user)
 	}
 	// create default network gateway policies
-	go DeleteDefaultUserGroupNetworkPolicies(g)
+	DeleteDefaultUserGroupNetworkPolicies(g)
 	return database.DeleteRecord(database.USER_GROUPS_TABLE_NAME, gid.String())
 }