<?php
namespace MailPoet\AdminPages\Pages;
if (!defined('ABSPATH')) exit;
use MailPoet\AdminPages\PageRenderer;
use MailPoet\Cron\ActionScheduler\Actions\DaemonRun;
use MailPoet\Cron\ActionScheduler\Actions\DaemonTrigger;
use MailPoet\Cron\CronHelper;
use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Helpscout\Beacon;
use MailPoet\Mailer\MailerLog;
use MailPoet\Newsletter\Sending\ScheduledTasksRepository;
use MailPoet\Newsletter\Sending\SendingQueuesRepository;
use MailPoet\Newsletter\Url as NewsletterURL;
use MailPoet\Router\Endpoints\CronDaemon;
use MailPoet\Services\Bridge;
use MailPoet\Tasks\Sending;
use MailPoet\WP\DateTime;
class Help {
/** @var PageRenderer */
private $pageRenderer;
/** @var CronHelper */
private $cronHelper;
/** @var Beacon */
private $helpscoutBeacon;
/** @var Bridge $bridge */
private $bridge;
/*** @var ScheduledTasksRepository */
private $scheduledTasksRepository;
/*** @var SendingQueuesRepository */
private $sendingQueuesRepository;
/*** @var NewsletterURL */
private $newsletterUrl;
public function __construct(
PageRenderer $pageRenderer,
CronHelper $cronHelper,
Beacon $helpscoutBeacon,
Bridge $bridge,
ScheduledTasksRepository $scheduledTasksRepository,
SendingQueuesRepository $sendingQueuesRepository,
NewsletterURL $newsletterUrl
) {
$this->pageRenderer = $pageRenderer;
$this->cronHelper = $cronHelper;
$this->helpscoutBeacon = $helpscoutBeacon;
$this->bridge = $bridge;
$this->scheduledTasksRepository = $scheduledTasksRepository;
$this->sendingQueuesRepository = $sendingQueuesRepository;
$this->newsletterUrl = $newsletterUrl;
}
public function render() {
$systemInfoData = $this->helpscoutBeacon->getData(true);
try {
$cronPingUrl = $this->cronHelper->getCronUrl(CronDaemon::ACTION_PING);
$cronPingResponse = $this->cronHelper->pingDaemon();
} catch (\Exception $e) {
$cronPingResponse = __('Can‘t generate cron URL.', 'mailpoet') . ' (' . $e->getMessage() . ')';
$cronPingUrl = $cronPingResponse;
}
$mailerLog = MailerLog::getMailerLog();
$mailerLog['sent'] = MailerLog::sentSince();
$systemStatusData = [
'cron' => [
'url' => $cronPingUrl,
'isReachable' => $this->cronHelper->validatePingResponse($cronPingResponse),
'pingResponse' => $cronPingResponse,
],
'mss' => [
'enabled' => $this->bridge->isMailpoetSendingServiceEnabled(),
'isReachable' => $this->bridge->pingBridge(),
],
'cronStatus' => $this->cronHelper->getDaemon(),
'queueStatus' => $mailerLog,
];
$systemStatusData['cronStatus']['accessible'] = $this->cronHelper->isDaemonAccessible();
$systemStatusData['queueStatus']['tasksStatusCounts'] = $this->scheduledTasksRepository->getCountsPerStatus();
$systemStatusData['queueStatus']['latestTasks'] = array_map(function ($task) {
return $this->buildTaskData($task);
}, $this->scheduledTasksRepository->getLatestTasks(Sending::TASK_TYPE));
$this->pageRenderer->displayPage(
'help.html',
[
'systemInfoData' => $systemInfoData,
'systemStatusData' => $systemStatusData,
'actionSchedulerData' => $this->getActionSchedulerData(),
]
);
}
private function getActionSchedulerData(): ?array {
if (!class_exists(\ActionScheduler_Store::class)) {
return null;
}
$actionSchedulerData = [];
$actionSchedulerData['version'] = \ActionScheduler_Versions::instance()->latest_version();
$actionSchedulerData['storage'] = str_replace('ActionScheduler_', '', get_class(\ActionScheduler_Store::instance()));
$actionSchedulerData['latestTrigger'] = $this->getLatestActionSchedulerActionDate(DaemonTrigger::NAME);
$actionSchedulerData['latestCompletedTrigger'] = $this->getLatestActionSchedulerActionDate(DaemonTrigger::NAME, 'complete');
$actionSchedulerData['latestCompletedRun'] = $this->getLatestActionSchedulerActionDate(DaemonRun::NAME, 'complete');
return $actionSchedulerData;
}
private function getLatestActionSchedulerActionDate(string $hook, string $status = null): ?string {
$query = [
'per_page' => 1,
'order' => 'DESC',
'hook' => $hook,
];
if ($status) {
$query['status'] = $status;
}
$store = \ActionScheduler_Store::instance();
$action = $store->query_actions($query);
if (!empty($action)) {
$dateObject = $store->get_date( $action[0] );
return $dateObject->format('Y-m-d H:i:s');
}
return null;
}
public function buildTaskData(ScheduledTaskEntity $task): array {
$queue = $newsletter = null;
if ($task->getType() === Sending::TASK_TYPE) {
$queue = $this->sendingQueuesRepository->findOneBy(['task' => $task]);
$newsletter = $queue ? $queue->getNewsletter() : null;
}
return [
'id' => $task->getId(),
'type' => $task->getType(),
'priority' => $task->getPriority(),
'updated_at' => $task->getUpdatedAt()->format(DateTime::DEFAULT_DATE_TIME_FORMAT),
'scheduled_at' => $task->getScheduledAt() ?
$task->getScheduledAt()->format(DateTime::DEFAULT_DATE_TIME_FORMAT)
: null,
'status' => $task->getStatus(),
'newsletter' => $queue && $newsletter ? [
'newsletter_id' => $newsletter->getId(),
'queue_id' => $queue->getId(),
'subject' => $queue->getNewsletterRenderedSubject() ?: $newsletter->getSubject(),
'preview_url' => $this->newsletterUrl->getViewInBrowserUrl($newsletter, null, $queue),
] : [
'newsletter_id' => null,
'queue_id' => null,
'subject' => null,
'preview_url' => null,
],
];
}
}