Packages

ethereumex

0.11.0
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_server.ex
Raw

lib/ethereumex/ipc_server.ex 

defmodule Ethereumex.IpcServer do

  @moduledoc false



  use GenServer



  def start_link(state \\ []) do

    GenServer.start_link(__MODULE__, Keyword.merge(state, socket: nil))

  end



  def post(pid, request) do

    GenServer.call(pid, {:request, request})

  end



  def init(state) do

    opts = [:binary, active: false, reuseaddr: true]



    response = :gen_tcp.connect({:local, state[:path]}, 0, opts)



    case response do

      {:ok, socket} -> {:ok, Keyword.put(state, :socket, socket)}

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

    end

  end



  def handle_call(

        {:request, request},

        _from,

        [socket: socket, path: _, ipc_request_timeout: timeout] = state

      ) do

    response =

      socket

      |> :gen_tcp.send(request)

      |> receive_response(socket, timeout)



    {:reply, response, state}

  end



  defp receive_response(data, socket, timeout), do: receive_response(data, socket, timeout, <<>>)



  defp receive_response({:error, reason}, _socket, _timeout, _result) do

    {:error, reason}

  end



  defp receive_response(:ok, socket, timeout, result) do

    with {:ok, response} <- :gen_tcp.recv(socket, 0, timeout) do

      new_result = result <> response



      if String.ends_with?(response, "\n") do

        {:ok, new_result}

      else

        receive_response(:ok, socket, timeout, new_result)

      end

    end

  end

end