Modified vault unseal

internal/client/vault.go

@@ -181,17 +181,19 @@ func (vc *VaultClient) DeleteCredential(ctx context.Context, mountPath, secretPa
 func (vc *VaultClient) JoinRaftCluster(podip string) error {
 	var req *api.RaftJoinRequest
 	address := fmt.Sprintf("http://%s:8200", podip)
+
 	err := vc.c.SetAddress(address)
 	if err != nil {
 		vc.log.Errorf("Error while setting address")
 	}
 	vc.log.Debug("Address", address)
 
 	leaderInfo, err := vc.c.Sys().Leader()
+	vc.log.Debug("Leader address",leaderInfo.LeaderAddress)
 	if err != nil {
-
 		vc.log.Debugf("Failed to retrieve leader information: %v", err)
 		return err
+
 	}
 
 	if leaderInfo.LeaderAddress == "" {

internal/job/vault_seal_watcher.go

@@ -119,7 +119,12 @@ func (v *VaultSealWatcher) Run() {
 						v.log.Errorf("failed to retrieve pod ip, %s", err)
 						return
 					}
+					err = vc.JoinRaftCluster(podip)
+					if err != nil {
+						v.log.Errorf("Failed to join the HA cluster: %v\n", err)
+						return
 
+					}
 					_, unsealKeys, err := vc.GetVaultSecretValuesforMultiInstance()
 					v.log.Debug("Unseal Keys", unsealKeys)
 					if err != nil {
@@ -133,12 +138,6 @@ func (v *VaultSealWatcher) Run() {
 						v.log.Errorf("failed to unseal vault, %s", err)
 						return
 					}
-					err = vc.JoinRaftCluster(podip)
-					if err != nil {
-						v.log.Errorf("Failed to join the HA cluster: %v\n", err)
-						return
-
-					}
 
 				}