bin/createApi.php

@@ -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 = $projectSourceDirectory . 'ApiDomain/' . $apiType . '/' . $apiNamespace . '/src/Handler/' . $apiHandlerName . '.php';
-$apiHandlerFilePath = $apiDirectoryPath . '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
@@ -248,7 +138,7 @@ namespace {$cqrsNamespace};
 class {$cqrsName}
 {
     public function __construct(
-        #TODO
+        #TODO    
     ) {    
     }
 }
@@ -264,7 +154,7 @@ namespace {$cqrsNamespace};
 class {$cqrsResultName}
 {
     public function __construct(
-        #TODO
+        #TODO    
     ) {    
     }
 }

bin/createPipeline.php

@@ -16,8 +16,7 @@ $stepNames          = array_slice($argv, 3);
 # Pipeline
 $pipelineClassName = $pipelineName . 'Pipeline';
 $pipelineVariableName = lcfirst($pipelineClassName);
-$pipelineDirectoryPath = $projectSourceDirectory . 'HandlingDomain/' . $pipelineNamespace . '/';
+$pipelineFilePath = $projectSourceDirectory . 'HandlingDomain/' . $pipelineNamespace . '/src/Pipeline/' . $pipelineName . '/' . $pipelineClassName . '.php';
-$pipelineFilePath = $pipelineDirectoryPath . '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}
 {
-    #TODO
+    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($payloadFilePath, $payloadFileContent);
-    writeToFile($configProviderFilePath, $configProviderFileContent);
-
-}

composer.development.json

@@ -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",

config/config.php

@@ -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
 

config/pipeline.php

@@ -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);

data/migrations/myTube/Version20240223130626.php

@@ -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 (
+        // this up() migration is auto-generated, please modify it to your needs
-                    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;");
+        // this down() migration is auto-generated, please modify it to your needs
+
     }
 }

data/migrations/myTube/Version20240223130835.php

@@ -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;");
-    }
-}

data/migrations/myTube/Version20240223142111.php

@@ -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;");
-    }
-}

docker/nginx/config/nginx.conf

@@ -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;

docker/php/config/uploads.ini

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

src/ApiDomain/Console/config/console.php

@@ -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,
     ]
 ];

src/ApiDomain/Console/config/service_manager.php

@@ -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,
     ],
 ];

src/ApiDomain/Console/src/Command/AnalyzeVideoTitlesCommand.php

@@ -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;
-    }
-}

src/ApiDomain/Console/src/Command/ReadUntaggedVideosCommand.php

@@ -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;
-    }
-}

src/ApiDomain/External/Authentication/src/Handler/ConfirmRegistrationHandler.php

@@ -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']),

src/ApiDomain/External/Authentication/src/Handler/LoginUserHandler.php

@@ -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,

src/ApiDomain/External/Authentication/src/Handler/RegisterUserHandler.php

@@ -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'],

src/ApiDomain/External/Tag/config/routes.php

@@ -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,
-        ],
-    ],
-];

src/ApiDomain/External/Tag/config/service_manager.php

@@ -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,
-    ],
-];

src/ApiDomain/External/Tag/src/ConfigProvider.php

@@ -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',
-        ];
-    }
-}

src/ApiDomain/External/Tag/src/Handler/AddAliasHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/Tag/src/Handler/CreateHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/Tag/src/Handler/ReadDetailsHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/Tag/src/Handler/ReadVideoListHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/Tag/src/ResponseFormatter/AddAliasResponseFormatter.php

@@ -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()
-            ],
-        ];
-    }
-}

src/ApiDomain/External/Tag/src/ResponseFormatter/CreateResponseFormatter.php

@@ -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(),
-        ];
-    }
-}

src/ApiDomain/External/Tag/src/ResponseFormatter/ReadDetailsResponseFormatter.php

@@ -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
-        ];
-    }
-}

src/ApiDomain/External/Tag/src/ResponseFormatter/ReadVideoListResponseFormatter.php

@@ -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,
-        ];
-    }
-}

src/ApiDomain/External/TagList/config/routes.php

@@ -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,
-        ],
-    ],
-];

src/ApiDomain/External/TagList/config/service_manager.php

@@ -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,
-    ],
-];

src/ApiDomain/External/TagList/src/ConfigProvider.php

@@ -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',
-        ];
-    }
-}

src/ApiDomain/External/TagList/src/Handler/ReadListHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/TagList/src/ResponseFormatter/ReadListResponseFormatter.php

