http.bend fails

raw source on the hub · import 0x575208cf32f35c10d64d398769aef1bc/http.bend as Http

4 imports

import Base
import ./wire.bend as Wire
import ./dns/dns.bend as Dns
import ./url/url.bend as Url

Types

type Req source · line 13 · raw

Data

Req

@method:String -> @path:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> Req

type Res source · line 16 · raw

Data

Res

@status:U32 -> @headers:Map<&2, List<&2, String>> -> @body:String -> Res

type Err source · line 21 · raw

Data

Why fetch failed. Wire errors keep the errno and the text the effect already had. ponytail: 60 and 110 are ETIMEDOUT on macOS and Linux. Windows is out of scope.

ErrUrl
```
Err
```
ErrDns
```
Err
```
ErrConnect
```
@code:U32 -> @why:String -> Err
```
ErrTls
```
@code:U32 -> @why:String -> Err
```
ErrRead
```
@code:U32 -> @why:String -> Err
```
ErrWrite
```
@code:U32 -> @why:String -> Err
```
ErrTimeout
```
Err
```
ErrRedirect
```
Err
```
ErrBad
```
Err
```

type Fields source · line 45 · raw

Data

FieldsBad
```
Fields
```
FieldsOk
```
@m:Map<&2, List<&2, String>> -> Fields
```

type HexSize source · line 279 · raw

Data

HexSize
```
@n:U32 -> @rest:String -> HexSize
```

type Step source · line 282 · raw

Data

StepFail
```
Step
```
StepDone
```
@body:String -> Step
```
StepNext
```
@rest:String -> @acc:String -> Step
```

type Took source · line 384 · raw

Data

Took
```
@racc:String -> @rest:String -> Took
```

type Frame source · line 569 · raw

Data

Bad: never a message. More: a valid prefix; read on. Done: a whole response.

FrameBad
```
Frame
```
FrameMore
```
Frame
```
FrameDone
```
@res:Res -> Frame
```

type Need source · line 686 · raw

Data

When can a response be whole? fetch uses this to skip re-framing a growing buffer after every read. Head: the header block is not in yet. Len: the message is total bytes long. Chunk: it ends with CRLF CRLF. Close: only at close. Now: frame it at once (no body, or already malformed).

NeedHead
```
Need
```
NeedLen
```
@total:Nat -> Need
```
NeedChunk
```
Need
```
NeedClose
```
Need
```
NeedNow
```
Need
```

type Hop source · line 851 · raw

Data

One request to make: headers are already lowercased (see req.put).

Hop

@method:String -> @url:0x575208cf32f35c10d64d398769aef1bc/url/url.Abs -> @headers:Map<&2, List<&2, String>> -> @body:String -> Hop

type Rd source · line 941 · raw

Data

Read state: bytes so far reversed (appends are cheap), their count, the framing hint, the last verdict, and a wire error if the read itself failed.

Rd

@rbuf:String -> @n:Nat -> @need:Need -> @f:Frame -> @err:Maybe<&2, Err> -> Rd

type Next source · line 1100 · raw

Data

NDone
```
@res:Result<&2, &2, Err, Res> -> Next
```
NStop
```
Next
```
NGo
```
@left:Nat -> @hop:Hop -> Next
```

Definitions

def err.late source · line 32 · raw

@+code:U32 -> Bool

def err.pick source · line 35 · raw

@e:Err -> @late:Bool -> Err

def err.or_late source · line 42 · raw

@code:U32 -> @e:Err -> Err

def empty source · line 51 · raw

Map<&2, List<&2, String>>

One list per field name, in arrival order. header() is the first value. Set-Cookie is never joined. Encode writes one line per value.

def fields.of source · line 54 · raw

@r:Pair(Map<&2, List<&2, String>>, List<&2, String>) -> List<&2, String>

def fields source · line 58 · raw

@+h:Map<&2, List<&2, String>> -> @k:String -> List<&2, String>

@xs:List<&2, String> -> String

def header source · line 68 · raw

@+h:Map<&2, List<&2, String>> -> @k:String -> String

def field.last source · line 71 · raw

@xs:List<&2, String> -> String

@+h:Map<&2, List<&2, String>> -> @k:String -> String

Transfer-Encoding is a list; chunked, when present, is the last coding.

def snoc source · line 84 · raw

