]> Entropealabs - wampex_router.git/commitdiff
change transition event to established
authorChristopher Coté <ccote@thecitybase.com>
Thu, 20 Feb 2020 22:50:33 +0000 (16:50 -0600)
committerChristopher Coté <ccote@thecitybase.com>
Thu, 20 Feb 2020 22:50:33 +0000 (16:50 -0600)
lib/wampex/roles/callee.ex
lib/wampex/roles/caller.ex
lib/wampex/roles/peer.ex
lib/wampex/roles/publisher.ex
lib/wampex/roles/subscriber.ex
priv/session.json

index cbbcd99f218c007e045d71b0195a2b1219d69bf1..3962eb406c43ba1e53d0e151f8dc82075ff576ca 100644 (file)
@@ -69,12 +69,12 @@ defmodule Wampex.Role.Callee do
 
   @impl true
   def handle([@unregistered, request_id], sl) do
-    {sl, [{:next_event, :internal, :noop}], request_id, {:ok, request_id}}
+    {sl, [{:next_event, :internal, :established}], request_id, {:ok, request_id}}
   end
 
   @impl true
   def handle([@registered, request_id, id], sl) do
-    {sl, [{:next_event, :internal, :noop}], request_id, {:ok, id}}
+    {sl, [{:next_event, :internal, :established}], request_id, {:ok, id}}
   end
 
   @impl true
index 2ab17716477589b27ba49be93ada461c832b79de..9612135ece4a022377281bafbf84cfa4ec5a002f 100644 (file)
@@ -44,6 +44,6 @@ defmodule Wampex.Role.Caller do
 
   @impl true
   def handle([@result, id, _dets, arg_l, arg_kw], sl) do
-    {sl, [{:next_event, :internal, :noop}], id, {:ok, arg_l, arg_kw}}
+    {sl, [{:next_event, :internal, :established}], id, {:ok, arg_l, arg_kw}}
   end
 end
index 5a6581b3762271ea8171c46e529963bc29d4fc00..6ac2e2d276673b62244af874dd6acb57bb3a6887 100644 (file)
@@ -71,7 +71,7 @@ defmodule Wampex.Role.Peer do
 
   @impl true
   def handle([@welcome, session_id, _dets], sl) do
-    {sl, [{:next_event, :internal, :noop}], nil, {:update, :id, session_id}}
+    {sl, [{:next_event, :internal, :established}], nil, {:update, :id, session_id}}
   end
 
   @impl true
@@ -101,6 +101,6 @@ defmodule Wampex.Role.Peer do
 
   @impl true
   def handle([@error, type, id, _dets, error, arg_l, arg_kw], sl) do
-    {sl, [{:next_event, :internal, :noop}], id, {:error, type, error, arg_l, arg_kw}}
+    {sl, [{:next_event, :internal, :established}], id, {:error, type, error, arg_l, arg_kw}}
   end
 end
index d8ba01bf84d341cb8e98eaadf9fa879d920eb01f..2e61c9781d2572271472c33789488c62117ff893 100644 (file)
@@ -34,6 +34,6 @@ defmodule Wampex.Role.Publisher do
 
   @impl true
   def handle([@published, request_id, id], sl) do
-    {sl, [{:next_event, :internal, :noop}], request_id, {:ok, id}}
+    {sl, [{:next_event, :internal, :established}], request_id, {:ok, id}}
   end
 end
index 6a6419d96d0377f7f97e0b7d92b93de3263bc799..abbef1a498b8c5d5497ea0f536c497ce1e9d7f89 100644 (file)
@@ -50,12 +50,12 @@ defmodule Wampex.Role.Subscriber do
 
   @impl true
   def handle([@subscribed, request_id, id], sl) do
-    {sl, [{:next_event, :internal, :noop}], request_id, {:ok, id}}
+    {sl, [{:next_event, :internal, :established}], request_id, {:ok, id}}
   end
 
   @impl true
   def handle([@unsubscribed, request_id], sl) do
-    {sl, [{:next_event, :internal, :noop}], request_id, :ok}
+    {sl, [{:next_event, :internal, :established}], request_id, :ok}
   end
 
   @impl true
index 1329a99498c40b1f370d35b56dbccbfab70749e5..52723b078c358b0b889df8c503471d53b6f60fc6 100644 (file)
@@ -64,7 +64,7 @@
       "Resource": "HandleMessage",
       "Choices": [
         {
-          "StringEquals": ":noop",
+          "StringEquals": ":established",
           "Next": "Established"
         },
         {