Implemented post hook actions

config/services.yaml

@@ -59,6 +59,13 @@ services:
                 '@App\Action\Order\History',
             ]
 
+    App\Command\ExportCommand:
+        arguments:
+            $postHookActions: [
+                '@App\Action\FileSystem\CreateCsvFileAction',
+                '@App\Action\Download\FileDownloadAction'
+            ]
+
     App\ActionHandler\ActionHandlerInterface $accountActionHandler: '@App\ActionHandler\AccountActionHandler'
     App\ActionHandler\ActionHandlerInterface $dailyDataActionHandler: '@App\ActionHandler\DailyDataActionHandler'
     App\ActionHandler\ActionHandlerInterface $dailyGainActionHandler: '@App\ActionHandler\DailyGainsActionHandler'

src/Action/Download/FileDownloadAction.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Action\Download;
+
+use App\Action\ActionInterface;
+use App\Dto\Aggregator\AggregateInterface;
+use App\FileSystem\File;
+use App\Manager\FileDownloadManager;
+
+final class FileDownloadAction implements ActionInterface
+{
+    public function __construct(private readonly FileDownloadManager $fileDownloadManager)
+    {
+    }
+
+    public function __invoke(AggregateInterface $aggregator): void
+    {
+        if (($aggregator->getData() instanceof File) === false) {
+            throw new \RuntimeException('Data should be an instance of class ' . File::class);
+        }
+
+        ($this->fileDownloadManager)($aggregator->getData());
+    }
+}

src/Action/FileSystem/CreateCsvFileAction.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Action\FileSystem;
+
+use App\Action\ActionInterface;
+use App\Dto\Aggregator\AggregateInterface;
+use App\FileSystem\CsvFile;
+use App\Serializer\Serializer;
+
+class CreateCsvFileAction implements ActionInterface
+{
+    public function __construct(private readonly Serializer $serializer)
+    {
+    }
+
+    public function __invoke(AggregateInterface $aggregator): void
+    {
+        $csvFile = new CsvFile();
+
+        $csvFile->setFileName(sprintf('export_%d', (new \DateTime())->getTimestamp()));
+
+        $csvFile->setContents(
+            $this->serializer->encode($aggregator->getData(), 'csv', ['csv_delimiter' => ','])
+        );
+
+        $aggregator->setData($csvFile);
+    }
+}

src/ActionHandler/ActionHandler.php

@@ -12,15 +12,25 @@
 abstract class ActionHandler implements ActionHandlerInterface
 {
     /**
-     * @param iterable<ActionInterface> $actions
+     * @param array<ActionInterface> $actions
      */
     public function __construct(
-        private readonly iterable $actions,
+        private array $actions,
         private readonly CircuitBreakerInterface $circuitBreaker,
         private readonly LoggerInterface $logger
     ) {
     }
 
+    public function preHook(ActionInterface $action): void
+    {
+        array_unshift($this->actions, $action);
+    }
+
+    public function postHook(ActionInterface $action): void
+    {
+        array_push($this->actions, $action);
+    }
+
     public function __invoke(AggregateInterface $aggregate): void
     {
         foreach ($this->actions as $action) {

src/Command/ExportCommand.php

@@ -4,11 +4,9 @@
 
 namespace App\Command;
 
+use App\ActionHandler\ActionHandler;
 use App\Dto\Aggregator\AggregateRoot;
-use App\FileSystem\CsvFile;
 use App\Manager\ActionHandlerManager;
-use App\Manager\FileDownloadManager;
-use App\Serializer\Serializer;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Helper\QuestionHelper;
@@ -27,8 +25,7 @@ class ExportCommand extends Command
 
     public function __construct(
         private readonly ActionHandlerManager $actionHandlerManager,
-        private readonly FileDownloadManager $fileDownloadManager,
-        private readonly Serializer $serializer
+        private readonly array $postHookActions
     ) {
         parent::__construct();
     }
@@ -45,18 +42,16 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 
         $aggregator = new AggregateRoot();
 
+        /** @var ActionHandler $actionHandler */
         $actionHandler = ($this->actionHandlerManager)($handler);
-        $actionHandler($aggregator);
 
-        $csvFile = new CsvFile();
-        $csvFile->setFileName($handler);
-        $csvFile->setContents(
-            $this->serializer->encode($aggregator->getData(), 'csv', ['csv_delimiter' => ','])
-        );
+        foreach ($this->postHookActions as $action) {
+            $actionHandler->postHook($action);
+        }
 
-        ($this->fileDownloadManager)($csvFile);
+        $actionHandler($aggregator);
 
-        $io->success(sprintf('Finished downloading data to: %s', $csvFile->getFileName()));
+        $io->success('Finished downloading the data...');
 
         return Command::SUCCESS;
     }

src/Dto/Aggregator/AggregateInterface.php

@@ -18,15 +18,15 @@ public function getAccounts(): array;
     public function setAccounts(array $accounts): void;
 
     /**
-     * @return array<mixed>
+     * @return mixed
      * @throws \Exception
      */
-    public function getData(): array;
+    public function getData(): mixed;
 
     /**
-     * @param array<mixed> $data
+     * @param mixed $data
      */
-    public function setData(array $data): void;
+    public function setData(mixed $data): void;
 
     /**
      * @throws \Exception

src/Dto/Aggregator/AggregateRoot.php

@@ -9,8 +9,8 @@ class AggregateRoot implements AggregateInterface
     /** @var array<mixed> */
     private array $accounts = [];
 
-    /** @var array<mixed> */
-    private array $data = [];
+    /** @var mixed */
+    private mixed $data = null;
 
     private ?string $session;
 
@@ -28,14 +28,14 @@ public function getAccounts(): array
         return $this->accounts;
     }
 
-    public function setData(array $data): void
+    public function setData(mixed $data): void
     {
         $this->data = $data;
     }
 
-    public function getData(): array
+    public function getData(): mixed
     {
-        if (empty($this->data)) {
+        if ($this->data === null) {
             throw new \Exception('No data found!');
         }