Commit PusherManager.cs

Author: aonemd

Examples/1-realtime-controlled-2d-game/RealtimeControlled2dGame/Assets/PusherManager.cs

@@ -5,9 +5,9 @@
 
 public enum State
 {
-    IDLE,
-    RUNRIGHT,
     RUNLEFT,
+    RUNRIGHT,
+    IDLE,
     ATTACK
 }
 
@@ -17,9 +17,9 @@ public class PusherManager : MonoBehaviour
     public static PusherManager instance = null;
     private Pusher _pusher;
     private Channel _channel;
-    private State _currentState = State.IDLE;
     private const string APP_KEY = "APP_KEY";
     private const string APP_CLUSTER = "APP_CLUSTER";
+    private State _state = State.IDLE;
 
     async Task Start()
     {
@@ -63,38 +63,26 @@ private async Task InitialisePusher()
 
     private void PusherOnConnected(object sender)
     {
-        Debug.Log("Connected");
-
-        // Bind to game control events
-        _channel.Bind("move_right", (dynamic data) =>
+        _channel.Bind("run-left", (dynamic data) =>
         {
-            Debug.Log("move_right received");
-            SetCurrentState(State.RUNRIGHT);
+            _state = State.RUNLEFT;
         });
 
-        _channel.Bind("move_left", (dynamic data) =>
+        _channel.Bind("run-right", (dynamic data) =>
         {
-            Debug.Log("move_left received");
-            SetCurrentState(State.RUNLEFT);
-        });
-
-        _channel.Bind("attack", (dynamic data) =>
-        {
-            Debug.Log("attack received");
-            SetCurrentState(State.ATTACK);
+            _state = State.RUNRIGHT;
         });
 
         _channel.Bind("idle", (dynamic data) =>
         {
-            Debug.Log("idle received");
-            SetCurrentState(State.IDLE);
+            _state = State.IDLE;
         });
 
-        // Keep the original event binding for compatibility
-        _channel.Bind("my-event", (dynamic data) =>
+        _channel.Bind("attack", (dynamic data) =>
         {
-            Debug.Log("my-event received");
+            _state = State.ATTACK;
         });
+        Debug.Log("Connected");
     }
 
     private void PusherOnConnectionStateChanged(object sender, ConnectionState state)
@@ -112,21 +100,21 @@ private void OnChannelOnSubscribed(object s, Channel channel)
         Debug.Log("Subscribed");
     }
 
-    async Task OnApplicationQuit()
+    public void Message(string message)
     {
-        if (_pusher != null)
-        {
-            await _pusher.DisconnectAsync();
-        }
+        _channel?.Trigger("time has occured", message);
     }
 
     public State CurrentState()
     {
-        return _currentState;
+        return _state;
     }
 
-    public void SetCurrentState(State newState)
+    async Task OnApplicationQuit()
     {
-        _currentState = newState;
+        if (_pusher != null)
+        {
+            await _pusher.DisconnectAsync();
+        }
     }
 }