When events requested without project, events for all projects should be returned

Author: butschster

app/modules/Events/Interfaces/Queries/CountEventsHandler.php

@@ -7,16 +7,20 @@
 use App\Application\Commands\CountEvents;
 use Modules\Events\Domain\EventRepositoryInterface;
 use Spiral\Cqrs\Attribute\QueryHandler;
+use Spiral\Cqrs\QueryBusInterface;
 
 final class CountEventsHandler extends EventsHandler
 {
     public function __construct(
         private readonly EventRepositoryInterface $events,
-    ) {}
+        QueryBusInterface $bus,
+    ) {
+        parent::__construct($bus);
+    }
 
     #[QueryHandler]
     public function __invoke(CountEvents $query): int
     {
-        return $this->events->countAll(self::getScopeFromFindEvents($query));
+        return $this->events->countAll($this->getScopeFromFindEvents($query));
     }
 }

app/modules/Events/Interfaces/Queries/EventsHandler.php

@@ -3,17 +3,36 @@
 namespace Modules\Events\Interfaces\Queries;
 
 use App\Application\Commands\AskEvents;
+use App\Application\Commands\FindAllProjects;
+use Modules\Projects\Domain\ProjectInterface;
+use Modules\Projects\Domain\ValueObject\Key;
+use Spiral\Cqrs\QueryBusInterface;
 
 abstract class EventsHandler
 {
-    protected static function getScopeFromFindEvents(AskEvents $query): array
+    public function __construct(
+        private readonly QueryBusInterface $bus,
+    ) {}
+
+    protected function getScopeFromFindEvents(AskEvents $query): array
     {
         $scope = [];
         if ($query->type !== null) {
             $scope['type'] = $query->type;
         }
 
-        $scope['project'] = $query->project;
+        if ($query->project !== null) {
+            $scope['project'] = $query->project;
+        } elseif ($query->project !== []) {
+            // TODO: refactor this
+            $projects = $this->bus->ask(new FindAllProjects());
+            $keys = \array_map(
+                static fn(ProjectInterface $project): Key => $project->getKey(),
+                \iterator_to_array($projects),
+            );
+
+            $scope['project'] = $keys;
+        }
 
         return $scope;
     }

app/modules/Events/Interfaces/Queries/FindEventsHandler.php

@@ -6,19 +6,24 @@
 
 use App\Application\Commands\FindEvents;
 use Modules\Events\Domain\EventRepositoryInterface;
+use Spiral\Core\Container;
 use Spiral\Cqrs\Attribute\QueryHandler;
+use Spiral\Cqrs\QueryBusInterface;
 
 final class FindEventsHandler extends EventsHandler
 {
     public function __construct(
         private readonly EventRepositoryInterface $events,
-    ) {}
+        QueryBusInterface $bus,
+    ) {
+        parent::__construct($bus);
+    }
 
     #[QueryHandler]
     public function __invoke(FindEvents $query): iterable
     {
         return $this->events->findAll(
-            scope: self::getScopeFromFindEvents($query),
+            scope: $this->getScopeFromFindEvents($query),
             orderBy: ['timestamp' => 'desc'],
             limit: $query->limit,
         );

app/src/Application/Commands/FindAllProjects.php

@@ -4,10 +4,10 @@
 
 namespace App\Application\Commands;
 
-use Modules\Projects\Domain\Project;
+use Modules\Projects\Domain\ProjectInterface;
 use Spiral\Cqrs\QueryInterface;
 
 /**
- * @implements QueryInterface<Project[]>
+ * @implements QueryInterface<ProjectInterface[]>
  */
 final class FindAllProjects implements QueryInterface {}