jblu/Inex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases 8 Wiki Activity

updated client

Browse Source
This commit is contained in:
jblu 2024-07-27 18:24:15 -05:00
parent 1f255ec33a
commit 11b312a1e8
1 changed files with 7 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
inexConnect.py
View File

@ -42,20 +42,12 @@ def databaseQuery(self, cursor, query, args=()):
# return (r[0] if r else None) if one else r # return (r[0] if r else None) if one else r
return r return r
def renewToken(func): def getToken(reqObj,idpUrl, id, secret):
def wrapper(*args, **kwargs): getTokenResponse = reqObj.post(idpUrl, headers={"client_id": id,"client_secret": secret})
try: return getTokenResponse["access_token"]
return func(*args, **kwargs)
except error:
getToken()
return func(*args, **kwargs)
return wrapper
def getToken(idpUrl, id, secret): def pushPayload(reqObj, host, token, tenant_id, payload):
pass url = f'{host}/api/v1/unity/data/{tenant_id}/machine_event'
pushPayloadResponse = reqObj.post(url, headers={'Authorization': f'bearer {token}'},\
@renewToken payload=payload)
def pushPayload(reqObj, targetUrl, token, payload):
pushPayloadResponse = reqObj.post(targetUrl, headers={"Bearer": token},\
payload=payload,verify=False)
return pushPayloadResponse.status_code return pushPayloadResponse.status_code