From 11b312a1e8cf834f0912e73ba749312459516b5b Mon Sep 17 00:00:00 2001 From: jblu Date: Sat, 27 Jul 2024 18:24:15 -0500 Subject: [PATCH] updated client --- inexConnect.py | 22 +++++++--------------- 1 file changed, 7 insertions(+), 15 deletions(-) diff --git a/inexConnect.py b/inexConnect.py index cad9d37..fcb7474 100644 --- a/inexConnect.py +++ b/inexConnect.py @@ -42,20 +42,12 @@ def databaseQuery(self, cursor, query, args=()): # return (r[0] if r else None) if one else r return r -def renewToken(func): - def wrapper(*args, **kwargs): - try: - return func(*args, **kwargs) - except error: - getToken() - return func(*args, **kwargs) - return wrapper +def getToken(reqObj,idpUrl, id, secret): + getTokenResponse = reqObj.post(idpUrl, headers={"client_id": id,"client_secret": secret}) + return getTokenResponse["access_token"] -def getToken(idpUrl, id, secret): - pass - -@renewToken -def pushPayload(reqObj, targetUrl, token, payload): - pushPayloadResponse = reqObj.post(targetUrl, headers={"Bearer": token},\ - payload=payload,verify=False) +def pushPayload(reqObj, host, token, tenant_id, payload): + url = f'{host}/api/v1/unity/data/{tenant_id}/machine_event' + pushPayloadResponse = reqObj.post(url, headers={'Authorization': f'bearer {token}'},\ + payload=payload) return pushPayloadResponse.status_code \ No newline at end of file