Move code to BoardService

Signed-off-by: Sergey Shliakhov <[email protected]>

lib/Command/TransferOwnership.php

@@ -1,15 +1,24 @@
 <?php
-declare(strict_types=1);
 
 namespace OCA\Deck\Command;
 
+use OCA\Deck\Service\BoardService;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
 final class TransferOwnership extends Command {
 
+	protected $boardService;
+
+	public function __construct(BoardService $boardService)
+	{
+		parent::__construct();
+
+		$this->boardService = $boardService;
+	}
+
 	protected function configure() {
 		$this
 			->setName('deck:transfer-ownership')
@@ -19,45 +28,22 @@ protected function configure() {
 				InputArgument::REQUIRED,
 				'Owner uid'
 			)
-            ->addArgument(
-                'newOwner',
-                InputArgument::REQUIRED,
-                'New owner uid'
-            );
+			->addArgument(
+				'newOwner',
+				InputArgument::REQUIRED,
+				'New owner uid'
+			);
 	}
 
 	protected function execute(InputInterface $input, OutputInterface $output) {
 		$owner = $input->getArgument('owner');
 		$newOwner = $input->getArgument('newOwner');
-        $db = \OC::$server->getDatabaseConnection();
 
-        $output->writeln("Transfer deck entities from $owner to $newOwner");
-        $params = [
-            'owner' => $owner,
-            'newOwner' => $newOwner
-        ];
+		$output->writeln("Transfer deck entities from $owner to $newOwner");
 
-        $output->writeln('update oc_deck_assigned_users');
-        $stmt = $db->prepare('UPDATE `oc_deck_assigned_users` SET `participant` = :newOwner WHERE `participant` = :owner');
-        $stmt->execute($params);
+		$this->boardService->transferOwnership($owner, $newOwner);
 
-        $output->writeln('update oc_deck_attachment');
-        $stmt = $db->prepare('UPDATE `oc_deck_attachment` SET `created_by` = :newOwner WHERE `created_by` = :owner');
-        $stmt->execute($params);
-
-        $output->writeln('update oc_deck_boards');
-        $stmt = $db->prepare('UPDATE `oc_deck_boards` SET `owner` = :newOwner WHERE `owner` = :owner');
-        $stmt->execute($params);
-
-        $output->writeln('update oc_deck_board_acl');
-        $stmt = $db->prepare('UPDATE `oc_deck_board_acl` SET `participant` = :newOwner WHERE `participant` = :owner');
-        $stmt->execute($params);
-
-        $output->writeln('update oc_deck_cards');
-        $stmt = $db->prepare('UPDATE `oc_deck_cards` SET `owner` = :newOwner WHERE `owner` = :owner');
-        $stmt->execute($params);
-
-        $output->writeln("Transfer deck entities from $owner to $newOwner completed");
-    }
+		$output->writeln("Transfer deck entities from $owner to $newOwner completed");
+	}
 
 }

lib/Db/AclMapper.php

@@ -51,4 +51,21 @@ public function findByParticipant($type, $participant) {
 		$sql = 'SELECT * from *PREFIX*deck_board_acl WHERE type = ? AND participant = ?';
 		return $this->findEntities($sql, [$type, $participant]);
 	}
+
+	/**
+	 * @param $ownerId
+	 * @param $newOwnerId
+	 * @return void
+	 */
+	public function transferOwnership($ownerId, $newOwnerId)
+	{
+		$params = [
+			'owner' => $ownerId,
+			'newOwner' => $newOwnerId,
+			'type' => Acl::PERMISSION_TYPE_USER
+		];
+		$sql = "UPDATE `{$this->tableName}`  SET `participant` = :newOwner WHERE `participant` = :owner AND `type` = :type";
+		$stmt = $this->execute($sql, $params);
+		$stmt->closeCursor();
+	}
 }

lib/Db/AssignedUsersMapper.php

@@ -114,4 +114,20 @@ private function getOrigin(AssignedUsers $assignment) {
 		}
 		return null;
 	}
