Packages

mist

0.8.0
6.0.3 6.0.2 6.0.1 6.0.0 5.0.4 5.0.3 5.0.2 5.0.1 5.0.0 5.0.0-rc1 4.0.7 4.0.6 4.0.5 4.0.4 4.0.3 4.0.2 4.0.1 4.0.0 3.0.0 2.0.0 1.2.0 1.1.0 1.0.0 1.0.0-rc3 1.0.0-rc2 1.0.0-rc1 0.17.0 0.15.0 0.14.3 0.14.2 0.14.1 0.14.0 0.13.2 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.1 0.6.0 0.5.2 0.5.1 0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.3

a misty Gleam web server

HexDocs

Current section

Files

Jump to
Readme
67 Versions
5 Dependencies
Dependants
Files
Activity
mist src mist.gleam
Raw

src/mist.gleam 

import glisten

import glisten/tcp

import mist/handler.{State}

import gleam/bit_builder

import gleam/bit_string

import gleam/erlang/process

import gleam/http/request.{Request}

import gleam/http/response

import gleam/int

import gleam/string

import mist/file

import mist/handler.{Response}

import mist/http.{BitBuilderBody, Body, FileBody}



/// Runs an HTTP Request->Response server at the given port, with your defined

/// handler. This will automatically read the full body contents up to the

/// specified `max_body_limit` in bytes. If you'd prefer to have finer-grain

/// control over this behavior, consider using `mist.serve`.

pub fn run_service(

  port: Int,

  handler: handler.Handler,

  max_body_limit max_body_limit: Int,

) -> Result(Nil, glisten.StartError) {

  handler

  |> handler.with(max_body_limit)

  |> tcp.acceptor_pool_with_data(handler.new_state())

  |> glisten.serve(port, _)

}



/// Slightly more flexible alternative to `run_service`. This allows hooking

/// into the `mist/http.{handler_func}` method. Note that the request body

/// will not be automatically read. You will need to call `http.read_body`.

pub fn serve(

  port: Int,

  handler: tcp.LoopFn(State),

) -> Result(Nil, glisten.StartError) {

  handler

  |> tcp.acceptor_pool_with_data(handler.new_state())

  |> glisten.serve(port, _)

}



pub fn main() {

  assert Ok(_) =

    serve(

      8080,

      handler.with_func(fn(req: Request(Body)) {

        case request.path_segments(req) {

          ["static", ..path] -> {

            // verify, validate, etc

            let file_path =

              path

              |> string.join("/")

              |> string.append("/", _)

              |> bit_string.from_string

            let size = file.size(file_path)

            assert Ok(fd) = file.open(file_path)

            response.new(200)

            |> response.set_body(FileBody(fd, int.to_string(size), 0, size))

            |> Response

          }

          _ ->

            response.new(404)

            |> response.set_body(BitBuilderBody(bit_builder.new()))

            |> Response

        }

      }),

    )

  process.sleep_forever()

}