@@ -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,
-        ];
-    }
-}

src/ApiDomain/External/User/src/Handler/ChangePasswordHandler.php

@@ -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,

src/ApiDomain/External/User/src/Handler/ChangeUsernameHandler.php

@@ -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,

src/ApiDomain/External/User/src/Handler/CreateUserHandler.php

@@ -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'],

src/ApiDomain/External/Video/src/Handler/ReadDetailsHandler.php

@@ -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'])

src/ApiDomain/External/Video/src/ResponseFormatter/ReadDetailsResponseFormatter.php

@@ -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(),
+            'title' => $video->getTitle()
-            'tags' => $tags,
         ];
     }
 }

src/ApiDomain/External/VideoList/config/routes.php

@@ -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
-        ],
-    ],
 ];

src/ApiDomain/External/VideoList/config/service_manager.php

@@ -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,
     ],
 ];

src/ApiDomain/External/VideoList/src/Handler/ReadListHandler.php

@@ -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
-            $data['page'],
-            $data['perPage'],
         );
         $result = $this->readListQueryHandler->execute($readListQuery);
         

src/ApiDomain/External/VideoList/src/Handler/UploadHandler.php

@@ -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));
-    }
-}

src/ApiDomain/External/VideoList/src/ResponseFormatter/ReadListResponseFormatter.php

@@ -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();
+        $result = [];
-        $videos = $paginator->getIterator();
-
-        $items = [];
 
         /** @var Video $video */
         foreach ($videos as $video) {
-            $tags = [];
+            $result[] = [
-
-            /** @var Tag $tag */
-            foreach ($video->getTags() as $tag) {
-                $tags[] = [
-                    'id' => $tag->getId(),
-                    'description' => $tag->getDescription()
-                ];
-            }
-
-            $items[] = [
                 'title' => $video->getTitle(),
-                'id' => $video->getId(),
+                'id' => $video->getId()->toString(),
-                'tags' => $tags
             ];
         }
 
-        return [
+        return $result;
-            'total' => $paginator->count(),
-            'items' => $items,
-        ];
     }
 }

src/ApiDomain/External/VideoList/src/ResponseFormatter/UploadResponseFormatter.php

@@ -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
-        ];
-    }
-}

src/DataDomain/Business/src/Entity/Tag.php

@@ -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;
-    }
-}

src/DataDomain/Business/src/Entity/TagAlias.php

@@ -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;
-    }
-}

src/DataDomain/Business/src/Entity/Video.php

@@ -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;
 
@@ -41,9 +33,7 @@ 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;
     }

src/DataDomain/Business/src/Repository/TagAliasRepository.php

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

src/DataDomain/Business/src/Repository/TagRepository.php

@@ -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();
-    }
-}

src/DataDomain/Business/src/Repository/VideoRepository.php

@@ -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,
+        string $identifier
-        int $page,
-        int $perPage,
-        ?Tag $tag = null,
     ): 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) {
+        /** @var ?Registration $registration */
-            $query = '%'.$query.'%';
+        $registration = $query->execute()[0] ?? null;
-
+        return $registration;
-            $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());
     }
 }

src/HandlingDomain/Tag/config/service_manager.php

@@ -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,
-    ],
-];

src/HandlingDomain/Tag/src/Builder/TagAliasBuilder.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Builder/TagBuilder.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/ConfigProvider.php

@@ -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',
-        ];
-    }
-}

src/HandlingDomain/Tag/src/Exception/TagAliasAlreadyExistsException.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Exception/TagAlreadyExistsException.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Exception/TagNotFoundByIdException.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommand.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandBuilder.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandHandler.php

@@ -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);
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/AddAlias/AddAliasCommandResult.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommand.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandBuilder.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandHandler.php

@@ -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);
-    }
-}

src/HandlingDomain/Tag/src/Handler/Command/Create/CreateCommandResult.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQuery.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryBuilder.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryHandler.php

@@ -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);
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadDetails/ReadDetailsQueryResult.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQuery.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryBuilder.php

@@ -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,
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryHandler.php

@@ -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
-            )
-        );
-    }
-}

src/HandlingDomain/Tag/src/Handler/Query/ReadVideoList/ReadVideoListQueryResult.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Rule/TagAliasExistsRule.php

@@ -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;
-    }
-}

src/HandlingDomain/Tag/src/Rule/TagExistsRule.php

@@ -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;
-    }
-}

