flo/bee-backend-ARCHIVED
Archived
1
0
Fork 0
generated from flo/template-backend
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

changes

Browse Source
This commit is contained in:
Flo 2024-08-26 14:05:55 +00:00
parent 624e4e4b97
commit 9237801bc1
26 changed files with 430 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
.env.example
View File

@ -18,3 +18,11 @@ BEE_API_KEY=
INIT_USER_NAME=admin INIT_USER_NAME=admin
INIT_USER_PASSWORD=password INIT_USER_PASSWORD=password
INIT_USER_MAIL=admin@test.com INIT_USER_MAIL=admin@test.com
# Mail
MAIL_DEFAULT_SENDER=info@bee.local
SMTP_USERNAME=smtp@stack-up.de
SMTP_PASSWORD=
SMTP_HOST= #srv-mail-01.lab.jonasf.de
SMTP_PORT=465
SMTP_ENCRYPTION=ssl

4
composer.json
View File

@ -19,7 +19,9 @@
"monolog/monolog": "^3.4", "monolog/monolog": "^3.4",
"laminas/laminas-mail": "^2.23", "laminas/laminas-mail": "^2.23",
"teewurst/pipeline": "^3.0", "teewurst/pipeline": "^3.0",
"guzzlehttp/guzzle": "^7.8" "guzzlehttp/guzzle": "^7.8",
"nette/mail": "^4.0",
"latte/latte": "^3.0"
}, },
"autoload": { "autoload": {
"psr-4": { "psr-4": {

16
config/autoload/mail.global.php Normal file
View File

@ -0,0 +1,16 @@
<?php
return [
'mail' => [
'default' => [
'sender' => $_ENV['MAIL_DEFAULT_SENDER']
],
'smtp-server' => [
'host' => $_ENV['SMTP_HOST'],
'port' => (int)$_ENV['SMTP_PORT'] ?? 25,
'encryption' => $_ENV['SMTP_ENCRYPTION'],
'username' => $_ENV['SMTP_USERNAME'],
'password' => $_ENV['SMTP_PASSWORD'],
]
]
];

1
config/config.php
View File

@ -52,6 +52,7 @@ $aggregator = new ConfigAggregator([
\Bee\Infrastructure\Rbac\ConfigProvider::class, \Bee\Infrastructure\Rbac\ConfigProvider::class,
\Bee\Infrastructure\Request\ConfigProvider::class, \Bee\Infrastructure\Request\ConfigProvider::class,
\Bee\Infrastructure\Session\ConfigProvider::class, \Bee\Infrastructure\Session\ConfigProvider::class,
\Bee\Infrastructure\Mail\ConfigProvider::class,
// HandlingDomain // HandlingDomain
\Bee\Handling\User\ConfigProvider::class, \Bee\Handling\User\ConfigProvider::class,

BIN
data/mails/registration/assets/icon.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 1.7 KiB

63
data/mails/registration/template.latte Normal file
View File

@ -0,0 +1,63 @@
<html>
<head>
<meta charset="utf-8">
<title>Willkommen beim Beekeeper!</title>
<style>
body {
}
.message-block {
font-family: Arial, sans-serif;
max-width: 600px;
margin: 0 auto;
margin-top: 20px;
padding: 20px;
}
.header {
background-color: rgb(255, 199, 44);
width: 100%;
height: 15%;
text-align: center;
}
.title {
display: flex;
flex-wrap: wrap;
}
.wrapper {
display: inline-block;
}
.quote {
font-style: italic;
font-size: x-small;
color: slategray;
}
img {
margin: 1rem;
}
h1 {
margin-top: auto;
margin-bottom: auto;
}
</style>
</head>
<body>
<div id="header" class="header">
<div class="wrapper">
<div id="title" class="title">
<img src="assets/icon.png" />
<h1>Beekeeper</h1>
</div>
</div>
</div>
<div id="message-block" class="message-block">
<p>Hallo {$username},</p>
<br />
<p>Herzlich willkommen beim Beekeeper!</p>
<br />
<p>Bitte klicke auf <a href="{$confirmationLink}">diesen Link</a> um dein Passwort festzulegen.</p>
<p>Danach ist deine Registierung abgeschlossen und du kannst loslegen!</p>
<br />
<p>Mit fleißigen Grüßen,</p>
<p>Der Beekeeper</p>
</div>
</body>
</html>

6
src/ApiDomain/External/Authentication/config/service_manager.php vendored
View File

@ -1,5 +1,7 @@
<?php <?php
use Bee\API\External\Authentication\Formatter\ConfirmRegistrationFormatter;
use Bee\API\External\Authentication\Formatter\LoginUserFormatter;
use Bee\API\External\Authentication\Handler\ConfirmRegistrationHandler; use Bee\API\External\Authentication\Handler\ConfirmRegistrationHandler;
use Bee\API\External\Authentication\Handler\LoginUserHandler; use Bee\API\External\Authentication\Handler\LoginUserHandler;
use Bee\API\External\Authentication\Handler\LogoutUserHandler; use Bee\API\External\Authentication\Handler\LogoutUserHandler;
@ -8,6 +10,10 @@ use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [ return [
'factories' => [ 'factories' => [
// Formatter
ConfirmRegistrationFormatter::class => AutoWiringFactory::class,
LoginUserFormatter::class => AutoWiringFactory::class,
// Handler // Handler
LoginUserHandler::class => AutoWiringFactory::class, LoginUserHandler::class => AutoWiringFactory::class,
LogoutUserHandler::class => AutoWiringFactory::class, LogoutUserHandler::class => AutoWiringFactory::class,

27
src/ApiDomain/External/Authentication/src/Formatter/ConfirmRegistrationFormatter.php vendored Normal file
View File

@ -0,0 +1,27 @@
<?php
namespace Bee\API\External\Authentication\Formatter;
use DateTime;
use Bee\Data\Business\Entity\User;
class ConfirmRegistrationFormatter {
public function format(User $user): array {
$userArray = [
'id' => $user->getId()->toString(),
'username' => $user->getUsername(),
'roleIdentifier' => $user->getRole()->getIdentifier(),
'createdAt' => $user->getCreatedAt()->format(DateTime::ATOM),
'updatedAt' => $user->getUpdatedAt()->format(DateTime::ATOM)
];
$userArray['permissions'] = [];
foreach ($user->getRole()->getPermissions()->toArray() as $permission) {
$userArray['permissions'][] = $permission->getIdentifier();
}
return $userArray;
}
}

14
src/ApiDomain/External/Authentication/src/Formatter/LoginUserFormatter.php vendored Normal file
View File

@ -0,0 +1,14 @@
<?php
namespace Bee\API\External\Authentication\Formatter;
use Bee\Data\Business\Entity\UserSession;
class LoginUserFormatter {
public function format(UserSession $session): array {
return [
'sessionId' => $session->getId()->toString()
];
}
}

5
src/ApiDomain/External/Authentication/src/Handler/ConfirmRegistrationHandler.php vendored
View File

@ -4,6 +4,7 @@ declare(strict_types=1);
namespace Bee\API\External\Authentication\Handler; namespace Bee\API\External\Authentication\Handler;
use Bee\API\External\Authentication\Formatter\ConfirmRegistrationFormatter;
use Bee\API\External\User\Formatter\UserFormatter; use Bee\API\External\User\Formatter\UserFormatter;
use Bee\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandBuilder; use Bee\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandBuilder;
use Bee\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandHandler; use Bee\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandHandler;
@ -20,7 +21,7 @@ class ConfirmRegistrationHandler implements RequestHandlerInterface
public function __construct( public function __construct(
private readonly ConfirmRegistrationCommandHandler $handler, private readonly ConfirmRegistrationCommandHandler $handler,
private readonly ConfirmRegistrationCommandBuilder $builder, private readonly ConfirmRegistrationCommandBuilder $builder,
private readonly UserFormatter $userFormatter private readonly ConfirmRegistrationFormatter $formatter
) { ) {
} }
@ -36,7 +37,7 @@ class ConfirmRegistrationHandler implements RequestHandlerInterface
$result = $this->handler->execute($query); $result = $this->handler->execute($query);
return new JsonResponse( return new JsonResponse(
$this->userFormatter->format($result) $this->formatter->format($result)
); );
} }
} }

28
src/ApiDomain/External/Authentication/src/Handler/LoginUserHandler.php vendored
View File

@ -4,9 +4,18 @@ declare(strict_types=1);
namespace Bee\API\External\Authentication\Handler; namespace Bee\API\External\Authentication\Handler;
use Bee\API\External\Authentication\Formatter\LoginUserFormatter;
use Bee\Handling\User\Exception\UserNotFoundByIdentifierException;
use Bee\Handling\User\Exception\UserWrongPasswordException;
use Bee\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandBuilder; use Bee\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandBuilder;
use Bee\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandHandler; use Bee\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandHandler;
use Bee\Infrastructure\Exception\ErrorCode;
use Bee\Infrastructure\Exception\ErrorDomain;
use Bee\Infrastructure\Exception\Exception\Exception;
use Bee\Infrastructure\Logging\Logger\Logger;
use Bee\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware; use Bee\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Bee\Infrastructure\Response\ErrorResponse;
use Bee\Infrastructure\Response\UnauthorizedResponse;
use Bee\Infrastructure\Session\Middleware\SessionMiddleware; use Bee\Infrastructure\Session\Middleware\SessionMiddleware;
use Laminas\Diactoros\Response\JsonResponse; use Laminas\Diactoros\Response\JsonResponse;
use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ResponseInterface;
@ -17,10 +26,16 @@ class LoginUserHandler implements RequestHandlerInterface
{ {
public function __construct( public function __construct(
private readonly LoginUserCommandHandler $handler, private readonly LoginUserCommandHandler $handler,
private readonly LoginUserCommandBuilder $builder private readonly LoginUserCommandBuilder $builder,
private readonly LoginUserFormatter $formatter,
private readonly Logger $logger,
) { ) {
} }
/**
* @throws UserWrongPasswordException
* @throws UserNotFoundByIdentifierException
*/
public function handle(ServerRequestInterface $request): ResponseInterface public function handle(ServerRequestInterface $request): ResponseInterface
{ {
$session = $request->getAttribute(SessionMiddleware::SESSION_ATTRIBUTE); $session = $request->getAttribute(SessionMiddleware::SESSION_ATTRIBUTE);
@ -32,9 +47,12 @@ class LoginUserHandler implements RequestHandlerInterface
$data['password'], $data['password'],
); );
$result = $this->handler->execute($query); try {
return new JsonResponse([ $result = $this->handler->execute($query);
'sessionId' => $result->getId()->toString() return new JsonResponse($this->formatter->format($result));
]); } catch (Exception $e) {
$this->logger->exception($e);
return new ErrorResponse(ErrorDomain::Login, ErrorCode::SomethingWentWrong);
}
} }
} }

2
src/ApiDomain/External/Authentication/src/Handler/LogoutUserHandler.php vendored
View File

@ -30,6 +30,6 @@ class LogoutUserHandler implements RequestHandlerInterface
); );
$this->handler->execute($query); $this->handler->execute($query);
return new JsonResponse('OK'); return new SuccessResponse();
} }
} }

