284 lines
8.9 KiB
PHP
284 lines
8.9 KiB
PHP
<?php
|
|
/**
|
|
* @copyright Copyright (c) 2016 Julius Härtl <jus@bitgrid.net>
|
|
*
|
|
* @author Julius Härtl <jus@bitgrid.net>
|
|
*
|
|
* @license GNU AGPL version 3 or any later version
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as
|
|
* published by the Free Software Foundation, either version 3 of the
|
|
* License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
namespace OCA\Deck\Db;
|
|
|
|
use OCP\AppFramework\Db\DoesNotExistException;
|
|
use OCP\IDBConnection;
|
|
use OCP\ILogger;
|
|
use OCP\IUserManager;
|
|
use OCP\IGroupManager;
|
|
|
|
class BoardMapper extends DeckMapper implements IPermissionMapper {
|
|
private $labelMapper;
|
|
private $aclMapper;
|
|
private $stackMapper;
|
|
private $userManager;
|
|
private $groupManager;
|
|
|
|
private $circlesEnabled;
|
|
|
|
public function __construct(
|
|
IDBConnection $db,
|
|
LabelMapper $labelMapper,
|
|
AclMapper $aclMapper,
|
|
StackMapper $stackMapper,
|
|
IUserManager $userManager,
|
|
IGroupManager $groupManager
|
|
) {
|
|
parent::__construct($db, 'deck_boards', Board::class);
|
|
$this->labelMapper = $labelMapper;
|
|
$this->aclMapper = $aclMapper;
|
|
$this->stackMapper = $stackMapper;
|
|
$this->userManager = $userManager;
|
|
$this->groupManager = $groupManager;
|
|
|
|
$this->circlesEnabled = \OC::$server->getAppManager()->isEnabledForUser('circles');
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $id
|
|
* @param bool $withLabels
|
|
* @param bool $withAcl
|
|
* @return \OCP\AppFramework\Db\Entity
|
|
* @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException
|
|
* @throws DoesNotExistException
|
|
*/
|
|
public function find($id, $withLabels = false, $withAcl = false) {
|
|
$sql = 'SELECT id, title, owner, color, archived, deleted_at, last_modified FROM `*PREFIX*deck_boards` ' .
|
|
'WHERE `id` = ?';
|
|
$board = $this->findEntity($sql, [$id]);
|
|
|
|
// Add labels
|
|
if ($withLabels) {
|
|
$labels = $this->labelMapper->findAll($id);
|
|
$board->setLabels($labels);
|
|
}
|
|
|
|
// Add acl
|
|
if ($withAcl) {
|
|
$acl = $this->aclMapper->findAll($id);
|
|
$board->setAcl($acl);
|
|
}
|
|
|
|
return $board;
|
|
}
|
|
|
|
/**
|
|
* Find all boards for a given user
|
|
*
|
|
* @param $userId
|
|
* @param null $limit
|
|
* @param null $offset
|
|
* @return array
|
|
*/
|
|
public function findAllByUser($userId, $limit = null, $offset = null, $since = -1, $includeArchived = true) {
|
|
// FIXME: One moving to QBMapper we should allow filtering the boards probably by method chaining for additional where clauses
|
|
$sql = 'SELECT id, title, owner, color, archived, deleted_at, 0 as shared, last_modified FROM `*PREFIX*deck_boards` WHERE owner = ? AND last_modified > ?';
|
|
if (!$includeArchived) {
|
|
$sql .= ' AND NOT archived AND deleted_at = 0';
|
|
}
|
|
$sql .= ' UNION ' .
|
|
'SELECT boards.id, title, owner, color, archived, deleted_at, 1 as shared, last_modified FROM `*PREFIX*deck_boards` as boards ' .
|
|
'JOIN `*PREFIX*deck_board_acl` as acl ON boards.id=acl.board_id WHERE acl.participant=? AND acl.type=? AND boards.owner != ? AND last_modified > ?';
|
|
if (!$includeArchived) {
|
|
$sql .= ' AND NOT archived AND deleted_at = 0';
|
|
}
|
|
$entries = $this->findEntities($sql, [$userId, $since, $userId, Acl::PERMISSION_TYPE_USER, $userId, $since], $limit, $offset);
|
|
/* @var Board $entry */
|
|
foreach ($entries as $entry) {
|
|
$acl = $this->aclMapper->findAll($entry->id);
|
|
$entry->setAcl($acl);
|
|
}
|
|
return $entries;
|
|
}
|
|
|
|
public function findAllByOwner(string $userId, int $limit = null, int $offset = null) {
|
|
$sql = 'SELECT * FROM `*PREFIX*deck_boards` WHERE owner = ?';
|
|
return $this->findEntities($sql, [$userId], $limit, $offset);
|
|
}
|
|
|
|
/**
|
|
* Find all boards for a given user
|
|
*
|
|
* @param $userId
|
|
* @param $groups
|
|
* @param null $limit
|
|
* @param null $offset
|
|
* @return array
|
|
*/
|
|
public function findAllByGroups($userId, $groups, $limit = null, $offset = null, $since = -1,$includeArchived = true) {
|
|
if (count($groups) <= 0) {
|
|
return [];
|
|
}
|
|
$sql = 'SELECT boards.id, title, owner, color, archived, deleted_at, 2 as shared, last_modified FROM `*PREFIX*deck_boards` as boards ' .
|
|
'INNER JOIN `*PREFIX*deck_board_acl` as acl ON boards.id=acl.board_id WHERE owner != ? AND type=? AND (';
|
|
for ($i = 0, $iMax = count($groups); $i < $iMax; $i++) {
|
|
$sql .= 'acl.participant = ? ';
|
|
if (count($groups) > 1 && $i < count($groups) - 1) {
|
|
$sql .= ' OR ';
|
|
}
|
|
}
|
|
$sql .= ')';
|
|
if (!$includeArchived) {
|
|
$sql .= ' AND NOT archived AND deleted_at = 0';
|
|
}
|
|
$entries = $this->findEntities($sql, array_merge([$userId, Acl::PERMISSION_TYPE_GROUP], $groups), $limit, $offset);
|
|
/* @var Board $entry */
|
|
foreach ($entries as $entry) {
|
|
$acl = $this->aclMapper->findAll($entry->id);
|
|
$entry->setAcl($acl);
|
|
}
|
|
return $entries;
|
|
}
|
|
|
|
public function findAllByCircles($userId, $limit = null, $offset = null, $since = -1,$includeArchived = true) {
|
|
if (!$this->circlesEnabled) {
|
|
return [];
|
|
}
|
|
$circles = array_map(function ($circle) {
|
|
return $circle->getUniqueId();
|
|
}, \OCA\Circles\Api\v1\Circles::joinedCircles($userId, true));
|
|
if (count($circles) === 0) {
|
|
return [];
|
|
}
|
|
|
|
$sql = 'SELECT boards.id, title, owner, color, archived, deleted_at, 2 as shared, last_modified FROM `*PREFIX*deck_boards` as boards ' .
|
|
'INNER JOIN `*PREFIX*deck_board_acl` as acl ON boards.id=acl.board_id WHERE owner != ? AND type=? AND (';
|
|
for ($i = 0, $iMax = count($circles); $i < $iMax; $i++) {
|
|
$sql .= 'acl.participant = ? ';
|
|
if (count($circles) > 1 && $i < count($circles) - 1) {
|
|
$sql .= ' OR ';
|
|
}
|
|
}
|
|
$sql .= ')';
|
|
if (!$includeArchived) {
|
|
$sql .= ' AND NOT archived AND deleted_at = 0';
|
|
}
|
|
$entries = $this->findEntities($sql, array_merge([$userId, Acl::PERMISSION_TYPE_CIRCLE], $circles), $limit, $offset);
|
|
/* @var Board $entry */
|
|
foreach ($entries as $entry) {
|
|
$acl = $this->aclMapper->findAll($entry->id);
|
|
$entry->setAcl($acl);
|
|
}
|
|
return $entries;
|
|
}
|
|
|
|
public function findAll() {
|
|
$sql = 'SELECT id from *PREFIX*deck_boards;';
|
|
return $this->findEntities($sql);
|
|
}
|
|
|
|
public function findToDelete() {
|
|
// add buffer of 5 min
|
|
$timeLimit = time() - (60 * 5);
|
|
$sql = 'SELECT id, title, owner, color, archived, deleted_at, last_modified FROM `*PREFIX*deck_boards` ' .
|
|
'WHERE `deleted_at` > 0 AND `deleted_at` < ?';
|
|
return $this->findEntities($sql, [$timeLimit]);
|
|
}
|
|
|
|
public function delete(/** @noinspection PhpUnnecessaryFullyQualifiedNameInspection */
|
|
\OCP\AppFramework\Db\Entity $entity) {
|
|
// delete acl
|
|
$acl = $this->aclMapper->findAll($entity->getId());
|
|
foreach ($acl as $item) {
|
|
$this->aclMapper->delete($item);
|
|
}
|
|
|
|
// delete stacks ( includes cards, assigned labels)
|
|
$stacks = $this->stackMapper->findAll($entity->getId());
|
|
foreach ($stacks as $stack) {
|
|
$this->stackMapper->delete($stack);
|
|
}
|
|
// delete labels
|
|
$labels = $this->labelMapper->findAll($entity->getId());
|
|
foreach ($labels as $label) {
|
|
$this->labelMapper->delete($label);
|
|
}
|
|
|
|
return parent::delete($entity);
|
|
}
|
|
|
|
public function isOwner($userId, $boardId): bool {
|
|
$board = $this->find($boardId);
|
|
return ($board->getOwner() === $userId);
|
|
}
|
|
|
|
public function findBoardId($id): ?int {
|
|
return $id;
|
|
}
|
|
|
|
public function mapAcl(Acl &$acl) {
|
|
$userManager = $this->userManager;
|
|
$groupManager = $this->groupManager;
|
|
$acl->resolveRelation('participant', function ($participant) use (&$acl, &$userManager, &$groupManager) {
|
|
if ($acl->getType() === Acl::PERMISSION_TYPE_USER) {
|
|
$user = $userManager->get($participant);
|
|
if ($user !== null) {
|
|
return new User($user);
|
|
}
|
|
\OC::$server->getLogger()->debug('User ' . $acl->getId() . ' not found when mapping acl ' . $acl->getParticipant());
|
|
return null;
|
|
}
|
|
if ($acl->getType() === Acl::PERMISSION_TYPE_GROUP) {
|
|
$group = $groupManager->get($participant);
|
|
if ($group !== null) {
|
|
return new Group($group);
|
|
}
|
|
\OC::$server->getLogger()->debug('Group ' . $acl->getId() . ' not found when mapping acl ' . $acl->getParticipant());
|
|
return null;
|
|
}
|
|
if ($acl->getType() === Acl::PERMISSION_TYPE_CIRCLE) {
|
|
if (!$this->circlesEnabled) {
|
|
return null;
|
|
}
|
|
try {
|
|
$circle = \OCA\Circles\Api\v1\Circles::detailsCircle($acl->getParticipant(), true);
|
|
if ($circle) {
|
|
return new Circle($circle);
|
|
}
|
|
} catch (\Exception $e) {
|
|
}
|
|
return null;
|
|
}
|
|
\OC::$server->getLogger()->log(ILogger::WARN, 'Unknown permission type for mapping acl ' . $acl->getId());
|
|
return null;
|
|
});
|
|
}
|
|
|
|
/**
|
|
* @param Board $board
|
|
*/
|
|
public function mapOwner(Board &$board) {
|
|
$userManager = $this->userManager;
|
|
$board->resolveRelation('owner', function ($owner) use (&$userManager) {
|
|
$user = $userManager->get($owner);
|
|
if ($user !== null) {
|
|
return new User($user);
|
|
}
|
|
return null;
|
|
});
|
|
}
|
|
}
|