src/HandlingDomain/TagList/config/service_manager.php

@@ -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,
-    ],
-];

src/HandlingDomain/TagList/src/ConfigProvider.php

@@ -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',
-        ];
-    }
-}

src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQuery.php

@@ -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;
-    }
-}

src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryBuilder.php

@@ -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,
-        );
-    }
-}

src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryHandler.php

@@ -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(),
-            )
-        );
-    }
-}

src/HandlingDomain/TagList/src/Handler/Query/ReadList/ReadListQueryResult.php

@@ -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;
-    }
-}

src/HandlingDomain/Video/config/service_manager.php

@@ -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,
     ],
 ];

src/HandlingDomain/Video/src/Analyzer/VideoTitleAnalyzer.php

@@ -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)
-        );
-    }
-}

src/HandlingDomain/Video/src/Builder/VideoImageBuilder.php

@@ -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(
+        $videoId = $video->getId()->toString();
-            '%s/%s/%s',
-            APP_ROOT,
-            'var/filestore',
-            $directoryId->toString()
-        );
 
         $targetPath = sprintf(
-            '%s/%s',
+            '%s/%s/%s/%s',
-            $directoryPath,
+            APP_ROOT,
+            'var/filestore',
+            $videoId,
             self::FILE_NAME
         );
 
@@ -30,14 +27,11 @@ class VideoImageBuilder
             return null;
         }
 
-        $command = sprintf(
+        $command =  "cd /var/www/html/var/filestore/" . $videoId . "/" .
-            "cd %s && ffmpeg -i video.mp4 -ss %s -vframes 1 %s",
+            " && " .
-            $directoryPath,
+            "ffmpeg -i video.mp4 -ss " . $timestamp . " -vframes 1 " . self::FILE_NAME;
-            $timestamp,
-            self::FILE_NAME
-        );
 
-        shell_exec($command);
+        $output = shell_exec($command);
 
         return $targetPath;
     }

src/HandlingDomain/Video/src/Exception/VideoAlreadyExistsException.php

@@ -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
-        );
-    }
-}

src/HandlingDomain/Video/src/Exception/VideoNotFoundByIdException.php

@@ -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)
     {

src/HandlingDomain/Video/src/Handler/Command/Upload/UploadCommandHandler.php

@@ -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\Uploader\VideoUploader;
-use MyTube\Handling\Video\Pipeline\Upload\UploadPipeline;
-use MyTube\Handling\Video\Uploader\VideoTitleAnalyzer;
 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();
+        $uploadedFile = $uploadCommand->getUploadedFile();
-        $payload->setUploadedFile($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;
     }
 }

src/HandlingDomain/Video/src/Handler/Query/ReadDetails/ReadDetailsQueryHandler.php

@@ -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);
     }
 }

src/HandlingDomain/Video/src/Pipeline/Upload/Step/AnalyzeTitleStep.php

@@ -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);
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/Step/BuildVideoStep.php

@@ -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);
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/Step/CheckVideoStep.php

@@ -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);
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/Step/SaveEntityStep.php

@@ -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();
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/Step/UploadFileStep.php

@@ -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);
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/UploadPayload.php

@@ -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;
-    }
-}

src/HandlingDomain/Video/src/Pipeline/Upload/UploadPipeline.php

@@ -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,
-        ];
-    }
-}

src/HandlingDomain/Video/src/Rule/VideoExistsRule.php

@@ -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;
-    }
-}

src/HandlingDomain/Video/src/Uploader/VideoUploader.php

@@ -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,
+        Video $video,
-    ): string {
+    ): void {
-        $directoryPath = sprintf(
+        $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);
     }
 }

src/HandlingDomain/VideoList/config/service_manager.php

@@ -1,7 +1,10 @@
 <?php
 
-use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandBuilder;
+use MyTube\Handling\Video\Builder\VideoBuilder;
-use MyTube\Handling\VideoList\Handler\Command\Upload\UploadCommandHandler;
+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
+        ReadListQueryBuilder::class => AutoWiringFactory::class,
-        UploadCommandBuilder::class => AutoWiringFactory::class,
-        UploadCommandHandler::class => AutoWiringFactory::class,
     ],
 ];

src/HandlingDomain/VideoList/src/Handler/Command/Upload/UploadCommand.php

@@ -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;
-    }
-}

src/HandlingDomain/VideoList/src/Handler/Command/Upload/UploadCommandBuilder.php

@@ -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
-        );
-    }
-}