6f70cd1651
The probability of the routine to run is 5% so it should run approximately 5 times per 100 writes. So the limit 1000 should be pretty safe to prevent the table from bloating. [MAILPOET-5071]
97 lines
2.9 KiB
PHP
97 lines
2.9 KiB
PHP
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing
|
|
|
|
namespace MailPoet\Logging;
|
|
|
|
use MailPoet\Doctrine\Repository;
|
|
use MailPoet\Entities\LogEntity;
|
|
use MailPoet\Entities\NewsletterEntity;
|
|
use MailPoet\Util\Helpers;
|
|
use MailPoetVendor\Carbon\Carbon;
|
|
use MailPoetVendor\Doctrine\DBAL\Driver\PDO\Connection;
|
|
|
|
/**
|
|
* @extends Repository<LogEntity>
|
|
*/
|
|
class LogRepository extends Repository {
|
|
protected function getEntityClassName() {
|
|
return LogEntity::class;
|
|
}
|
|
|
|
/**
|
|
* @param \DateTimeInterface|null $dateFrom
|
|
* @param \DateTimeInterface|null $dateTo
|
|
* @param string|null $search
|
|
* @param string $offset
|
|
* @param string $limit
|
|
* @return LogEntity[]
|
|
*/
|
|
public function getLogs(
|
|
\DateTimeInterface $dateFrom = null,
|
|
\DateTimeInterface $dateTo = null,
|
|
string $search = null,
|
|
string $offset = null,
|
|
string $limit = null
|
|
): array {
|
|
$query = $this->doctrineRepository->createQueryBuilder('l')
|
|
->select('l');
|
|
|
|
if ($dateFrom instanceof \DateTimeInterface) {
|
|
$query
|
|
->andWhere('l.createdAt >= :dateFrom')
|
|
->setParameter('dateFrom', $dateFrom->format('Y-m-d 00:00:00'));
|
|
}
|
|
if ($dateTo instanceof \DateTimeInterface) {
|
|
$query
|
|
->andWhere('l.createdAt <= :dateTo')
|
|
->setParameter('dateTo', $dateTo->format('Y-m-d 23:59:59'));
|
|
}
|
|
if ($search) {
|
|
$search = Helpers::escapeSearch($search);
|
|
$query
|
|
->andWhere('l.name LIKE :search or l.message LIKE :search')
|
|
->setParameter('search', "%$search%");
|
|
}
|
|
|
|
$query->orderBy('l.createdAt', 'desc');
|
|
if ($offset !== null) {
|
|
$query->setFirstResult((int)$offset);
|
|
}
|
|
if ($limit === null) {
|
|
$query->setMaxResults(500);
|
|
} else {
|
|
$query->setMaxResults((int)$limit);
|
|
}
|
|
|
|
|
|
return $query->getQuery()->getResult();
|
|
}
|
|
|
|
public function purgeOldLogs(int $daysToKeepLogs, int $limit = 1000) {
|
|
$logsTable = $this->entityManager->getClassMetadata(LogEntity::class)->getTableName();
|
|
$this->entityManager->getConnection()->executeStatement("
|
|
DELETE FROM $logsTable
|
|
WHERE `created_at` < :date LIMIT :limit
|
|
", [
|
|
'date' => Carbon::now()->subDays($daysToKeepLogs)->toDateTimeString(),
|
|
'limit' => $limit,
|
|
],
|
|
[
|
|
'date' => Connection::PARAM_STR,
|
|
'limit' => Connection::PARAM_INT,
|
|
]);
|
|
}
|
|
|
|
public function getRawMessagesForNewsletter(NewsletterEntity $newsletter, string $topic): array {
|
|
return $this->entityManager->createQueryBuilder()
|
|
->select('DISTINCT logs.rawMessage message')
|
|
->from(LogEntity::class, 'logs')
|
|
->where('logs.name = :topic')
|
|
->andWhere('logs.context LIKE :context')
|
|
->orderBy('logs.createdAt')
|
|
->setParameter('context', json_encode(['newsletter_id' => $newsletter->getId()]))
|
|
->setParameter('topic', $topic)
|
|
->getQuery()
|
|
->getSingleColumnResult();
|
|
}
|
|
}
|