Skip to content

Commit

Permalink
feat: Add extensive loggers across all the apis (#20)
Browse files Browse the repository at this point in the history
  • Loading branch information
@Ashutosh619-sudo
Ashutosh619-sudo authored Oct 13, 2024
1 parent 317f4c7 commit ccdf5a2
Show file tree
Hide file tree
Showing 2 changed files with 56 additions and 40 deletions.
94 changes: 55 additions & 39 deletions dynamics/apis/api_base.py
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import logging
from dynamics.exceptions.dynamics_exceptions import (
DynamicsError,
ExpiredTokenError,
Expand All @@ -11,6 +12,8 @@
import json


logger = logging.getLogger(__name__)

class ApiBase:
"""The base class for all API classes."""

Expand Down Expand Up @@ -75,27 +78,30 @@ def _get_request(self, params, api_url):
headers=api_headers,
params=api_params
)

if response.status_code == 200 or response.status_code == 201:
logger.debug('Response for get request for url: %s, %s', api_url, response.text)
result = json.loads(response.text)
return result


elif response.status_code == 400:
logger.info('Response for get request for url: %s, %s', api_url, response.text)
if response.status_code == 400:
raise WrongParamsError('Some of the parameters are wrong', response.text)

elif response.status_code == 401:
if response.status_code == 401:
raise InvalidTokenError('Invalid token, try to refresh it', response.text)

elif response.status_code == 403:
if response.status_code == 403:
raise NoPrivilegeError('Forbidden, the user has insufficient privilege', response.text)

elif response.status_code == 404:
if response.status_code == 404:
raise NotFoundItemError('Not found item with ID', response.text)

elif response.status_code == 498:
if response.status_code == 498:
raise ExpiredTokenError('Expired token, try to refresh it', response.text)

elif response.status_code == 500:
if response.status_code == 500:
raise InternalServerError('Internal server error', response.text)

else:
Expand Down Expand Up @@ -180,30 +186,33 @@ def _post_request(self, data, api_url):
headers=api_headers,
json=data
)
logger.debug('Payload for post request: %s', data)

if response.status_code == 200 or response.status_code == 201:
logger.debug('Response for post request: %s', response.text)
result = json.loads(response.text)
return result

elif response.status_code == 400:
logger.info('Response for post request: %s', response.text)
if response.status_code == 400:
raise WrongParamsError('Some of the parameters are wrong', response.text)

elif response.status_code == 401:
if response.status_code == 401:
raise InvalidTokenError('Invalid token, try to refresh it', response.text)

elif response.status_code == 403:
if response.status_code == 403:
raise NoPrivilegeError('Forbidden, the user has insufficient privilege', response.text)

elif response.status_code == 404:
if response.status_code == 404:
raise NotFoundItemError('Not found item with ID', response.text)

elif response.status_code == 498:
if response.status_code == 498:
raise ExpiredTokenError('Expired token, try to refresh it', response.text)

elif response.status_code == 500:
if response.status_code == 500:
raise InternalServerError('Internal server error', response.text)

else:
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)

def _patch_request(self, content_type, data, api_url):
"""Create a HTTP patch request.
Expand All @@ -227,29 +236,32 @@ def _patch_request(self, content_type, data, api_url):
data=data
)

logger.debug('Payload for patch request: %s', data)

if response.status_code == 200 or response.status_code == 201 or response.status_code == 204:
logger.debug('Response for patch request: %s', response.text)
return {'status': 'success'}

elif response.status_code == 400:
logger.info('Response for patch request: %s', response.text)
if response.status_code == 400:
raise WrongParamsError('Some of the parameters are wrong', response.text)

elif response.status_code == 401:
if response.status_code == 401:
raise InvalidTokenError('Invalid token, try to refresh it', response.text)

elif response.status_code == 403:
if response.status_code == 403:
raise NoPrivilegeError('Forbidden, the user has insufficient privilege', response.text)

elif response.status_code == 404:
if response.status_code == 404:
raise NotFoundItemError('Not found item with ID', response.text)

elif response.status_code == 498:
if response.status_code == 498:
raise ExpiredTokenError('Expired token, try to refresh it', response.text)

elif response.status_code == 500:
if response.status_code == 500:
raise InternalServerError('Internal server error', response.text)

else:
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)

def _delete_request(self, params, api_url):
"""
Expand Down Expand Up @@ -279,28 +291,29 @@ def _delete_request(self, params, api_url):
)

if response.status_code == 204:
logger.debug('Response for delete request for url: %s, %s', api_url, response.text)
return {'status': 'success'}

elif response.status_code == 400:
logger.info('Response for delete request for url: %s, %s', api_url, response.text)
if response.status_code == 400:
raise WrongParamsError('Some of the parameters are wrong', response.text)

elif response.status_code == 401:
if response.status_code == 401:
raise InvalidTokenError('Invalid token, try to refresh it', response.text)

elif response.status_code == 403:
if response.status_code == 403:
raise NoPrivilegeError('Forbidden, the user has insufficient privilege', response.text)

elif response.status_code == 404:
if response.status_code == 404:
raise NotFoundItemError('Not found item with ID', response.text)

elif response.status_code == 498:
if response.status_code == 498:
raise ExpiredTokenError('Expired token, try to refresh it', response.text)

elif response.status_code == 500:
if response.status_code == 500:
raise InternalServerError('Internal server error', response.text)

else:
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)

def _bulk_post_request(self, data, isolation: str, company_id: str = None, purchase_invoice_id: str = None):
"""Create a HTTP batch request.
Expand All @@ -327,7 +340,10 @@ def _bulk_post_request(self, data, isolation: str, company_id: str = None, purch
json=data
)

logger.debug('Payload for post request: %s', data)

if response.status_code == 200 or response.status_code == 201:
logger.debug('Response for post request: %s', response.text)
result = json.loads(response.text)

error_messages = [resp.get('body', {}).get('error', {}).get('message', None) for resp in result.get('responses', []) if 400 <= resp.get('status', 0) < 500]
Expand All @@ -338,23 +354,23 @@ def _bulk_post_request(self, data, isolation: str, company_id: str = None, purch
raise WrongParamsError('Some of the parameters are wrong', error_messages)
return result

elif response.status_code == 400:
logger.info('Response for post request: %s', response.text)
if response.status_code == 400:
raise WrongParamsError('Some of the parameters are wrong', response.text)

elif response.status_code == 401:
if response.status_code == 401:
raise InvalidTokenError('Invalid token, try to refresh it', response.text)

elif response.status_code == 403:
if response.status_code == 403:
raise NoPrivilegeError('Forbidden, the user has insufficient privilege', response.text)

elif response.status_code == 404:
if response.status_code == 404:
raise NotFoundItemError('Not found item with ID', response.text)

elif response.status_code == 498:
if response.status_code == 498:
raise ExpiredTokenError('Expired token, try to refresh it', response.text)

elif response.status_code == 500:
if response.status_code == 500:
raise InternalServerError('Internal server error', response.text)

else:
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)
raise DynamicsError('Error: {0}'.format(response.status_code), response.text)
2 changes: 1 addition & 1 deletion setup.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

setuptools.setup(
name='ms-dynamics-business-central-sdk',
version='1.5.0',
version='1.5.1',
author='Shwetabh Kumar',
author_email='[email protected]',
description='Python SDK for accessing Dynamics APIs',
Expand Down

0 comments on commit ccdf5a2

Please sign in to comment.