. */ declare(strict_types=1); namespace Fisharebest\Webtrees\Http\RequestHandlers; use Fisharebest\Webtrees\FlashMessages; use Fisharebest\Webtrees\Http\ViewResponseTrait; use Fisharebest\Webtrees\I18N; use Fisharebest\Webtrees\Services\MessageService; use Fisharebest\Webtrees\Validator; use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ServerRequestInterface; use Psr\Http\Server\RequestHandlerInterface; use function e; use function redirect; use function route; /** * Send messages from an administrator. */ class BroadcastAction implements RequestHandlerInterface { use ViewResponseTrait; private MessageService $message_service; /** * MessagePage constructor. * * @param MessageService $message_service */ public function __construct(MessageService $message_service) { $this->message_service = $message_service; } /** * @param ServerRequestInterface $request * * @return ResponseInterface */ public function handle(ServerRequestInterface $request): ResponseInterface { $recipients = $this->message_service->recipientTypes(); $user = Validator::attributes($request)->user(); $to = Validator::attributes($request)->isInArrayKeys($recipients)->string('to'); $ip = Validator::attributes($request)->string('client-ip'); $body = Validator::parsedBody($request)->isNotEmpty()->string('body'); $subject = Validator::parsedBody($request)->isNotEmpty()->string('subject'); if ($body === '' || $subject === '') { return redirect(route(BroadcastPage::class, [ 'body' => $body, 'subject' => $subject, 'to' => $to, ])); } foreach ($this->message_service->recipientUsers($to) as $to_user) { if ($this->message_service->deliverMessage($user, $to_user, $subject, $body, '', $ip)) { FlashMessages::addMessage( I18N::translate('The message was successfully sent to %s.', e($to_user->realName())), 'success' ); } else { FlashMessages::addMessage( I18N::translate('The message was not sent to %s.', e($to_user->realName())), 'danger' ); } } return redirect(route(ControlPanel::class)); } }