ringcentral.http.client

  1#!/usr/bin/env python
  2# encoding: utf-8
  3import json
  4import urllib
  5import requests
  6
  7from .api_response import ApiResponse
  8from .api_exception import ApiException
  9from ..core import urlencode, iterator
 10
 11
 12class Client:
 13    def __init__(self):
 14        pass
 15
 16    def send(self, request):
 17        """
 18            Send the HTTP request and handle the response.
 19
 20            Args:
 21                request (obj): The HTTP request object.
 22
 23            Returns:
 24                obj: The HTTP response object.
 25
 26            Raises:
 27                ApiException: If an error occurs during the request or response handling.
 28        """
 29        response = None
 30
 31        try:
 32            prepared = request
 33            if isinstance(prepared, requests.models.Request): # not a prepared request
 34                prepared = request.prepare()
 35            response = self.load_response(prepared)
 36
 37            if response.ok():
 38                return response
 39            else:
 40                response.response().raise_for_status()
 41
 42        except Exception as e:
 43            if response is None:
 44                response = ApiResponse(request)
 45
 46            raise ApiException(response, e)
 47
 48    def load_response(self, request):
 49        # TODO Persist between requests?
 50        session = None
 51
 52        try:
 53            session = requests.sessions.Session()
 54            response = session.send(request)
 55            session.close()
 56
 57            return ApiResponse(request, response)
 58
 59        except Exception:
 60            if session:
 61                session.close()
 62            raise
 63
 64    def create_request(self, method='', url='', query_params=None, body=None, headers=None):
 65        """
 66            Create an HTTP request object.
 67
 68            Args:
 69                method (str): The HTTP method (e.g., GET, POST).
 70                url (str): The URL for the request.
 71                query_params (dict, optional): Dictionary containing query parameters.
 72                body (dict, optional): Request body data.
 73                headers (dict, optional): Request headers.
 74
 75            Returns:
 76                requests.Request: The HTTP request object.
 77
 78            """
 79        if query_params:
 80            if type(query_params) is dict:
 81                query = ""
 82                for key, value in  iter(query_params.items()):
 83                    if type(value) is list:
 84                        for k in value:
 85                            query += ("%s=%s&" % (key, k))
 86                    else:
 87                        query += ("%s=%s&" % (key, value))
 88                query = query[:-1]
 89            else:
 90                query = urlencode(query_params)
 91            if query:
 92                url = url + ('&' if url.find('?') > 0 else '?') + query
 93
 94        content_type = None
 95
 96        if headers is None:
 97            headers = {}
 98
 99        it = iterator(headers)
100
101        for key, value in it:
102            if key.lower().find('content-type') >= 0:
103                content_type = value
104            if key.lower().find('accept') >= 0:
105                headers['Accept'] = value
106
107        if content_type is None:
108            content_type = 'application/json'
109            headers['Content-Type'] = content_type
110
111        if content_type.lower().find('application/json') >= 0:
112            body = json.dumps(body) if body else None
113        elif content_type.lower().find('application/x-www-form-urlencoded') >= 0:
114            body = urlencode(body) if body else None
115
116        return requests.Request(method, url, headers=headers, data=body)