From: Christopher <chris@entropealabs.com>
Date: Thu, 16 Apr 2020 16:45:06 +0000 (-0500)
Subject: handle updating currupted call index
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=refs%2Fheads%2Flive-callee-logging;p=wampex_router.git

handle updating currupted call index
---

diff --git a/lib/router/realms/session.ex b/lib/router/realms/session.ex
index 22636bf..f82dde3 100644
--- a/lib/router/realms/session.ex
+++ b/lib/router/realms/session.ex
@@ -98,10 +98,16 @@ defmodule Wampex.Router.Realms.Session do
     current_id + 1
   end
 
-  defp update_round_robin({id, [values] = v}, value) do
+  defp update_round_robin({id, v}, value) do
     Logger.info("Update Round Robin: #{inspect(id)} -> #{inspect(v)}: #{inspect(value)}")
 
-    case values + 1 do
+    val =
+      case v do
+        [values] -> values
+        [_ | t] -> Enum.reduce(t, 0, fn a, _acc -> a end)
+      end
+
+    case val + 1 do
       ni when ni < value ->
         Logger.info("Incrementing round robin: #{inspect(id)} to #{inspect(ni)}")
         {id, [ni]}