# api.py # Copyright (C) 2021 Alexander Schillemans # # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see . import requests from requests_oauthlib import OAuth2Session import json import sys from config import * from cachehandler import CacheHandler from authhandler import AuthHandler class OpenbravoToBanqupAPI: def __init__(self, clientId, clientSecret, demo=False): self.clientId = clientId self.clientSecret = clientSecret self.demo = demo self.headers = { 'Accept' : 'application/json', 'Content-Type' : 'application/json', } self.baseUrl = bq_base_url self.cacheHandler = CacheHandler() self.authHandler = AuthHandler(self, self.clientId, self.clientSecret) def doRequest(self, method, url, data=None, headers=None, files=None): if headers: mergedHeaders = self.headers mergedHeaders.update(headers) headers = mergedHeaders else: headers = self.headers reqUrl = '{base}/{url}'.format(base=self.baseUrl, url=url) if method == 'GET': response = requests.get(reqUrl, params=data, headers=headers) elif method == 'POST': if files: response = requests.post(reqUrl, data=json.dumps(data), files=files, headers=headers) else: response = requests.post(reqUrl, data=json.dumps(data), headers=headers) elif method == 'PUT': response = requests.put(reqUrl, data=json.dumps(data), headers=headers) elif method == 'DELETE': response = requests.delete(reqUrl, params=json.dumps(data), headers=headers) return response def request(self, method, url, data=None, headers=None, files=None): self.authHandler.checkHeaderTokens() response = self.doRequest(method, url, data, headers, files) if 'json' in response.headers['Content-Type']: respContent = response.json() elif 'pdf' in response.headers['Content-Type']: respContent = response.content return response.status_code, response.headers, respContent def get(self, url, data=None, headers=None): status, headers, response = self.request('GET', url, data, headers) return status, headers, response def post(self, url, data=None, headers=None, files=None): status, headers, response = self.request('POST', url, data, headers, files) return status, headers, response def put(self, url, data=None, headers=None): status, headers, response = self.request('PUT', url, data, headers) return status, headers, response def delete(self, url, data=None, headers=None): status, headers, response = self.request('DELETE', url, data, headers) return status, headers, response