fix getting updated user namespaces

core/clustersmngr/factory.go

@@ -103,6 +103,8 @@ type clustersManager struct {
 
 	// list of watchers to notify of clusters updates
 	watchers []*ClustersWatcher
+
+	usersLock sync.Map
 }
 
 // ClusterListUpdate records the changes to the cluster state managed by the factory.
@@ -413,7 +415,11 @@ func (cf *clustersManager) UpdateUserNamespaces(ctx context.Context, user *auth.
 		go func(cluster Cluster) {
 			defer wg.Done()
 
-			clusterNs := cf.clustersNamespaces.Get(cluster.Name)
+			clusterNs, found := cf.clustersNamespaces.Get(cluster.Name)
+			if !found {
+				cf.log.Error(nil, "failed to get cluster namespaces", "cluster", cluster.Name)
+				return
+			}
 
 			cfg, err := ClientConfigWithUser(user, cf.kubeConfigOptions...)(cluster)
 			if err != nil {
@@ -434,11 +440,21 @@ func (cf *clustersManager) UpdateUserNamespaces(ctx context.Context, user *auth.
 	wg.Wait()
 }
 
+func (cf *clustersManager) UserLock(userId string) *sync.Mutex {
+	actual, _ := cf.usersLock.LoadOrStore(userId, &sync.Mutex{})
+	lock := actual.(*sync.Mutex)
+	lock.Lock()
+	return lock
+}
+
 func (cf *clustersManager) GetUserNamespaces(user *auth.UserPrincipal) map[string][]v1.Namespace {
 	return cf.usersNamespaces.GetAll(user, cf.clusters.Get())
 }
 
 func (cf *clustersManager) userNsList(ctx context.Context, user *auth.UserPrincipal) map[string][]v1.Namespace {
+	userLock := cf.UserLock(user.ID)
+	defer userLock.Unlock()
+
 	userNamespaces := cf.GetUserNamespaces(user)
 	if len(userNamespaces) > 0 {
 		return userNamespaces

core/clustersmngr/factory_caches.go

@@ -104,11 +104,15 @@ func (cn *ClustersNamespaces) Clear() {
 	cn.namespaces = make(map[string][]v1.Namespace)
 }
 
-func (cn *ClustersNamespaces) Get(cluster string) []v1.Namespace {
+func (cn *ClustersNamespaces) Get(cluster string) ([]v1.Namespace, bool) {
 	cn.Lock()
 	defer cn.Unlock()
 
-	return cn.namespaces[cluster]
+	clusterObj, ok := cn.namespaces[cluster]
+	if !ok {
+		return nil, false
+	}
+	return clusterObj, true
 }
 
 type UsersNamespaces struct {