reqs.py 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. import requests
  2. import json
  3. from datetime import datetime
  4. def get_urls(base_url, auth: str) -> list:
  5. url = f"{base_url}/getUserAccounts/streams"
  6. payload = {}
  7. headers = {"Authorization": f"Basic {auth}"}
  8. response = requests.request("GET", url, headers=headers, data=payload)
  9. return json.loads(response.text)
  10. def get_user_accounts(base_url, auth: str) -> list:
  11. url = f"{base_url}/getUserAccounts"
  12. payload = {}
  13. headers = {"Authorization": f"Basic {auth}"}
  14. response = requests.request("GET", url, headers=headers, data=payload)
  15. res_json = json.loads(response.text)
  16. for account in res_json:
  17. account["expiaryDate_rendered"] = datetime.utcfromtimestamp(
  18. account["expiaryDate"]
  19. ).strftime("%d/%m/%Y")
  20. return res_json
  21. def delete_user_account(base_url: str, auth: str, stream:str, username:str) -> bool:
  22. """_summary_
  23. Args:
  24. base_url (str): _description_
  25. auth (str): _description_
  26. stream (str): _description_
  27. username (str): _description_
  28. Returns:
  29. bool: _description_
  30. """
  31. url = f"{base_url}/getUserAccounts"
  32. payload = {"stream": stream, "user": username}
  33. headers = {"Authorization": f"Basic {auth}"}
  34. response = requests.request("POST", url, headers=headers, data=payload)
  35. res_json = json.loads(response.text)
  36. return res_json