mirror of
https://github.com/chenasraf/nextcloud-forum.git
synced 2026-05-18 01:28:58 +00:00
417 lines
13 KiB
PHP
417 lines
13 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
// SPDX-FileCopyrightText: Chen Asraf <contact@casraf.dev>
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
namespace OCA\Forum\Db;
|
|
|
|
use OCA\Forum\AppInfo\Application;
|
|
use OCP\AppFramework\Db\DoesNotExistException;
|
|
use OCP\AppFramework\Db\QBMapper;
|
|
use OCP\DB\QueryBuilder\IQueryBuilder;
|
|
use OCP\IDBConnection;
|
|
|
|
/**
|
|
* @template-extends QBMapper<Thread>
|
|
*/
|
|
class ThreadMapper extends QBMapper {
|
|
public function __construct(
|
|
IDBConnection $db,
|
|
) {
|
|
parent::__construct($db, Application::tableName('forum_threads'), Thread::class);
|
|
}
|
|
|
|
/**
|
|
* @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException
|
|
* @throws DoesNotExistException
|
|
*/
|
|
public function find(int $id): Thread {
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()
|
|
->eq('id', $qb->createNamedParameter($id, IQueryBuilder::PARAM_INT))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
return $this->findEntity($qb);
|
|
}
|
|
|
|
/**
|
|
* @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException
|
|
* @throws DoesNotExistException
|
|
*/
|
|
public function findBySlug(string $slug): Thread {
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()
|
|
->eq('slug', $qb->createNamedParameter($slug, IQueryBuilder::PARAM_STR))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
return $this->findEntity($qb);
|
|
}
|
|
|
|
/**
|
|
* @return array<Thread>
|
|
*/
|
|
public function findByCategoryId(int $categoryId, int $limit = 50, int $offset = 0): array {
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()->eq('category_id', $qb->createNamedParameter($categoryId, IQueryBuilder::PARAM_INT))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->eq('is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
)
|
|
->orderBy('is_pinned', 'DESC')
|
|
->addOrderBy($qb->createFunction('COALESCE(last_reply_at, created_at)'), 'DESC')
|
|
->setMaxResults($limit)
|
|
->setFirstResult($offset);
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* @return array<Thread>
|
|
*/
|
|
public function findAll(): array {
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()->isNull('deleted_at')
|
|
)
|
|
->orderBy('is_pinned', 'DESC')
|
|
->addOrderBy($qb->createFunction('COALESCE(last_reply_at, created_at)'), 'DESC');
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Count all threads
|
|
*/
|
|
public function countAll(): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select($qb->func()->count('*', 'count'))
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
$result = $qb->executeQuery();
|
|
$row = $result->fetch();
|
|
$result->closeCursor();
|
|
return (int)($row['count'] ?? 0);
|
|
}
|
|
|
|
/**
|
|
* Count threads created since a timestamp
|
|
*/
|
|
public function countSince(int $timestamp): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select($qb->func()->count('*', 'count'))
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->gte('created_at', $qb->createNamedParameter($timestamp, IQueryBuilder::PARAM_INT)))
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
$result = $qb->executeQuery();
|
|
$row = $result->fetch();
|
|
$result->closeCursor();
|
|
return (int)($row['count'] ?? 0);
|
|
}
|
|
|
|
/**
|
|
* Move all threads from one category to another
|
|
*/
|
|
public function moveToCategoryId(int $fromCategoryId, int $toCategoryId): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->update($this->getTableName())
|
|
->set('category_id', $qb->createNamedParameter($toCategoryId, IQueryBuilder::PARAM_INT))
|
|
->set('updated_at', $qb->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
|
|
->where($qb->expr()->eq('category_id', $qb->createNamedParameter($fromCategoryId, IQueryBuilder::PARAM_INT)));
|
|
return $qb->executeStatement();
|
|
}
|
|
|
|
/**
|
|
* Soft delete all threads in a category (set is_hidden = true)
|
|
*/
|
|
public function softDeleteByCategoryId(int $categoryId): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->update($this->getTableName())
|
|
->set('is_hidden', $qb->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
|
|
->set('updated_at', $qb->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
|
|
->where($qb->expr()->eq('category_id', $qb->createNamedParameter($categoryId, IQueryBuilder::PARAM_INT)));
|
|
return $qb->executeStatement();
|
|
}
|
|
|
|
/**
|
|
* Count threads in a category
|
|
*/
|
|
public function countByCategoryId(int $categoryId): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select($qb->func()->count('*', 'count'))
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->eq('category_id', $qb->createNamedParameter($categoryId, IQueryBuilder::PARAM_INT)))
|
|
->andWhere($qb->expr()->eq('is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)))
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
$result = $qb->executeQuery();
|
|
$row = $result->fetch();
|
|
$result->closeCursor();
|
|
return (int)($row['count'] ?? 0);
|
|
}
|
|
|
|
/**
|
|
* Find threads by multiple IDs
|
|
*
|
|
* @param array<int> $ids Array of thread IDs
|
|
* @return array<Thread>
|
|
*/
|
|
public function findByIds(array $ids): array {
|
|
if (empty($ids)) {
|
|
return [];
|
|
}
|
|
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()->in('id', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
);
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* @return array<Thread>
|
|
*/
|
|
public function findByAuthorId(string $authorId, int $limit = 50, int $offset = 0): array {
|
|
/* @var $qb IQueryBuilder */
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where(
|
|
$qb->expr()->eq('author_id', $qb->createNamedParameter($authorId, IQueryBuilder::PARAM_STR))
|
|
)
|
|
->andWhere(
|
|
$qb->expr()->isNull('deleted_at')
|
|
)
|
|
->orderBy('created_at', 'DESC')
|
|
->setMaxResults($limit)
|
|
->setFirstResult($offset);
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Get last activity timestamp (max updated_at) per category
|
|
*
|
|
* @return array<int, int> categoryId => lastActivityTimestamp
|
|
*/
|
|
public function getLastActivityByCategories(): array {
|
|
$postsTable = Application::tableName('forum_posts');
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('t.category_id')
|
|
->selectAlias($qb->func()->max('p.created_at'), 'last_activity')
|
|
->from($this->getTableName(), 't')
|
|
->innerJoin('t', $postsTable, 'p', $qb->expr()->eq('p.thread_id', 't.id'))
|
|
->where($qb->expr()->isNull('t.deleted_at'))
|
|
->andWhere($qb->expr()->isNull('p.deleted_at'))
|
|
->andWhere($qb->expr()->eq('t.is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)))
|
|
->groupBy('t.category_id');
|
|
|
|
$result = $qb->executeQuery();
|
|
$rows = $result->fetchAll();
|
|
$result->closeCursor();
|
|
|
|
$map = [];
|
|
foreach ($rows as $row) {
|
|
$map[(int)$row['category_id']] = (int)$row['last_activity'];
|
|
}
|
|
return $map;
|
|
}
|
|
|
|
/**
|
|
* Get the last activity timestamp for a single category
|
|
*
|
|
* @return int|null The timestamp of the last post, or null if no activity
|
|
*/
|
|
public function getLastActivityForCategory(int $categoryId): ?int {
|
|
$postsTable = Application::tableName('forum_posts');
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->selectAlias($qb->func()->max('p.created_at'), 'last_activity')
|
|
->from($this->getTableName(), 't')
|
|
->innerJoin('t', $postsTable, 'p', $qb->expr()->eq('p.thread_id', 't.id'))
|
|
->where($qb->expr()->eq('t.category_id', $qb->createNamedParameter($categoryId, IQueryBuilder::PARAM_INT)))
|
|
->andWhere($qb->expr()->isNull('t.deleted_at'))
|
|
->andWhere($qb->expr()->isNull('p.deleted_at'))
|
|
->andWhere($qb->expr()->eq('t.is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)));
|
|
|
|
$result = $qb->executeQuery();
|
|
$row = $result->fetch();
|
|
$result->closeCursor();
|
|
|
|
return $row && $row['last_activity'] !== null ? (int)$row['last_activity'] : null;
|
|
}
|
|
|
|
/**
|
|
* Find recent threads in specified categories
|
|
*
|
|
* @param array<int> $categoryIds Category IDs to filter by
|
|
* @param int $limit Maximum results
|
|
* @return array<Thread>
|
|
*/
|
|
public function findRecentThreads(array $categoryIds, int $limit = 7): array {
|
|
if (empty($categoryIds)) {
|
|
return [];
|
|
}
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->in('category_id', $qb->createNamedParameter($categoryIds, IQueryBuilder::PARAM_INT_ARRAY)))
|
|
->andWhere($qb->expr()->eq('is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)))
|
|
->andWhere($qb->expr()->isNull('deleted_at'))
|
|
->orderBy('created_at', 'DESC')
|
|
->setMaxResults($limit);
|
|
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Find top threads by view count in specified categories
|
|
*
|
|
* @param array<int> $categoryIds Category IDs to filter by
|
|
* @param int $limit Maximum results
|
|
* @return array<Thread>
|
|
*/
|
|
public function findTopByViews(array $categoryIds, int $limit = 7): array {
|
|
if (empty($categoryIds)) {
|
|
return [];
|
|
}
|
|
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->in('category_id', $qb->createNamedParameter($categoryIds, IQueryBuilder::PARAM_INT_ARRAY)))
|
|
->andWhere($qb->expr()->eq('is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)))
|
|
->andWhere($qb->expr()->isNull('deleted_at'))
|
|
->orderBy('view_count', 'DESC')
|
|
->setMaxResults($limit);
|
|
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Search threads by title and first post content
|
|
*
|
|
* @param IQueryBuilder $qb QueryBuilder instance (with parameters already bound)
|
|
* @param \OCP\DB\QueryBuilder\ICompositeExpression $titleConditions WHERE expression for title field
|
|
* @param \OCP\DB\QueryBuilder\ICompositeExpression $contentConditions WHERE expression for content field
|
|
* @param array<int> $categoryIds Category IDs to search in
|
|
* @param int $limit Maximum results
|
|
* @param int $offset Results offset
|
|
* @return array<Thread>
|
|
*/
|
|
public function search(IQueryBuilder $qb, \OCP\DB\QueryBuilder\ICompositeExpression $titleConditions, \OCP\DB\QueryBuilder\ICompositeExpression $contentConditions, array $categoryIds, int $limit = 50, int $offset = 0): array {
|
|
|
|
// Select threads with LEFT JOIN to first post
|
|
$qb->select('t.*')
|
|
->from($this->getTableName(), 't')
|
|
->leftJoin('t', 'forum_posts', 'p', $qb->expr()->andX(
|
|
$qb->expr()->eq('t.id', 'p.thread_id'),
|
|
$qb->expr()->eq('p.is_first_post', $qb->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
|
|
))
|
|
->where($qb->expr()->in('t.category_id', $qb->createNamedParameter($categoryIds, IQueryBuilder::PARAM_INT_ARRAY)))
|
|
->andWhere($qb->expr()->eq('t.is_hidden', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL)))
|
|
->andWhere($qb->expr()->isNull('t.deleted_at'))
|
|
->andWhere(
|
|
// Search in title OR first post content
|
|
$qb->expr()->orX(
|
|
$titleConditions,
|
|
$contentConditions
|
|
)
|
|
)
|
|
->orderBy('t.is_pinned', 'DESC')
|
|
->addOrderBy($qb->createFunction('COALESCE(t.last_reply_at, t.created_at)'), 'DESC')
|
|
->setMaxResults($limit)
|
|
->setFirstResult($offset);
|
|
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Find a thread by ID including soft-deleted threads
|
|
*
|
|
* @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException
|
|
* @throws DoesNotExistException
|
|
*/
|
|
public function findIncludingDeleted(int $id): Thread {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->eq('id', $qb->createNamedParameter($id, IQueryBuilder::PARAM_INT)));
|
|
return $this->findEntity($qb);
|
|
}
|
|
|
|
/**
|
|
* Find soft-deleted threads with pagination, search, and sorting
|
|
*
|
|
* @return array<Thread>
|
|
*/
|
|
public function findDeleted(int $limit = 20, int $offset = 0, string $search = '', string $sort = 'newest'): array {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select('*')
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->isNotNull('deleted_at'));
|
|
|
|
if ($search !== '') {
|
|
$qb->andWhere($qb->expr()->iLike('title', $qb->createNamedParameter('%' . $this->db->escapeLikeParameter($search) . '%')));
|
|
}
|
|
|
|
$qb->orderBy('deleted_at', $sort === 'oldest' ? 'ASC' : 'DESC')
|
|
->setMaxResults($limit)
|
|
->setFirstResult($offset);
|
|
|
|
return $this->findEntities($qb);
|
|
}
|
|
|
|
/**
|
|
* Count soft-deleted threads
|
|
*/
|
|
public function countDeleted(string $search = ''): int {
|
|
$qb = $this->db->getQueryBuilder();
|
|
$qb->select($qb->func()->count('*', 'count'))
|
|
->from($this->getTableName())
|
|
->where($qb->expr()->isNotNull('deleted_at'));
|
|
|
|
if ($search !== '') {
|
|
$qb->andWhere($qb->expr()->iLike('title', $qb->createNamedParameter('%' . $this->db->escapeLikeParameter($search) . '%')));
|
|
}
|
|
|
|
$result = $qb->executeQuery();
|
|
$count = (int)($result->fetchOne() ?? 0);
|
|
$result->closeCursor();
|
|
return $count;
|
|
}
|
|
}
|