Pass tests

lib/blacksmith/application.ex

@@ -12,7 +12,8 @@ defmodule Blacksmith.Application do
 
     children = [
       supervisor(Blacksmith.Repo, []),
-      {Db.Redis, name: Db.Redis},
+      {Redis, name: Redis},
+      {TransactionProccessor, name: TransactionProccessor},
       {Forger, name: Forger},
       {VM, name: VM},
       {TransactionPool, name: TransactionPool},

lib/forger.ex

@@ -1,4 +1,5 @@
 defmodule Forger do
+  @one_second 1_000
   use GenServer
 
   def start_link(opts) do
@@ -39,11 +40,14 @@ defmodule Forger do
   end
 
   def handle_cast(:auto_forge, state = %{redis: redis, auto_forge: auto_forge}) do
-    {:ok, ["transactions::done", receipt]} =
-      Redix.command(redis, ["BRPOP", "transactions::done", 0])
+    case Redix.command(redis, ["BRPOP", "transactions::done", 1]) do
+      {:ok, ["transactions::done", receipt]} ->
+        GenServer.cast(self(), {:forge, [receipt]})
+      {:ok, nil} ->
+    end
+
 
     if auto_forge do
-      GenServer.cast(self(), {:forge, [receipt]})
       GenServer.cast(self(), :auto_forge)
     end
 
@@ -55,6 +59,10 @@ defmodule Forger do
       send(subscriber, receipts)
     end)
 
+    state = Map.put(state, :subscribers, [])
+    {:noreply, state}
+  end
+  def handle_cast({:forge, receipts}, state) do
     {:noreply, state}
   end
 

lib/models/block.ex

@@ -12,7 +12,7 @@ defmodule Models.Block do
     timestamps
   end
 
-  def max_burned(query \\ __MODULE__), do: from(q in query, order_by: q.max_burned) |> Repo.one()
+  def max_burned(query \\ __MODULE__), do: from(q in query, order_by: q.total_burned)
 
   def latest(query \\ __MODULE__, count), do: from(q in query, order_by: q.number, limit: ^count)