From 1f255ec33a38faa7a768b29807d8efabf023c0e0 Mon Sep 17 00:00:00 2001 From: jblu Date: Thu, 25 Jul 2024 22:22:08 -0500 Subject: [PATCH] Added push payload --- inex.py | 2 ++ inexConnect.py | 20 +++++++++++++++++++- 2 files changed, 21 insertions(+), 1 deletion(-) diff --git a/inex.py b/inex.py index 7e2e149..ad805c6 100644 --- a/inex.py +++ b/inex.py @@ -9,6 +9,7 @@ from inexDataModel import dataTemplate from inexDataProcessing import processData import json import decimal +import requests class Inex: def __init__(self): @@ -23,6 +24,7 @@ class Inex: self.tm = datetime self.il = logging self.ic = inexConnect + self.r = requests # set config self.dbDriver = self.config["database"]["driver"] diff --git a/inexConnect.py b/inexConnect.py index dad618a..cad9d37 100644 --- a/inexConnect.py +++ b/inexConnect.py @@ -40,4 +40,22 @@ def databaseQuery(self, cursor, query, args=()): if self.useLog: self.il.debug(f"Database connection closed") # return (r[0] if r else None) if one else r - return r \ No newline at end of file + 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(idpUrl, id, secret): + pass + +@renewToken +def pushPayload(reqObj, targetUrl, token, payload): + pushPayloadResponse = reqObj.post(targetUrl, headers={"Bearer": token},\ + payload=payload,verify=False) + return pushPayloadResponse.status_code \ No newline at end of file