diff --git a/lib/CF/Controller/Websockets.pm b/lib/CF/Controller/Websockets.pm index 3ae28fc224dc23d0263a48a99ccbe57b55f10cc8..639054695af76faeaadd8f4f30abdc485e3eb34e 100644 --- a/lib/CF/Controller/Websockets.pm +++ b/lib/CF/Controller/Websockets.pm @@ -23,24 +23,22 @@ sub main { my $listener = $pubsub->listen( "notify:$event_id" => sub($pubsub, $payload, $channel) { - $c->trace("$pubsub, $payload, $channel"); $c->send(decode("UTF-8", $payload)); } ); my $listener_online = $pubsub->listen( "online:$event_id" => sub($pubsub, $payload, $channel) { - $c->trace("$pubsub, $payload, $channel"); -# my @counts = split ' ', $payload; -# $c->send({json => { -# event => 'online_users_updated', -# payload => { -# all => $counts[0]+0, -# members => $counts[1]+0, -# group_size_full => $counts[2]+0, -# group_size_half => $counts[3]+0, -# } -# }}); + my @counts = split ' ', $payload; + $c->send({json => { + event => 'online_users_updated', + payload => { + all => $counts[0]+0, + members => $counts[1]+0, + group_size_full => $counts[2]+0, + group_size_half => $counts[3]+0, + } + }}); } );