@xs:List<&2, String> -> @v:String -> List<&2, String>

def set source · line 91 · raw

@m:Map<&2, List<&2, String>> -> @k:String -> @v:String -> Map<&2, List<&2, String>>

def add source · line 94 · raw

@+m:Map<&2, List<&2, String>> -> @+k:String -> @v:String -> Map<&2, List<&2, String>>

def sanitize.cons source · line 97 · raw

@ch:Char -> @rest:String -> @drop:Bool -> String

def sanitize source · line 104 · raw

@s:String -> String

def drop_cr.if source · line 111 · raw

@+s:String -> @cr:Bool -> String

def drop_cr source · line 118 · raw

@+s:String -> String

def take_sp.go source · line 121 · raw

@s:String -> @+acc:String -> Pair(String, String)

def take_sp source · line 128 · raw

@s:String -> Pair(String, String)

def start_line.ver source · line 131 · raw

@m:String -> @pv:Pair(String, String) -> Pair(String, Pair(String, String))

def start_line.rest source · line 135 · raw

@mr:Pair(String, String) -> Pair(String, Pair(String, String))

def start_line source · line 139 · raw

@s:String -> Pair(String, Pair(String, String))

def split_at_blank.go source · line 142 · raw

@s:String -> @e:Bool -> @w:U32 -> @acc:String -> Pair(String, String)

def split_at_blank source · line 154 · raw

@s:String -> Pair(String, String)

def split_colon.go source · line 157 · raw

@s:String -> @+acc:String -> Pair(String, String)

def split_colon source · line 164 · raw

@s:String -> Pair(String, String)

def has_header.of source · line 167 · raw

@r:Pair(Map<&2, List<&2, String>>, Bool) -> Bool

def has_header source · line 171 · raw

@+h:Map<&2, List<&2, String>> -> @k:String -> Bool

def folded source · line 174 · raw

@+line:String -> Bool

def tracked source · line 177 · raw

@+k:String -> Bool

def fields_put.dup source · line 180 · raw

@m:Map<&2, List<&2, String>> -> @k:String -> @v:String -> @bad:Bool -> Fields

def fields_put.key source · line 187 · raw

@+m:Map<&2, List<&2, String>> -> @+k:String -> @v:String -> Fields

def fields_put.kv source · line 190 · raw

@m:Map<&2, List<&2, String>> -> @kv:Pair(String, String) -> Fields

def fields_put.fold source · line 194 · raw

@m:Map<&2, List<&2, String>> -> @line:String -> @fold:Bool -> Fields

def fields_put.empty source · line 201 · raw

@m:Map<&2, List<&2, String>> -> @+line:String -> @e:Bool -> Fields

def fields_put.ok source · line 208 · raw

@m:Map<&2, List<&2, String>> -> @+line:String -> Fields

def fields_put source · line 211 · raw

@acc:Fields -> @line:String -> Fields

def parse.headers.done source · line 218 · raw

@acc:Fields -> Maybe<&2, Map<&2, List<&2, String>>>

def parse.headers source · line 225 · raw

@xs:List<&2, String> -> @acc:Fields -> Maybe<&2, Map<&2, List<&2, String>>>

def parse_u32.digit source · line 232 · raw

@+c:U32 -> Bool

def parse_u32.add source · line 235 · raw

@acc:U32 -> @c:U32 -> U32

def parse_u32.done source · line 238 · raw

@acc:U32 -> @bad:Bool -> Maybe<&2, U32>

def parse_u32.go source · line 245 · raw

@s:String -> @acc:U32 -> @bad:Bool -> Maybe<&2, U32>

def parse_u32 source · line 252 · raw

@s:String -> Maybe<&2, U32>

def parse.take.if source · line 261 · raw

@+rest:String -> @+k:Nat -> @short:Bool -> Maybe<&2, String>

def parse.take.have source · line 269 · raw

@+rest:String -> @+k:Nat -> Maybe<&2, String>

RFC 9112 §8: fewer bytes than Content-Length is an incomplete message.

def parse.take source · line 272 · raw

@rest:String -> @n:Maybe<&2, U32> -> Maybe<&2, String>

def is_hex source · line 287 · raw

@+c:U32 -> Bool

def hexv source · line 290 · raw

@+c:U32 -> U32

def chunk.lf1 source · line 293 · raw

