18
18
from .utils import *
19
19
from .parallel import *
20
20
from functools import wraps
21
-
21
+ from pprint import pformat
22
22
import json ,urllib ,contextlib
23
23
import socket ,urllib .request ,http ,urllib
24
24
from contextlib import contextmanager ,ExitStack
25
- from urllib .request import Request ,urlretrieve ,install_opener
25
+ from urllib .request import Request ,urlretrieve ,install_opener , HTTPErrorProcessor
26
26
from urllib .error import HTTPError ,URLError
27
27
from urllib .parse import urlencode ,urlparse ,urlunparse
28
28
from http .client import InvalidURL
@@ -104,7 +104,11 @@ def urlopen(url, data=None, headers=None, timeout=None, **kwargs):
104
104
if data is not None :
105
105
if not isinstance (data , (str ,bytes )): data = urlencode (data )
106
106
if not isinstance (data , bytes ): data = data .encode ('ascii' )
107
- return urlopener ().open (urlwrap (url , data = data , headers = headers ), timeout = timeout )
107
+ try : return urlopener ().open (urlwrap (url , data = data , headers = headers ), timeout = timeout )
108
+ except HTTPError as e :
109
+ e .msg += f"\n ====Error Body====\n { pformat (json .loads (e .read ()))} "
110
+ raise e
111
+ except Exception as e : raise e
108
112
109
113
# %% ../nbs/03b_net.ipynb 18
110
114
def urlread (url , data = None , headers = None , decode = True , return_json = False , return_headers = False , timeout = None , ** kwargs ):
@@ -119,13 +123,13 @@ def urlread(url, data=None, headers=None, decode=True, return_json=False, return
119
123
if return_json : res = loads (res )
120
124
return (res ,dict (hdrs )) if return_headers else res
121
125
122
- # %% ../nbs/03b_net.ipynb 19
126
+ # %% ../nbs/03b_net.ipynb 20
123
127
def urljson (url , data = None , timeout = None ):
124
128
"Retrieve `url` and decode json"
125
129
res = urlread (url , data = data , timeout = timeout )
126
130
return json .loads (res ) if res else {}
127
131
128
- # %% ../nbs/03b_net.ipynb 21
132
+ # %% ../nbs/03b_net.ipynb 22
129
133
def urlcheck (url , timeout = 10 ):
130
134
if not url : return True
131
135
try :
@@ -134,12 +138,12 @@ def urlcheck(url, timeout=10):
134
138
except socket .timeout : return False
135
139
except InvalidURL : return False
136
140
137
- # %% ../nbs/03b_net.ipynb 22
141
+ # %% ../nbs/03b_net.ipynb 23
138
142
def urlclean (url ):
139
143
"Remove fragment, params, and querystring from `url` if present"
140
144
return urlunparse (urlparse (str (url ))[:3 ]+ ('' ,'' ,'' ))
141
145
142
- # %% ../nbs/03b_net.ipynb 24
146
+ # %% ../nbs/03b_net.ipynb 25
143
147
def urlretrieve (url , filename = None , reporthook = None , data = None , timeout = None ):
144
148
"Same as `urllib.request.urlretrieve` but also works with `Request` objects"
145
149
with contextlib .closing (urlopen (url , data , timeout = timeout )) as fp :
@@ -165,43 +169,43 @@ def urlretrieve(url, filename=None, reporthook=None, data=None, timeout=None):
165
169
raise ContentTooShortError (f"retrieval incomplete: got only { read } out of { size } bytes" , headers )
166
170
return filename ,headers
167
171
168
- # %% ../nbs/03b_net.ipynb 25
172
+ # %% ../nbs/03b_net.ipynb 26
169
173
def urldest (url , dest = None ):
170
174
name = urlclean (Path (url ).name )
171
175
if dest is None : dest = name
172
176
dest = Path (dest )
173
177
return dest / name if dest .is_dir () else dest
174
178
175
- # %% ../nbs/03b_net.ipynb 26
179
+ # %% ../nbs/03b_net.ipynb 27
176
180
def urlsave (url , dest = None , reporthook = None , timeout = None ):
177
181
"Retrieve `url` and save based on its name"
178
182
dest = urldest (url , dest )
179
183
dest .parent .mkdir (parents = True , exist_ok = True )
180
184
nm ,msg = urlretrieve (url , dest , reporthook , timeout = timeout )
181
185
return nm
182
186
183
- # %% ../nbs/03b_net.ipynb 28
187
+ # %% ../nbs/03b_net.ipynb 29
184
188
def urlvalid (x ):
185
189
"Test if `x` is a valid URL"
186
190
return all (getattrs (urlparse (str (x )), 'scheme' , 'netloc' ))
187
191
188
- # %% ../nbs/03b_net.ipynb 30
192
+ # %% ../nbs/03b_net.ipynb 31
189
193
def urlrequest (url , verb , headers = None , route = None , query = None , data = None , json_data = True ):
190
194
"`Request` for `url` with optional route params replaced by `route`, plus `query` string, and post `data`"
191
195
if route : url = url .format (** route )
192
196
if query : url += '?' + urlencode (query )
193
197
if isinstance (data ,dict ): data = (json .dumps if json_data else urlencode )(data ).encode ('ascii' )
194
198
return Request (url , headers = headers or {}, data = data or None , method = verb .upper ())
195
199
196
- # %% ../nbs/03b_net.ipynb 33
200
+ # %% ../nbs/03b_net.ipynb 34
197
201
@patch
198
202
def summary (self :Request , skip = None )-> dict :
199
203
"Summary containing full_url, headers, method, and data, removing `skip` from headers"
200
204
res = L ('full_url' ,'method' ,'data' ).map_dict (partial (getattr ,self ))
201
205
res ['headers' ] = {k :v for k ,v in self .headers .items () if k not in listify (skip )}
202
206
return res
203
207
204
- # %% ../nbs/03b_net.ipynb 35
208
+ # %% ../nbs/03b_net.ipynb 36
205
209
def urlsend (url , verb , headers = None , route = None , query = None , data = None , json_data = True ,
206
210
return_json = True , return_headers = False , debug = None ):
207
211
"Send request with `urlrequest`, converting result to json if `return_json`"
@@ -213,7 +217,7 @@ def urlsend(url, verb, headers=None, route=None, query=None, data=None, json_dat
213
217
214
218
return urlread (req , return_json = return_json , return_headers = return_headers )
215
219
216
- # %% ../nbs/03b_net.ipynb 36
220
+ # %% ../nbs/03b_net.ipynb 37
217
221
def do_request (url , post = False , headers = None , ** data ):
218
222
"Call GET or json-encoded POST on `url`, depending on `post`"
219
223
if data :
@@ -223,13 +227,13 @@ def do_request(url, post=False, headers=None, **data):
223
227
data = None
224
228
return urljson (Request (url , headers = headers , data = data or None ))
225
229
226
- # %% ../nbs/03b_net.ipynb 37
230
+ # %% ../nbs/03b_net.ipynb 38
227
231
def _socket_det (port ,host ,dgram ):
228
232
if isinstance (port ,int ): family ,addr = socket .AF_INET ,(host or socket .gethostname (),port )
229
233
else : family ,addr = socket .AF_UNIX ,port
230
234
return family ,addr ,(socket .SOCK_STREAM ,socket .SOCK_DGRAM )[dgram ]
231
235
232
- # %% ../nbs/03b_net.ipynb 38
236
+ # %% ../nbs/03b_net.ipynb 39
233
237
def start_server (port , host = None , dgram = False , reuse_addr = True , n_queue = None ):
234
238
"Create a `socket` server on `port`, with optional `host`, of type `dgram`"
235
239
listen_args = [n_queue ] if n_queue else []
@@ -243,7 +247,7 @@ def start_server(port, host=None, dgram=False, reuse_addr=True, n_queue=None):
243
247
s .listen (* listen_args )
244
248
return s
245
249
246
- # %% ../nbs/03b_net.ipynb 40
250
+ # %% ../nbs/03b_net.ipynb 41
247
251
def start_client (port , host = None , dgram = False ):
248
252
"Create a `socket` client on `port`, with optional `host`, of type `dgram`"
249
253
family ,addr ,typ = _socket_det (port ,host ,dgram )
0 commit comments