+
+	/**
+	 * @param $ownerId
+	 * @param $newOwnerId
+	 * @return void
+	 */
+	public function transferOwnership($ownerId, $newOwnerId)
+	{
+		$params = [
+			'owner' => $ownerId,
+			'newOwner' => $newOwnerId
+		];
+		$sql = "UPDATE `{$this->tableName}`  SET `participant` = :newOwner WHERE `participant` = :owner";
+		$stmt = $this->execute($sql, $params);
+		$stmt->closeCursor();
+	}
 }

lib/Db/BoardMapper.php

@@ -261,4 +261,20 @@ public function mapOwner(Board &$board) {
 			return null;
 		});
 	}
+
+    /**
+     * @param $ownerId
+     * @param $newOwnerId
+     * @return void
+     */
+    public function transferOwnership($ownerId, $newOwnerId)
+    {
+        $params = [
+            'owner' => $ownerId,
+            'newOwner' => $newOwnerId
+        ];
+        $sql = "UPDATE `{$this->tableName}` SET `owner` = :newOwner WHERE `owner` = :owner";
+        $stmt = $this->execute($sql, $params);
+        $stmt->closeCursor();
+    }
 }

lib/Db/CardMapper.php

@@ -205,4 +205,20 @@ public function mapOwner(Card &$card) {
 			return null;
 		});
 	}
+
+	/**
+	 * @param $ownerId
+	 * @param $newOwnerId
+	 * @return void
+	 */
+	public function transferOwnership($ownerId, $newOwnerId)
+	{
+		$params = [
+			'owner' => $ownerId,
+			'newOwner' => $newOwnerId
+		];
+		$sql = "UPDATE `{$this->tableName}`  SET `owner` = :newOwner WHERE `owner` = :owner";
+		$stmt = $this->execute($sql, $params);
+		$stmt->closeCursor();
+	}
 }

lib/Service/BoardService.php

@@ -29,6 +29,7 @@
 use OCA\Deck\Db\Acl;
 use OCA\Deck\Db\AclMapper;
 use OCA\Deck\Db\AssignedUsersMapper;
+use OCA\Deck\Db\CardMapper;
 use OCA\Deck\Db\ChangeHelper;
 use OCA\Deck\Db\IPermissionMapper;
 use OCA\Deck\Db\Label;
@@ -63,6 +64,7 @@ class BoardService {
 	/** @var EventDispatcherInterface */
 	private $eventDispatcher;
 	private $changeHelper;
+	private $cardMapper;
 
 	public function __construct(
 		BoardMapper $boardMapper,
@@ -73,6 +75,7 @@ public function __construct(
 		PermissionService $permissionService,
 		NotificationHelper $notificationHelper,
 		AssignedUsersMapper $assignedUsersMapper,
+		CardMapper $cardMapper,
 		IUserManager $userManager,
 		IGroupManager $groupManager,
 		ActivityManager $activityManager,
@@ -94,6 +97,7 @@ public function __construct(
 		$this->eventDispatcher = $eventDispatcher;
 		$this->changeHelper = $changeHelper;
 		$this->userId = $userId;
+		$this->cardMapper = $cardMapper;
 	}
 
 	/**
@@ -669,6 +673,19 @@ public function clone($id, $userId) {
 		return $newBoard;
 	}
 
+	/**
+	 * @param $ownerId
+	 * @param $newOwnerId
+	 * @return void
+	 */
+	public function transferOwnership($owner, $newOwner)
+	{
+		$this->boardMapper->transferOwnership($owner, $newOwner);
+		$this->assignedUsersMapper->transferOwnership($owner, $newOwner);
+		$this->aclMapper->transferOwnership($owner, $newOwner);
+		$this->cardMapper->transferOwnership($owner, $newOwner);
+	}
+
 	private function enrichWithStacks($board, $since = -1) {
 		$stacks = $this->stackMapper->findAll($board->getId(), null, null, $since);