reqs.py 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  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}/deleteAccount"
  32. payload = {"stream": stream, "user": username}
  33. headers = {"Authorization": f"Basic {auth}"}
  34. response = requests.request("POST", url, headers=headers, data=payload)
  35. if "Deleted" in response.text:
  36. return True
  37. else:
  38. return False
  39. def add_user_account(base_url: str, auth: str, username:str, password:str, stream:str,) -> bool:
  40. """_summary_
  41. Args:
  42. base_url (str): _description_
  43. auth (str): _description_
  44. stream (str): _description_
  45. username (str): _description_
  46. Returns:
  47. bool: _description_
  48. """
  49. url = f"{base_url}/addAccount"
  50. payload = {"username": username, "password": password, "stream": stream}
  51. headers = {"Authorization": f"Basic {auth}"}
  52. response = requests.request("POST", url, headers=headers, data=payload)
  53. if "Added successfully" in response.text:
  54. return True
  55. else:
  56. return False