Packages

ethereumex

0.12.1
0.14.0 0.12.3 0.12.2 0.12.1 0.12.0 0.11.1 0.11.0 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 0.9.0 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0

Elixir JSON-RPC client for the Ethereum blockchain

HexDocs

Current section

Files

Jump to
Readme
44 Versions
5 Dependencies
Dependants
Files
Activity
ethereumex lib ethereumex ipc_client.ex
Raw

lib/ethereumex/ipc_client.ex 

defmodule Ethereumex.IpcClient do

  @moduledoc false



  use Ethereumex.Client.BaseClient



  alias Ethereumex.Config

  alias Ethereumex.IpcServer



  @timeout 60_000

  @spec post_request(binary(), []) :: {:ok | :error, any()}

  def post_request(payload, _opts) do

    with {:ok, response} <- call_ipc(payload),

         {:ok, decoded_body} <- jason_decode(response) do

      case decoded_body do

        %{"error" => error} -> {:error, error}

        result = [%{} | _] -> {:ok, format_batch(result)}

        result -> {:ok, Map.get(result, "result")}

      end

    else

      {:error, error} -> {:error, error}

      error -> {:error, error}

    end

  end



  defp call_ipc(payload) do

    :poolboy.transaction(:ipc_worker, fn pid -> IpcServer.post(pid, payload) end, @timeout)

  end



  defp jason_decode(response) do

    case Config.json_module().decode(response) do

      {:ok, _result} = result -> result

      {:error, error} -> {:error, {:decode_error, error}}

    end

  end

end