fix: import (#419)

* fix: import * Update internal/secrets/import.go Co-authored-by: Patrick D'appollonio <[email protected]> * fix: return --------- Co-authored-by: Patrick D'appollonio <[email protected]>
konstructio · Aug 31, 2024 · 41a549c · 41a549c
1 parent 28af1d7
commit 41a549c
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/internal/secrets/import.go b/internal/secrets/import.go
@@ -55,10 +55,13 @@ func ImportClusterIfEmpty(silent bool) (pkgtypes.Cluster, error) {
 	log.Info().Msgf("import cluster secret discovered for cluster %s", cluster.ClusterName)
 
 	// if you find a record bail
-	_, err = GetCluster(kcfg.Clientset, cluster.ClusterName)
+	existingCluster, err := GetCluster(kcfg.Clientset, cluster.ClusterName)
 	if err != nil {
-		log.Info().Stack().Msgf("did not find preexisting record for cluster %s. importing record.", cluster.ClusterName)
+		return existingCluster, fmt.Errorf("unable to find cluster: %w", err)
+	}
 
+	if existingCluster.ClusterID == "" {
+		log.Info().Stack().Msgf("did not find preexisting record for cluster %s. importing record.", cluster.ClusterName)
 		// Create if entry does not exist
 		err = InsertCluster(kcfg.Clientset, cluster)
 		if err != nil {