@r:String -> @n:U32 -> @lf:Bool -> Maybe<&2, HexSize>

def chunk.lf source · line 300 · raw

@t:String -> @n:U32 -> Maybe<&2, HexSize>

def chunk.ext.go source · line 311 · raw

@t:String -> @+c:U32 -> @+n:U32 -> @stop:Bool -> Maybe<&2, HexSize>

def chunk.ext source · line 323 · raw

@s:String -> @n:U32 -> Maybe<&2, HexSize>

RFC 9112 §7.1.1: recipients ignore unknown chunk extensions; a bare LF is not CRLF.

def chunk.size.end source · line 330 · raw

@+c:U32 -> @+t:String -> @+n:U32 -> @seen:Bool -> Maybe<&2, HexSize>

def chunk.digit source · line 338 · raw

@+c:U32 -> @+acc:U32 -> Bool

A size that would overflow 32 bits ends the digits, and size.end then refuses it.

def chunk.size.go source · line 341 · raw

@t:String -> @+c:U32 -> @+acc:U32 -> @seen:Bool -> @digit:Bool -> Maybe<&2, HexSize>

def chunk.size source · line 353 · raw

@s:String -> Maybe<&2, HexSize>

def chunk.trailer.ok source · line 362 · raw

@racc:String -> @ok:Bool -> Step

def chunk.trailer.end source · line 369 · raw

@hb:Pair(String, String) -> @racc:String -> Step

def chunk.trailer.if source · line 373 · raw

@rest:String -> @racc:String -> @blank:Bool -> Step

def chunk.trailer source · line 381 · raw

@+rest:String -> @racc:String -> Step

ponytail: trailer fields are dropped unparsed (§7.1.2 allows discarding)

def take.exact source · line 388 · raw

@s:String -> @k:Nat -> @racc:String -> Maybe<&2, Took>

Moves exactly k chars onto racc; None if s runs out first. O(k), no length scan.

def chunk.crlf.if source · line 403 · raw

@racc:String -> @+after:String -> @ok:Bool -> Step

def chunk.data source · line 410 · raw

@m:Maybe<&2, Took> -> Step

def chunk.step.n source · line 417 · raw

@+n:U32 -> @rest:String -> @racc:String -> @zero:Bool -> Step

def chunk.step.got source · line 424 · raw

@got:Maybe<&2, HexSize> -> @racc:String -> Step

def chunk.step source · line 431 · raw

@s:String -> @racc:String -> Step

def chunk.go source · line 434 · raw

@fuel:Nat -> @st:Step -> Maybe<&2, String>

def chunk.decode source · line 448 · raw

@+s:String -> Maybe<&2, String>

Every chunk eats at least 3 bytes, so length(s) steps always suffice.

def parse.body.cl source · line 451 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> @hascl:Bool -> Maybe<&2, String>

def parse.body.chunked.eq source · line 458 · raw

@rest:String -> @ok:Bool -> Maybe<&2, String>

def parse.body.chunked.val source · line 465 · raw

@te:String -> @rest:String -> Maybe<&2, String>

def parse.body.chunked source · line 468 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> @hascl:Bool -> Maybe<&2, String>

def parse.body.te source · line 475 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> @te:Bool -> Maybe<&2, String>

def parse.body source · line 482 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> Maybe<&2, String>

def parse.finish source · line 485 · raw

@method:String -> @path:String -> @h:Map<&2, List<&2, String>> -> @body:Maybe<&2, String> -> Maybe<&2, Req>

def parse.host source · line 492 · raw

@method:String -> @path:String -> @+h:Map<&2, List<&2, String>> -> @rest:String -> @has:Bool -> Maybe<&2, Req>

def parse.fields source · line 499 · raw

@method:String -> @path:String -> @rest:String -> @fs:Maybe<&2, Map<&2, List<&2, String>>> -> Maybe<&2, Req>

def target_ok source · line 506 · raw

@+p:String -> Bool

def parse.target source · line 509 · raw

@method:String -> @+path:String -> @headers:List<&2, String> -> @rest:String -> @ok:Bool -> Maybe<&2, Req>

def parse.ver source · line 516 · raw

@method:String -> @+path:String -> @v:String -> @headers:List<&2, String> -> @rest:String -> @ok:Bool -> Maybe<&2, Req>

