1212
1313class RestClient (object ):
1414
15- def __init__ (self , timeout = None , base_url = None ):
15+ def __init__ (self , timeout = None , base_url = None , requests_verify = None , requests_cert = None ):
1616 self .timeout = timeout
1717 self .base_url = base_url
18+ self .requests_verify = requests_verify
19+ self .requests_cert = requests_cert
1820
1921 def _base_url (self ):
2022 return self .base_url or Config .base_url
2123
2224 def _timeout (self ):
2325 return self .timeout or Config .timeout
2426
27+ def _requests_verify (self ):
28+ return self .requests_verify or Config .requests_verify
29+
30+ def _requests_cert (self ):
31+ return self .requests_cert or Config .requests_cert
32+
2533 def _log (self , action , url , ** kwargs ):
2634 ctx = {'timeout' : kwargs .get ('timeout' )}
2735 logger .debug (
@@ -32,6 +40,10 @@ def _log(self, action, url, **kwargs):
3240 def post (self , uri , ** kwargs ):
3341 if 'timeout' not in kwargs :
3442 kwargs ['timeout' ] = self ._timeout ()
43+ if 'requests_verify' not in kwargs :
44+ kwargs ['verify' ] = self ._requests_verify ()
45+ if 'requests_cert' not in kwargs :
46+ kwargs ['cert' ] = self ._requests_cert ()
3547 try :
3648 url = self ._base_url () + uri
3749 self ._log ("POST" , url , ** kwargs )
@@ -44,6 +56,10 @@ def post(self, uri, **kwargs):
4456 def get (self , uri , ** kwargs ):
4557 if 'timeout' not in kwargs :
4658 kwargs ['timeout' ] = self ._timeout ()
59+ if 'requests_verify' not in kwargs :
60+ kwargs ['verify' ] = self ._requests_verify ()
61+ if 'requests_cert' not in kwargs :
62+ kwargs ['cert' ] = self ._requests_cert ()
4763 try :
4864 url = self ._base_url () + uri
4965 self ._log ("GET" , url , ** kwargs )
@@ -56,6 +72,10 @@ def get(self, uri, **kwargs):
5672 def put (self , uri , ** kwargs ):
5773 if 'timeout' not in kwargs :
5874 kwargs ['timeout' ] = self ._timeout ()
75+ if 'requests_verify' not in kwargs :
76+ kwargs ['verify' ] = self ._requests_verify ()
77+ if 'requests_cert' not in kwargs :
78+ kwargs ['cert' ] = self ._requests_cert ()
5979 try :
6080 url = self ._base_url () + uri
6181 self ._log ("PUT" , url , ** kwargs )
@@ -68,6 +88,10 @@ def put(self, uri, **kwargs):
6888 def patch (self , uri , ** kwargs ): # pragma: no cover
6989 if 'timeout' not in kwargs :
7090 kwargs ['timeout' ] = self ._timeout ()
91+ if 'requests_verify' not in kwargs :
92+ kwargs ['verify' ] = self ._requests_verify ()
93+ if 'requests_cert' not in kwargs :
94+ kwargs ['cert' ] = self ._requests_cert ()
7195 try :
7296 url = self ._base_url () + uri
7397 self ._log ("PATCH" , url , ** kwargs )
@@ -80,6 +104,10 @@ def patch(self, uri, **kwargs): # pragma: no cover
80104 def delete (self , uri , ** kwargs ):
81105 if 'timeout' not in kwargs :
82106 kwargs ['timeout' ] = self ._timeout ()
107+ if 'requests_verify' not in kwargs :
108+ kwargs ['verify' ] = self ._requests_verify ()
109+ if 'requests_cert' not in kwargs :
110+ kwargs ['cert' ] = self ._requests_cert ()
83111 try :
84112 url = self ._base_url () + uri
85113 self ._log ("DELETE" , url , ** kwargs )
@@ -92,6 +120,10 @@ def delete(self, uri, **kwargs):
92120 def options (self , uri , ** kwargs ): # pragma: no cover
93121 if 'timeout' not in kwargs :
94122 kwargs ['timeout' ] = self ._timeout ()
123+ if 'requests_verify' not in kwargs :
124+ kwargs ['verify' ] = self ._requests_verify ()
125+ if 'requests_cert' not in kwargs :
126+ kwargs ['cert' ] = self ._requests_cert ()
95127 try :
96128 url = self ._base_url () + uri
97129 self ._log ("OPTIONS" , url , ** kwargs )
@@ -104,6 +136,10 @@ def options(self, uri, **kwargs): # pragma: no cover
104136 def head (self , uri , ** kwargs ): # pragma: no cover
105137 if 'timeout' not in kwargs :
106138 kwargs ['timeout' ] = self ._timeout ()
139+ if 'requests_verify' not in kwargs :
140+ kwargs ['verify' ] = self ._requests_verify ()
141+ if 'requests_cert' not in kwargs :
142+ kwargs ['cert' ] = self ._requests_cert ()
107143 try :
108144 url = self ._base_url () + uri
109145 self ._log ("HEAD" , url , ** kwargs )
0 commit comments