[GH-#69] GET /info

Author: d-velev

apps/aecore/lib/aecore/peers/worker.ex

@@ -1,6 +1,8 @@
 defmodule Aecore.Peers.Worker do
 
   alias Aehttpclient.Client
+  alias Aecore.Structures.Block
+  alias Aecore.Utils.Blockchain.BlockValidation
 
   use GenServer
 
@@ -32,10 +34,21 @@ defmodule Aecore.Peers.Worker do
     GenServer.call(__MODULE__, :all_peers)
   end
 
+  @spec genesis_block_header_hash() :: term()
+  def genesis_block_header_hash() do
+    Block.genesis_header()
+    |> BlockValidation.block_header_hash()
+    |> Base.encode16()
+  end
+
   def handle_call({:add_peer,uri}, _from, peers) do
-    case(Client.ping_uri(uri)) do
-      :ok ->
-        {:reply, :ok, [uri | peers]}
+    case(Client.get_info(uri)) do
+      {:ok, info} ->
+        if(Map.get(info,"genesis_block_hash") == genesis_block_header_hash()) do
+          {:reply, :ok, [uri | peers]}
+        else
+          {:reply, :error, peers}
+        end
       :error ->
         {:reply, :error, peers}
     end
@@ -51,8 +64,8 @@ defmodule Aecore.Peers.Worker do
 
   def handle_call(:check_peers, _from, peers) do
     updated_peers = Enum.filter(peers, fn(peer) ->
-      reply = Client.ping_uri(peer)
-      :ok = reply
+      {status, _} = Client.get_info(peer)
+      :ok = status
       end)
     {:reply, :ok, updated_peers}
   end

apps/aecore/lib/aecore/structures/block.ex

@@ -2,7 +2,6 @@ defmodule Aecore.Structures.Block do
   @moduledoc """
   Structure of the block
   """
-
   alias Aecore.Structures.Block
   alias Aecore.Structures.Header
 

apps/aehttpclient/lib/client.ex

@@ -1,10 +1,13 @@
 defmodule Aehttpclient.Client do
 
-  def ping_uri(uri) do
-    case(HTTPoison.get(uri <> "/ping")) do
-      {:ok, %{status_code: status_code}} when status_code == 200 ->
-        :ok
-      true ->
+  def get_info(uri) do
+    case(HTTPoison.get(uri <> "/info",[recv_timeout: 10000000])) do
+      {:ok, %{body: body, status_code: 200}} ->
+        response = Poison.decode!(body)
+        {:ok, response}
+      {:ok, %HTTPoison.Response{status_code: 404}} ->
+        :error
+      {:error, %HTTPoison.Error{}} ->
         :error
     end
   end

apps/aehttpserver/web/controllers/info_controller.ex

@@ -0,0 +1,32 @@
+defmodule Aehttpserver.InfoController do
+  use Aehttpserver.Web, :controller
+
+  alias Aecore.Structures.Block
+  alias Aecore.Chain.Worker, as: Chain
+  alias Aecore.Utils.Blockchain.BlockValidation
+  alias Aecore.Peers.Worker, as: Peers
+  alias Aecore.Keys.Worker, as: Keys
+
+  def info(conn, _params) do
+    latest_block = Chain.latest_block()
+    latest_block_header = latest_block.header
+      |> BlockValidation.block_header_hash()
+      |> Base.encode16()
+
+    genesis_block_header = Block.genesis_header()
+    genesis_block_hash = genesis_block_header
+     |> BlockValidation.block_header_hash()
+     |> Base.encode16()
+
+    {:ok, pubkey} = Keys.pubkey()
+    pubkey = Base.encode16(pubkey)
+    
+    json conn, %{current_block_version: latest_block.header.version,
+                 current_block_height: latest_block.header.height,
+                 current_block_hash: latest_block_header,
+                 genesis_block_hash: genesis_block_hash,
+                 peer_count: Enum.count(Peers.all_peers),
+                 difficulty_target: latest_block.header.difficulty_target,
+                 public_key: pubkey}
+  end
+end

apps/aehttpserver/web/controllers/ping_controller.ex

@@ -17,7 +17,7 @@ defmodule Aehttpserver.Router do
     pipe_through :browser # Use the default browser stack
 
     get "/", PageController, :index
-    get "/ping", PingController, :index
+    get "/info", InfoController, :info
   end
 
   # Other scopes may use custom stacks.