23
src/ApiDomain/External/Authentication/src/Handler/RegisterUserHandler.php vendored
View File

@ -4,7 +4,13 @@ declare(strict_types=1);
namespace Bee\API\External\Authentication\Handler; namespace Bee\API\External\Authentication\Handler;
use Bee\Handling\Registration\Exception\RegistrationWithIdentifierAlreadyExistsException;
use Bee\Handling\User\Exception\UserWithIdentifierAlreadyExistsException;
use Bee\Infrastructure\Exception\ErrorCode;
use Bee\Infrastructure\Exception\ErrorDomain;
use Bee\Infrastructure\Mail\Exception\SendMailFailedException;
use Bee\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware; use Bee\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Bee\Infrastructure\Response\ErrorResponse;
use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface; use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface; use Psr\Http\Server\RequestHandlerInterface;
@ -18,7 +24,8 @@ class RegisterUserHandler implements RequestHandlerInterface
{ {
public function __construct( public function __construct(
private readonly RegisterUserCommandHandler $handler, private readonly RegisterUserCommandHandler $handler,
private readonly RegisterUserCommandBuilder $builder private readonly RegisterUserCommandBuilder $builder,
private readonly Logger $logger,
) { ) {
} }
@ -33,7 +40,19 @@ class RegisterUserHandler implements RequestHandlerInterface
$host $host
); );
$this->handler->execute($query); try {
$this->handler->execute($query);
} catch (RegistrationWithIdentifierAlreadyExistsException $e) {
$this->logger->exception($e);
return new ErrorResponse(ErrorDomain::Registration, ErrorCode::SomethingWentWrong);
} catch (UserWithIdentifierAlreadyExistsException $e) {
$this->logger->exception($e);
return new ErrorResponse(ErrorDomain::Registration, ErrorCode::SomethingWentWrong);
} catch (SendMailFailedException $e) {
$this->logger->exception($e);
return new ErrorResponse(ErrorDomain::Registration, ErrorCode::SomethingWentWrong);
}
return new SuccessResponse(); return new SuccessResponse();
} }
} }

