USING: accessors assocs kernel math math.parser namespaces make
sequences io io.sockets io.streams.string io.files io.timeouts
strings splitting calendar continuations accessors vectors
- math.order hashtables byte-arrays prettyprint destructors
+ math.order hashtables byte-arrays destructors
io.encodings
io.encodings.string
io.encodings.ascii
+ io.encodings.utf8
io.encodings.8-bit
io.encodings.binary
io.streams.duplex
- fry debugger summary ascii urls urls.encoding present
+ fry ascii urls urls.encoding present
http http.parsers ;
IN: http.client
M: post-data >post-data ;
- M: string >post-data "application/octet-stream" <post-data> ;
+ M: string >post-data utf8 encode "application/octet-stream" <post-data> ;
M: byte-array >post-data "application/octet-stream" <post-data> ;
- M: assoc >post-data assoc>query "application/x-www-form-urlencoded" <post-data> ;
+ M: assoc >post-data assoc>query ascii encode "application/x-www-form-urlencoded" <post-data> ;
M: f >post-data ;
[ >post-data ] change-post-data ;
: write-post-data ( request -- request )
- dup method>> [ "POST" = ] [ "PUT" = ] bi or [ dup post-data>> raw>> write ] when ;
+ dup method>> [ "POST" = ] [ "PUT" = ] bi or
+ [ dup post-data>> [ raw>> write ] when* ] when ;
: write-request ( request -- )
unparse-post-data
write-request-line
write-request-header
+ binary encode-output
write-post-data
flush
drop ;
ERROR: too-many-redirects ;
-<PRIVATE
+M: too-many-redirects summary
+ drop
+ [ "Redirection limit of " % max-redirects # " exceeded" % ] "" make ;
+
+DEFER: with-http-request
-DEFER: (with-http-request)
+<PRIVATE
SYMBOL: redirects
redirects get max-redirects < [
request get clone
swap "location" header redirect-url
- "GET" >>method swap (with-http-request)
+ "GET" >>method swap with-http-request
] [ too-many-redirects ] if ; inline recursive
: read-chunk-size ( -- n )
request get url>> url-addr ascii <client> drop
1 minutes over set-timeout ;
-: (with-http-request) ( request quot: ( chunk -- ) -- response )
+PRIVATE>
+
+: with-http-request ( request quot: ( chunk -- ) -- response )
swap
request [
<request-socket> [
[ do-redirect ] [ nip ] if
] with-variable ; inline recursive
-PRIVATE>
-
: success? ( code -- ? ) 200 299 between? ;
-ERROR: download-failed response ;
+ERROR: download-failed response data ;
-: check-response ( response -- response )
- dup code>> success? [ download-failed ] unless ;
+M: download-failed error.
+ "HTTP request failed:" print nl
+ [ response>> . ] [ data>> . ] bi ;
+
+: check-response* ( response data -- response data )
+ over code>> success? [ download-failed ] unless ;
-: with-http-request ( request quot -- response )
- (with-http-request) check-response ; inline
+: check-response ( response -- response )
+ f check-response* drop ;
: http-request ( request -- response data )
[ [ % ] with-http-request ] B{ } make
- over content-charset>> decode ;
+ over content-charset>> decode check-response* ;
+
+: <client-request> ( url -- request )
+ <request> swap >url ensure-port >>url ;
+
+: <client-data-request> ( data url -- request )
+ <client-request> swap >>post-data ;
: <get-request> ( url -- request )
- <request>
- "GET" >>method
- swap >url ensure-port >>url ;
+ <client-request> "GET" >>method ;
: http-get ( url -- response data )
<get-request> http-request ;
: with-http-get ( url quot -- response )
- [ <get-request> ] dip with-http-request ; inline
+ [ <get-request> ] dip with-http-request check-response ; inline
+
+: <delete-request> ( url -- request )
+ <client-request> "DELETE" >>method ;
+
+: http-delete ( url -- response data )
+ <delete-request> http-request ;
+
+: <trace-request> ( url -- request )
+ <client-request> "TRACE" >>method ;
+
+: http-trace ( url -- response data )
+ <trace-request> http-request ;
: download-name ( url -- name )
present file-name "?" split1 drop "/" ?tail drop ;
dup download-name download-to ;
: <post-request> ( post-data url -- request )
- <request>
- "POST" >>method
- swap >url ensure-port >>url
- swap >>post-data ;
+ <client-data-request> "POST" >>method ;
: http-post ( post-data url -- response data )
<post-request> http-request ;
+: <put-request> ( data url -- request )
+ <client-data-request> "PUT" >>method ;
+
+: http-put ( data url -- response data )
+ <put-request> http-request ;
++
+ USING: vocabs vocabs.loader ;
+
+ "debugger" vocab [ "http.client.debugger" require ] when