changed to update password cmd

Author: Jeff McCormick

client/cmd/user.go

@@ -151,7 +151,7 @@ func userManager() {
 				fmt.Println("changing password of user " + ChangePasswordForUser)
 				newPassword := util.GeneratePassword(PasswordLength)
 				newExpireDate := GeneratePasswordExpireDate(PasswordAgeDays)
-				err = updatePassword(info, ChangePasswordForUser, newPassword, newExpireDate)
+				err = updatePassword(cluster.Spec.Name, info, ChangePasswordForUser, newPassword, newExpireDate)
 				if err != nil {
 					log.Error(err.Error())
 					os.Exit(2)
@@ -166,7 +166,7 @@ func userManager() {
 				addUser(d.ObjectMeta.Name, info, AddUser)
 				newPassword := util.GeneratePassword(PasswordLength)
 				newExpireDate := GeneratePasswordExpireDate(PasswordAgeDays)
-				err = updatePassword(info, AddUser, newPassword, newExpireDate)
+				err = updatePassword(cluster.Spec.Name, info, AddUser, newPassword, newExpireDate)
 				if err != nil {
 					log.Error(err.Error())
 					os.Exit(2)
@@ -182,7 +182,7 @@ func userManager() {
 						if UpdatePasswords {
 							newPassword := util.GeneratePassword(PasswordLength)
 							newExpireDate := GeneratePasswordExpireDate(PasswordAgeDays)
-							err = updatePassword(v.ConnDetails, v.Rolname, newPassword, newExpireDate)
+							err = updatePassword(cluster.Spec.Name, v.ConnDetails, v.Rolname, newPassword, newExpireDate)
 							if err != nil {
 								fmt.Println("error in updating password")
 							}
@@ -246,7 +246,7 @@ func callDB(info ConnInfo, clusterName, maxdays string) []PswResult {
 
 }
 
-func updatePassword(p ConnInfo, username, newPassword, passwordExpireDate string) error {
+func updatePassword(clusterName string, p ConnInfo, username, newPassword, passwordExpireDate string) error {
 	var err error
 	var conn *sql.DB
 
@@ -283,6 +283,11 @@ func updatePassword(p ConnInfo, username, newPassword, passwordExpireDate string
 		}
 	}()
 
+	err = util.UpdateUserSecret(Clientset, clusterName, username, newPassword, Namespace)
+	if err != nil {
+		log.Debug(err.Error())
+		return err
+	}
 	return err
 }
 

operator/util/secrets.go

@@ -223,3 +223,30 @@ func CreateUserSecret(clientset *kubernetes.Clientset, clustername, username, pa
 
 	return err
 }
+
+func UpdateUserSecret(clientset *kubernetes.Clientset, clustername, username, password, namespace string) error {
+
+	var err error
+
+	secretName := clustername + "-" + username + "-secret"
+
+	//delete current secret
+	options := meta_v1.DeleteOptions{}
+	err = clientset.Secrets(namespace).Delete(secretName, &options)
+	if err != nil {
+		log.Error("error deleting secret" + err.Error())
+		return err
+	} else {
+		log.Info("deleted secret " + secretName)
+	}
+	//create secret with updated password
+	err = CreateUserSecret(clientset, clustername, username, password, namespace)
+	if err != nil {
+		log.Error("error creating secret" + err.Error())
+		return err
+	} else {
+		log.Info("created secret " + secretName)
+	}
+
+	return err
+}