def parse.empty_method source · line 523 · raw

@method:String -> @path:String -> @+v:String -> @headers:List<&2, String> -> @rest:String -> @empty:Bool -> Maybe<&2, Req>

def parse.start3 source · line 530 · raw

@mpv:Pair(String, Pair(String, String)) -> @headers:List<&2, String> -> @rest:String -> Maybe<&2, Req>

def parse.lines source · line 534 · raw

@xs:List<&2, String> -> @rest:String -> Maybe<&2, Req>

def parse.head source · line 541 · raw

@head:String -> @rest:String -> Maybe<&2, Req>

def parse.of source · line 544 · raw

@hb:Pair(String, String) -> Maybe<&2, Req>

def parse source · line 548 · raw

@raw:String -> Maybe<&2, Req>

def parse.res.cl source · line 551 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> @hascl:Bool -> Maybe<&2, String>

def parse.res.te source · line 558 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> @te:Bool -> Maybe<&2, String>

def parse.res.body source · line 565 · raw

@+h:Map<&2, List<&2, String>> -> @rest:String -> Maybe<&2, String>

def frame.cut source · line 575 · raw

@closed:Bool -> Frame

RFC 9112 §8: a message cut short by close is incomplete, not valid.

def frame.wait source · line 582 · raw

@res:Res -> @wait:Bool -> Frame

def frame.done source · line 589 · raw

@status:U32 -> @h:Map<&2, List<&2, String>> -> @body:Maybe<&2, String> -> @+closed:Bool -> @open:Bool -> Frame

def frame.open source · line 597 · raw

@+h:Map<&2, List<&2, String>> -> Bool

RFC 9112 §6.3 (8): no TE and no CL ⇒ the body runs until the server closes.

def frame.nobody source · line 602 · raw

@+status:U32 -> @head:Bool -> Bool

RFC 9112 §6.3 (1): HEAD, 1xx, 204 and 304 responses end at the blank line. ponytail: 1xx is returned as final; skip interim responses if a server sends 103

def frame.status source · line 605 · raw

@status:U32 -> @+h:Map<&2, List<&2, String>> -> @rest:String -> @closed:Bool -> @nobody:Bool -> Frame

def parse.res.fields source · line 612 · raw

@+status:U32 -> @rest:String -> @fs:Maybe<&2, Map<&2, List<&2, String>>> -> @closed:Bool -> @head:Bool -> Frame

def parse.res.num source · line 619 · raw

@code:Maybe<&2, U32> -> @headers:List<&2, String> -> @rest:String -> @closed:Bool -> @head:Bool -> Frame

def parse.res.ver source · line 626 · raw

@code:String -> @headers:List<&2, String> -> @rest:String -> @closed:Bool -> @head:Bool -> @ok:Bool -> Frame

def parse.res.start3 source · line 633 · raw

@mpv:Pair(String, Pair(String, String)) -> @headers:List<&2, String> -> @rest:String -> @closed:Bool -> @head:Bool -> Frame

def parse.res.lines source · line 637 · raw

@xs:List<&2, String> -> @rest:String -> @closed:Bool -> @head:Bool -> Frame

def parse.res.blank source · line 644 · raw

@hd:String -> @rest:String -> @+closed:Bool -> @head:Bool -> @ok:Bool -> Frame

def parse.res.of source · line 651 · raw

@hb:Pair(String, String) -> @closed:Bool -> @head:Bool -> Frame

def frame source · line 656 · raw

@raw:String -> @closed:Bool -> @head:Bool -> Frame

frame(bytes so far, server closed?, request was HEAD?)

def frame.res source · line 659 · raw

@f:Frame -> Maybe<&2, Res>

def parse_res source · line 668 · raw

@raw:String -> Maybe<&2, Res>

def res_fields.res source · line 671 · raw

@res:Res -> @k:String -> List<&2, String>

def res_fields source · line 675 · raw

@m:Maybe<&2, Res> -> @k:String -> List<&2, String>

def need.cl source · line 693 · raw

@hlen:Nat -> @n:Maybe<&2, U32> -> Need

def need.framing source · line 700 · raw

@+h:Map<&2, List<&2, String>> -> @hlen:Nat -> @te:Bool -> @cl:Bool -> Need

def need.fields source · line 711 · raw

