Packages

plug

1.4.1
1.20.3 1.20.2 1.20.1 retired 1.20.0 retired 1.19.5 1.19.4 1.19.3 1.19.2 1.19.1 1.19.0 1.18.5 1.18.4 1.18.3 1.18.2 1.18.1 1.18.0 1.17.4 1.17.3 1.17.2 1.17.1 1.17.0 1.16.6 1.16.5 1.16.4 1.16.3 1.16.2 1.16.1 1.16.0 1.15.6 1.15.5 1.15.4 1.15.3 1.15.2 1.15.1 1.15.0 1.14.2 1.14.1 1.14.0 1.13.6 1.13.5 1.13.4 1.13.3 1.13.2 1.13.1 retired 1.13.0 retired 1.12.1 1.12.0 1.11.1 1.11.0 1.10.4 1.10.3 1.10.2 1.10.1 1.10.0 1.9.0 1.8.3 1.8.2 1.8.1 1.8.0 1.7.2 1.7.1 1.7.0 1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0 1.5.0-rc.2 1.5.0-rc.1 1.5.0-rc.0 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.4.0-rc.0 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.2.0-rc.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.14.0 0.13.1 0.13.0 0.12.2 0.12.1 0.12.0 0.11.3 0.11.2 0.11.1 0.11.0 0.10.0 0.9.0 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1

Compose web applications with functions

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

Current section

Files

Jump to
Readme
138 Versions
2 Dependencies
Dependants
7 Advisories
Files
Activity
plug lib plug adapters cowboy conn.ex
Raw

lib/plug/adapters/cowboy/conn.ex 

defmodule Plug.Adapters.Cowboy.Conn do

  @behaviour Plug.Conn.Adapter

  @moduledoc false



  def conn(req, transport) do

    {path, req} = :cowboy_req.path req

    {host, req} = :cowboy_req.host req

    {port, req} = :cowboy_req.port req

    {meth, req} = :cowboy_req.method req

    {hdrs, req} = :cowboy_req.headers req

    {qs, req}   = :cowboy_req.qs req

    {peer, req} = :cowboy_req.peer req

    {remote_ip, _} = peer



    %Plug.Conn{

      adapter: {__MODULE__, req},

      host: host,

      method: meth,

      owner: self(),

      path_info: split_path(path),

      peer: peer,

      port: port,

      remote_ip: remote_ip,

      query_string: qs,

      req_headers: hdrs,

      request_path: path,

      scheme: scheme(transport)

    }

  end



  def send_resp(req, status, headers, body) do

    status = Integer.to_string(status) <> " " <> Plug.Conn.Status.reason_phrase(status)

    {:ok, req} = :cowboy_req.reply(status, headers, body, req)

    {:ok, nil, req}

  end



  def send_file(req, status, headers, path, offset, length) do

    %File.Stat{type: :regular, size: size} = File.stat!(path)



    length =

      cond do

        length == :all -> size

        is_integer(length) -> length

      end



    body_fun = fn(socket, transport) -> transport.sendfile(socket, path, offset, length) end



    {:ok, req} = :cowboy_req.reply(status, headers, :cowboy_req.set_resp_body_fun(length, body_fun, req))

    {:ok, nil, req}

  end



  def send_chunked(req, status, headers) do

    {:ok, req} = :cowboy_req.chunked_reply(status, headers, req)

    {:ok, nil, req}

  end



  def chunk(req, body) do

    :cowboy_req.chunk(body, req)

  end



  def read_req_body(req, opts \\ []) do

    :cowboy_req.body(req, opts)

  end



  ## Helpers



  defp scheme(:tcp), do: :http

  defp scheme(:ssl), do: :https



  defp split_path(path) do

    segments = :binary.split(path, "/", [:global])

    for segment <- segments, segment != "", do: segment

  end

end