sregnery/ez1-m-cloud-poll
1
1
Fork 0
Code Issues 2 Packages Activity

add debuging things

Browse Source
This commit is contained in:
Stefan Regnery 2023-09-29 22:32:27 +00:00
parent dda662f3ca
commit 0a0f9a0980
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
CloudConnection.py
View File

@ -16,7 +16,7 @@ class CloudConnection:
@staticmethod @staticmethod
def _retry_one_any_exception(exception): def _retry_one_any_exception(exception):
logging.error(f"An Exception occurred: \n{exception}") logging.error(f"An Exception occurred: \n{type(exception)}, {exception}")
return True return True
@retry(retry_on_exception=_retry_one_any_exception, wait_exponential_multiplier=1000, wait_exponential_max=10000) @retry(retry_on_exception=_retry_one_any_exception, wait_exponential_multiplier=1000, wait_exponential_max=10000)
@ -30,7 +30,9 @@ class CloudConnection:
"username": self.username "username": self.username
} }
post = requests.post(url, data=data) post = requests.post(url, data=data)
self._handle_api_return_codes(post) ret = self._handle_api_return_codes(post)
if ret == False:
return
user_token = post.json()["data"]["access_token"] user_token = post.json()["data"]["access_token"]
self._user_id = post.json()["data"]["user_id"] self._user_id = post.json()["data"]["user_id"]
self._refresh_token = post.json()["data"]["refresh_token"] self._refresh_token = post.json()["data"]["refresh_token"]
@ -43,7 +45,9 @@ class CloudConnection:
"refresh_token": self._refresh_token "refresh_token": self._refresh_token
} }
result = requests.post(url, data=data, headers=self._auth_header) result = requests.post(url, data=data, headers=self._auth_header)
self._handle_api_return_codes(result) ret = self._handle_api_return_codes(result)
if ret == False:
return
user_token = result.json()["data"]["access_token"] user_token = result.json()["data"]["access_token"]
self._auth_header = {"authorization": f"Bearer {user_token}"} self._auth_header = {"authorization": f"Bearer {user_token}"}
@ -52,7 +56,9 @@ class CloudConnection:
url = f"https://app.api.apsystemsema.com:9223/aps-api-web/api/v2/data/device/ezInverter/realTime/{inverter_id}" url = f"https://app.api.apsystemsema.com:9223/aps-api-web/api/v2/data/device/ezInverter/realTime/{inverter_id}"
while True: while True:
result = requests.get(url, headers=self._auth_header) result = requests.get(url, headers=self._auth_header)
self._handle_api_return_codes(result) ret = self._handle_api_return_codes(result)
if ret == False:
continue
if result.json()["code"] == 0: if result.json()["code"] == 0:
data = result.json()["data"] data = result.json()["data"]
break break
@ -63,7 +69,9 @@ class CloudConnection:
url = f"https://app.api.apsystemsema.com:9223/aps-api-web/api/v2/data/device/ezInverter/statistic/{inverter_id}" url = f"https://app.api.apsystemsema.com:9223/aps-api-web/api/v2/data/device/ezInverter/statistic/{inverter_id}"
while True: while True:
result = requests.get(url, headers=self._auth_header) result = requests.get(url, headers=self._auth_header)
self._handle_api_return_codes(result) ret = self._handle_api_return_codes(result)
if ret == False:
continue
if result.json()["code"] == 0: if result.json()["code"] == 0:
data = result.json()["data"] data = result.json()["data"]
break break
@ -75,7 +83,9 @@ class CloudConnection:
inverter = [] inverter = []
while True: while True:
result = requests.get(url, headers=self._auth_header) result = requests.get(url, headers=self._auth_header)
self._handle_api_return_codes(result) ret = self._handle_api_return_codes(result)
if ret == False:
continue
if result.json()["code"] == 0: if result.json()["code"] == 0:
data = result.json()["data"] data = result.json()["data"]
for inv in data["inverter"]: for inv in data["inverter"]:
@ -88,9 +98,10 @@ class CloudConnection:
result_api_code = result.json()["code"] result_api_code = result.json()["code"]
if result_api_code == 0: if result_api_code == 0:
pass return True
if result_api_code == 3003: if result_api_code == 3003:
self.refresh_user_token() self.refresh_user_token()
return True
if result_api_code == 3001: if result_api_code == 3001:
logging.error(f"Not authorized {result.url}", ) logging.error(f"Not authorized {result.url}", )
exit(1) exit(1)
@ -99,3 +110,4 @@ class CloudConnection:
exit(1) exit(1)
else: else:
logging.error(f"Something went wrong in the request. Status code: {result.status_code}") logging.error(f"Something went wrong in the request. Status code: {result.status_code}")
return False