@hlen:Nat -> @nobody:Bool -> @fs:Maybe<&2, Map<&2, List<&2, String>>> -> Need

def need.num source · line 722 · raw

@code:Maybe<&2, U32> -> @headers:List<&2, String> -> @hlen:Nat -> @head:Bool -> Need

def need.start3 source · line 729 · raw

@mpv:Pair(String, Pair(String, String)) -> @headers:List<&2, String> -> @hlen:Nat -> @head:Bool -> Need

def need.lines source · line 733 · raw

@xs:List<&2, String> -> @hlen:Nat -> @head:Bool -> Need

def need.blank source · line 740 · raw

@+hd:String -> @head:Bool -> @ok:Bool -> Need

def need.of source · line 747 · raw

@hb:Pair(String, String) -> @head:Bool -> Need

def need source · line 752 · raw

@raw:String -> @head:Bool -> Need

A hint only: frame() stays the judge of every byte.

def res_body.res source · line 755 · raw

@res:Res -> String

def res_body source · line 759 · raw

@m:Maybe<&2, Res> -> String

def got_body.req source · line 766 · raw

@req:Req -> String

def got_body source · line 770 · raw

@m:Maybe<&2, Req> -> String

def body.of source · line 777 · raw

@hb:Pair(String, String) -> String

def body source · line 781 · raw

@s:String -> String

def headers_lines source · line 784 · raw

@+k:String -> @vs:List<&2, String> -> @acc:String -> String

def headers_block.go source · line 791 · raw

@xs:List<&2, Sigma<&2, &2, String, _ => List<&2, String>>> -> @acc:String -> String

def headers_block source · line 798 · raw

@h:Map<&2, List<&2, String>> -> String

def response source · line 801 · raw

@status:U32 -> @headers:Map<&2, List<&2, String>> -> @body:String -> String

def nat_u32 source · line 804 · raw

@n:Nat -> U32

def encode source · line 811 · raw

@r:Res -> String

def request source · line 815 · raw

@method:String -> @path:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> String

def req.reserved source · line 818 · raw

@+k:String -> Bool

def req.put.one source · line 821 · raw

@m:Map<&2, List<&2, String>> -> @+k:String -> @vs:List<&2, String> -> @skip:Bool -> Map<&2, List<&2, String>>

def req.put source · line 828 · raw

@xs:List<&2, Sigma<&2, &2, String, _ => List<&2, String>>> -> @m:Map<&2, List<&2, String>> -> Map<&2, List<&2, String>>

def req.cl source · line 837 · raw

@+m:Map<&2, List<&2, String>> -> @+method:String -> @+body:String -> Map<&2, List<&2, String>>

RFC 9110 §8.6: no Content-Length on a bodiless request whose method gives a body no meaning.

def encode_req source · line 843 · raw

@+method:String -> @target:String -> @host:String -> @headers:Map<&2, List<&2, String>> -> @+body:String -> String

Caller headers are lowercased so they cannot duplicate ours; host, connection, content-length and transfer-encoding are always ours (no smuggling through them).

def redirect.code source · line 854 · raw

@+s:U32 -> Bool

def redirect.origin source · line 857 · raw

@a:0x575208cf32f35c10d64d398769aef1bc/url/url.Abs -> String

def redirect.del source · line 861 · raw

@ks:List<&2, String> -> @m:Map<&2, List<&2, String>> -> Map<&2, List<&2, String>>

def redirect.hdrs source · line 868 · raw

@+h:Map<&2, List<&2, String>> -> @drop:Bool -> @cross:Bool -> Map<&2, List<&2, String>>

def redirect.to source · line 875 · raw

@+status:U32 -> @+method:String -> @+from:0x575208cf32f35c10d64d398769aef1bc/url/url.Abs -> @headers:Map<&2, List<&2, String>> -> @+body:String -> @next:Maybe<&2, 0x575208cf32f35c10d64d398769aef1bc/url/url.Abs> -> Maybe<&2, Hop>

303 turns any method but HEAD into GET; 301 and 302 turn POST into GET; 307 and 308 keep method and body. A GET carries no body or body headers. Credentials do not follow a hop to another origin.

def redirect.hop source · line 883 · raw

@status:U32 -> @h:Hop -> @loc:String -> Maybe<&2, Hop>

def redirect.if source · line 887 · raw

