From 3514198cbc5c33719288384f45ba469fb43d4921 Mon Sep 17 00:00:00 2001
From: Adisun Wheelock <awheelock@clearstreet.io>
Date: Mon, 4 Mar 2024 15:55:55 +0000
Subject: [PATCH] revert

---
 gestalt/vault.py | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/gestalt/vault.py b/gestalt/vault.py
index 3bbd898..48a4151 100644
--- a/gestalt/vault.py
+++ b/gestalt/vault.py
@@ -44,13 +44,10 @@ def __init__(
         self.vault_client = hvac.Client(url=url, token=token, cert=cert, verify=verify)
         self._secret_expiry_times: Dict[str, datetime] = dict()
         self._secret_values: Dict[str, Union[str, int, float, bool, List[Any]]] = dict()
-        self._is_connected: bool = False
-        self._role: Optional[str] = role
-        self._jwt: Optional[str] = jwt
+
         self.delay = delay
         self.tries = tries
 
-    def connect(self) -> None:
         try:
             retry_call(
                 self.vault_client.is_authenticated,
@@ -63,10 +60,10 @@ def connect(self) -> None:
                 "Gestalt Error: Unable to connect to vault with the given configuration"
             )
 
-        if self._role and self._jwt:
+        if role and jwt:
             try:
                 hvac.api.auth_methods.Kubernetes(self.vault_client.adapter).login(
-                    role=self._role, jwt=self._jwt
+                    role=role, jwt=jwt
                 )
                 token = retry_call(
                     self.vault_client.auth.token.lookup_self,
@@ -102,7 +99,6 @@ def connect(self) -> None:
                 args=(self.kubes_token_queue,),
             )
             kubernetes_ttl_renew.start()
-        self._is_connected = True
 
     def stop(self) -> None:
         self._run_worker = False
@@ -122,8 +118,6 @@ def get(
         Returns:
             secret (str): secret
         """
-        if not self._is_connected:
-            self.connect()
         # if the key has been read before and is not a TTL secret
         if key in self._secret_values and key not in self._secret_expiry_times:
             return self._secret_values[key]