flo/mytube-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: flo:1df97ff32672850ed7a450ddb4754ba83e910c41
Branches Tags
flo:master
flo:prod
..
compare: flo:7c6bd31a6ca1768c118031a3beff734acca7fbd7
Branches Tags
flo:prod
flo:master

No commits in common. "1df97ff32672850ed7a450ddb4754ba83e910c41" and "7c6bd31a6ca1768c118031a3beff734acca7fbd7" have entirely different histories.
1df97ff326 ... 7c6bd31a6c

109 changed files with 149 additions and 2853 deletions
Show Stats Expand all files Collapse all files

126
bin/createApi.php
View File

@ -14,25 +14,20 @@ $apiNamespace = $argv[2];
$apiName = $argv[3];
$cqrsType = strtolower($argv[4]) === 'true' ? 'Command' : 'Query';
$cqrsNamespace = $argv[5];
$originalCqrsNamespace = $cqrsNamespace;
$apiDirectoryPath = $projectSourceDirectory . 'ApiDomain/' . $apiType . '/' . $apiNamespace . '/';
$cqrsDirectoryPath = $projectSourceDirectory . 'HandlingDomain/' . $cqrsNamespace . '/';
# API Handler
$apiHandlerName = $apiName . 'Handler';
$apiHandlerNamespace = $projectNamespace . '\\API\\' . $apiType . '\\' . $apiNamespace . '\\Handler';
$apiHandlerUsingNamespace = $apiHandlerNamespace . '\\' . $apiHandlerName;
$apiHandlerFilePath = $apiDirectoryPath . 'src/Handler/' . $apiHandlerName . '.php';
$apiHandlerFilePath = $projectSourceDirectory . 'ApiDomain/' . $apiType . '/' . $apiNamespace . '/src/Handler/' . $apiHandlerName . '.php';
# Response Formatter
$apiResponseFormatterName = $apiName . 'ResponseFormatter';
$apiResponseFormatterNamespace = $projectNamespace . '\\API\\' . $apiType . '\\' . $apiNamespace . '\\ResponseFormatter';
$apiResponseFormatterUsingNamespace = $apiResponseFormatterNamespace . '\\' . $apiResponseFormatterName;
$apiResponseFormatterFilePath = $apiDirectoryPath . 'src/ResponseFormatter/' . $apiResponseFormatterName . '.php';
$apiResponseFormatterFilePath = $projectSourceDirectory . 'ApiDomain/' . $apiType . '/' . $apiNamespace . '/src/ResponseFormatter/' . $apiResponseFormatterName . '.php';
# CQRS
$cqrsFilePath = $cqrsDirectoryPath . 'src/Handler/' . $cqrsType . '/' . $apiName . '/';
$cqrsFilePath = $projectSourceDirectory . 'HandlingDomain/' . $cqrsNamespace . '/src/Handler/' . $cqrsType . '/' . $apiName . '/';
$cqrsName = $apiName . $cqrsType;
$cqrsVariableName = lcfirst($cqrsName);
$cqrsNamespace = $projectNamespace . '\\Handling\\' . $cqrsNamespace . '\\Handler\\' . $cqrsType . '\\' . $apiName;
@ -75,113 +70,6 @@ function writeToFile($path, $content) {
file_put_contents($path, $content);
}
if (!file_exists($apiDirectoryPath)) {
$routesFileContent = "<?php
declare(strict_types=1);
use {$apiHandlerUsingNamespace};
return [
[
'name' => 'TODO.TODO',
'path' => '/api/TODO/TODO[/]',
'allowed_methods' => ['POST'],
'middleware' => [
{$apiHandlerName}::class,
],
],
];
";
$routesFilePath = $apiDirectoryPath . 'config/routes.php';
writeToFile($routesFilePath, $routesFileContent);
$serviceManagerFileContent = "<?php
declare(strict_types=1);
use {$apiHandlerUsingNamespace};
use {$apiResponseFormatterUsingNamespace};
use Reinfi\\DependencyInjection\\Factory\\AutoWiringFactory;
return [
'factories' => [
// Handler
{$apiHandlerName}::class => AutoWiringFactory::class,
// Response Formatter
{$apiResponseFormatterName}::class => AutoWiringFactory::class,
],
];
";
$serviceManagerFilePath = $apiDirectoryPath . 'config/service_manager.php';
writeToFile($serviceManagerFilePath, $serviceManagerFileContent);
$configProviderFileContent = "<?php
declare(strict_types=1);
namespace MyTube\\API\\{$apiType}\\{$apiNamespace};
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
'routes' => require __DIR__ . '/./../config/routes.php',
];
}
}
";
$configProviderFilePath = $apiDirectoryPath . 'src/ConfigProvider.php';
writeToFile($configProviderFilePath, $configProviderFileContent);
}
if (!file_exists($cqrsDirectoryPath)) {
$serviceManagerFileContent = "<?php
declare(strict_types=1);
use {$cqrsHandlerUsingNamespace};
use {$cqrsBuilderUsingNamespace};
use Reinfi\\DependencyInjection\\Factory\\AutoWiringFactory;
use Reinfi\\DependencyInjection\\Factory\\InjectionFactory;
return [
'factories' => [
/// CQRS
// {$apiName}
{$cqrsBuilderName}::class => AutoWiringFactory::class,
{$cqrsHandlerName}::class => AutoWiringFactory::class,
],
];
";
$serviceManagerFilePath = $cqrsDirectoryPath . 'config/service_manager.php';
writeToFile($serviceManagerFilePath, $serviceManagerFileContent);
$configProviderFileContent = "<?php
declare(strict_types=1);
namespace MyTube\\Handling\\{$originalCqrsNamespace};
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
];
}
}
";
$configProviderFilePath = $cqrsDirectoryPath . 'src/ConfigProvider.php';
writeToFile($configProviderFilePath, $configProviderFileContent);
}
$apiHandlerFileContent = "<?php
declare(strict_types=1);
@ -191,11 +79,10 @@ namespace {$apiHandlerNamespace};
use {$cqrsHandlerUsingNamespace};
use {$cqrsBuilderUsingNamespace};
use {$apiResponseFormatterUsingNamespace};
use {$projectNamespace}\\Infrastructure\\Request\\Middleware\\AnalyzeBodyMiddleware;
use {$projectNamespace}\\Infrastructure\\Response\\SuccessResponse;
use Psr\\Http\\Message\\ResponseInterface;
use Psr\\Http\\Message\\ServerRequestInterface;
use Psr\\Http\\Server\\RequestHandlerInterface;
use {$projectNamespace}\\Infrastructure\\Response\\SuccessResponse;
class {$apiHandlerName} implements RequestHandlerInterface
{
@ -208,7 +95,10 @@ class {$apiHandlerName} implements RequestHandlerInterface
public function handle(ServerRequestInterface \$request): ResponseInterface
{
\$data = \$request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
\$data = json_decode(
\$request->getBody()->getContents(),
true
);
\${$cqrsVariableName} = \$this->{$cqrsBuilderVariableName}->build(
\$data

61
bin/createPipeline.php
View File

@ -16,8 +16,7 @@ $stepNames = array_slice($argv, 3);
# Pipeline
$pipelineClassName = $pipelineName . 'Pipeline';
$pipelineVariableName = lcfirst($pipelineClassName);
$pipelineDirectoryPath = $projectSourceDirectory . 'HandlingDomain/' . $pipelineNamespace . '/';
$pipelineFilePath = $pipelineDirectoryPath . 'src/Pipeline/' . $pipelineName . '/' . $pipelineClassName . '.php';
$pipelineFilePath = $projectSourceDirectory . 'HandlingDomain/' . $pipelineNamespace . '/src/Pipeline/' . $pipelineName . '/' . $pipelineClassName . '.php';
$pipelineFullNamespace = $projectNamespace . '\\Handling\\' . $pipelineNamespace . '\\Pipeline\\' . $pipelineName;
$pipelineUsingNamespace = $pipelineFullNamespace . '\\' . $pipelineClassName;
@ -58,11 +57,8 @@ function writeToFile($path, $content) {
file_put_contents($path, $content);
}
$createNamespaceFiles = !file_exists($pipelineDirectoryPath);
$stepsUsingNamespaces = [];
$stepsDeclarations = [];
$stepsAutoWirings = [];
$stepsReferences = [];
foreach ($steps as $step) {
@ -73,7 +69,6 @@ foreach ($steps as $step) {
$stepsUsingNamespaces[] = $stepUsingNamespace . ';';
$stepsDeclarations[] = 'private readonly ' . $stepClassName . ' $' . $stepVariableName . ',';
$stepsAutoWirings[] = $stepClassName . '::class => AutoWiringFactory::class,';
$stepsReferences[] = '$this->' . $stepVariableName . ',';
$stepFileContent = "<?php
@ -94,7 +89,10 @@ class {$stepClassName} implements TaskInterface
) {
}
public function __invoke(\$payload, PipelineInterface \$pipeline): void
public function __invoke(
\$payload,
PipelineInterface \$pipeline
): void
{
/** @var {$payloadClassName} \${$payloadVariableName} */
\${$payloadVariableName} = \$payload;
@ -108,7 +106,6 @@ class {$stepClassName} implements TaskInterface
$stepsUsingNamespace = implode(PHP_EOL, $stepsUsingNamespaces);
$stepsDeclaration = implode(PHP_EOL . ' ', $stepsDeclarations);
$stepsAutoWiring = implode(PHP_EOL . ' ', $stepsAutoWirings);
$stepsReference = implode(PHP_EOL . ' ', $stepsReferences);
@ -143,52 +140,10 @@ namespace {$payloadFullNamespace};
class {$payloadClassName}
{
public function __construct(
#TODO
}
";
writeToFile($payloadFilePath, $payloadFileContent);
if ($createNamespaceFiles) {
$serviceManagerFileContent = "<?php
declare(strict_types=1);
use {$pipelineUsingNamespace};
{$stepsUsingNamespace}
use Reinfi\\DependencyInjection\\Factory\\AutoWiringFactory;
use Reinfi\\DependencyInjection\\Factory\\InjectionFactory;
return [
'factories' => [
/// Pipeline
// {$pipelineName}
{$pipelineClassName}::class => AutoWiringFactory::class,
{$stepsAutoWiring}
],
];
";
$serviceManagerFilePath = $pipelineDirectoryPath . 'config/service_manager.php';
writeToFile($serviceManagerFilePath, $serviceManagerFileContent);
$configProviderFileContent = "<?php
declare(strict_types=1);
namespace MyTube\\Handling\\{$pipelineNamespace};
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
];
) {
}
}
";
$configProviderFilePath = $pipelineDirectoryPath . 'src/ConfigProvider.php';
writeToFile($configProviderFilePath, $configProviderFileContent);
}
writeToFile($payloadFilePath, $payloadFileContent);

8
composer.development.json
View File

@ -27,8 +27,6 @@
"MyTube\\API\\Console\\": "src\/ApiDomain\/Console\/src",
"MyTube\\API\\External\\Authentication\\": "src\/ApiDomain\/External\/Authentication\/src",
"MyTube\\API\\External\\Health\\": "src\/ApiDomain\/External\/Health\/src",
"MyTube\\API\\External\\Tag\\": "src\/ApiDomain\/External\/Tag\/src",
"MyTube\\API\\External\\TagList\\": "src\/ApiDomain\/External\/TagList\/src",
"MyTube\\API\\External\\User\\": "src\/ApiDomain\/External\/User\/src",
"MyTube\\API\\External\\Video\\": "src\/ApiDomain\/External\/Video\/src",
"MyTube\\API\\External\\VideoList\\": "src\/ApiDomain\/External\/VideoList\/src",
@ -36,8 +34,6 @@
"MyTube\\Data\\Log\\": "src\/DataDomain\/Log\/src",
"MyTube\\Handling\\Registration\\": "src\/HandlingDomain\/Registration\/src",
"MyTube\\Handling\\Role\\": "src\/HandlingDomain\/Role\/src",
"MyTube\\Handling\\Tag\\": "src\/HandlingDomain\/Tag\/src",
"MyTube\\Handling\\TagList\\": "src\/HandlingDomain\/TagList\/src",
"MyTube\\Handling\\User\\": "src\/HandlingDomain\/User\/src",
"MyTube\\Handling\\UserSession\\": "src\/HandlingDomain\/UserSession\/src",
"MyTube\\Handling\\Video\\": "src\/HandlingDomain\/Video\/src",
@ -99,8 +95,6 @@
"psr-4": {
"MyTube\\API\\External\\Authentication\\": "src\/ApiDomain\/External\/Authentication\/src",
"MyTube\\API\\External\\Health\\": "src\/ApiDomain\/External\/Health\/src",
"MyTube\\API\\External\\Tag\\": "src\/ApiDomain\/External\/Tag\/src",
"MyTube\\API\\External\\TagList\\": "src\/ApiDomain\/External\/TagList\/src",
"MyTube\\API\\External\\User\\": "src\/ApiDomain\/External\/User\/src",
"MyTube\\API\\External\\Video\\": "src\/ApiDomain\/External\/Video\/src",
"MyTube\\API\\External\\VideoList\\": "src\/ApiDomain\/External\/VideoList\/src",
@ -108,8 +102,6 @@
"MyTube\\Data\\Log\\": "src\/DataDomain\/Log\/src",
"MyTube\\Handling\\Registration\\": "src\/HandlingDomain\/Registration\/src",
"MyTube\\Handling\\Role\\": "src\/HandlingDomain\/Role\/src",
"MyTube\\Handling\\Tag\\": "src\/HandlingDomain\/Tag\/src",
"MyTube\\Handling\\TagList\\": "src\/HandlingDomain\/TagList\/src",
"MyTube\\Handling\\User\\": "src\/HandlingDomain\/User\/src",
"MyTube\\Handling\\UserSession\\": "src\/HandlingDomain\/UserSession\/src",
"MyTube\\Handling\\Video\\": "src\/HandlingDomain\/Video\/src",

4
config/config.php
View File

@ -59,8 +59,6 @@ $aggregator = new ConfigAggregator([
\MyTube\Handling\Registration\ConfigProvider::class,
\MyTube\Handling\Video\ConfigProvider::class,
\MyTube\Handling\VideoList\ConfigProvider::class,
\MyTube\Handling\Tag\ConfigProvider::class,
\MyTube\Handling\TagList\ConfigProvider::class,
// API
/// Command
@ -72,8 +70,6 @@ $aggregator = new ConfigAggregator([
\MyTube\API\External\Authentication\ConfigProvider::class,
\MyTube\API\External\Video\ConfigProvider::class,
\MyTube\API\External\VideoList\ConfigProvider::class,
\MyTube\API\External\Tag\ConfigProvider::class,
\MyTube\API\External\TagList\ConfigProvider::class,
/// Internal

2
config/pipeline.php
View File

@ -3,7 +3,6 @@
declare(strict_types=1);
use MyTube\Infrastructure\Exception\Middleware\MyTubeExceptionHandlerMiddleware;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Request\Middleware\AnalyzeHeaderMiddleware;
use MyTube\Infrastructure\Session\Middleware\SessionMiddleware;
use Laminas\Stratigility\Middleware\ErrorHandler;
@ -70,7 +69,6 @@ return function (Application $app, MiddlewareFactory $factory, ContainerInterfac
//// Pre MyTube Space
$app->pipe(MyTubeExceptionHandlerMiddleware::class);
$app->pipe(AnalyzeHeaderMiddleware::class);
$app->pipe(AnalyzeBodyMiddleware::class);
//// MyTube Space
$app->pipe(SessionMiddleware::class);

14
data/migrations/myTube/Version20240223130626.php
View File

@ -14,24 +14,18 @@ final class Version20240223130626 extends AbstractMigration
{
public function getDescription(): string
{
return "Create Table 'tag'";
return '';
}
public function up(Schema $schema): void
{
$sql = "CREATE TABLE tag (
id binary(16) NOT NULL,
description varchar(255) NOT NULL,
created_at datetime NOT NULL,
updated_at datetime NOT NULL,
PRIMARY KEY (id)
);";
// this up() migration is auto-generated, please modify it to your needs
$this->addSql($sql);
}
public function down(Schema $schema): void
{
$this->addSql("DROP TABLE tag;");
// this down() migration is auto-generated, please modify it to your needs
}
}

38
data/migrations/myTube/Version20240223130835.php
View File

@ -1,38 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Migrations\MyTube;
use Doctrine\DBAL\Schema\Schema;
use Doctrine\Migrations\AbstractMigration;
/**
* Auto-generated Migration: Please modify to your needs!
*/
final class Version20240223130835 extends AbstractMigration
{
public function getDescription(): string
{
return "Create Table 'tag_alias'";
}
public function up(Schema $schema): void
{
$sql = "CREATE TABLE tag_alias (
id binary(16) NOT NULL,
tag_id binary(16) NOT NULL,
description varchar(255) NOT NULL,
created_at datetime NOT NULL,
updated_at datetime NOT NULL,
PRIMARY KEY (id)
);";
$this->addSql($sql);
}
public function down(Schema $schema): void
{
$this->addSql("DROP TABLE tag_alias;");
}
}

35
data/migrations/myTube/Version20240223142111.php
View File

@ -1,35 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Migrations\MyTube;
use Doctrine\DBAL\Schema\Schema;
use Doctrine\Migrations\AbstractMigration;
/**
* Auto-generated Migration: Please modify to your needs!
*/
final class Version20240223142111 extends AbstractMigration
{
public function getDescription(): string
{
return "Create Table 'video_tag'";
}
public function up(Schema $schema): void
{
$sql = "CREATE TABLE video_tag (
video_id binary(16) NOT NULL,
tag_id binary(16) NOT NULL,
PRIMARY KEY (video_id, tag_id)
);";
$this->addSql($sql);
}
public function down(Schema $schema): void
{
$this->addSql("DROP TABLE video_tag;");
}
}

2
docker/nginx/config/nginx.conf
View File

@ -5,7 +5,7 @@ upstream host-backend-app {
server {
listen 80 default_server;
client_max_body_size 10000M;
client_max_body_size 1000M;
location / {
fastcgi_pass host-backend-app;

9
docker/php/config/uploads.ini
View File

@ -1,6 +1,5 @@
file_uploads = On
max_file_uploads = 1000
memory_limit = 10000M
upload_max_filesize = 10000M
post_max_size = 10000M
max_execution_time = 1000
memory_limit = 1000M
upload_max_filesize = 1000M
post_max_size = 1000M
max_execution_time = 600

4
src/ApiDomain/Console/config/console.php
View File

@ -1,15 +1,11 @@
<?php
use MyTube\API\Console\Command\AnalyzeVideoTitlesCommand;
use MyTube\API\Console\Command\InitializeDataCommand;
use MyTube\API\Console\Command\RbacUpdateCommand;
use MyTube\API\Console\Command\ReadUntaggedVideosCommand;
return [
'commands' => [
InitializeDataCommand::class,
RbacUpdateCommand::class,
AnalyzeVideoTitlesCommand::class,
ReadUntaggedVideosCommand::class,
]
];

4
src/ApiDomain/Console/config/service_manager.php
View File

@ -1,16 +1,12 @@
<?php
use MyTube\API\Console\Command\AnalyzeVideoTitlesCommand;
use MyTube\API\Console\Command\InitializeDataCommand;
use MyTube\API\Console\Command\RbacUpdateCommand;
use MyTube\API\Console\Command\ReadUntaggedVideosCommand;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [
'factories' => [
InitializeDataCommand::class => AutoWiringFactory::class,
RbacUpdateCommand::class => AutoWiringFactory::class,
AnalyzeVideoTitlesCommand::class => AutoWiringFactory::class,
ReadUntaggedVideosCommand::class => AutoWiringFactory::class,
],
];

66
src/ApiDomain/Console/src/Command/AnalyzeVideoTitlesCommand.php
View File

@ -1,66 +0,0 @@
<?php
namespace MyTube\API\Console\Command;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\Video;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Data\Business\Repository\VideoRepository;
use MyTube\Handling\Video\Analyzer\VideoTitleAnalyzer;
use MyTube\Infrastructure\Logging\Logger\Logger;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
#[AsCommand(name: 'analyze:video-title', description: 'Analyzes video titles and add tags')]
class AnalyzeVideoTitlesCommand extends Command
{
private readonly VideoRepository $videoRepository;
public function __construct(
private readonly MyTubeEntityManager $entityManager,
private readonly VideoTitleAnalyzer $analyzer,
private readonly Logger $logger,
) {
parent::__construct($this->getName());
$this->videoRepository = $this->entityManager->getRepository(Video::class);
}
protected function execute(
InputInterface $input,
OutputInterface $output
): int {
$io = new SymfonyStyle($input, $output);
try {
$videos = $this->videoRepository->findAll();
/** @var Video $video */
foreach ($videos as $video) {
$io->info($video->getTitle());
$matches = $this->analyzer->analyze($video);
/** @var Tag $match */
foreach ($matches as $match) {
echo sprintf("Added Tag '%s'", $match->getDescription());
}
$this->entityManager->persist($video);
$this->entityManager->flush();
}
$io->success('OK!');
} catch (\Throwable $e) {
$io->error($e->getMessage());
$io->error($e->getTraceAsString());
$this->logger->error($e->getMessage(), ['exception' => $e]);
return Command::FAILURE;
}
return Command::SUCCESS;
}
}

64
src/ApiDomain/Console/src/Command/ReadUntaggedVideosCommand.php
View File

@ -1,64 +0,0 @@
<?php
namespace MyTube\API\Console\Command;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\Video;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Data\Business\Repository\VideoRepository;
use MyTube\Handling\Video\Analyzer\VideoTitleAnalyzer;
use MyTube\Infrastructure\Logging\Logger\Logger;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
#[AsCommand(name: 'analyze:untagged', description: 'Returns the names of all untagged videos')]
class ReadUntaggedVideosCommand extends Command
{
private readonly VideoRepository $videoRepository;
public function __construct(
private readonly MyTubeEntityManager $entityManager,
private readonly Logger $logger,
) {
parent::__construct($this->getName());
$this->videoRepository = $this->entityManager->getRepository(Video::class);
}
protected function execute(
InputInterface $input,
OutputInterface $output
): int {
$io = new SymfonyStyle($input, $output);
try {
$qb = $this->videoRepository
->createQueryBuilder('v')
->leftJoin('v.tags', 't')
->groupBy('v.id')
->having('COUNT(t.id) = 0')
->orderBy('v.title');
$videos = $qb->getQuery()->execute();
/** @var Video $video */
foreach ($videos as $video) {
echo $video->getTitle() . PHP_EOL;
}
$io->info('total: ' . count($videos));
$io->success('OK!');
} catch (\Throwable $e) {
$io->error($e->getMessage());
$io->error($e->getTraceAsString());
$this->logger->error($e->getMessage(), ['exception' => $e]);
return Command::FAILURE;
}
return Command::SUCCESS;
}
}

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

@ -7,7 +7,6 @@ namespace MyTube\API\External\Authentication\Handler;
use MyTube\API\External\User\Formatter\UserFormatter;
use MyTube\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandBuilder;
use MyTube\Handling\Registration\Handler\Command\ConfirmRegistration\ConfirmRegistrationCommandHandler;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Session\Middleware\SessionMiddleware;
use Laminas\Diactoros\Response\JsonResponse;
use Psr\Http\Message\ResponseInterface;
@ -26,7 +25,10 @@ class ConfirmRegistrationHandler implements RequestHandlerInterface
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$query = $this->builder->build(
Uuid::fromString($data['id']),

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

@ -6,7 +6,6 @@ namespace MyTube\API\External\Authentication\Handler;
use MyTube\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandBuilder;
use MyTube\Handling\UserSession\Handler\Command\LoginUser\LoginUserCommandHandler;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Session\Middleware\SessionMiddleware;
use Laminas\Diactoros\Response\JsonResponse;
use Psr\Http\Message\ResponseInterface;
@ -24,7 +23,10 @@ class LoginUserHandler implements RequestHandlerInterface
public function handle(ServerRequestInterface $request): ResponseInterface
{
$session = $request->getAttribute(SessionMiddleware::SESSION_ATTRIBUTE);
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$query = $this->builder->build(
$session,

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

@ -8,7 +8,6 @@ use MyTube\Handling\Registration\Handler\Command\RegisterUser\RegisterUserComman
use MyTube\Handling\Registration\Handler\Command\RegisterUser\RegisterUserCommandHandler;
use MyTube\Infrastructure\Exception\Middleware\MyTubeExceptionHandlerMiddleware;
use MyTube\Infrastructure\Logging\Logger\Logger;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Request\Middleware\AnalyzeHeaderMiddleware;
use MyTube\Infrastructure\Response\SuccessResponse;
use MyTube\Infrastructure\Session\Middleware\SessionMiddleware;
@ -29,7 +28,10 @@ class RegisterUserHandler implements RequestHandlerInterface
public function handle(ServerRequestInterface $request): ResponseInterface
{
$host = $request->getAttribute(AnalyzeHeaderMiddleware::HOST_ATTRIBUTE);
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$query = $this->builder->build(
$data['username'],

41
src/ApiDomain/External/Tag/config/routes.php vendored
View File

@ -1,41 +0,0 @@
<?php
use MyTube\API\External\Tag\Handler\AddAliasHandler;
use MyTube\API\External\Tag\Handler\CreateHandler;
use MyTube\API\External\Tag\Handler\ReadDetailsHandler;
use MyTube\API\External\Tag\Handler\ReadVideoListHandler;
return [
[
'name' => 'tag.create',
'path' => '/api/tag/create[/]',
'allowed_methods' => ['POST'],
'middleware' => [
CreateHandler::class,
],
],
[
'name' => 'tag.add-alias',
'path' => '/api/tag/add-alias[/]',
'allowed_methods' => ['POST'],
'middleware' => [
AddAliasHandler::class,
],
],
[
'name' => 'tag.read-details',
'path' => '/api/tag/read-details[/]',
'allowed_methods' => ['POST'],
'middleware' => [
ReadDetailsHandler::class,
],
],
[
'name' => 'tag.read-video-list',
'path' => '/api/tag/read-video-list[/]',
'allowed_methods' => ['POST'],
'middleware' => [
ReadVideoListHandler::class,
],
],
];

27
src/ApiDomain/External/Tag/config/service_manager.php vendored
View File

@ -1,27 +0,0 @@
<?php
use MyTube\API\External\Tag\Handler\AddAliasHandler;
use MyTube\API\External\Tag\Handler\CreateHandler;
use MyTube\API\External\Tag\Handler\ReadDetailsHandler;
use MyTube\API\External\Tag\Handler\ReadVideoListHandler;
use MyTube\API\External\Tag\ResponseFormatter\AddAliasResponseFormatter;
use MyTube\API\External\Tag\ResponseFormatter\CreateResponseFormatter;
use MyTube\API\External\Tag\ResponseFormatter\ReadDetailsResponseFormatter;
use MyTube\API\External\Tag\ResponseFormatter\ReadVideoListResponseFormatter;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [
'factories' => [
// Handler
AddAliasHandler::class => AutoWiringFactory::class,
CreateHandler::class => AutoWiringFactory::class,
ReadDetailsHandler::class => AutoWiringFactory::class,
ReadVideoListHandler::class => AutoWiringFactory::class,
// Response Formatter
AddAliasResponseFormatter::class => AutoWiringFactory::class,
CreateResponseFormatter::class => AutoWiringFactory::class,
ReadDetailsResponseFormatter::class => AutoWiringFactory::class,
ReadVideoListResponseFormatter::class => AutoWiringFactory::class,
],
];

16
src/ApiDomain/External/Tag/src/ConfigProvider.php vendored
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag;
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
'routes' => require __DIR__ . '/./../config/routes.php',
];
}
}

44
src/ApiDomain/External/Tag/src/Handler/AddAliasHandler.php vendored
View File

@ -1,44 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\Handler;
use MyTube\Handling\Tag\Exception\TagAliasAlreadyExistsException;
use MyTube\Handling\Tag\Exception\TagNotFoundByIdException;
use MyTube\Handling\Tag\Handler\Command\AddAlias\AddAliasCommandHandler;
use MyTube\Handling\Tag\Handler\Command\AddAlias\AddAliasCommandBuilder;
use MyTube\API\External\Tag\ResponseFormatter\AddAliasResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use MyTube\Infrastructure\Response\SuccessResponse;
use Ramsey\Uuid\Uuid;
class AddAliasHandler implements RequestHandlerInterface
{
public function __construct(
private readonly AddAliasCommandHandler $addAliasCommandHandler,
private readonly AddAliasCommandBuilder $addAliasCommandBuilder,
private readonly AddAliasResponseFormatter $responseFormatter,
) {
}
/**
* @throws TagNotFoundByIdException
* @throws TagAliasAlreadyExistsException
*/
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$addAliasCommand = $this->addAliasCommandBuilder->build(
Uuid::fromString($data['tagId']),
$data['description']
);
$result = $this->addAliasCommandHandler->execute($addAliasCommand);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

40
src/ApiDomain/External/Tag/src/Handler/CreateHandler.php vendored
View File

@ -1,40 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\Handler;
use MyTube\Handling\Tag\Exception\TagAlreadyExistsException;
use MyTube\Handling\Tag\Handler\Command\Create\CreateCommandHandler;
use MyTube\Handling\Tag\Handler\Command\Create\CreateCommandBuilder;
use MyTube\API\External\Tag\ResponseFormatter\CreateResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use MyTube\Infrastructure\Response\SuccessResponse;
class CreateHandler implements RequestHandlerInterface
{
public function __construct(
private readonly CreateCommandHandler $createCommandHandler,
private readonly CreateCommandBuilder $createCommandBuilder,
private readonly CreateResponseFormatter $responseFormatter,
) {
}
/**
* @throws TagAlreadyExistsException
*/
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$createCommand = $this->createCommandBuilder->build(
$data['description']
);
$result = $this->createCommandHandler->execute($createCommand);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

41
src/ApiDomain/External/Tag/src/Handler/ReadDetailsHandler.php vendored
View File

@ -1,41 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\Handler;
use MyTube\Handling\Tag\Exception\TagNotFoundByIdException;
use MyTube\Handling\Tag\Handler\Query\ReadDetails\ReadDetailsQueryHandler;
use MyTube\Handling\Tag\Handler\Query\ReadDetails\ReadDetailsQueryBuilder;
use MyTube\API\External\Tag\ResponseFormatter\ReadDetailsResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Response\SuccessResponse;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Ramsey\Uuid\Uuid;
class ReadDetailsHandler implements RequestHandlerInterface
{
public function __construct(
private readonly ReadDetailsQueryHandler $readDetailsQueryHandler,
private readonly ReadDetailsQueryBuilder $readDetailsQueryBuilder,
private readonly ReadDetailsResponseFormatter $responseFormatter,
) {
}
/**
* @throws TagNotFoundByIdException
*/
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$readDetailsQuery = $this->readDetailsQueryBuilder->build(
Uuid::fromString($data['tagId']),
);
$result = $this->readDetailsQueryHandler->execute($readDetailsQuery);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

40
src/ApiDomain/External/Tag/src/Handler/ReadVideoListHandler.php vendored
View File

@ -1,40 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\Handler;
use MyTube\Handling\Tag\Handler\Query\ReadVideoList\ReadVideoListQueryHandler;
use MyTube\Handling\Tag\Handler\Query\ReadVideoList\ReadVideoListQueryBuilder;
use MyTube\API\External\Tag\ResponseFormatter\ReadVideoListResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Response\SuccessResponse;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Ramsey\Uuid\Uuid;
class ReadVideoListHandler implements RequestHandlerInterface
{
public function __construct(
private readonly ReadVideoListQueryHandler $readVideoListQueryHandler,
private readonly ReadVideoListQueryBuilder $readVideoListQueryBuilder,
private readonly ReadVideoListResponseFormatter $responseFormatter,
) {
}
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$readVideoListQuery = $this->readVideoListQueryBuilder->build(
Uuid::fromString($data['tagId']),
$data['query'] ?? null,
$data['page'],
$data['perPage'],
);
$result = $this->readVideoListQueryHandler->execute($readVideoListQuery);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

25
src/ApiDomain/External/Tag/src/ResponseFormatter/AddAliasResponseFormatter.php vendored
View File

@ -1,25 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\ResponseFormatter;
use MyTube\Handling\Tag\Handler\Command\AddAlias\AddAliasCommandResult;
class AddAliasResponseFormatter
{
public function format(AddAliasCommandResult $addAliasCommandResult): array
{
$alias = $addAliasCommandResult->getAlias();
$tag = $alias->getTag();
return [
'id' => $alias->getId()->toString(),
'description' => $alias->getDescription(),
'tag' => [
'id' => $tag->getId()->toString(),
'description' => $tag->getDescription()
],
];
}
}

19
src/ApiDomain/External/Tag/src/ResponseFormatter/CreateResponseFormatter.php vendored
View File

@ -1,19 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\ResponseFormatter;
use MyTube\Handling\Tag\Handler\Command\Create\CreateCommandResult;
class CreateResponseFormatter
{
public function format(CreateCommandResult $createCommandResult): array
{
$tag = $createCommandResult->getTag();
return [
'id' => $tag->getId()->toString(),
'description' => $tag->getDescription(),
];
}
}

29
src/ApiDomain/External/Tag/src/ResponseFormatter/ReadDetailsResponseFormatter.php vendored
View File

@ -1,29 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\ResponseFormatter;
use MyTube\Data\Business\Entity\TagAlias;
use MyTube\Handling\Tag\Handler\Query\ReadDetails\ReadDetailsQueryResult;
class ReadDetailsResponseFormatter
{
public function format(ReadDetailsQueryResult $readDetailsQueryResult): array
{
$tag = $readDetailsQueryResult->getTag();
$aliases = [];
/** @var TagAlias $alias */
foreach ($tag->getAliases() as $alias) {
$aliases[] = $alias->getDescription();
}
return [
'id' => $tag->getId()->toString(),
'description' => $tag->getDescription(),
'aliases' => $aliases
];
}
}

44
src/ApiDomain/External/Tag/src/ResponseFormatter/ReadVideoListResponseFormatter.php vendored
View File

@ -1,44 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\Tag\ResponseFormatter;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\Video;
use MyTube\Handling\Tag\Handler\Query\ReadVideoList\ReadVideoListQueryResult;
class ReadVideoListResponseFormatter
{
public function format(ReadVideoListQueryResult $readVideoListQueryResult): array
{
$paginator = $readVideoListQueryResult->getPaginator();
$videos = $paginator->getIterator();
$items = [];
/** @var Video $video */
foreach ($videos as $video) {
$tags = [];
/** @var Tag $tag */
foreach ($video->getTags() as $tag) {
$tags[] = [
'id' => $tag->getId(),
'description' => $tag->getDescription()
];
}
$items[] = [
'title' => $video->getTitle(),
'id' => $video->getId(),
'tags' => $tags
];
}
return [
'total' => $paginator->count(),
'items' => $items,
];
}
}

16
src/ApiDomain/External/TagList/config/routes.php vendored
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
use MyTube\API\External\TagList\Handler\ReadListHandler;
return [
[
'name' => 'tag-list.read-list',
'path' => '/api/tag-list/read-list[/]',
'allowed_methods' => ['POST'],
'middleware' => [
ReadListHandler::class,
],
],
];

17
src/ApiDomain/External/TagList/config/service_manager.php vendored
View File

@ -1,17 +0,0 @@
<?php
declare(strict_types=1);
use MyTube\API\External\TagList\Handler\ReadListHandler;
use MyTube\API\External\TagList\ResponseFormatter\ReadListResponseFormatter;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [
'factories' => [
// Handler
ReadListHandler::class => AutoWiringFactory::class,
// Response Formatter
ReadListResponseFormatter::class => AutoWiringFactory::class,
],
];

16
src/ApiDomain/External/TagList/src/ConfigProvider.php vendored
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\TagList;
class ConfigProvider
{
public function __invoke(): array
{
return [
'dependencies' => require __DIR__ . './../config/service_manager.php',
'routes' => require __DIR__ . '/./../config/routes.php',
];
}
}

36
src/ApiDomain/External/TagList/src/Handler/ReadListHandler.php vendored
View File

@ -1,36 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\TagList\Handler;
use MyTube\Handling\TagList\Handler\Query\ReadList\ReadListQueryHandler;
use MyTube\Handling\TagList\Handler\Query\ReadList\ReadListQueryBuilder;
use MyTube\API\External\TagList\ResponseFormatter\ReadListResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Infrastructure\Response\SuccessResponse;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
class ReadListHandler implements RequestHandlerInterface
{
public function __construct(
private readonly ReadListQueryHandler $readListQueryHandler,
private readonly ReadListQueryBuilder $readListQueryBuilder,
private readonly ReadListResponseFormatter $responseFormatter,
) {
}
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$readListQuery = $this->readListQueryBuilder->build(
$data['query'] ?? null,
);
$result = $this->readListQueryHandler->execute($readListQuery);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

30
src/ApiDomain/External/TagList/src/ResponseFormatter/ReadListResponseFormatter.php vendored
View File

@ -1,30 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\TagList\ResponseFormatter;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Handling\TagList\Handler\Query\ReadList\ReadListQueryResult;
class ReadListResponseFormatter
{
public function format(ReadListQueryResult $readListQueryResult): array
{
$tags = $readListQueryResult->getItems();
$items = [];
/** @var Tag $tag */
foreach ($tags as $tag) {
$items[] = [
'id' => $tag->getId()->toString(),
'description' => $tag->getDescription(),
];
}
return [
'total' => count($items),
'items' => $items,
];
}
}

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

@ -26,7 +26,10 @@ class ChangePasswordHandler implements RequestHandlerInterface
/** @var User $user */
$user = $request->getAttribute(LoggedInUserMiddleware::USER_KEY);
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$query = $this->builder->build(
$user,

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

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

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

@ -8,7 +8,6 @@ use MyTube\API\External\User\Formatter\UserFormatter;
use MyTube\Handling\User\Handler\Command\CreateUser\CreateUserCommandBuilder;
use MyTube\Handling\User\Handler\Command\CreateUser\CreateUserCommandHandler;
use Laminas\Diactoros\Response\JsonResponse;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
@ -24,7 +23,10 @@ class CreateUserHandler implements RequestHandlerInterface
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$query = $this->builder->build(
$data['username'],

6
src/ApiDomain/External/Video/src/Handler/ReadDetailsHandler.php vendored
View File

@ -8,7 +8,6 @@ use MyTube\Handling\Video\Exception\VideoNotFoundByIdException;
use MyTube\Handling\Video\Handler\Query\ReadDetails\ReadDetailsQueryHandler;
use MyTube\Handling\Video\Handler\Query\ReadDetails\ReadDetailsQueryBuilder;
use MyTube\API\External\Video\ResponseFormatter\ReadDetailsResponseFormatter;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
@ -29,7 +28,10 @@ class ReadDetailsHandler implements RequestHandlerInterface
*/
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$readDetailsQuery = $this->readDetailsQueryBuilder->build(
Uuid::fromString($data['videoId'])

14
src/ApiDomain/External/Video/src/ResponseFormatter/ReadDetailsResponseFormatter.php vendored
View File

@ -4,7 +4,6 @@ declare(strict_types=1);
namespace MyTube\API\External\Video\ResponseFormatter;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Handling\Video\Handler\Query\ReadDetails\ReadDetailsQueryResult;
class ReadDetailsResponseFormatter
@ -13,20 +12,9 @@ class ReadDetailsResponseFormatter
{
$video = $readDetailsQueryResult->getVideo();
$tags = [];
/** @var Tag $tag */
foreach ($video->getTags() as $tag) {
$tags = [
'id' => $tag->getId(),
'description' => $tag->getDescription(),
];
}
return [
'id' => $video->getId(),
'title' => $video->getTitle(),
'tags' => $tags,
'title' => $video->getTitle()
];
}
}

9
src/ApiDomain/External/VideoList/config/routes.php vendored
View File

@ -1,7 +1,6 @@
<?php
use MyTube\API\External\VideoList\Handler\ReadListHandler;
use MyTube\API\External\VideoList\Handler\UploadHandler;
return [
[
@ -12,12 +11,4 @@ return [
ReadListHandler::class
],
],
[
'name' => 'video-list.upload',
'path' => '/api/video-list/upload[/]',
'allowed_methods' => ['POST'],
'middleware' => [
UploadHandler::class
],
],
];

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

@ -1,17 +1,15 @@
<?php
use MyTube\API\External\VideoList\Handler\UploadHandler;
use MyTube\API\External\Video\Handler\StreamHandler;
use MyTube\API\External\Video\Handler\UploadHandler;
use MyTube\API\External\VideoList\Handler\ReadListHandler;
use MyTube\API\External\VideoList\ResponseFormatter\ReadListResponseFormatter;
use MyTube\API\External\VideoList\ResponseFormatter\UploadResponseFormatter;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
return [
'factories' => [
ReadListHandler::class => AutoWiringFactory::class,
UploadHandler::class => AutoWiringFactory::class,
ReadListResponseFormatter::class => AutoWiringFactory::class,
UploadResponseFormatter::class => AutoWiringFactory::class,
],
];

12
src/ApiDomain/External/VideoList/src/Handler/ReadListHandler.php vendored
View File

@ -5,9 +5,8 @@ declare(strict_types=1);
namespace MyTube\API\External\VideoList\Handler;
use MyTube\API\External\VideoList\ResponseFormatter\ReadListResponseFormatter;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryBuilder;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryHandler;
use MyTube\Infrastructure\Request\Middleware\AnalyzeBodyMiddleware;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryBuilder;
use MyTube\Infrastructure\Response\SuccessResponse;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
@ -24,12 +23,13 @@ class ReadListHandler implements RequestHandlerInterface
public function handle(ServerRequestInterface $request): ResponseInterface
{
$data = $request->getAttribute(AnalyzeBodyMiddleware::JSON_DATA);
$data = json_decode(
$request->getBody()->getContents(),
true
);
$readListQuery = $this->readListQueryBuilder->build(
$data['query'] ?? null,
$data['page'],
$data['perPage'],
$data
);
$result = $this->readListQueryHandler->execute($readListQuery);

41
src/ApiDomain/External/VideoList/src/Handler/UploadHandler.php vendored
View File

@ -1,41 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\VideoList\Handler;
use Laminas\Diactoros\Response\JsonResponse;
use Laminas\Http\Response;
use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandHandler;
use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandBuilder;
use MyTube\API\External\VideoList\ResponseFormatter\UploadResponseFormatter;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use MyTube\Infrastructure\Response\SuccessResponse;
class UploadHandler implements RequestHandlerInterface
{
public function __construct(
private readonly UploadCommandHandler $uploadCommandHandler,
private readonly UploadCommandBuilder $uploadCommandBuilder,
private readonly UploadResponseFormatter $responseFormatter,
) {
}
public function handle(ServerRequestInterface $request): ResponseInterface
{
$uploadedFiles = $request->getUploadedFiles();
if (count($uploadedFiles) < 1) {
return new JsonResponse('Upload at least one File', Response::STATUS_CODE_400);
}
$uploadCommand = $this->uploadCommandBuilder->build(
$request->getUploadedFiles()
);
$result = $this->uploadCommandHandler->execute($uploadCommand);
return new SuccessResponse($this->responseFormatter->format($result));
}
}

29
src/ApiDomain/External/VideoList/src/ResponseFormatter/ReadListResponseFormatter.php vendored
View File

@ -4,41 +4,22 @@ declare(strict_types=1);
namespace MyTube\API\External\VideoList\ResponseFormatter;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\Video;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryResult;
class ReadListResponseFormatter
{
public function format(ReadListQueryResult $queryResult): array
public function format(array $videos): array
{
$paginator = $queryResult->getPaginator();
$videos = $paginator->getIterator();
$items = [];
$result = [];
/** @var Video $video */
foreach ($videos as $video) {
$tags = [];
/** @var Tag $tag */
foreach ($video->getTags() as $tag) {
$tags[] = [
'id' => $tag->getId(),
'description' => $tag->getDescription()
];
}
$items[] = [
$result[] = [
'title' => $video->getTitle(),
'id' => $video->getId(),
'tags' => $tags
'id' => $video->getId()->toString(),
];
}
return [
'total' => $paginator->count(),
'items' => $items,
];
return $result;
}
}

46
src/ApiDomain/External/VideoList/src/ResponseFormatter/UploadResponseFormatter.php vendored
View File

@ -1,46 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\API\External\VideoList\ResponseFormatter;
use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandResult;
use MyTube\Handling\VideoList\Model\UploadedFileResult;
class UploadResponseFormatter
{
public function format(UploadCommandResult $uploadCommandResult): array
{
$uploadedFileResults = $uploadCommandResult->getUploadedFileResults();
$details = [];
$successCount = 0;
$failCount = 0;
/** @var UploadedFileResult $uploadedFileResult */
foreach ($uploadedFileResults as $uploadedFileResult) {
$detail = [
'file' => $uploadedFileResult->getUploadedFile()->getClientFilename(),
'success' => $uploadedFileResult->getSuccess(),
];
if ($uploadedFileResult->getSuccess()) {
$detail['id'] = $uploadedFileResult->getVideo()->getId()->toString();
$successCount++;
} else {
$detail['error'] = $uploadedFileResult->getException()->getMessage();
$failCount++;
}
$details[] = $detail;
}
return [
'total' => count($uploadedFileResults),
'failed' => $failCount,
'succeeded' => $successCount,
'details' => $details
];
}
}

119
src/DataDomain/Business/src/Entity/Tag.php
View File

@ -1,119 +0,0 @@
<?php
namespace MyTube\Data\Business\Entity;
use DateTime;
use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;
use MyTube\Infrastructure\UuidGenerator\UuidGenerator;
use Ramsey\Uuid\UuidInterface;
/**
* @ORM\Entity(repositoryClass="MyTube\Data\Business\Repository\TagRepository")
* @ORM\Table(name="tag")
*/
class Tag {
/**
* @ORM\Id
* @ORM\Column(name="id", type="uuid_binary_ordered_time")
*/
private UuidInterface $id;
/** @ORM\Column(name="description", type="string") */
private string $description;
/**
* @ORM\ManyToMany(targetEntity="Video", mappedBy="tags")
* @ORM\JoinTable(name="video_tag")
*/
private Collection $videos;
/** @ORM\OneToMany(targetEntity="TagAlias", mappedBy="tag") */
private Collection $aliases;
/** @ORM\Column(name="created_at", type="datetime") */
private DateTime $createdAt;
/** @ORM\Column(name="updated_at", type="datetime") */
private DateTime $updatedAt;
public function __construct() {
$this->id = UuidGenerator::generate();
$this->aliases = new ArrayCollection();
$this->videos = new ArrayCollection();
$now = new DateTime();
$this->setCreatedAt($now);
$this->setUpdatedAt($now);
}
public function getId(): UuidInterface {
return $this->id;
}
public function getDescription(): string {
return $this->description;
}
public function setDescription(string $description): void {
$this->description = $description;
}
public function getVideos(): Collection
{
return $this->videos;
}
public function setVideos(Collection $videos): void
{
$this->videos = $videos;
}
public function addVideo(Video $video): void
{
if (!$this->videos->contains($video)) {
$this->videos->add($video);
}
}
public function removeVideo(Video $video): void
{
if ($this->videos->contains($video)) {
$this->videos->removeElement($video);
}
}
public function getAliases(): Collection
{
return $this->aliases;
}
public function setAliases(Collection $aliases): void
{
$this->aliases = $aliases;
}
public function addAlias(TagAlias $alias): void
{
if (!$this->aliases->contains($alias)) {
$this->aliases->add($alias);
}
}
public function removeAlias(TagAlias $alias): void
{
if ($this->aliases->contains($alias)) {
$this->aliases->removeElement($alias);
}
}
public function getCreatedAt(): DateTime {
return $this->createdAt;
}
public function setCreatedAt(DateTime $createdAt): void {
$this->createdAt = $createdAt;
}
public function getUpdatedAt(): DateTime {
return $this->updatedAt;
}
public function setUpdatedAt(DateTime $updatedAt): void {
$this->updatedAt = $updatedAt;
}
}

90
src/DataDomain/Business/src/Entity/TagAlias.php
View File

@ -1,90 +0,0 @@
<?php
namespace MyTube\Data\Business\Entity;
use DateTime;
use Doctrine\ORM\Mapping as ORM;
use MyTube\Infrastructure\UuidGenerator\UuidGenerator;
use Ramsey\Uuid\UuidInterface;
/**
* @ORM\Entity(repositoryClass="MyTube\Data\Business\Repository\TagAliasRepository")
* @ORM\Table(name="tag_alias")
*/
class TagAlias {
/**
* @ORM\Id
* @ORM\Column(name="id", type="uuid_binary_ordered_time")
*/
private UuidInterface $id;
/** @ORM\Column(name="tag_id", type="uuid_binary_ordered_time") */
private UuidInterface $tagId;
/**
* @ORM\ManyToOne(targetEntity="Tag", inversedBy="aliases")
* @ORM\JoinColumn(name="tag_id", referencedColumnName="id")
*/
private Tag $tag;
/** @ORM\Column(name="description", type="string") */
private string $description;
/** @ORM\Column(name="created_at", type="datetime") */
private DateTime $createdAt;
/** @ORM\Column(name="updated_at", type="datetime") */
private DateTime $updatedAt;
public function __construct() {
$this->id = UuidGenerator::generate();
$now = new DateTime();
$this->setCreatedAt($now);
$this->setUpdatedAt($now);
}
public function getId(): UuidInterface {
return $this->id;
}
public function getTagId(): UuidInterface
{
return $this->tagId;
}
public function setTagId(UuidInterface $tagId): void
{
$this->tagId = $tagId;
}
public function getTag(): Tag
{
return $this->tag;
}
public function setTag(Tag $tag): void
{
$this->tag = $tag;
}
public function getDescription(): string {
return $this->description;
}
public function setDescription(string $description): void {
$this->description = $description;
}
public function getCreatedAt(): DateTime {
return $this->createdAt;
}
public function setCreatedAt(DateTime $createdAt): void {
$this->createdAt = $createdAt;
}
public function getUpdatedAt(): DateTime {
return $this->updatedAt;
}
public function setUpdatedAt(DateTime $updatedAt): void {
$this->updatedAt = $updatedAt;
}
}

35
src/DataDomain/Business/src/Entity/Video.php
View File

@ -3,8 +3,6 @@
namespace MyTube\Data\Business\Entity;
use DateTime;
use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;
use MyTube\Infrastructure\UuidGenerator\UuidGenerator;
use Ramsey\Uuid\UuidInterface;
@ -26,12 +24,6 @@ class Video {
/** @ORM\Column(name="directory_path", type="string") */
private ?string $directoryPath;
/**
* @ORM\ManyToMany(targetEntity="Tag", inversedBy="videos")
* @ORM\JoinTable(name="video_tag")
*/
private Collection $tags;
/** @ORM\Column(name="created_at", type="datetime") */
private DateTime $createdAt;
@ -42,8 +34,6 @@ class Video {
public function __construct() {
$this->id = UuidGenerator::generate();
$this->tags = new ArrayCollection();
$now = new DateTime();
$this->setCreatedAt($now);
$this->setUpdatedAt($now);
@ -57,6 +47,7 @@ class Video {
public function getTitle(): string {
return $this->title;
}
public function setTitle(string $title): void {
$this->title = $title;
}
@ -64,34 +55,15 @@ class Video {
public function getDirectoryPath(): ?string {
return $this->directoryPath;
}
public function setDirectoryPath(?string $directoryPath): void {
$this->directoryPath = $directoryPath;
}
public function getTags(): Collection
{
return $this->tags;
}
public function setTags(Collection $tags): void
{
$this->tags = $tags;
}
public function addTag(Tag $tag): void
{
if (!$this->tags->contains($tag)) {
$this->tags->add($tag);
}
}
public function removeTag(Tag $tag): void
{
if ($this->tags->contains($tag)) {
$this->tags->removeElement($tag);
}
}
public function getCreatedAt(): DateTime {
return $this->createdAt;
}
public function setCreatedAt(DateTime $createdAt): void {
$this->createdAt = $createdAt;
}
@ -99,6 +71,7 @@ class Video {
public function getUpdatedAt(): DateTime {
return $this->updatedAt;
}
public function setUpdatedAt(DateTime $updatedAt): void {
$this->updatedAt = $updatedAt;
}

8
src/DataDomain/Business/src/Repository/TagAliasRepository.php
View File

@ -1,8 +0,0 @@
<?php
namespace MyTube\Data\Business\Repository;
use Doctrine\ORM\EntityRepository;
class TagAliasRepository extends EntityRepository {
}

24
src/DataDomain/Business/src/Repository/TagRepository.php
View File

@ -1,24 +0,0 @@
<?php
namespace MyTube\Data\Business\Repository;
use Doctrine\ORM\EntityRepository;
class TagRepository extends EntityRepository {
public function findByFilter(
?string $query,
): array
{
$queryBuilder = $this->createQueryBuilder('t');
if ($query !== null) {
$query = '%'.$query.'%';
$queryBuilder
->where('t.description like :query')
->setParameter('query', $query);
}
return $queryBuilder->getQuery()->execute();
}
}

39
src/DataDomain/Business/src/Repository/VideoRepository.php
View File

@ -5,37 +5,24 @@ namespace MyTube\Data\Business\Repository;
use Doctrine\ORM\Tools\Pagination\Paginator;
use MyTube\Data\Business\Entity\Registration;
use Doctrine\ORM\EntityRepository;
use MyTube\Data\Business\Entity\Tag;
use Ramsey\Uuid\Doctrine\UuidBinaryOrderedTimeType;
class VideoRepository extends EntityRepository {
public function findByFilter(
?string $query,
int $page,
int $perPage,
?Tag $tag = null,
string $identifier
): Paginator
{
$queryBuilder = $this->createQueryBuilder('v');
$queryBuilder = $this->createQueryBuilder('r');
$queryBuilder->where(
$queryBuilder->expr()->orX(
$queryBuilder->expr()->eq('r.username', ':identifier'),
$queryBuilder->expr()->eq('r.mail', ':identifier')
)
)
->setParameter('identifier', $identifier);
$query = $queryBuilder->getQuery();
if ($query !== null) {
$query = '%'.$query.'%';
$queryBuilder
->where('v.title like :query')
->setParameter('query', $query);
}
if ($tag !== null) {
$queryBuilder
->join('v.tags', 't')
->andWhere('t.id = :tagId')
->setParameter('tagId', $tag->getId(), UuidBinaryOrderedTimeType::NAME);
}
$queryBuilder->setFirstResult($perPage * ($page - 1));
$queryBuilder->setMaxResults($perPage);
return new Paginator($queryBuilder->getQuery());
/** @var ?Registration $registration */
$registration = $query->execute()[0] ?? null;
return $registration;
}
}

44
src/HandlingDomain/Tag/config/service_manager.php
View File

@ -1,44 +0,0 @@
<?php
use MyTube\Handling\Tag\Builder\TagAliasBuilder;
use MyTube\Handling\Tag\Builder\TagBuilder;
use MyTube\Handling\Tag\Handler\Command\AddAlias\AddAliasCommandBuilder;
use MyTube\Handling\Tag\Handler\Command\AddAlias\AddAliasCommandHandler;
use MyTube\Handling\Tag\Handler\Command\Create\CreateCommandBuilder;
use MyTube\Handling\Tag\Handler\Command\Create\CreateCommandHandler;
use MyTube\Handling\Tag\Handler\Query\ReadDetails\ReadDetailsQueryBuilder;
use MyTube\Handling\Tag\Handler\Query\ReadDetails\ReadDetailsQueryHandler;
use MyTube\Handling\Tag\Handler\Query\ReadVideoList\ReadVideoListQueryBuilder;
use MyTube\Handling\Tag\Handler\Query\ReadVideoList\ReadVideoListQueryHandler;
use MyTube\Handling\Tag\Rule\TagAliasExistsRule;
use MyTube\Handling\Tag\Rule\TagExistsRule;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
use Reinfi\DependencyInjection\Factory\InjectionFactory;
return [
'factories' => [
/// Rule
TagExistsRule::class => InjectionFactory::class,
TagAliasExistsRule::class => InjectionFactory::class,
/// Builder
TagBuilder::class => AutoWiringFactory::class,
TagAliasBuilder::class => AutoWiringFactory::class,
/// CQRS
// Add Alias
AddAliasCommandBuilder::class => AutoWiringFactory::class,
AddAliasCommandHandler::class => InjectionFactory::class,
// Create
CreateCommandBuilder::class => AutoWiringFactory::class,
CreateCommandHandler::class => AutoWiringFactory::class,
// Read Details
ReadDetailsQueryBuilder::class => AutoWiringFactory::class,
ReadDetailsQueryHandler::class => InjectionFactory::class,
// Read Video List
ReadVideoListQueryBuilder::class => AutoWiringFactory::class,
ReadVideoListQueryHandler::class => InjectionFactory::class,
],
];

21
src/HandlingDomain/Tag/src/Builder/TagAliasBuilder.php
View File

@ -1,21 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Builder;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\TagAlias;
class TagAliasBuilder
{
public function build(
Tag $tag,
string $description,
): TagAlias
{
$tagAlias = new TagAlias();
$tagAlias->setTag($tag);
$tagAlias->setDescription($description);
return $tagAlias;
}
}

18
src/HandlingDomain/Tag/src/Builder/TagBuilder.php
View File

@ -1,18 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Builder;
use MyTube\Data\Business\Entity\Tag;
class TagBuilder
{
public function build(
string $description,
): Tag
{
$tag = new Tag();
$tag->setDescription($description);
return $tag;
}
}

15
src/HandlingDomain/Tag/src/ConfigProvider.php
View File

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

25
src/HandlingDomain/Tag/src/Exception/TagAliasAlreadyExistsException.php
View File

@ -1,25 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Exception;
use MyTube\Infrastructure\Exception\ErrorCode;
use MyTube\Infrastructure\Exception\ErrorDomain;
use MyTube\Infrastructure\Exception\Exception\MyTubeException;
use Ramsey\Uuid\UuidInterface;
class TagAliasAlreadyExistsException extends MyTubeException {
private const MESSAGE = "The TagAlias '%s' already exists!";
public function __construct(string $description)
{
parent::__construct(
sprintf(
self::MESSAGE,
$description
),
ErrorDomain::TagAlias,
ErrorCode::AlreadyExists
);
}
}

25
src/HandlingDomain/Tag/src/Exception/TagAlreadyExistsException.php
View File

@ -1,25 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Exception;
use MyTube\Infrastructure\Exception\ErrorCode;
use MyTube\Infrastructure\Exception\ErrorDomain;
use MyTube\Infrastructure\Exception\Exception\MyTubeException;
use Ramsey\Uuid\UuidInterface;
class TagAlreadyExistsException extends MyTubeException {
private const MESSAGE = "The Tag '%s' already exists!";
public function __construct(string $description)
{
parent::__construct(
sprintf(
self::MESSAGE,
$description
),
ErrorDomain::Tag,
ErrorCode::AlreadyExists
);
}
}

25
src/HandlingDomain/Tag/src/Exception/TagNotFoundByIdException.php
View File

@ -1,25 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Exception;
use MyTube\Infrastructure\Exception\ErrorCode;
use MyTube\Infrastructure\Exception\ErrorDomain;
use MyTube\Infrastructure\Exception\Exception\MyTubeException;
use Ramsey\Uuid\UuidInterface;
class TagNotFoundByIdException extends MyTubeException {
private const MESSAGE = 'The Tag with the Id %s was not found!';
public function __construct(UuidInterface $id)
{
parent::__construct(
sprintf(
self::MESSAGE,
$id->toString()
),
ErrorDomain::Tag,
ErrorCode::NotFound
);
}
}

26
src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommand.php
View File

@ -1,26 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\AddAlias;
use Ramsey\Uuid\UuidInterface;
class AddAliasCommand
{
public function __construct(
private readonly UuidInterface $tagId,
private readonly string $description,
) {
}
public function getTagId(): UuidInterface
{
return $this->tagId;
}
public function getDescription(): string
{
return $this->description;
}
}

20
src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandBuilder.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\AddAlias;
use Ramsey\Uuid\UuidInterface;
class AddAliasCommandBuilder
{
public function build(
UuidInterface $tagId,
string $description,
): AddAliasCommand {
return new AddAliasCommand(
$tagId,
$description
);
}
}

63
src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandHandler.php
View File

@ -1,63 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\AddAlias;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Data\Business\Repository\TagRepository;
use MyTube\Handling\Tag\Builder\TagAliasBuilder;
use MyTube\Handling\Tag\Exception\TagAliasAlreadyExistsException;
use MyTube\Handling\Tag\Exception\TagNotFoundByIdException;
use MyTube\Handling\Tag\Rule\TagAliasExistsRule;
use Reinfi\DependencyInjection\Annotation\Inject;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class AddAliasCommandHandler
{
/**
* @Inject("MyTube\Handling\Tag\Rule\TagAliasExistsRule")
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
* @Inject("MyTube\Handling\Tag\Builder\TagAliasBuilder")
* @Inject("MyTube\Data\Business\Manager\MyTubeEntityManager")
*/
public function __construct(
private readonly TagAliasExistsRule $existsRule,
private readonly TagRepository $tagRepository,
private readonly TagAliasBuilder $aliasBuilder,
private readonly MyTubeEntityManager $entityManager,
) {
}
/**
* @throws TagAliasAlreadyExistsException
* @throws TagNotFoundByIdException
*/
public function execute(AddAliasCommand $addAliasCommand): AddAliasCommandResult
{
$tagId = $addAliasCommand->getTagId();
$description = $addAliasCommand->getDescription();
if ($this->existsRule->appliesTo($description)) {
throw new TagAliasAlreadyExistsException($description);
}
$tag = $this->tagRepository->findOneBy(['id' => $tagId]);
if ($tag === null) {
throw new TagNotFoundByIdException($tagId);
}
$tagAlias = $this->aliasBuilder->build(
$tag,
$description
);
$this->entityManager->persist($tagAlias);
$this->entityManager->flush();
return new AddAliasCommandResult($tagAlias);
}
}

20
src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandResult.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\AddAlias;
use MyTube\Data\Business\Entity\TagAlias;
class AddAliasCommandResult
{
public function __construct(
private readonly TagAlias $alias,
) {
}
public function getAlias(): TagAlias
{
return $this->alias;
}
}

18
src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommand.php
View File

@ -1,18 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\Create;
class CreateCommand
{
public function __construct(
private readonly string $description
) {
}
public function getDescription(): string
{
return $this->description;
}
}

16
src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandBuilder.php
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\Create;
class CreateCommandBuilder
{
public function build(
string $description
): CreateCommand {
return new CreateCommand(
$description
);
}
}

39
src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandHandler.php
View File

@ -1,39 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\Create;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Handling\Tag\Builder\TagBuilder;
use MyTube\Handling\Tag\Exception\TagAlreadyExistsException;
use MyTube\Handling\Tag\Rule\TagExistsRule;
class CreateCommandHandler
{
public function __construct(
private readonly TagExistsRule $existsRule,
private readonly TagBuilder $tagBuilder,
private readonly MyTubeEntityManager $entityManager
) {
}
/**
* @throws TagAlreadyExistsException
*/
public function execute(CreateCommand $createCommand): CreateCommandResult
{
$description = $createCommand->getDescription();
if ($this->existsRule->appliesTo($description)) {
throw new TagAlreadyExistsException($description);
}
$tag = $this->tagBuilder->build($description);
$this->entityManager->persist($tag);
$this->entityManager->flush();
return new CreateCommandResult($tag);
}
}

20
src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandResult.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Command\Create;
use MyTube\Data\Business\Entity\Tag;
class CreateCommandResult
{
public function __construct(
private readonly Tag $tag,
) {
}
public function getTag(): Tag
{
return $this->tag;
}
}

20
src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQuery.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadDetails;
use Ramsey\Uuid\UuidInterface;
class ReadDetailsQuery
{
public function __construct(
private readonly UuidInterface $tagId,
) {
}
public function getTagId(): UuidInterface
{
return $this->tagId;
}
}

18
src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryBuilder.php
View File

@ -1,18 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadDetails;
use Ramsey\Uuid\UuidInterface;
class ReadDetailsQueryBuilder
{
public function build(
UuidInterface $tagId,
): ReadDetailsQuery {
return new ReadDetailsQuery(
$tagId
);
}
}

39
src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryHandler.php
View File

@ -1,39 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadDetails;
use MyTube\Data\Business\Repository\TagRepository;
use MyTube\Handling\Tag\Exception\TagNotFoundByIdException;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class ReadDetailsQueryHandler
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
*/
public function __construct(
private readonly TagRepository $tagRepository,
) {
}
/**
* @throws TagNotFoundByIdException
*/
public function execute(ReadDetailsQuery $readDetailsQuery): ReadDetailsQueryResult
{
$tagId = $readDetailsQuery->getTagId();
$tag = $this->tagRepository->findOneBy(['id' => $tagId]);
if ($tag === null) {
throw new TagNotFoundByIdException($tagId);
}
return new ReadDetailsQueryResult($tag);
}
}

20
src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryResult.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadDetails;
use MyTube\Data\Business\Entity\Tag;
class ReadDetailsQueryResult
{
public function __construct(
private readonly Tag $tag,
) {
}
public function getTag(): Tag
{
return $this->tag;
}
}

38
src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQuery.php
View File

@ -1,38 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadVideoList;
use Ramsey\Uuid\UuidInterface;
class ReadVideoListQuery
{
public function __construct(
private readonly UuidInterface $tagId,
private readonly ?string $query,
private readonly int $page,
private readonly int $perPage,
) {
}
public function getTagId(): UuidInterface
{
return $this->tagId;
}
public function getQuery(): ?string
{
return $this->query;
}
public function getPage(): int
{
return $this->page;
}
public function getPerPage(): int
{
return $this->perPage;
}
}

24
src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryBuilder.php
View File

@ -1,24 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadVideoList;
use Ramsey\Uuid\UuidInterface;
class ReadVideoListQueryBuilder
{
public function build(
UuidInterface $tagId,
?string $query,
int $page,
int $perPage,
): ReadVideoListQuery {
return new ReadVideoListQuery(
$tagId,
$query,
$page,
$perPage,
);
}
}

51
src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryHandler.php
View File

@ -1,51 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadVideoList;
use MyTube\Data\Business\Repository\TagRepository;
use MyTube\Data\Business\Repository\VideoRepository;
use MyTube\Handling\Tag\Exception\TagNotFoundByIdException;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class ReadVideoListQueryHandler
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Video"
* )
*/
public function __construct(
private readonly TagRepository $tagRepository,
private readonly VideoRepository $videoRepository,
) {
}
/**
* @throws TagNotFoundByIdException
*/
public function execute(ReadVideoListQuery $readVideoListQuery): ReadVideoListQueryResult
{
$tagId = $readVideoListQuery->getTagId();
$tag = $this->tagRepository->findOneBy(['id' => $tagId]);
if ($tag === null) {
throw new TagNotFoundByIdException($tagId);
}
return new ReadVideoListQueryResult(
$this->videoRepository->findByFilter(
query: $readVideoListQuery->getQuery(),
page: $readVideoListQuery->getPage(),
perPage: $readVideoListQuery->getPerPage(),
tag: $tag
)
);
}
}

20
src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryResult.php
View File

@ -1,20 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Tag\Handler\Query\ReadVideoList;
use Doctrine\ORM\Tools\Pagination\Paginator;
class ReadVideoListQueryResult
{
public function __construct(
private readonly Paginator $paginator
) {
}
public function getPaginator(): Paginator
{
return $this->paginator;
}
}

27
src/HandlingDomain/Tag/src/Rule/TagAliasExistsRule.php
View File

@ -1,27 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Rule;
use MyTube\Data\Business\Repository\TagAliasRepository;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class TagAliasExistsRule
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\TagAlias"
* )
*/
public function __construct(
private readonly TagAliasRepository $tagAliasRepository,
) {
}
public function appliesTo(
string $description,
): bool
{
return $this->tagAliasRepository->findOneBy(['description' => $description]) !== null;
}
}

28
src/HandlingDomain/Tag/src/Rule/TagExistsRule.php
View File

@ -1,28 +0,0 @@
<?php
namespace MyTube\Handling\Tag\Rule;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Repository\TagRepository;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class TagExistsRule
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
*/
public function __construct(
private readonly TagRepository $tagRepository,
) {
}
public function appliesTo(
string $description,
): bool
{
return $this->tagRepository->findOneBy(['description' => $description]) !== null;
}
}

17
src/HandlingDomain/TagList/config/service_manager.php
View File

@ -1,17 +0,0 @@
<?php
declare(strict_types=1);
use MyTube\Handling\TagList\Handler\Query\ReadList\ReadListQueryHandler;
use MyTube\Handling\TagList\Handler\Query\ReadList\ReadListQueryBuilder;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
use Reinfi\DependencyInjection\Factory\InjectionFactory;
return [
'factories' => [
/// CQRS
// ReadList
ReadListQueryBuilder::class => AutoWiringFactory::class,
ReadListQueryHandler::class => InjectionFactory::class,
],
];

15
src/HandlingDomain/TagList/src/ConfigProvider.php
View File

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

18
src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQuery.php
View File

@ -1,18 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\TagList\Handler\Query\ReadList;
class ReadListQuery
{
public function __construct(
private readonly ?string $query,
) {
}
public function getQuery(): ?string
{
return $this->query;
}
}

16
src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryBuilder.php
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\TagList\Handler\Query\ReadList;
class ReadListQueryBuilder
{
public function build(
?string $query,
): ReadListQuery {
return new ReadListQuery(
$query,
);
}
}

31
src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryHandler.php
View File

@ -1,31 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\TagList\Handler\Query\ReadList;
use MyTube\Data\Business\Repository\TagRepository;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class ReadListQueryHandler
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
*/
public function __construct(
private readonly TagRepository $tagRepository
) {
}
public function execute(ReadListQuery $readListQuery): ReadListQueryResult
{
return new ReadListQueryResult(
$this->tagRepository->findByFilter(
$readListQuery->getQuery(),
)
);
}
}

18
src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryResult.php
View File

@ -1,18 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\TagList\Handler\Query\ReadList;
class ReadListQueryResult
{
public function __construct(
private readonly array $items
) {
}
public function getItems(): array
{
return $this->items;
}
}

23
src/HandlingDomain/Video/config/service_manager.php
View File

@ -10,14 +10,6 @@ use MyTube\Handling\Video\Handler\Query\Stream\StreamQueryBuilder;
use MyTube\Handling\Video\Handler\Query\Stream\StreamQueryHandler;
use MyTube\Handling\Video\Handler\Query\Thumbnail\ThumbnailQueryBuilder;
use MyTube\Handling\Video\Handler\Query\Thumbnail\ThumbnailQueryHandler;
use MyTube\Handling\Video\Analyzer\VideoTitleAnalyzer;
use MyTube\Handling\Video\Pipeline\Upload\Step\AnalyzeTitleStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\BuildVideoStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\CheckVideoStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\SaveEntityStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\UploadFileStep;
use MyTube\Handling\Video\Pipeline\Upload\UploadPipeline;
use MyTube\Handling\Video\Rule\VideoExistsRule;
use MyTube\Handling\Video\Uploader\VideoUploader;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
use Reinfi\DependencyInjection\Factory\InjectionFactory;
@ -25,9 +17,6 @@ use Reinfi\DependencyInjection\Factory\InjectionFactory;
return [
'factories' => [
/// Analyzer
VideoTitleAnalyzer::class => InjectionFactory::class,
/// Uploader
VideoUploader::class => AutoWiringFactory::class,
@ -35,9 +24,6 @@ return [
VideoBuilder::class => AutoWiringFactory::class,
VideoImageBuilder::class => AutoWiringFactory::class,
/// Rule
VideoExistsRule::class => InjectionFactory::class,
/// CQRS
// Stream Query
StreamQueryHandler::class => InjectionFactory::class,
@ -51,14 +37,5 @@ return [
// Read Details
ReadDetailsQueryHandler::class => InjectionFactory::class,
ReadDetailsQueryBuilder::class => AutoWiringFactory::class,
/// Pipeline
// Upload
UploadPipeline::class => AutoWiringFactory::class,
CheckVideoStep::class => AutoWiringFactory::class,
BuildVideoStep::class => AutoWiringFactory::class,
AnalyzeTitleStep::class => AutoWiringFactory::class,
UploadFileStep::class => AutoWiringFactory::class,
SaveEntityStep::class => AutoWiringFactory::class,
],
];

66
src/HandlingDomain/Video/src/Analyzer/VideoTitleAnalyzer.php
View File

@ -1,66 +0,0 @@
<?php
namespace MyTube\Handling\Video\Analyzer;
use Exception;
use MyTube\Data\Business\Entity\Tag;
use MyTube\Data\Business\Entity\TagAlias;
use MyTube\Data\Business\Entity\Video;
use MyTube\Data\Business\Repository\TagRepository;
use Psr\Http\Message\UploadedFileInterface;
use Ramsey\Uuid\UuidInterface;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class VideoTitleAnalyzer
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Tag"
* )
*/
public function __construct(
private readonly TagRepository $tagRepository,
) {
}
public function analyze(
Video $video
): array {
$title = $this->normalizeString($video->getTitle());
$tags = $this->tagRepository->findAll();
$matches = [];
/** @var Tag $tag */
foreach ($tags as $tag) {
if (str_contains($title, $this->normalizeString($tag->getDescription()))) {
$matches[] = $tag;
continue;
}
/** @var TagAlias $alias */
foreach ($tag->getAliases() as $alias) {
if (str_contains($title, $this->normalizeString($alias->getDescription()))) {
$matches[] = $tag;
break;
}
}
}
/** @var Tag $match */
foreach ($matches as $match) {
$video->addTag($match);
}
return $matches;
}
private function normalizeString(string $string): string {
return preg_replace(
'/[^a-zA-Z0-9]+/',
'',
strtolower($string)
);
}
}

28
src/HandlingDomain/Video/src/Builder/VideoImageBuilder.php
View File

@ -2,27 +2,24 @@
namespace MyTube\Handling\Video\Builder;
use Ramsey\Uuid\UuidInterface;
use MyTube\Data\Business\Entity\Video;
class VideoImageBuilder
{
private const FILE_NAME = 'thumbnail.png';
public function build(
UuidInterface $directoryId,
Video $video,
string $timestamp = '00:00:10'
): string|null
{
$directoryPath = sprintf(
'%s/%s/%s',
APP_ROOT,
'var/filestore',
$directoryId->toString()
);
$videoId = $video->getId()->toString();
$targetPath = sprintf(
'%s/%s',
$directoryPath,
'%s/%s/%s/%s',
APP_ROOT,
'var/filestore',
$videoId,
self::FILE_NAME
);
@ -30,14 +27,11 @@ class VideoImageBuilder
return null;
}
$command = sprintf(
"cd %s && ffmpeg -i video.mp4 -ss %s -vframes 1 %s",
$directoryPath,
$timestamp,
self::FILE_NAME
);
$command = "cd /var/www/html/var/filestore/" . $videoId . "/" .
" && " .
"ffmpeg -i video.mp4 -ss " . $timestamp . " -vframes 1 " . self::FILE_NAME;
shell_exec($command);
$output = shell_exec($command);
return $targetPath;
}

25
src/HandlingDomain/Video/src/Exception/VideoAlreadyExistsException.php
View File

@ -1,25 +0,0 @@
<?php
namespace MyTube\Handling\Video\Exception;
use MyTube\Infrastructure\Exception\ErrorCode;
use MyTube\Infrastructure\Exception\ErrorDomain;
use MyTube\Infrastructure\Exception\Exception\MyTubeException;
use Psr\Http\Message\UploadedFileInterface;
class VideoAlreadyExistsException extends MyTubeException {
private const MESSAGE = 'A Video with the Title %s does already exist!';
public function __construct(UploadedFileInterface $uploadedFile)
{
parent::__construct(
sprintf(
self::MESSAGE,
$uploadedFile->getClientFilename()
),
ErrorDomain::Video,
ErrorCode::AlreadyExists
);
}
}

2
src/HandlingDomain/Video/src/Exception/VideoNotFoundByIdException.php
View File

@ -9,7 +9,7 @@ use Ramsey\Uuid\UuidInterface;
class VideoNotFoundByIdException extends MyTubeException {
private const MESSAGE = 'The Video with the Id %s was not found!';
private const MESSAGE = 'The user with the Id %s was not found!';
public function __construct(UuidInterface $id)
{

28
src/HandlingDomain/Video/src/Handler/Command/Upload/UploadCommandHandler.php
View File

@ -8,26 +8,38 @@ use MyTube\Data\Business\Entity\Video;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Handling\Video\Builder\VideoBuilder;
use MyTube\Handling\Video\Builder\VideoImageBuilder;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use MyTube\Handling\Video\Pipeline\Upload\UploadPipeline;
use MyTube\Handling\Video\Uploader\VideoTitleAnalyzer;
use MyTube\Handling\Video\Uploader\VideoUploader;
use Psr\Http\Message\UploadedFileInterface;
use Exception;
class UploadCommandHandler
{
public function __construct(
private readonly UploadPipeline $pipeline,
private readonly VideoBuilder $videoBuilder,
private readonly MyTubeEntityManager $entityManager,
private readonly VideoUploader $uploader,
) {
}
/**
* @throws Exception
*/
public function execute(UploadCommand $uploadCommand): Video
{
$payload = new UploadPayload();
$payload->setUploadedFile($uploadCommand->getUploadedFile());
$uploadedFile = $uploadCommand->getUploadedFile();
$this->pipeline->handle($payload);
$video = $this->videoBuilder->build(
$uploadedFile->getClientFilename()
);
return $payload->getVideo();
$this->uploader->upload(
$uploadedFile,
$video
);
$this->entityManager->persist($video);
$this->entityManager->flush();
return $video;
}
}

4
src/HandlingDomain/Video/src/Handler/Query/ReadDetails/ReadDetailsQueryHandler.php
View File

@ -18,11 +18,9 @@ class ReadDetailsQueryHandler
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Video"
* )
* @Inject("MyTube\Handling\Video\Builder\VideoImageBuilder")
*/
public function __construct(
private readonly VideoRepository $videoRepository,
private readonly VideoImageBuilder $videoImageBuilder,
) {
}
@ -40,8 +38,6 @@ class ReadDetailsQueryHandler
throw new VideoNotFoundByIdException($videoId);
}
$this->videoImageBuilder->build($video->getId());
return new ReadDetailsQueryResult($video);
}
}

33
src/HandlingDomain/Video/src/Pipeline/Upload/Step/AnalyzeTitleStep.php
View File

@ -1,33 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload\Step;
use MyTube\Handling\Video\Analyzer\VideoTitleAnalyzer;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface;
class AnalyzeTitleStep implements TaskInterface
{
public function __construct(
private readonly VideoTitleAnalyzer $analyzer,
) {
}
public function __invoke(
$payload,
PipelineInterface $pipeline
): void
{
/** @var UploadPayload $uploadPayload */
$uploadPayload = $payload;
$video = $uploadPayload->getVideo();
$this->analyzer->analyze($video);
$pipeline->next()($payload, $pipeline);
}
}

36
src/HandlingDomain/Video/src/Pipeline/Upload/Step/BuildVideoStep.php
View File

@ -1,36 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload\Step;
use MyTube\Handling\Video\Builder\VideoBuilder;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface;
class BuildVideoStep implements TaskInterface
{
public function __construct(
private readonly VideoBuilder $videoBuilder,
) {
}
public function __invoke(
$payload,
PipelineInterface $pipeline
): void
{
/** @var UploadPayload $uploadPayload */
$uploadPayload = $payload;
$uploadedFile = $uploadPayload->getUploadedFile();
$video = $this->videoBuilder->build(
$uploadedFile->getClientFilename()
);
$uploadPayload->setVideo($video);
$pipeline->next()($payload, $pipeline);
}
}

40
src/HandlingDomain/Video/src/Pipeline/Upload/Step/CheckVideoStep.php
View File

@ -1,40 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload\Step;
use MyTube\Handling\Video\Builder\VideoBuilder;
use MyTube\Handling\Video\Exception\VideoAlreadyExistsException;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use MyTube\Handling\Video\Rule\VideoExistsRule;
use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface;
class CheckVideoStep implements TaskInterface
{
public function __construct(
private readonly VideoExistsRule $existsRule,
) {
}
/**
* @throws VideoAlreadyExistsException
*/
public function __invoke(
$payload,
PipelineInterface $pipeline
): void
{
/** @var UploadPayload $uploadPayload */
$uploadPayload = $payload;
$uploadedFile = $uploadPayload->getUploadedFile();
if ($this->existsRule->appliesTo($uploadedFile)) {
throw new VideoAlreadyExistsException($uploadedFile);
}
$pipeline->next()($payload, $pipeline);
}
}

31
src/HandlingDomain/Video/src/Pipeline/Upload/Step/SaveEntityStep.php
View File

@ -1,31 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload\Step;
use MyTube\Data\Business\Manager\MyTubeEntityManager;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface;
class SaveEntityStep implements TaskInterface
{
public function __construct(
private readonly MyTubeEntityManager $entityManager,
) {
}
public function __invoke(
$payload,
PipelineInterface $pipeline
): void
{
/** @var UploadPayload $uploadPayload */
$uploadPayload = $payload;
$video = $uploadPayload->getVideo();
$this->entityManager->persist($video);
$this->entityManager->flush();
}
}

42
src/HandlingDomain/Video/src/Pipeline/Upload/Step/UploadFileStep.php
View File

@ -1,42 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload\Step;
use MyTube\Handling\Video\Builder\VideoImageBuilder;
use MyTube\Handling\Video\Pipeline\Upload\UploadPayload;
use MyTube\Handling\Video\Uploader\VideoUploader;
use teewurst\Pipeline\PipelineInterface;
use teewurst\Pipeline\TaskInterface;
class UploadFileStep implements TaskInterface
{
public function __construct(
private readonly VideoUploader $uploader,
private readonly VideoImageBuilder $imageBuilder,
) {
}
/**
* @throws \Exception
*/
public function __invoke(
$payload,
PipelineInterface $pipeline
): void
{
/** @var UploadPayload $uploadPayload */
$uploadPayload = $payload;
$video = $uploadPayload->getVideo();
$uploadedFile = $uploadPayload->getUploadedFile();
$directoryPath = $this->uploader->upload($uploadedFile, $video->getId());
$video->setDirectoryPath($directoryPath);
$this->imageBuilder->build($video->getId());
$pipeline->next()($payload, $pipeline);
}
}

32
src/HandlingDomain/Video/src/Pipeline/Upload/UploadPayload.php
View File

@ -1,32 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload;
use MyTube\Data\Business\Entity\Video;
use Psr\Http\Message\UploadedFileInterface;
class UploadPayload
{
private UploadedFileInterface $uploadedFile;
private Video $video;
public function getUploadedFile(): UploadedFileInterface
{
return $this->uploadedFile;
}
public function setUploadedFile(UploadedFileInterface $uploadedFile): void
{
$this->uploadedFile = $uploadedFile;
}
public function getVideo(): Video
{
return $this->video;
}
public function setVideo(Video $video): void
{
$this->video = $video;
}
}

42
src/HandlingDomain/Video/src/Pipeline/Upload/UploadPipeline.php
View File

@ -1,42 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\Video\Pipeline\Upload;
use MyTube\Handling\Video\Pipeline\Upload\Step\BuildVideoStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\AnalyzeTitleStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\CheckVideoStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\UploadFileStep;
use MyTube\Handling\Video\Pipeline\Upload\Step\SaveEntityStep;
use teewurst\Pipeline\Pipeline;
class UploadPipeline extends Pipeline
{
public function __construct(
private readonly CheckVideoStep $checkVideoStep,
private readonly BuildVideoStep $buildVideoStep,
private readonly AnalyzeTitleStep $analyzeTitleStep,
private readonly UploadFileStep $uploadFileStep,
private readonly SaveEntityStep $saveEntityStep,
) {
parent::__construct([
$this->checkVideoStep,
$this->buildVideoStep,
$this->analyzeTitleStep,
$this->uploadFileStep,
$this->saveEntityStep,
]);
}
public function reset(): void
{
$this->tasks = [
$this->checkVideoStep,
$this->buildVideoStep,
$this->analyzeTitleStep,
$this->uploadFileStep,
$this->saveEntityStep,
];
}
}

29
src/HandlingDomain/Video/src/Rule/VideoExistsRule.php
View File

@ -1,29 +0,0 @@
<?php
namespace MyTube\Handling\Video\Rule;
use MyTube\Data\Business\Entity\Video;
use MyTube\Data\Business\Repository\VideoRepository;
use Psr\Http\Message\UploadedFileInterface;
use Reinfi\DependencyInjection\Annotation\InjectDoctrineRepository;
class VideoExistsRule
{
/**
* @InjectDoctrineRepository(
* entityManager="MyTube\Data\Business\Manager\MyTubeEntityManager",
* entity="MyTube\Data\Business\Entity\Video"
* )
*/
public function __construct(
private readonly VideoRepository $tagRepository,
) {
}
public function appliesTo(
UploadedFileInterface $uploadedFile,
): bool
{
return $this->tagRepository->findOneBy(['title' => $uploadedFile->getClientFilename()]) !== null;
}
}

24
src/HandlingDomain/Video/src/Uploader/VideoUploader.php
View File

@ -4,31 +4,37 @@ namespace MyTube\Handling\Video\Uploader;
use Exception;
use MyTube\Data\Business\Entity\Video;
use MyTube\Handling\Video\Builder\VideoImageBuilder;
use Psr\Http\Message\UploadedFileInterface;
use Ramsey\Uuid\UuidInterface;
class VideoUploader
{
public function __construct(
private readonly VideoImageBuilder $imageBuilder,
) {
}
public function upload(
UploadedFileInterface $file,
UuidInterface $directoryId,
): string {
$directoryPath = sprintf(
Video $video,
): void {
$targetPath = sprintf(
'%s/%s/%s/',
APP_ROOT,
'var/filestore',
$directoryId->toString(),
$video->getId()->toString(),
);
if (file_exists($directoryPath)) {
if (file_exists($targetPath)) {
throw new Exception('File already exists');
}
mkdir($directoryPath, 0777, true);
mkdir($targetPath, 0777, true);
$video->setDirectoryPath($targetPath);
$targetPath = $directoryPath . 'video.' . substr(strrchr($file->getClientFilename(),'.'),1);
$targetPath = $targetPath . 'video.' . substr(strrchr($file->getClientFilename(),'.'),1);
$file->moveTo($targetPath);
return $directoryPath;
$this->imageBuilder->build($video);
}
}

12
src/HandlingDomain/VideoList/config/service_manager.php
View File

@ -1,7 +1,10 @@
<?php
use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandBuilder;
use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandHandler;
use MyTube\Handling\Video\Builder\VideoBuilder;
use MyTube\Handling\Video\Handler\Command\Upload\UploadCommandBuilder;
use MyTube\Handling\Video\Handler\Command\Upload\UploadCommandHandler;
use MyTube\Handling\Video\Handler\Query\Stream\StreamQueryBuilder;
use MyTube\Handling\Video\Handler\Query\Stream\StreamQueryHandler;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryBuilder;
use MyTube\Handling\VideoList\Handler\Query\ReadList\ReadListQueryHandler;
use Reinfi\DependencyInjection\Factory\AutoWiringFactory;
@ -12,10 +15,7 @@ return [
'factories' => [
/// CQRS
// Read List
ReadListQueryBuilder::class => AutoWiringFactory::class,
ReadListQueryHandler::class => InjectionFactory::class,
// Upload
UploadCommandBuilder::class => AutoWiringFactory::class,
UploadCommandHandler::class => AutoWiringFactory::class,
ReadListQueryBuilder::class => AutoWiringFactory::class,
],
];

18
src/HandlingDomain/VideoList/src/Handler/Command/Upload/UploadCommand.php
View File

@ -1,18 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\VideoList\Handler\Command\Upload;
class UploadCommand
{
public function __construct(
private array $uploadedFiles
) {
}
public function getUploadedFiles(): array
{
return $this->uploadedFiles;
}
}

16
src/HandlingDomain/VideoList/src/Handler/Command/Upload/UploadCommandBuilder.php
View File

@ -1,16 +0,0 @@
<?php
declare(strict_types=1);
namespace MyTube\Handling\VideoList\Handler\Command\Upload;
class UploadCommandBuilder
{
public function build(
array $uploadedFiles
): UploadCommand {
return new UploadCommand(
$uploadedFiles
);
}
}

Some files were not shown because too many files have changed in this diff Show More