From 33281da43f1e8714a9d4e8b3f9f9d076585fa10f Mon Sep 17 00:00:00 2001
From: Andre Henriques <andr3h3nriqu3s@gmail.com>
Date: Tue, 16 Jan 2024 19:59:01 +0000
Subject: [PATCH] Lot of changes

---
 lib/paxos.ex  | 615 ++++++++++++++++++++++++++------------------------
 lib/server.ex | 161 +++++++++++++
 lib/test.ex   |  26 ++-
 3 files changed, 496 insertions(+), 306 deletions(-)
 create mode 100644 lib/server.ex

diff --git a/lib/paxos.ex b/lib/paxos.ex
index 69b3b2a..fc01e1f 100644
--- a/lib/paxos.ex
+++ b/lib/paxos.ex
@@ -1,4 +1,8 @@
 defmodule Utils do
+
+  @min_print_level 0
+
+  
   def safecast(p, m) when p == nil, do: IO.puts('Trying to safecast #{m} with p as nil')
   def safecast(p, m) when is_pid(p), do: send(p, m)
   def safecast(p, m) do
@@ -8,6 +12,10 @@ defmodule Utils do
     end
   end
 
+  def alter_name(name, part) do
+    String.to_atom(Atom.to_string(name) <> part)
+  end
+
   def beb_broadcast(m, dest), do: for(p <- dest, do: safecast(p, m))
 
   def register_name(name, pid, link \\ true) do
@@ -26,6 +34,21 @@ defmodule Utils do
     end
   end
 
+  defmacro create_log(level) do
+    quote do
+      def log(msg) do
+        Utils._log(msg, unquote(level))
+      end
+    end
+  end
+
+  def _log(msg, level) do
+    if (@min_print_level < level) do
+      IO.puts(msg)
+    end
+  end
+  
+
   defmacro or_state(val, do: expr) do
     quote do
       case unquote(val) do
@@ -34,6 +57,17 @@ defmodule Utils do
       end
     end
   end
+
+  defmacro runfn(do: expr) do
+    quote do
+      def run(s) do
+        var!(state) = s
+        run(receive do
+          unquote(expr)
+        end)
+      end
+    end
+  end
 end
 
 #
@@ -47,6 +81,8 @@ defmodule Paxos do
   require Utils
   import Utils
 
+  create_log 0
+
   defmacro set_instmap(do: expr) do
     quote do
       var!(map) = var!(state).instmap[var!(inst)]
@@ -57,22 +93,21 @@ defmodule Paxos do
 
 
   # Starts the Paxos replica with a specific name and some processes
-  def start(name, processes) do
-    IO.puts("Starting paxos for #{name}")
+  def start(name, processes, link \\ false) do
+    log("Starting paxos for #{name}")
 
-    pid = spawn(Paxos, :init, [name, name, processes])
-    register_name(name, pid, false)
+    pid = spawn(Paxos, :init, [name, processes])
+    register_name(name, pid, link)
   end
 
   # Init event must be the first
   # one after the component is created
