alef 0.24.17

Opinionated polyglot binding generator for Rust libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

  # HandlerWrapper GenServer: wraps a closure for use as a handler
  defmodule HandlerWrapper do
    use GenServer

    def start_link(handler_fn) do
      GenServer.start_link(__MODULE__, handler_fn)
    end

    def init(handler_fn) do
      {:ok, handler_fn}
    end

    def handle_cast({:trait_call, _method, args_json, reply_id}, handler_fn) do
      case Jason.decode(args_json) do
        {:ok, args} ->
          # Build request context from RequestData fields in args
          try do
            conn = build_conn(args)
            response = handler_fn.(conn)
            response_json = Jason.encode!(response)
            Native.complete_trait_call(reply_id, response_json)
          rescue
            _e -> Native.complete_trait_call(reply_id, "{\"error\": \"handler error\"}")
          end

        {:error, _} ->
          Native.complete_trait_call(reply_id, "{\"error\": \"json decode error\"}")
      end

      {:noreply, handler_fn}
    end

    # Convert RequestData JSON to request context struct
    defp build_conn(args) do
      %{{ conn_module }}{
        path_params: args["path_params"] || %{},
        query_params: args["query_params"] || %{},
        headers: args["headers"] || %{},
        cookies: args["cookies"] || %{},
        body: args["body"],
        raw_body: args["raw_body"],
        method: args["method"] || "GET",
        path: args["path"] || "/"
      }
    end
  end