View GitHub Repository WampWatch

Schedule Inspection
Subscribe
Completed
Push — master ( f06500...b00bf4 )
by Timo
03:52
created
Status
Category
Toggle Patches
src/Tidal/WampWatch/SessionMonitor.php 1 patch
Spacing   +12 added lines, -12 removed lines patch added patch discarded remove patch 
@@ -36,7 +36,7 @@  discard block
 
 block discarded – undo
36 36
37 37
38 38 
     public function start() {
39 
-        $this->once('list', function(){
39 
+        $this->once('list', function() {
40 40 
             $this->doStart();
41 41 
         });
42 42 
         $this->startSubscriptions();

@@ -51,39 +51,39 @@  discard block
 
 block discarded – undo
51 51
52 52 
     public function getSessionInfo($sessionId, callable $callback) {
53 53 
         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
54 
-            function ($res)use($callback){
54 
+            function($res)use($callback){
55 55 
                 $this->emit('info', [$res[0]]);
56 56 
                 $callback($res[0]);
57 57 
             },
58 
-            function ($error) {
58 
+            function($error) {
59 59 
                 $this->emit('error', [$error]);
60 60 
             }
61 61 
         );
62 62 
     }
63 63
64 64 
     public function getSessionIds(callable $callback) {
65 
-        if(!count($this->sessionIds)){
65 
+        if (!count($this->sessionIds)) {
66 66 
             $this->retrieveSessionIds($callback);
67 
-        }else{
67 
+        }else {
68 68 
             $callback($this->sessionIds);
69 69 
         }
70 70 
     }
71 71
72 72 
     protected function startSubscriptions() {
73 
-        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function($res){
73 
+        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function($res) {
74 74 
             $sessionInfo = $res[0];
75 75 
             $sessionId = $sessionInfo['session'];
76 
-            if((array_search($sessionId, $this->sessionIds)) === false) {
76 
+            if ((array_search($sessionId, $this->sessionIds)) === false) {
77 77 
                 $this->sessionIds[] = $sessionId;
78 78 
                 $this->emit('join', [$sessionInfo]);
79 79 
             }
80 80 
         });
81 
-        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function($res){
81 
+        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function($res) {
82 82 
             // @bug : wamp.session.on_leave is bugged as of crossbar.io 0.11.0
83 83 
             // will provide sessionID when Browser closes/reloads,
84 84 
             // but not when calling connection.close();
85 85 
             $sessionId = $res[0];
86 
-            if(($key = array_search($sessionId, $this->sessionIds)) !== false) {
86 
+            if (($key = array_search($sessionId, $this->sessionIds)) !== false) {
87 87 
                 unset($this->sessionIds[$key]);
88 88 
                 $this->emit('leave', [$sessionId]);
89 89 
             }

@@ -98,14 +98,14 @@  discard block
 
 block discarded – undo
98 98
99 99 
     protected function retrieveSessionIds($callback = null) {
100 100 
         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(
101 
-            function ($res)use($callback){
101 
+            function($res)use($callback){
102 102 
                 $this->sessionIds = $res[0];
103 103 
                 $this->emit('list', [$this->sessionIds]);
104 
-                if($callback){
104 
+                if ($callback) {
105 105 
                     $callback($this->sessionIds);
106 106 
                 }
107 107 
             },
108 
-            function ($error) {
108 
+            function($error) {
109 109 
                 $this->emit('error', [$error]);
110 110 
             }
111 111 
         );
Please login to merge, or discard this patch.