From 45cb05bb31f6cd7c4537668b0a6f93b4da32a1bc Mon Sep 17 00:00:00 2001
From: Torsten Dittmann <torsten.dittmann@googlemail.com>
Date: Thu, 26 Aug 2021 18:10:53 +0200
Subject: [PATCH] fix(realtime): exception

---
 app/realtime.php | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/app/realtime.php b/app/realtime.php
index d84f557644..415c9457eb 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -476,12 +476,7 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
         $message = json_decode($message, true);
 
         if (is_null($message) || (!array_key_exists('type', $message) && !array_key_exists('data', $message))) {
-            $response = [
-                'code' => 1003,
-                'message' => 'Message format is wrong.'
-            ];
-            $server->close($connection, 1003);
-            $server->send([$connection], json_encode($response));
+            throw new Exception('Message format is not valid.', 1003);
         }
 
         switch ($message['type']) {