Packages

ewe

0.3.0
4.0.1 4.0.0 3.0.8 3.0.7 3.0.6 3.0.5 3.0.4 3.0.3 3.0.2 3.0.1 3.0.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.3 2.0.2 2.0.1 2.0.0 1.0.1 1.0.0 1.0.0-rc2 1.0.0-rc1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0 0.0.2 0.0.1

🐑 a fluffy Gleam web server

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
36 Versions
5 Dependencies
Dependants
3 Advisories
Files
Activity
ewe src ewe internal handler.gleam
Raw

src/ewe/internal/handler.gleam 

import ewe/internal/exception

import ewe/internal/http as http_

import ewe/internal/response as response_

import gleam/bytes_tree

import gleam/http/request

import gleam/http/response

import gleam/result

import glisten

import glisten/socket

import glisten/transport



pub fn loop(

  handler: http_.Handler,

  on_crash: response.Response(bytes_tree.BytesTree),

) -> glisten.Loop(http_.Connection, a) {

  fn(http_conn, msg, _conn) {

    let assert glisten.Packet(msg) = msg



    http_.parse_request(http_conn, msg)

    |> result.map(fn(parsed) {

      case run(parsed.request, handler, on_crash, parsed.version) {

        Ok(Nil) -> glisten.continue(http_conn)

        Error(_exception) -> glisten.stop()

      }

    })

    |> result.replace_error(glisten.stop())

    |> result.unwrap_both()

  }

}



fn run(

  req: request.Request(http_.Connection),

  handler: http_.Handler,

  on_crash: response.Response(bytes_tree.BytesTree),

  version: http_.HttpVersion,

) -> Result(Nil, socket.SocketReason) {

  exception.rescue(fn() { handler(req) })

  |> result.map_error(fn(_) { on_crash })

  |> result.unwrap_both()

  |> response_.append_default_headers(version)

  |> response_.encode()

  |> transport.send(req.body.transport, req.body.socket, _)

}