From 1b1e1ed5659a748c567d6eeeea44433d37ec23ac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tim=20D=C3=BCsterhus?= <tim@bastelstu.be>
Date: Sun, 1 Nov 2020 13:25:42 +0100
Subject: [PATCH] Add missing transaction to WhisperCommand

---
 files/lib/system/command/WhisperCommand.class.php | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/files/lib/system/command/WhisperCommand.class.php b/files/lib/system/command/WhisperCommand.class.php
index 351f4b6..3918fe5 100644
--- a/files/lib/system/command/WhisperCommand.class.php
+++ b/files/lib/system/command/WhisperCommand.class.php
@@ -1,11 +1,11 @@
 <?php
 /*
- * Copyright (c) 2010-2018 Tim Düsterhus.
+ * Copyright (c) 2010-2020 Tim Düsterhus.
  *
  * Use of this software is governed by the Business Source License
  * included in the LICENSE file.
  *
- * Change Date: 2024-10-20
+ * Change Date: 2024-11-01
  *
  * On the date above, in accordance with the Business Source
  * License, use of this software will be governed by version 2
@@ -17,7 +17,6 @@ namespace chat\system\command;
 use \chat\data\message\MessageAction;
 use \chat\data\message\MessageEditor;
 use \chat\data\room\Room;
-use \wcf\data\user\User;
 use \wcf\data\user\UserProfile;
 use \wcf\system\exception\UserInputException;
 use \wcf\system\WCF;
@@ -58,6 +57,8 @@ class WhisperCommand extends AbstractInputProcessedCommand implements ICommand {
 		$objectTypeID = $this->getMessageObjectTypeID('be.bastelstu.chat.messageType.whisper');
 		$recipient = $this->assertUser($this->assertParameter($parameters, 'username'));
 		$this->setText($this->assertParameter($parameters, 'text'));
+
+		WCF::getDB()->beginTransaction();
 		$message = (new MessageAction([ ], 'create', [ 'data' => [ 'roomID'       => $room->roomID
 		                                                         , 'userID'       => $user->userID
 		                                                         , 'username'     => $user->username
@@ -79,5 +80,6 @@ class WhisperCommand extends AbstractInputProcessedCommand implements ICommand {
 				'hasEmbeddedObjects' => 1
 			]);
 		}
+		WCF::getDB()->commitTransaction();
 	}
 }