3030 True : 'https' ,
3131}
3232
33+
3334class BaseConnection (object ):
3435 """Base Connection Class."""
3536
@@ -69,15 +70,15 @@ def __init__(self, debug=False, method='GET',
6970
7071 self .base_list_nodes = []
7172 self .datetime_nodes = []
72-
73+
7374 self ._reset ()
7475
7576 def debug_callback (self , debug_type , debug_message ):
7677 log .debug ('type: ' + str (debug_type ) + ' message' + str (debug_message ))
7778
7879 def v (self , * args , ** kwargs ):
7980 return getValue (self .response .dict (), * args , ** kwargs )
80-
81+
8182 def getNodeText (self , nodelist ):
8283 return getNodeTextUtils (nodelist )
8384
@@ -103,12 +104,13 @@ def _add_prefix(self, nodes, verb):
103104 if verb :
104105 for i , v in enumerate (nodes ):
105106 if not nodes [i ].startswith (verb .lower ()):
106- nodes [i ] = "%sresponse.%s" % (verb .lower (), nodes [i ].lower ())
107+ nodes [i ] = "%sresponse.%s" % (
108+ verb .lower (), nodes [i ].lower ())
107109
108110 def execute (self , verb , data = None , list_nodes = [], verb_attrs = None , files = None ):
109111 "Executes the HTTP request."
110112 log .debug ('execute: verb=%s data=%s' % (verb , data ))
111-
113+
112114 self ._reset ()
113115
114116 self ._list_nodes += list_nodes
@@ -118,44 +120,44 @@ def execute(self, verb, data=None, list_nodes=[], verb_attrs=None, files=None):
118120 self ._list_nodes += self .base_list_nodes
119121
120122 self .build_request (verb , data , verb_attrs , files )
121- self .execute_request ()
123+ self .execute_request ()
122124
123125 if hasattr (self .response , 'content' ):
124126 self .process_response ()
125127 self .error_check ()
126128
127129 log .debug ('total time=%s' % (time .time () - self ._time ))
128130
129- return self .response
131+ return self .response
130132
131133 def build_request (self , verb , data , verb_attrs , files = None ):
132-
134+
133135 self .verb = verb
134136 self ._request_dict = data
135137 self ._request_id = uuid .uuid4 ()
136138
137139 url = self .build_request_url (verb )
138140
139141 headers = self .build_request_headers (verb )
140- headers .update ({'User-Agent' : UserAgent ,
142+ headers .update ({'User-Agent' : UserAgent ,
141143 'X-EBAY-SDK-REQUEST-ID' : str (self ._request_id )})
142-
144+
143145 # if we are adding files, we ensure there is no Content-Type header already defined
144146 # otherwise Request will use the existing one which is likely not to be multipart/form-data
145147 # data must also be a dict so we make it so if needed
146148
147149 requestData = self .build_request_data (verb , data , verb_attrs )
148150 if files :
149151 del (headers ['Content-Type' ])
150- if isinstance (requestData , basestring ): # pylint: disable-msg=E0602
151- requestData = {'XMLPayload' :requestData }
152+ if isinstance (requestData , basestring ): # pylint: disable-msg=E0602
153+ requestData = {'XMLPayload' : requestData }
152154
153155 request = Request (self .method ,
154- url ,
155- data = smart_encode_request_data (requestData ),
156- headers = headers ,
157- files = files ,
158- )
156+ url ,
157+ data = smart_encode_request_data (requestData ),
158+ headers = headers ,
159+ files = files ,
160+ )
159161
160162 self .request = request .prepare ()
161163
@@ -175,8 +177,8 @@ def build_request_url(self, verb):
175177
176178 def execute_request (self ):
177179
178- log .debug ("REQUEST (%s): %s %s" \
179- % (self ._request_id , self .request .method , self .request .url ))
180+ log .debug ("REQUEST (%s): %s %s"
181+ % (self ._request_id , self .request .method , self .request .url ))
180182 log .debug ('headers=%s' % self .request .headers )
181183 log .debug ('body=%s' % self .request .body )
182184
@@ -185,18 +187,18 @@ def execute_request(self):
185187 return None
186188
187189 self .response = self .session .send (self .request ,
188- verify = True ,
189- proxies = self .proxies ,
190- timeout = self .timeout ,
191- allow_redirects = True
192- )
190+ verify = True ,
191+ proxies = self .proxies ,
192+ timeout = self .timeout ,
193+ allow_redirects = True
194+ )
193195
194196 log .debug ('RESPONSE (%s):' % self ._request_id )
195197 log .debug ('elapsed time=%s' % self .response .elapsed )
196198 log .debug ('status code=%s' % self .response .status_code )
197199 log .debug ('headers=%s' % self .response .headers )
198- log .debug ('content=%s' % self .response .text )
199-
200+ log .debug ('content=%s' % self .response .text )
201+
200202 def process_response (self , parse_response = True ):
201203 """Post processing of the response"""
202204
@@ -208,7 +210,7 @@ def process_response(self, parse_response=True):
208210
209211 # set for backward compatibility
210212 self ._response_content = self .response .content
211-
213+
212214 if self .response .status_code != 200 :
213215 self ._response_error = self .response .reason
214216
@@ -243,7 +245,8 @@ def response_soup(self):
243245 from bs4 import BeautifulStoneSoup
244246 except ImportError :
245247 from BeautifulSoup import BeautifulStoneSoup
246- log .warn ('DeprecationWarning: BeautifulSoup 3 or earlier is deprecated; install bs4 instead\n ' )
248+ log .warn (
249+ 'DeprecationWarning: BeautifulSoup 3 or earlier is deprecated; install bs4 instead\n ' )
247250
248251 self ._response_soup = BeautifulStoneSoup (
249252 smart_decode (self .response_content )
@@ -270,22 +273,25 @@ def response_dom(self):
270273 regex = re .compile (b'xmlns="[^"]+"' )
271274 content = regex .sub (b'' , self .response .content )
272275 else :
273- content = "<%sResponse></%sResponse>" % (self .verb , self .verb )
276+ content = "<%sResponse></%sResponse>" % (
277+ self .verb , self .verb )
274278
275279 dom = parseString (content )
276280 self ._response_dom = dom .getElementsByTagName (
277281 self .verb + 'Response' )[0 ]
278282
279283 except ExpatError as e :
280- raise ConnectionResponseError ("Invalid Verb: %s (%s)" % (self .verb , e ), self .response )
284+ raise ConnectionResponseError (
285+ "Invalid Verb: %s (%s)" % (self .verb , e ), self .response )
281286 except IndexError :
282287 self ._response_dom = dom
283288
284289 return self ._response_dom
285290
286291 def response_dict (self ):
287292 "Returns the response dictionary."
288- log .warn ('response_dict() DEPRECATED, use response.dict() or response.reply instead' )
293+ log .warn (
294+ 'response_dict() DEPRECATED, use response.dict() or response.reply instead' )
289295
290296 return self .response .reply
291297
@@ -330,12 +336,12 @@ def error(self):
330336 if len (error_array ) > 0 :
331337 # Force all errors to be unicode in a proper way
332338 error_array = [smart_decode (smart_encode (e )) for e in error_array ]
333- error_string = u"{verb}: {message}" .format (verb = self .verb , message = u", " .join (error_array ))
339+ error_string = u"{verb}: {message}" .format (
340+ verb = self .verb , message = u", " .join (error_array ))
334341
335342 return error_string
336343
337344 return None
338345
339346 def opendoc (self ):
340347 webbrowser .open (self .config .get ('doc_url' ))
341-
0 commit comments