From a229cc13676e4737bf2972b5e47d3d64d38aa7cb Mon Sep 17 00:00:00 2001 From: ArnabChatterjee20k Date: Mon, 6 Apr 2026 13:05:27 +0530 Subject: [PATCH] added logging --- app/realtime.php | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/app/realtime.php b/app/realtime.php index 67cfb19e2a..4a4ecbdb50 100644 --- a/app/realtime.php +++ b/app/realtime.php @@ -383,6 +383,22 @@ $server->onStart(function () use ($stats, $containerId, &$statsDocument) { } }); +function cloudRealtimeLogConnectionHostnames(Http $app, Document $project, Request $request): void +{ + try { + /** @var array $allowed */ + $allowed = $app->getResource('allowedHostnames'); + Console::info(sprintf( + '[Realtime] project=%s origin=%s allowedHostnames=%s', + $project->getId(), + $request->getOrigin(), + json_encode(array_values($allowed)) + )); + } catch (Throwable $e) { + Console::error('[Realtime] allowedHostnames log failed: ' . $e->getMessage()); + } +} + $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats, $realtime) { Console::success('Worker ' . $workerId . ' started successfully'); @@ -688,6 +704,9 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server, */ $origin = $request->getOrigin(); $originValidator = $app->getResource('originValidator'); + + + cloudRealtimeLogConnectionHostnames($app, $project, $request); if (!empty($origin) && !$originValidator->isValid($origin) && $project->getId() !== 'console') { throw new Exception(Exception::REALTIME_POLICY_VIOLATION, $originValidator->getDescription());