v0.2.0; netcode fix

Author: vans163

ex/lib/bic/sol.ex

@@ -16,7 +16,7 @@ defmodule BIC.Sol do
     end
     def verify(sol = <<epoch::32-little, _::192-binary, _segment_vr::96-binary, _::binary>>) when epoch >= 1 do
         if byte_size(sol) != 320, do: throw(%{error: :invalid_sol_seed_size})
-        #if !kv_get("bic:epoch:segment_vr:#{epoch}") == segment_vr, do: throw %{error: :segment_vr}
+        #if kv_get("bic:epoch:segment_vr") != segment_vr, do: throw %{error: :segment_vr}
         verify_cache(UPOW1, sol)
     end
 

ex/lib/consensus/fabric_sync_gen.ex

@@ -145,6 +145,17 @@ defmodule FabricSyncGen do
     next1000_holes = FabricSyncGen.next_1000_holes_rooted(rooted_height+1, highest_height)
     len1000_holes = length(next1000_holes)
 
+    highest_peers = NodePeers.highest_height(%{min_temporal: temporal_height, sort: :temporal})
+    {highest_height, _highest_consensus} = case List.first(highest_peers) do
+      nil -> {temporal_height, rooted_height}
+      [_, _, highest, consensus | _ ] -> {highest, consensus}
+    end
+
+    next1000_holes_temporal = FabricSyncGen.next_1000_holes_rooted(temporal_height+1, highest_height)
+    len1000_holes_temporal = length(next1000_holes_temporal)
+
+    #IO.inspect {highest_height, highest_consensus, len1000_holes}
+
     cond do
       !hasQuorum() -> nil
 
@@ -158,6 +169,16 @@ defmodule FabricSyncGen do
         peer_ips = Enum.shuffle(highest_peers) |> Enum.map(& hd(&1)) |> Enum.take(3)
         send(NodeGen, {:send_to_some, peer_ips, NodeProto.pack_message(msg)})
 
+      len1000_holes_temporal > 0 and len1000_holes_temporal <= 3 ->
+        if len1000_holes_temporal > 1 do
+          IO.puts "Syncing #{len1000_holes_temporal} temporal entries"
+        end
+        #IO.inspect {temporal_height, rooted_height, highest_peers}
+
+        msg = NodeProto.catchup_tri(next1000_holes_temporal)
+        peer_ips = Enum.shuffle(highest_peers) |> Enum.map(& hd(&1)) |> Enum.take(3)
+        send(NodeGen, {:send_to_some, peer_ips, NodeProto.pack_message(msg)})
+
       len1000_holes > 3 ->
         IO.puts "Syncing #{len1000_holes} entries"
         #IO.inspect next1000_holes

ex/mix.exs

@@ -6,7 +6,7 @@ defmodule Ama.MixProject do
   def project do
     [
       app: @app,
-      version: "0.1.4",
+      version: "0.2.0",
       elixir: "~> 1.17.0",
       start_permanent: Mix.env() == :prod,
       deps: deps(),