Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

add more logs

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-02-06 15:25:05 +05:30
parent dee2841701
commit 261c7bc050
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+5 -3
View File
@@ -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,