def admission.request

bend-kit-http@0.38.5.0 · http.bend:6210

import Base
import bend-kit-http@0.38.5.0/admission.bend as Admission
import bend-kit-http@0.38.5.0/completion.bend as Completion
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes

6210def admission.request(
6211  ~C: Data, ~h: C -> Req -> IO(Reply), ~observe: C -> U32 -> Completion.Outcome -> IO(Unit),
6212  admitted: Bool, +inbox: Chan(Admission.Command), +context: C, +settings: Limits, s: Socket, req: Req, rest: Bytes.Bytes, v11: Bool
6213) -> IO(Maybe<&1, Socket & Turn>):
6214  match admitted:
6215    case False{}:
6216      Limits{max, cap, hm, bm, im, wm} = settings
6217      do IO<Maybe<&1, Socket & Turn>>:
6218        admission.reject(Completion.Observed{status => outcome => observe(context, status, outcome)}, s, admission.head(req), wm)
6219        return None{}
6220    case True{}:
6221      Req{+method, path, +headers, body} = req
6222      do IO<Maybe<&1, Socket & Turn>>:
6223        res : Reply <- h(context, Req{method, path, headers, body})
6224        next : Maybe<&1, Socket & Turn> <- talk.respond(Completion.Observed{status => outcome => observe(context, status, outcome)}, settings, s, rest, headers, v11, String.eq(method, "HEAD"), res)
6225        Admission.give(inbox, 1)
6226        return next
6227
6228
6229@unsafe