6
src/ApiDomain/External/User/config/service_manager.php vendored
View File

@ -1,6 +1,7 @@
<?php <?php
use Bee\API\External\User\Formatter\UserFormatter; use Bee\API\External\User\Formatter\CreateUserFormatter;
use Bee\API\External\User\Formatter\UserStateFormatter;
use Bee\API\External\User\Handler\ChangePasswordHandler; use Bee\API\External\User\Handler\ChangePasswordHandler;
use Bee\API\External\User\Handler\ChangeUsernameHandler; use Bee\API\External\User\Handler\ChangeUsernameHandler;
use Bee\API\External\User\Handler\CreateUserHandler; use Bee\API\External\User\Handler\CreateUserHandler;
@ -10,7 +11,8 @@ use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [ return [
'factories' => [ 'factories' => [
// Formatter // Formatter
UserFormatter::class => AutoWiringFactory::class, UserStateFormatter::class => AutoWiringFactory::class,
CreateUserFormatter::class => AutoWiringFactory::class,
// Handler // Handler
CreateUserHandler::class => AutoWiringFactory::class, CreateUserHandler::class => AutoWiringFactory::class,

8
src/ApiDomain/External/User/src/Formatter/UserFormatter.php → src/ApiDomain/External/User/src/Formatter/CreateUserFormatter.php vendored
View File

@ -5,15 +5,15 @@ namespace Bee\API\External\User\Formatter;
use DateTime; use DateTime;
use Bee\Data\Business\Entity\User; use Bee\Data\Business\Entity\User;
class UserFormatter { class CreateUserFormatter {
public function format(User $user): array { public function format(User $user): array {
$userArray = [ $userArray = [
'id' => $user->getId()->toString(), 'id' => $user->getId()->toString(),
'username' => $user->getUsername(), 'username' => $user->getUsername(),
'role' => $user->getRole()->getIdentifier(), 'roleIdentifier' => $user->getRole()->getIdentifier(),
'created' => $user->getCreatedAt()->format(DateTime::ATOM), 'createdAt' => $user->getCreatedAt()->format(DateTime::ATOM),
'updated' => $user->getUpdatedAt()->format(DateTime::ATOM) 'updatedAt' => $user->getUpdatedAt()->format(DateTime::ATOM)
]; ];
$userArray['permissions'] = []; $userArray['permissions'] = [];

28
src/ApiDomain/External/User/src/Formatter/UserStateFormatter.php vendored Normal file
View File

@ -0,0 +1,28 @@
<?php
namespace Bee\API\External\User\Formatter;
use DateTime;
use Bee\Data\Business\Entity\User;
class UserStateFormatter {
public function format(User $user): array {
$userArray = [
'id' => $user->getId()->toString(),
'sessionId' => $user->getSession()->getId()->toString(),
'username' => $user->getUsername(),
'roleIdentifier' => $user->getRole()->getIdentifier(),
'createdAt' => $user->getCreatedAt()->format(DateTime::ATOM),
'updatedAt' => $user->getUpdatedAt()->format(DateTime::ATOM)
];
$userArray['permissions'] = [];
foreach ($user->getRole()->getPermissions()->toArray() as $permission) {
$userArray['permissions'][] = $permission->getIdentifier();
}
return $userArray;
}
}

2
src/ApiDomain/External/User/src/Handler/ChangeUsernameHandler.php vendored
View File

@ -7,6 +7,7 @@ namespace Bee\API\External\User\Handler;
use Bee\Data\Business\Entity\User; use Bee\Data\Business\Entity\User;
use Bee\Handling\User\Handler\Command\ChangeUsername\ChangeUsernameCommandBuilder; use Bee\Handling\User\Handler\Command\ChangeUsername\ChangeUsernameCommandBuilder;
use Bee\Handling\User\Handler\Command\ChangeUsername\ChangeUsernameCommandHandler; use Bee\Handling\User\Handler\Command\ChangeUsername\ChangeUsernameCommandHandler;
use Bee\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Bee\Infrastructure\Response\SuccessResponse; use Bee\Infrastructure\Response\SuccessResponse;
use Bee\Infrastructure\Session\Middleware\LoggedInUserMiddleware; use Bee\Infrastructure\Session\Middleware\LoggedInUserMiddleware;
use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ResponseInterface;
@ -25,7 +26,6 @@ class ChangeUsernameHandler implements RequestHandlerInterface
{ {
/** @var User $user */ /** @var User $user */
$user = $request->getAttribute(LoggedInUserMiddleware::USER_KEY); $user = $request->getAttribute(LoggedInUserMiddleware::USER_KEY);
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA); $data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$query = $this->builder->build( $query = $this->builder->build(

5
src/ApiDomain/External/User/src/Handler/CreateUserHandler.php vendored
View File

@ -4,6 +4,7 @@ declare(strict_types=1);
namespace Bee\API\External\User\Handler; namespace Bee\API\External\User\Handler;
use Bee\API\External\User\Formatter\CreateUserFormatter;
use Bee\API\External\User\Formatter\UserFormatter; use Bee\API\External\User\Formatter\UserFormatter;
use Bee\Handling\User\Handler\Command\CreateUser\CreateUserCommandBuilder; use Bee\Handling\User\Handler\Command\CreateUser\CreateUserCommandBuilder;
use Bee\Handling\User\Handler\Command\CreateUser\CreateUserCommandHandler; use Bee\Handling\User\Handler\Command\CreateUser\CreateUserCommandHandler;
@ -18,7 +19,7 @@ class CreateUserHandler implements RequestHandlerInterface
public function __construct( public function __construct(
private readonly CreateUserCommandHandler $handler, private readonly CreateUserCommandHandler $handler,
private readonly CreateUserCommandBuilder $builder, private readonly CreateUserCommandBuilder $builder,
private readonly UserFormatter $userFormatter, private readonly CreateUserFormatter $formatter,
) { ) {
} }
@ -34,7 +35,7 @@ class CreateUserHandler implements RequestHandlerInterface
$result = $this->handler->execute($query); $result = $this->handler->execute($query);
return new JsonResponse( return new JsonResponse(
$this->userFormatter->format($result) $this->formatter->format($result)
); );
} }
} }

7
src/ApiDomain/External/User/src/Handler/UserStateHandler.php vendored
View File

@ -4,10 +4,8 @@ declare(strict_types=1);
namespace Bee\API\External\User\Handler; namespace Bee\API\External\User\Handler;
use Bee\API\External\User\Formatter\UserFormatter; use Bee\API\External\User\Formatter\UserStateFormatter;
use Bee\Data\Business\Entity\User; use Bee\Data\Business\Entity\User;
use Bee\Handling\User\Handler\Command\CreateUser\CreateUserCommandBuilder;
use Bee\Handling\User\Handler\Command\CreateUser\ChangePasswordCommandHandler;
use Bee\Infrastructure\Session\Middleware\LoggedInUserMiddleware; use Bee\Infrastructure\Session\Middleware\LoggedInUserMiddleware;
use Laminas\Diactoros\Response\JsonResponse; use Laminas\Diactoros\Response\JsonResponse;
use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ResponseInterface;
@ -17,7 +15,7 @@ use Psr\Http\Server\RequestHandlerInterface;
class UserStateHandler implements RequestHandlerInterface class UserStateHandler implements RequestHandlerInterface
{ {
public function __construct( public function __construct(
private readonly UserFormatter $userFormatter, private readonly UserStateFormatter $userFormatter,
) { ) {
} }
@ -27,7 +25,6 @@ class UserStateHandler implements RequestHandlerInterface
$user = $request->getAttribute(LoggedInUserMiddleware::USER_KEY); $user = $request->getAttribute(LoggedInUserMiddleware::USER_KEY);
$response = $this->userFormatter->format($user); $response = $this->userFormatter->format($user);
$response['sessionId'] = $user->getSession()->getId()->toString();
return new JsonResponse($response); return new JsonResponse($response);
} }

38
src/HandlingDomain/Registration/src/Pipeline/RegisterUser/Step/SendMailStep.php
View File

@ -4,7 +4,8 @@ declare(strict_types=1);
namespace Bee\Handling\Registration\Pipeline\RegisterUser\Step; namespace Bee\Handling\Registration\Pipeline\RegisterUser\Step;
use Bee\Infrastructure\Request\Service\RequestService; use Bee\Infrastructure\Mail\Exception\SendMailFailedException;
use Bee\Infrastructure\Mail\Service\MailService;
use teewurst\Pipeline\PipelineInterface; use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface; use teewurst\Pipeline\TaskInterface;
@ -13,10 +14,13 @@ class SendMailStep implements TaskInterface
private const CONFIRM_LINK = 'https://%s/auth/registration/%s'; private const CONFIRM_LINK = 'https://%s/auth/registration/%s';
public function __construct( public function __construct(
private RequestService $requestService private MailService $mailService,
) { ) {
} }
/**
* @throws SendMailFailedException
*/
public function __invoke( public function __invoke(
$payload, $payload,
PipelineInterface $pipeline PipelineInterface $pipeline
@ -25,23 +29,19 @@ class SendMailStep implements TaskInterface
$command = $payload->getCommand(); $command = $payload->getCommand();
$registration = $payload->getRegistration(); $registration = $payload->getRegistration();
$this->requestService->request( $this->mailService->send(
'notification', template: 'registration',
'send-mail', templateData: [
[ 'username' => $command->getUsername(),
'bee-identifier' => 'new-account', 'confirmationLink' =>
'sender' => 'info@stack-up.de', sprintf(
'recipient' => $command->getMail(), self::CONFIRM_LINK,
'data' => [ $command->getHost(),
'username' => $command->getUsername(), $registration->getId()->toString()
'confirmationLink' => )
sprintf( ],
self::CONFIRM_LINK, recipient: $command->getMail(),
$command->getHost(), senderName: "Beekeeper"
$registration->getId()->toString()
)
]
]
); );
$pipeline->next()($payload, $pipeline); $pipeline->next()($payload, $pipeline);

1
src/Infrastructure/Exception/src/ErrorCode.php
View File

@ -9,4 +9,5 @@ enum ErrorCode : string {
case AlreadyExists = 'AlreadyExists'; case AlreadyExists = 'AlreadyExists';
case WrongCredentials = 'WrongCredentials'; case WrongCredentials = 'WrongCredentials';
case Mismatch = 'Mismatch'; case Mismatch = 'Mismatch';
case Failed = 'Failed';
} }

2
src/Infrastructure/Exception/src/ErrorDomain.php
View File

@ -10,4 +10,6 @@ enum ErrorDomain : string {
case UserPassword = 'UserPassword'; case UserPassword = 'UserPassword';
case Registration = 'Registration'; case Registration = 'Registration';
case Product = 'Product'; case Product = 'Product';
case Mail = 'Mail';
case Login = 'Login';
} }

12
src/Infrastructure/Mail/config/service_manager.php Normal file
View File

@ -0,0 +1,12 @@
<?php
declare(strict_types=1);
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
use Bee\Infrastructure\Mail\Service\MailService;
return [
'factories' => [
MailService::class => AutoWiringFactory::class,
],
];

15
src/Infrastructure/Mail/src/ConfigProvider.php Normal file
View File

@ -0,0 +1,15 @@
<?php
declare(strict_types=1);
namespace Bee\Infrastructure\Mail;
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
];
}
}

32
src/Infrastructure/Mail/src/Exception/SendMailFailedException.php Normal file
View File

@ -0,0 +1,32 @@
<?php
namespace Bee\Infrastructure\Mail\Exception;
use Throwable;
use Bee\Infrastructure\Exception\ErrorCode;
use Bee\Infrastructure\Exception\ErrorDomain;
use Bee\Infrastructure\Exception\Exception\Exception;
class SendMailFailedException extends Exception
{
private const MESSAGE = 'Das Mail template %s konnte mit den Daten {%s} nicht an %s gesendet werden. Grund: %s';
public function __construct(
string $templateIdentification,
array $templateData,
string $recipient,
Throwable $reason,
) {
parent::__construct(
sprintf(
self::MESSAGE,
$templateIdentification,
json_encode($templateData),
$recipient,
$reason->getMessage(),
),
ErrorDomain::Mail,
ErrorCode::Failed
);
}
}

120
src/Infrastructure/Mail/src/Service/MailService.php Normal file
View File

@ -0,0 +1,120 @@
<?php
declare(strict_types=1);
namespace Bee\Infrastructure\Mail\Service;
use Exception;
use Latte\Engine;
use Nette\Mail\Mailer;
use Nette\Mail\Message;
use Nette\Mail\SmtpMailer;
use Reinfi\DependencyInjection\Service\ConfigService;
use Throwable;
use Bee\Infrastructure\Logging\Logger\Logger;
use Bee\Infrastructure\Mail\Exception\SendMailFailedException;
class MailService
{
private const TEMPLATE_PATH = APP_ROOT . '/data/mails/';
private readonly Engine $engine;
public function __construct(
private readonly ConfigService $configService,
private readonly Logger $logger,
) {
$this->engine = new Engine();
}
/**
* @throws SendMailFailedException
*/
public function send(
string $template,
array $templateData,
string $recipient,
?string $sender = null,
?string $senderName = null
): void {
try {
$mail = $this->getMail(
template: $template,
templateData: $templateData,
recipient: $recipient,
sender: $sender,
senderName: $senderName
);
$mailer = $this->getMailer();
$mailer->send($mail);
} catch (Throwable $e) {
$this->logger->exception($e);
throw new SendMailFailedException(
$template,
$templateData,
$recipient,
$e
);
}
}
private function getMailer(): Mailer
{
$smtpConfig = $this->configService->resolve('mail.smtp-server');
return new SmtpMailer(
host: $smtpConfig['host'],
username: $smtpConfig['username'],
password: $smtpConfig['password'],
encryption: $smtpConfig['encryption'],
port: $smtpConfig['port'],
);
}
private function getMail(
string $template,
array $templateData,
string $recipient,
?string $sender = null,
?string $senderName = null
): Message {
$templatePath = self::TEMPLATE_PATH . $template . '/template.latte';
$assetsPath = self::TEMPLATE_PATH . $template . "/";
if (!file_exists($templatePath)) {
throw new Exception("Template File does not exist");
}
if (!is_dir($assetsPath)) {
$assetsPath = null;
}
$mail = new Message();
$mail->setFrom($this->getSenderName($sender, $senderName));
$mail->addTo($recipient);
$mail->setHtmlBody(
$this->engine->renderToString(
$templatePath,
$templateData,
),
$assetsPath
);
return $mail;
}
private function getSenderName(
?string $sender,
?string $senderName
): string {
$defaultConfig = $this->configService->resolve('mail.default');
$from = $sender ?? $defaultConfig['sender'] ?? throw new Exception('Could not determine Sender');
if ($senderName !== null) {
$from = sprintf('%s <%s>', $senderName, $from);
}
return $from;
}
}