package multipart_form-cohttp-lwt

You can search for identifiers within the package.

in-package search v0.2.0

multipart_form-cohttp-lwt
- Multipart_form_cohttp
  - Client
  - Server

Legend:
Library
Module
Module type
Parameter
Class
Class type

exception Invalid_multipart_form of string

val multipart_form : 
  identify:(Cohttp.Header.t -> 'id) ->
  Cohttp.Request.t ->
  Cohttp_lwt.Body.t ->
  [ `Tree of 'id Multipart_form.t Lwt.t ]
  * ('id * Cohttp.Header.t * Cohttp_lwt.Body.t) Lwt_stream.t

multipart_form ~identify req body returns a fiber which parses the given body and a stream of each part of the given body. The goal is to propose an easier interface specially for CoHTTP. By this way, this function expects a CoHTTP request and a CoHTTP body.

To consume the returned stream, the returned fiber must be launched:

let consume_parts stream =
  let* part = Lwt_stream.get stream in
  match part with
  | None -> ...
  | Some (uid, headers, body) -> ...

let handler _ req body =
  let `Tree th, stream = Multipart_form_cohttp.Server.multipart_form
    ~identify req body in
  Lwt.catch begin fun () ->
    let* tree, _ = Lwt.both (th, consume_parts stream) in
    ...
  end @@ function
  | Invalid_multipart_form err -> ...

In this example, we use Lwt.both to concurrently parse and consume parts. If the body is not a valid multipart-form/data, the exception Invalid_multipart_form is raised.