Current section

Files

Jump to
gleam_httpc src gleam httpc.gleam
Raw

src/gleam/httpc.gleam

import gleam/dynamic.{type Dynamic}
import gleam/http.{type Method}
import gleam/http/response.{type Response, Response}
import gleam/http/request.{type Request}
import gleam/bit_array
import gleam/result
import gleam/list
import gleam/uri
type Charlist
@external(erlang, "erlang", "binary_to_list")
fn binary_to_list(a: String) -> Charlist
@external(erlang, "erlang", "list_to_binary")
fn list_to_binary(a: Charlist) -> String
type ErlHttpOption
type BodyFormat {
Binary
}
type ErlOption {
BodyFormat(BodyFormat)
}
@external(erlang, "httpc", "request")
fn erl_request(
a: Method,
b: #(Charlist, List(#(Charlist, Charlist)), Charlist, BitArray),
c: List(ErlHttpOption),
d: List(ErlOption),
) -> Result(
#(#(Charlist, Int, Charlist), List(#(Charlist, Charlist)), BitArray),
Dynamic,
)
@external(erlang, "httpc", "request")
fn erl_request_no_body(
a: Method,
b: #(Charlist, List(#(Charlist, Charlist))),
c: List(ErlHttpOption),
d: List(ErlOption),
) -> Result(
#(#(Charlist, Int, Charlist), List(#(Charlist, Charlist)), BitArray),
Dynamic,
)
fn charlist_header(header: #(String, String)) -> #(Charlist, Charlist) {
let #(k, v) = header
#(binary_to_list(k), binary_to_list(v))
}
fn string_header(header: #(Charlist, Charlist)) -> #(String, String) {
let #(k, v) = header
#(list_to_binary(k), list_to_binary(v))
}
// TODO: test
// TODO: refine error type
pub fn send_bits(req: Request(BitArray)) -> Result(Response(BitArray), Dynamic) {
let erl_url =
req
|> request.to_uri
|> uri.to_string
|> binary_to_list
let erl_headers = list.map(req.headers, charlist_header)
let erl_http_options = []
let erl_options = [BodyFormat(Binary)]
use response <- result.then(case req.method {
http.Options | http.Head | http.Get -> {
let erl_req = #(erl_url, erl_headers)
erl_request_no_body(req.method, erl_req, erl_http_options, erl_options)
}
_ -> {
let erl_content_type =
req
|> request.get_header("content-type")
|> result.unwrap("application/octet-stream")
|> binary_to_list
let erl_req = #(erl_url, erl_headers, erl_content_type, req.body)
erl_request(req.method, erl_req, erl_http_options, erl_options)
}
})
let #(#(_version, status, _status), headers, resp_body) = response
Ok(Response(status, list.map(headers, string_header), resp_body))
}
// TODO: test
// TODO: refine error type
pub fn send(req: Request(String)) -> Result(Response(String), Dynamic) {
use resp <- result.then(
req
|> request.map(bit_array.from_string)
|> send_bits,
)
case bit_array.to_string(resp.body) {
Ok(body) -> Ok(response.set_body(resp, body))
Error(_) -> Error(dynamic.from("Response body was not valid UTF-8"))
}
}