forked from Chewing_Bever/rusty-bever
Fixed guard still using env var for jwt key
This commit is contained in:
parent
fb2a6126fe
commit
f50008ff99
4 changed files with 84 additions and 15 deletions
64
tests/admin.py
Normal file
64
tests/admin.py
Normal file
|
|
@ -0,0 +1,64 @@
|
|||
import requests
|
||||
|
||||
|
||||
class RbClient:
|
||||
def __init__(self, username, password, base_url = "http://localhost:8000/api"):
|
||||
self.username = username
|
||||
self.password = password
|
||||
self.base_url = base_url
|
||||
|
||||
self.jwt = None
|
||||
self.refresh_token = None
|
||||
|
||||
def _login(self):
|
||||
r = requests.post(f"{self.base_url}/auth/login", json={
|
||||
"username": self.username,
|
||||
"password": self.password,
|
||||
})
|
||||
|
||||
if r.status_code != 200:
|
||||
raise Exception("Couldn't login")
|
||||
|
||||
res = r.json()
|
||||
self.jwt = res["token"]
|
||||
self.refresh_token = res["refreshToken"]
|
||||
|
||||
def _refresh(self):
|
||||
r = requests.post(f"{self.base_url}/auth/refresh", json={"refreshToken": self.refresh_token})
|
||||
|
||||
if r.status_code != 200:
|
||||
raise Exception("Couldn't refresh")
|
||||
|
||||
res = r.json()
|
||||
self.jwt = res["token"]
|
||||
self.refresh_token = res["refreshToken"]
|
||||
|
||||
def _request(self, type_, url, retry=2, *args, **kwargs):
|
||||
if self.jwt:
|
||||
headers = kwargs.get("headers", {})
|
||||
headers["Authorization"] = f"Bearer {self.jwt}"
|
||||
kwargs["headers"] = headers
|
||||
print(kwargs["headers"])
|
||||
|
||||
r = requests.request(type_, url, *args, **kwargs)
|
||||
|
||||
if r.status_code != 200 and retry > 0:
|
||||
if self.refresh_token:
|
||||
self._refresh()
|
||||
|
||||
else:
|
||||
self._login()
|
||||
|
||||
r = self._request(type_, url, *args, **kwargs, retry=retry - 1)
|
||||
|
||||
return r
|
||||
|
||||
def get(self, url, *args, **kwargs):
|
||||
return self._request("GET", f"{self.base_url}{url}", *args, **kwargs)
|
||||
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
client = RbClient("admin", "password")
|
||||
|
||||
print(client.get("/admin/users").json())
|
||||
Loading…
Add table
Add a link
Reference in a new issue