@status:U32 -> @h:Hop -> @loc:String -> @ok:Bool -> Maybe<&2, Hop>

def redirect source · line 895 · raw

@+status:U32 -> @+headers:Map<&2, List<&2, String>> -> @h:Hop -> Maybe<&2, Hop>

The next request after a response, or None when it is not a redirect we follow.

def io.recv source · line 899 · raw

@tls:Bool -> @s:Socket -> @max:U32 -> @ms:U32 -> IO(Pair(Socket, Result<&1, &1, Pair(U32, String), String>))

Transport: plain TCP or TLS over the same socket.

def io.send source · line 906 · raw

@tls:Bool -> @s:Socket -> @data:String -> IO(Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>))

def io.close source · line 913 · raw

@tls:Bool -> @s:Socket -> IO(Unit)

def fetch.close source · line 920 · raw

@tls:Bool -> @s:Socket -> @r:Result<&2, &2, Err, Res> -> IO(Result<&2, &2, Err, Res>)

def fetch.fail source · line 925 · raw

@e:Err -> IO(Result<&2, &2, Err, Res>)

def fetch.cap source · line 928 · raw

@f:Frame -> @over:Bool -> Frame

def fetch.max source · line 936 · raw

Nat

Untrusted servers must not grow the buffer without bound.

def fetch.need source · line 945 · raw

@hint:Need -> @+rbuf:String -> @head:Bool -> Need

The hint is worked out once, when the header block has arrived.

def fetch.gate source · line 960 · raw

@closed:Bool -> @need:Need -> @+n:Nat -> @+got:String -> Bool

Could the buffer hold a whole response now? A yes may be wrong (frame then says More); a no must never be.

def fetch.try source · line 977 · raw

@gate:Bool -> @rbuf:String -> @closed:Bool -> @head:Bool -> Frame

def fetch.step source · line 984 · raw

@+head:Bool -> @s:Socket -> @rd:Rd -> @+got:String -> @+closed:Bool -> Pair(Socket, Rd)

def fetch.wire source · line 991 · raw

@s:Socket -> @rd:Rd -> @+code:U32 -> @why:String -> Pair(Socket, Rd)

def fetch.next.go source · line 996 · raw

@+head:Bool -> @s:Socket -> @rd:Rd -> @r:Result<&1, &1, Pair(U32, String), String> -> Pair(Socket, Rd)

def fetch.next source · line 1003 · raw

@head:Bool -> @rd:Rd -> @m:Pair(Socket, Result<&1, &1, Pair(U32, String), String>) -> Pair(Socket, Rd)

def fetch.bad source · line 1007 · raw

@tls:Bool -> @s:Socket -> @e:Maybe<&2, Err> -> IO(Result<&2, &2, Err, Res>)

def fetch.sent source · line 1029 · raw

@head:Bool -> @tls:Bool -> @ms:U32 -> @m:Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>) -> IO(Result<&2, &2, Err, Res>)

def fetch.send source · line 1037 · raw

@head:Bool -> @+tls:Bool -> @ms:U32 -> @s:Socket -> @wire:String -> IO(Result<&2, &2, Err, Res>)

def fetch.shook source · line 1043 · raw

@head:Bool -> @ms:U32 -> @wire:String -> @m:Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>) -> IO(Result<&2, &2, Err, Res>)

A failed handshake is an error, never plaintext.

def fetch.secure source · line 1051 · raw

@head:Bool -> @+ms:U32 -> @sni:String -> @wire:String -> @c:Socket -> @tls:Bool -> IO(Result<&2, &2, Err, Res>)

def fetch.conn source · line 1060 · raw

@head:Bool -> @ms:U32 -> @sni:String -> @wire:String -> @tls:Bool -> @r:Result<&1, &1, Pair(U32, String), Socket> -> IO(Result<&2, &2, Err, Res>)

def fetch.ip source · line 1068 · raw

@+method:String -> @ip:String -> @port:U32 -> @sni:String -> @hf:String -> @target:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @tls:Bool -> @+ms:U32 -> IO(Result<&2, &2, Err, Res>)

One request on one connection to an IPv4 address. Bodies are byte strings.

def fetch.addr source · line 1073 · raw

@method:String -> @port:U32 -> @sni:String -> @hf:String -> @target:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @tls:Bool -> @ms:U32 -> @ip:Maybe<&2, String> -> IO(Result<&2, &2, Err, Res>)

