From 5ab82f89360df818eb0dd866357feb86c19e4824 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Andrej=20Rama=C5=A1euski?= <andrej@x2.cz>
Date: Thu, 27 Apr 2023 21:54:27 +0200
Subject: [PATCH] Test
---
lib/CF/Controller/Websockets.pm | 26 ++++++++++++++------------
openapi.yaml | 2 +-
2 files changed, 15 insertions(+), 13 deletions(-)
diff --git a/lib/CF/Controller/Websockets.pm b/lib/CF/Controller/Websockets.pm
index bb8afc1..3ae28fc 100644
--- a/lib/CF/Controller/Websockets.pm
+++ b/lib/CF/Controller/Websockets.pm
@@ -22,23 +22,25 @@ sub main {
my $event_id = 0; #TODO - parametr!
my $listener = $pubsub->listen(
- "notify:$event_id" => sub($pubsub, $payload) {
+ "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) {
- 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,
- }
- }});
+ "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,
+# }
+# }});
}
);
diff --git a/openapi.yaml b/openapi.yaml
index 144c354..ad87abe 100644
--- a/openapi.yaml
+++ b/openapi.yaml
@@ -1,7 +1,7 @@
openapi: 3.0.3
info:
- version: "3.2.3"
+ version: "3.2.4"
title: CF Online
description: CF Online
license:
--
GitLab