.
*/
namespace SP\Providers\Mail;
use DI\Container;
use DI\DependencyException;
use DI\NotFoundException;
use Exception;
use SP\Core\Events\Event;
use SP\Core\Events\EventReceiver;
use SP\Core\Messages\MailMessage;
use SP\Core\Messages\TextFormatter;
use SP\Http\Request;
use SP\Providers\EventsTrait;
use SP\Providers\Provider;
use SP\Services\Mail\MailService;
use SplSubject;
/**
* Class MailHandler
*
* @package SP\Providers\Mail
*/
final class MailHandler extends Provider implements EventReceiver
{
use EventsTrait;
const EVENTS = [
'create.',
'delete.',
'edit.',
'save.',
'import.ldap.end',
'run.backup.end',
'run.import.end'
];
const EVENTS_FIXED = [
'clear.eventlog',
'refresh.masterPassword',
'update.masterPassword.start',
'update.masterPassword.end',
'request.account',
'edit.user.password',
'save.config.',
'create.tempMasterPassword'
];
/**
* @var MailService
*/
private $mailService;
/**
* @var string
*/
private $events;
/**
* @var Request
*/
private $request;
/**
* Devuelve los eventos que implementa el observador
*
* @return array
*/
public function getEvents(): array
{
return self::EVENTS;
}
/**
* Devuelve los eventos que implementa el observador en formato cadena
*
* @return string
*/
public function getEventsString(): string
{
return $this->events;
}
/**
* Receive update from subject
*
* @link http://php.net/manual/en/splobserver.update.php
*
* @param SplSubject $subject
* The SplSubject notifying the observer of an update.
*
*
* @return void
* @since 5.1.0
*/
public function update(SplSubject $subject)
{
$this->updateEvent('update', new Event($subject));
}
/**
* Evento de actualización
*
* @param string $eventType Nombre del evento
* @param Event $event Objeto del evento
*/
public function updateEvent(string $eventType, Event $event)
{
if (($eventMessage = $event->getEventMessage()) !== null) {
try {
$configData = $this->config->getConfigData();
$extra = $eventMessage->getExtra();
if (isset($extra['userId'], $extra['email'])) {
$recipients = $extra['email'];
} else {
$recipients = $configData->getMailRecipients();
}
$to = array_filter($recipients);
if (empty($to)) {
return;
}
$userData = $this->context->getUserData();
$mailMessage = new MailMessage();
if ($eventMessage->getDescriptionCounter() === 0
&& $eventMessage->getDetailsCounter() === 0
) {
$mailMessage->addDescription(sprintf(__('Event: %s'), $eventType));
} else {
$mailMessage->addDescription($eventMessage->composeText('
'));
}
$mailMessage->addDescriptionLine();
if ($userData->getId() !== null) {
$mailMessage->addDescription(sprintf(__('Performed by: %s (%s)'), $userData->getName(), $userData->getLogin()));
} else {
$mailMessage->addDescription(sprintf(__('Performed by: %s (%s)'), 'sysPass', 'APP'));
}
$mailMessage->addDescription(sprintf(__('IP Address: %s'), $this->request->getClientAddress(true)));
$subject = $eventMessage->getDescription(new TextFormatter(), true) ?: $eventType;
$this->mailService->send(
$subject,
$to,
$mailMessage
);
} catch (Exception $e) {
processException($e);
}
}
}
/**
* @param Container $dic
*
* @throws DependencyException
* @throws NotFoundException
*/
protected function initialize(Container $dic)
{
$this->mailService = $dic->get(MailService::class);
$this->request = $dic->get(Request::class);
$configEvents = $this->config->getConfigData()->getMailEvents();
if (empty($configEvents)) {
$this->events = $this->parseEventsToRegex(self::EVENTS_FIXED);
} else {
$this->events = $this->parseEventsToRegex(array_merge($configEvents, self::EVENTS_FIXED));
}
}
}