def fetch.dns source · line 1080 · raw

@method:String -> @+host:String -> @port:U32 -> @hf:String -> @target:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @tls:Bool -> @ms:U32 -> IO(Result<&2, &2, Err, Res>)

def fetch.scheme source · line 1085 · raw

@method:String -> @host:String -> @port:U32 -> @hf:String -> @target:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @ms:U32 -> @+scheme:String -> @known:Bool -> IO(Result<&2, &2, Err, Res>)

def fetch.abs source · line 1092 · raw

@method:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @ms:U32 -> @hf:String -> @a:0x575208cf32f35c10d64d398769aef1bc/url/url.Abs -> IO(Result<&2, &2, Err, Res>)

def fetch.one source · line 1096 · raw

@h:Hop -> @ms:U32 -> IO(Result<&2, &2, Err, Res>)

def fetch.hop source · line 1106 · raw

@left:Nat -> @h:Hop -> Next

left: redirects still allowed after the request we just finished.

def fetch.decide.r source · line 1113 · raw

@left:Nat -> @+r:Res -> @next:Maybe<&2, Hop> -> Next

def fetch.decide.res source · line 1120 · raw

@left:Nat -> @h:Hop -> @+r:Res -> Next

def fetch.decide source · line 1124 · raw

@left:Nat -> @h:Hop -> @m:Result<&2, &2, Err, Res> -> Next

def fetch.start source · line 1144 · raw

@method:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @u:Maybe<&2, 0x575208cf32f35c10d64d398769aef1bc/url/url.Abs> -> Next

def fetch.with source · line 1155 · raw

@method:String -> @url:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> @ms:U32 -> IO(Result<&2, &2, Err, Res>)

fetch("GET", "https://example.com/x?y=1", headers, body) follows redirects. Fail is a bad URL, a failed lookup, connect, handshake, send, read, a malformed response, more than 20 redirects, or a step past ms. Body and response body are bytes.

def fetch source · line 1159 · raw

@method:String -> @url:String -> @headers:Map<&2, List<&2, String>> -> @body:String -> IO(Result<&2, &2, Err, Res>)

fetch.with and a 30 s step timeout.

def get source · line 1162 · raw

@url:String -> IO(Result<&2, &2, Err, Res>)

def sent_fin source · line 1165 · raw

@m:Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>) -> IO(Unit)

def reply_send source · line 1169 · raw

@s:Socket -> @res:Res -> IO(Unit)

Templates

template reply_handle source · line 1174 · raw

@-h:(@_:Req -> IO(Res)) -> @s:Socket -> @req:Req -> IO(Unit)

template reply_parsed source · line 1179 · raw

@-h:(@_:Req -> IO(Res)) -> @s:Socket -> @m:Maybe<&2, Req> -> IO(Unit)

template reply_ok source · line 1186 · raw

@-h:(@_:Req -> IO(Res)) -> @s:Socket -> @raw:String -> IO(Unit)

template reply source · line 1189 · raw

@-h:(@_:Req -> IO(Res)) -> @m:Pair(Socket, Result<&1, &1, Pair(U32, String), String>) -> IO(Unit)

template talk source · line 1197 · raw

@-h:(@_:Req -> IO(Res)) -> @s:Socket -> IO(Unit)

template conn source · line 1202 · raw

@-h:(@_:Req -> IO(Res)) -> @m:Pair(Listener, Result<&1, &1, Pair(U32, String), Socket>) -> IO(Listener)

template serve source · line 1216 · raw

@-h:(@_:Req -> IO(Res)) -> @+port:U32 -> IO(Unit)

Unsafe

unsafe fetch.read source · line 1016 · raw

@+head:Bool -> @+tls:Bool -> @+ms:U32 -> @st:Pair(Socket, Rd) -> IO(Result<&2, &2, Err, Res>)

Reads until frame says Done or Bad; an empty recv means the server closed.

unsafe fetch.hops source · line 1133 · raw

@+ms:U32 -> @st:Next -> IO(Result<&2, &2, Err, Res>)

NGo.left is how many redirects may follow this request. 20 is WHATWG's limit.

unsafe loop source · line 1210 · raw

@-h:(@_:Req -> IO(Res)) -> @l:Listener -> IO(Unit)