-  def init(name, parent, processes) do
+  def init(name, processes) do
     EventualLeaderElector.start(name, processes)
     EagerReliableBroadcast.start(name, processes)
 
     state = %{
       name: name,
-      parent: parent,
       processes: processes,
       leader: nil,
       instmap: %{},
@@ -115,246 +150,242 @@ defmodule Paxos do
     end
   end
 
-  def run(state) do
-    run(
-      receive do
-        {:ele_trust, proc} ->
-          IO.puts("#{state.name} - #{proc} is leader")
+  runfn do
+    {:ele_trust, proc} ->
+      log("#{state.name} - #{proc} is leader")
 
-          Enum.reduce(Map.keys(state.instmap), %{state | leader: proc}, fn inst, st ->
-            prepare(st, inst)
-          end)
+      Enum.reduce(Map.keys(state.instmap), %{state | leader: proc}, fn inst, st ->
+        prepare(st, inst)
+      end)
 
-        {:propose, inst, value, pid_to_inform, action} ->
-          IO.puts("#{state.name} - Propose #{inspect(inst)} with action #{inspect(action)}")
+    {:propose, inst, value, pid_to_inform, action} ->
+      log("#{state.name} - Propose #{inspect(inst)} with action #{inspect(action)}")
 
-          cond do
-            has_finished(state, inst, true) ->
-              IO.puts("#{state.name} - Has already decided for #{inspect(inst)} sending #{inspect(state.decided[inst])}")
-              send(pid_to_inform, {:decision, inst, state.decided[inst]})
-              state
-
-            action == :increase_ballot_number ->
-              IO.puts("#{state.name} - Got request to increase ballot number for inst #{inst}")
-              state = has_or_create(state, inst)
-
-              set_instmap do
-                %{map| ballot: Ballot.inc(map.ballot)}
-              end
-
-            not Map.has_key?(state.instmap, inst) ->
-              EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
-              state = has_or_create(state, inst, value, pid_to_inform, action)
-              prepare(state, inst)
-
-            state.instmap[inst].value == nil ->
-              EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
-
-              set_instmap do
-                %{ map | 
-                    value: value,
-                    pid_to_inform: pid_to_inform,
-                    action: action,
-                }
-              end
-
-              prepare(state, inst)
-
-            true ->
-              EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
-              prepare(state, inst)
-          end
-
-        {:rb_deliver, proc, {:other_propose, inst, value}} ->
-          cond do
-            has_finished(state, inst, true) ->
-              EagerReliableBroadcast.broadcast(
-                state.name,
-                {:decide, inst, state.decided[inst]}
-              )
-              state
-
-            true -> 
-              state = has_or_create(state, inst)
-              set_instmap do
-                %{map | other_value: value}
-              end
-              prepare(state, inst)
-          end
-
-        {:rb_deliver, proc, {:prepare, proc, inst, ballot}} ->
-          IO.puts("#{state.name} - prepare from #{proc}")
-
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            not Map.has_key?(state.instmap, inst) ->
-              state = has_or_create(state, inst)
-
-              safecast(proc, {:prepared, inst, ballot, state.instmap[inst].accepted_ballot, state.instmap[inst].accepted_value});
-              
-              set_instmap do 
-                %{ map
-                  | ballot: ballot
-                } 
-              end
-
-            Ballot.compare(ballot, &>/2, state.instmap[inst].ballot) ->
-              safecast(proc,
-                {:prepared, inst, ballot, state.instmap[inst].accepted_ballot,
-                 state.instmap[inst].accepted_value}
-              )
-
-              set_instmap do 
-                %{ map
-                  | ballot: ballot
-                } 
-              end
-
-            true ->
-              safecast(proc, {:nack, inst, ballot})
-              state
-          end
-
-        {:nack, inst, ballot} ->
-          IO.puts("#{state.name} - nack #{inspect(inst)} #{inspect(ballot)}")
-
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            state.leader == state.name and Ballot.compare(state.instmap[inst].ballot, &==/2, ballot) ->
-              if Map.has_key?(state.instmap, inst) and state.instmap[inst].pid_to_inform != nil do
-                send(state.instmap[inst].pid_to_inform, {:abort, inst})
-              end
-
-              EagerReliableBroadcast.broadcast(state.name, {:abort, inst, ballot})
-
-              set_instmap do 
-                %{ map | has_sent_accept: false, 
-                  has_sent_prepare: false,
-                  ballot: Ballot.inc(map.ballot),
-                  aborted: true,
-                } 
-              end
-
-            true ->
-              state
-          end
-
-        {:rb_deliver, _proc, {:abort, inst, ballot}} ->
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            true ->
-              IO.puts("#{state.name} - got information to send abort")
-
-              if Map.has_key?(state.instmap, inst) and state.instmap[inst].pid_to_inform != nil do
-                send(state.instmap[inst].pid_to_inform, {:abort, inst})
-              end
-
-              state
-          end
-
-        {:prepared, inst, ballot, accepted_ballot, accepted_value} ->
-          IO.puts(
-            "#{state.name} - prepared #{inspect(inst)} #{inspect(ballot)} #{inspect(accepted_ballot)} #{inspect(accepted_value)}"
-          )
-
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            Ballot.compare(ballot, &==/2, state.instmap[inst].ballot) ->
-              set_instmap do
-                %{
-                  map
-                  | prepared_values: map.prepared_values ++ [{accepted_ballot, accepted_value}]
-                }
-              end
-              prepared(state, inst)
-
-            Ballot.compare(ballot, &>/2, state.instmap[inst].ballot) ->
-              IO.puts("#{state.name} - Probably recieved this before preare came to self sending with delay")
-              Process.send_after(self(), {:prepared, inst, ballot, accepted_ballot, accepted_value}, 100)
-              state
-
-            true ->
-              state
-          end
-
-        {:rb_deliver, proc, {:accept, inst, ballot, value}} ->
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            true ->
-              state = has_or_create(state, inst)
-
-              if Ballot.compare(ballot, &>=/2, state.instmap[inst].ballot) do
-                IO.puts("#{state.name} - accept #{inspect(inst)} #{inspect(ballot)} #{inspect(value)}")
-            
-                safecast(proc, {:accepted, inst, ballot})
-
-                set_instmap do 
-                  %{ map
-                    | ballot: ballot,
-                      accepted_value: value,
-                      accepted_ballot: ballot
-                  } 
-                end
-              else
-                IO.puts("#{state.name} -> #{proc} nack")
-                safecast(proc, {:nack, inst, ballot})
-                state
-              end
-          end
-
-        {:accepted, inst, ballot} ->
-          IO.puts("#{state.name} - accepted #{inspect(inst)} #{inspect(ballot)}")
-
-          cond do
-            has_finished(state, inst) ->
-              state
-
-            state.leader == state.name and state.instmap[inst].ballot == ballot ->
-              set_instmap do 
-                %{ map | 
-                  accepted: map.accepted + 1
-                }
-              end
-
-              accepted( state, inst)
-
-            true ->
-              state
-          end
-
-        {:get_value, inst, pid_to_inform} ->
-          # IO.puts("#{state.name} get_value")
-          if  has_finished(state, inst, true) do
-              send(pid_to_inform, {:get_value_res, inst, state.decided[inst]})
-          end
+      cond do
+        has_finished(state, inst, true) ->
+          log("#{state.name} - Has already decided for #{inspect(inst)} sending #{inspect(state.decided[inst])}")
+          send(pid_to_inform, {:decision, inst, state.decided[inst]})
           state
 
-        {:rb_deliver, _, {:decide, inst, value}} ->
-          IO.puts("#{state.name} - decided #{inspect(inst)} #{inspect(value)}")
+        action == :increase_ballot_number ->
+          log("#{state.name} - Got request to increase ballot number for inst #{inst}")
+          state = has_or_create(state, inst)
 
-          or_state not has_finished(state, inst) do
-            if Map.has_key?(state.instmap, inst) != nil and
-                 state.instmap[inst].pid_to_inform != nil do
-              send(state.instmap[inst].pid_to_inform, {:decision, inst, value})
-            end
+          set_instmap do
+            %{map| ballot: Ballot.inc(map.ballot)}
+          end
 
-            %{ state |
-                decided: Map.put(state.decided, inst, value),
-                instmap: Map.delete(state.instmap, inst)
+        not Map.has_key?(state.instmap, inst) ->
+          EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
+          state = has_or_create(state, inst, value, pid_to_inform, action)
+          prepare(state, inst)
+
+        state.instmap[inst].value == nil ->
+          EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
+
+          set_instmap do
+            %{ map | 
+                value: value,
+                pid_to_inform: pid_to_inform,
+                action: action,
             }
           end
+
+          prepare(state, inst)
+
+        true ->
+          EagerReliableBroadcast.broadcast(state.name, {:other_propose, inst, value})
+          prepare(state, inst)
+      end
+
+    {:rb_deliver, proc, {:other_propose, inst, value}} ->
+      cond do
+        has_finished(state, inst, true) ->
+          EagerReliableBroadcast.broadcast(
+            state.name,
+            {:decide, inst, state.decided[inst]}
+          )
+          state
+
+        true -> 
+          state = has_or_create(state, inst)
+          set_instmap do
+            %{map | other_value: value}
+          end
+          prepare(state, inst)
+      end
+
+    {:rb_deliver, proc, {:prepare, proc, inst, ballot}} ->
+      log("#{state.name} - prepare from #{proc}")
+
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        not Map.has_key?(state.instmap, inst) ->
+          state = has_or_create(state, inst)
+
+          safecast(proc, {:prepared, inst, ballot, state.instmap[inst].accepted_ballot, state.instmap[inst].accepted_value});
+          
+          set_instmap do 
+            %{ map
+              | ballot: ballot
+            } 
+          end
+
+        Ballot.compare(ballot, &>/2, state.instmap[inst].ballot) ->
+          safecast(proc,
+            {:prepared, inst, ballot, state.instmap[inst].accepted_ballot,
+             state.instmap[inst].accepted_value}
+          )
+
+          set_instmap do 
+            %{ map
+              | ballot: ballot
+            } 
+          end
+
+        true ->
+          safecast(proc, {:nack, inst, ballot})
+          state
+      end
+
+    {:nack, inst, ballot} ->
+      log("#{state.name} - nack #{inspect(inst)} #{inspect(ballot)}")
+
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        state.leader == state.name and Ballot.compare(state.instmap[inst].ballot, &==/2, ballot) ->
+          if Map.has_key?(state.instmap, inst) and state.instmap[inst].pid_to_inform != nil do
+            send(state.instmap[inst].pid_to_inform, {:abort, inst})
+          end
+
+          EagerReliableBroadcast.broadcast(state.name, {:abort, inst, ballot})
+
+          set_instmap do 
+            %{ map | has_sent_accept: false, 
+              has_sent_prepare: false,
+              ballot: Ballot.inc(map.ballot),
+              aborted: true,
+            } 
+          end
+
+        true ->
+          state
+      end
+
+    {:rb_deliver, _proc, {:abort, inst, ballot}} ->
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        true ->
+          log("#{state.name} - got information to send abort")
+
+          if Map.has_key?(state.instmap, inst) and state.instmap[inst].pid_to_inform != nil do
+            send(state.instmap[inst].pid_to_inform, {:abort, inst})
+          end
+
+          state
+      end
+
+    {:prepared, inst, ballot, accepted_ballot, accepted_value} ->
+      log(
+        "#{state.name} - prepared #{inspect(inst)} #{inspect(ballot)} #{inspect(accepted_ballot)} #{inspect(accepted_value)}"
+      )
+
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        Ballot.compare(ballot, &==/2, state.instmap[inst].ballot) ->
+          set_instmap do
+            %{
+              map
+              | prepared_values: map.prepared_values ++ [{accepted_ballot, accepted_value}]
+            }
+          end
+          prepared(state, inst)
+
+        Ballot.compare(ballot, &>/2, state.instmap[inst].ballot) ->
+          log("#{state.name} - Probably recieved this before preare came to self sending with delay")
+          Process.send_after(self(), {:prepared, inst, ballot, accepted_ballot, accepted_value}, 100)
+          state
+
+        true ->
+          state
+      end
+
+    {:rb_deliver, proc, {:accept, inst, ballot, value}} ->
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        true ->
+          state = has_or_create(state, inst)
+
+          if Ballot.compare(ballot, &>=/2, state.instmap[inst].ballot) do
+            log("#{state.name} - accept #{inspect(inst)} #{inspect(ballot)} #{inspect(value)}")
+        
+            safecast(proc, {:accepted, inst, ballot})
+
+            set_instmap do 
+              %{ map
+                | ballot: ballot,
+                  accepted_value: value,
+                  accepted_ballot: ballot
+              } 
+            end
+          else
+            log("#{state.name} -> #{proc} nack")
+            safecast(proc, {:nack, inst, ballot})
+            state
+          end
+      end
+
+    {:accepted, inst, ballot} ->
+      log("#{state.name} - accepted #{inspect(inst)} #{inspect(ballot)}")
+
+      cond do
+        has_finished(state, inst) ->
+          state
+
+        state.leader == state.name and state.instmap[inst].ballot == ballot ->
+          set_instmap do 
+            %{ map | 
+              accepted: map.accepted + 1
+            }
+          end
+
+          accepted( state, inst)
+
+        true ->
+          state
+      end
+
+    {:get_value, inst, pid_to_inform} ->
+      # log("#{state.name} get_value")
+      if  has_finished(state, inst, true) do
+          safecast(pid_to_inform, {:get_value_res, inst, state.decided[inst]})
+      end
+      state
+
+    {:rb_deliver, _, {:decide, inst, value}} ->
+      log("#{state.name} - decided #{inspect(inst)} #{inspect(value)}")
+
+      or_state not has_finished(state, inst) do
+        if Map.has_key?(state.instmap, inst) != nil and
+             state.instmap[inst].pid_to_inform != nil do
+          safecast(state.instmap[inst].pid_to_inform, {:decision, inst, value})
+        end
+
+        %{ state |
+            decided: Map.put(state.decided, inst, value),
+            instmap: Map.delete(state.instmap, inst)
+        }
       end
-    )
   end
 
   #
@@ -379,7 +410,7 @@ defmodule Paxos do
 
       true ->
         ballot = Ballot.inc(state.instmap[inst].ballot)
-        IO.puts("#{state.name} - sending all prepare #{inst} #{inspect(ballot)}")
+        log("#{state.name} - sending all prepare #{inst} #{inspect(ballot)}")
         EagerReliableBroadcast.broadcast(state.name, {:prepare, state.name, inst, ballot})
 
         set_instmap do 
@@ -453,7 +484,7 @@ defmodule Paxos do
       value = state.instmap[inst].ballot_value
 
       if state.instmap[inst].action == :kill_before_decision do
-        IO.puts("#{state.name} - Leader has action to die before decision #{inspect({:decide, inst, value})}")
+        log("#{state.name} - Leader has action to die before decision #{inspect({:decide, inst, value})}")
         Process.exit(self(), :kill)
       end
 
@@ -510,8 +541,8 @@ defmodule Paxos do
   def get_decision_loop(input) do
     {_, t} = input
     receive do
-      {:get_value_res, inst} ->
-        check_and_apply(inst, inst, input, &get_decision_loop/1)
+      {:get_value_res, inst, v} ->
+        check_and_apply(v, inst, input, &get_decision_loop/1)
 
       x ->
         Process.send_after(self(), x, 500)
@@ -568,26 +599,22 @@ defmodule EagerReliableBroadcast do
   require Utils
   import Utils
   
-  def get_rb_name(name) do
-    String.to_atom(Atom.to_string(name) <> "_rb")
-  end
-
   def get_non_rb_name(name) do
     String.to_atom(String.replace(Atom.to_string(name), "_rb", ""))
   end
 
   def start(name, processes) do
     pid = spawn(EagerReliableBroadcast, :init, [name, processes])
-    register_name(get_rb_name(name), pid)
+    register_name(alter_name(name, "_rb"), pid)
   end
 
   # Init event must be the first
   # one after the component is created
   def init(parent, processes) do
     state = %{
-      name: get_rb_name(parent),
+      name: alter_name(parent, "_rb"),
       parent: parent,
-      processes: Enum.map(processes, fn name -> get_rb_name(name) end),
+      processes: Enum.map(processes, fn name -> alter_name(name, "_rb") end),
       # Use this data structure to remember IDs of the delivered messages
       delivered: %{},
       # Use this variable to remember the last sequence number used to identify a message
@@ -597,39 +624,35 @@ defmodule EagerReliableBroadcast do
     run(state)
   end
 
-  def run(state) do
-    run(
-      receive do
-        # Handle the broadcast request event
-        {:broadcast, m} ->
-          data_msg = {:data, state.name, state.seq_no, m}
-          beb_broadcast(data_msg, state.processes)
-          %{state | seq_no: state.seq_no + 1}
+  runfn do
+    # Handle the broadcast request event
+    {:broadcast, m} ->
+      data_msg = {:data, state.name, state.seq_no, m}
+      beb_broadcast(data_msg, state.processes)
+      %{state | seq_no: state.seq_no + 1}
 
-        {:data, proc, seq_no, m} ->
-          if not Map.has_key?(state.delivered, {proc, seq_no, m}) do
-            data_msg = {:data, proc, seq_no, m}
-            beb_broadcast(data_msg, state.processes)
+    {:data, proc, seq_no, m} ->
+      if not Map.has_key?(state.delivered, {proc, seq_no, m}) do
+        data_msg = {:data, proc, seq_no, m}
+        beb_broadcast(data_msg, state.processes)
 
-            safecast(state.parent, {:rb_deliver, get_non_rb_name(proc), m})
-            %{state | delivered: Map.put(state.delivered, {proc, seq_no, m}, 1)}
-          else
-            val = Map.get(state.delivered, {proc, seq_no, m})
+        safecast(state.parent, {:rb_deliver, get_non_rb_name(proc), m})
+        %{state | delivered: Map.put(state.delivered, {proc, seq_no, m}, 1)}
+      else
+        val = Map.get(state.delivered, {proc, seq_no, m})
 
-            if val < Enum.count(state.processes) do
-              %{state | delivered: Map.put(state.delivered, {proc, seq_no, m}, val + 1)}
-            else
-              %{state | delivered: Map.delete(state.delivered, {proc, seq_no, m})}
-            end
-          end
+        if val < Enum.count(state.processes) do
+          %{state | delivered: Map.put(state.delivered, {proc, seq_no, m}, val + 1)}
+        else
+          %{state | delivered: Map.delete(state.delivered, {proc, seq_no, m})}
+        end
       end
-    )
   end
 
   #############
   # Interface #
   #############
-  def broadcast(name, m), do: safecast(get_rb_name(name), {:broadcast, m})
+  def broadcast(name, m), do: safecast(alter_name(name, "_rb"), {:broadcast, m})
 end
 
 #
@@ -640,12 +663,8 @@ defmodule EventualLeaderElector do
   require Utils
   import Utils
   
-  def getEleName(name) do
-    String.to_atom(Atom.to_string(name) <> "_ele")
-  end
-
   def start(name, processes) do
-    new_name = getEleName(name)
+    new_name = alter_name(name, "_ele")
     pid = spawn(EventualLeaderElector, :init, [new_name, name, processes])
 
     register_name(new_name, pid)
@@ -654,7 +673,7 @@ defmodule EventualLeaderElector do
   # Init event must be the first
   # one after the component is created
   def init(name, parent, processes) do
-    processes = Enum.map(processes, fn name -> getEleName(name) end)
+    processes = Enum.map(processes, fn name -> alter_name(name, "_ele") end)
 
     state = %{
       name: name,
@@ -677,30 +696,26 @@ defmodule EventualLeaderElector do
     state
   end
 
-  def run(state) do
-    run(
-      receive do
-        {:heartbeat_request, name, seq} ->
-          safecast(name, {:heartbeat, state.parent, seq})
-          state
+  runfn do
+    {:heartbeat_request, name, seq} ->
+      safecast(name, {:heartbeat, state.parent, seq})
+      state
 
-        {:heartbeat, name, seq} ->
-          or_state seq == state.seq do
-            %{state | heard_back: MapSet.put(state.heard_back, name)}
-          end
-
-        {:timeout} ->
-          state = or_state MapSet.size(state.heard_back) >= floor(length(state.processes)/2) + 1 do
-            to_trust = Enum.at(Enum.sort(MapSet.to_list(state.heard_back)), 0)
-
-            or_state state.last_trust != to_trust do
-              safecast(state.parent, {:ele_trust, to_trust})
-              %{state | last_trust: to_trust}
-            end
-          end
-
-          request_heartbeats(state)
+    {:heartbeat, name, seq} ->
+      or_state seq == state.seq do
+        %{state | heard_back: MapSet.put(state.heard_back, name)}
       end
-    )
+
+    {:timeout} ->
+      state = or_state MapSet.size(state.heard_back) >= floor(length(state.processes)/2) + 1 do
+        to_trust = Enum.at(Enum.sort(MapSet.to_list(state.heard_back)), 0)
+
+        or_state state.last_trust != to_trust do
+          safecast(state.parent, {:ele_trust, to_trust})
+          %{state | last_trust: to_trust}
+        end
+      end
+
+      request_heartbeats(state)
   end
 end
diff --git a/lib/server.ex b/lib/server.ex
new file mode 100644
index 0000000..2cc89df
--- /dev/null
+++ b/lib/server.ex
@@ -0,0 +1,161 @@
+defmodule ServerMacros do
+
+  def create_create_loop(name, do: match_exp, else: process_exp) do
+    function_name = :"#{name}_loop"
+
+    ast1 = quote do
+      {:timeout} -> :timeout
+    end
+    ast2 = quote do
+      value ->
+        Process.send_after(self(), value, 100)
+        unquote(function_name)(v)
+    end
+
+    ast3 = ast1 ++ match_exp ++ ast2
+    
+    quote do
+      def unquote(function_name)(v) do
+        var!(v) = v
+        unquote(process_exp)
+        receive do
+          unquote(ast3)
+        end
+      end
+    end
+  end
+
+  def create_create_loop(name, do: exp) do
+    create_create_loop(name, do: exp, else: nil)
+  end
+
+  defmacro create_loop(name, clauses) do
+  	create_create_loop(name, clauses)
+  end
+
+  defmacro try_propose(val, do: ready, else: recal_do) do
+    ast1 = quote do
+      {:timeout} ->  unquote(recal_do)
+      {:abort} ->   unquote(recal_do)
+    end
+    ast2 = quote do
+      {:decision, v} ->
+        var!(state) = apply_game(var!(state), v)
+        unquote(recal_do)
+
+      v ->
+        raise "Unknown message on try_propose #{inspect(v)}"
+    end
+
+    ast3 = ast1 ++ ready ++ ast2
+
+    quote do
+      v = Paxos.propose(var!(state).paxos, var!(state).instance, unquote(val), 1000)
+      case v do
+        unquote(ast3)
+      end
+    end
+  end
+
+end
+
+defmodule Server do
+  require ServerMacros
+  import ServerMacros
+  require Utils
+  import Utils
+
+  create_log 2
+
+  def start(name, participants) do
+    log("starting server")
+
+    pid = spawn(Server, :init, [name, participants])
+    register_name(name, pid, false)
+  end
+
+  def init(name, participants) do
+    paxos = Paxos.start(alter_name(name, "_paxos"), Enum.map(participants, fn name -> alter_name(name, "_paxos") end))
+    state = %{
+      name: name,
+      procs: participants,
+      games: %{},
+      paxos: paxos,
+      instance: 0,
+    }
+
+    run(state)
+  end
+
+  runfn do
+    {:start_game, participants, pid_to_inform} ->
+      {state, game_id} = try_to_create_game(state, participants)
+      safecast(pid_to_inform, {:start_game_ans, game_id})
+      state
+  end
+
+  def try_to_create_game(state, participants) do
+    game_ids = Map.keys(state.games)
+    new_game_id = Enum.at(Enum.sort(game_ids), length(game_ids) - 1) + 1
+
+    # TODO: randomize game state
+    new_game_state = [1, 1]
+    # TODO: randomize Initial hand value
+    hand = Enum.reduce(participants, %{}, fn p, acc -> Map.put(acc, p, 1) end)
+
+    try_propose {:start_game, new_game_id, participants, new_game_state, hand}
+    do
+      {:decision, {:start_game, ^new_game_id, ^participants, ^new_game_state, ^hand}} ->
+        state = apply_game(state, {:start_game, new_game_id, participants, new_game_state, hand})
+        {state, new_game_id}
+    else
+      try_to_create_game(state, participants)
+    end
+  end
+
+  #
+  # Apply Game States
+  #
+
+  def apply_game(state, {:start_game, game_id, participants, new_game_state, hand}) do
+    if state.name in participants do
+      %{state | games: Map.put(state.games, game_id, %{
+        game_state: new_game_state,
+        participants: participants,
+        hand: hand[state.name]
+      })}
+    else
+      %{state | games: Map.put(state.games, game_id, :not_playing_in_it)}
+    end
+  end
+
+  def apply_game(state, _), do: raise :do_not_know_how_to_apply_game_state
+
+  ############
+  # Interface 
+  ############
+
+  create_loop :start_game do
+     {:start_game, game_id} ->
+       log("Started a game #{game_id}")
+  end
+  
+  def start_game(name, participants) do
+    safecast(name, {:start_game, participants, self()})
+    start_game_loop(nil)
+  end
+
+  ############
+  # Debug 
+  ############
+
+  def spinup(number_of_participants) do
+    procs = Enum.to_list(0..number_of_participants) |> Enum.map(fn n -> :"p#{n}" end)
+    Enum.map(procs, fn proc -> Server.start(proc, procs) end)
+  end
+
+  def kill (pids) do
+    pids |> Enum.map(fn m -> Process.exit(m, :kill) end)
+  end
+
+end
diff --git a/lib/test.ex b/lib/test.ex
index ba9678a..e86b94f 100644
--- a/lib/test.ex
+++ b/lib/test.ex
@@ -1,9 +1,23 @@
 defmodule Test do
 
-  defmacro createfuncBase(name) do
-      quote do
-        def unquote(name)(true), do: true
+  defmacro createfuncBase(name, do: do_exp, else: else_exp) do
+      b1 = quote do
+        false -> unquote(else_exp)
       end
+
+      b2 = b1 ++ do_exp
+      
+      t = quote do
+        def test(v) do
+          case v do
+            unquote(b2)
+          end
+        end
+      end
+
+      IO.puts("test #{inspect(t)}")
+      
+      t
   end
 
 end
@@ -11,7 +25,7 @@ end
 defmodule Test2 do
   require Test
 
-  def test(), do: false
-
-  Test.createfuncBase(:test)
+  Test.createfuncBase :lol do 
+    true -> :test
+  else :test1 end
 end