From 261c7bc050da95074d2910f58a78122ada769f7f Mon Sep 17 00:00:00 2001
From: ArnabChatterjee20k <arnabchatterjee.ac.2@gmail.com>
Date: Fri, 6 Feb 2026 15:25:05 +0530
Subject: [PATCH] add more logs

---
 app/realtime.php | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/app/realtime.php b/app/realtime.php
index 2fc28eca71..208eee4c94 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -440,7 +440,7 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
                 $data = $event['data'];
                 // Send matched subscription IDs
                 $data['subscriptions'] = array_keys($matchedSubscriptions);
-
+                Console::log("[Debug][Worker test endpoint sending time: " . $time);
                 $server->send([$connectionId], json_encode([
                     'type' => 'event',
                     'data' => $data
@@ -653,8 +653,10 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
         $subscriptionMapping = [];
         foreach ($subscriptionsByIndex as $index => $subscription) {
             $subscriptionId = ID::unique();
-            Console::info("[Channels received] {$subscription['queries']}");
-            Console::info("[Queries received] {$subscription['queries']}");
+            $queries = json_encode($subscription['queries']);
+            $channelsPresent = json_encode($subscription['channels']);
+            Console::info("[Channels received] {$channelsPresent}");
+            Console::info("[Queries received] {$queries}");
             $realtime->subscribe(
                 $project->getId(),
                 $connection,