Add recent searches

Author: santiagolizardo

public/index.php

@@ -6,11 +6,14 @@
 
 use Monolog\Logger;
 use Reconmap\ApiRouter;
+use Reconmap\Events\SearchEvent;
 use Reconmap\Services\ApplicationConfig;
 use Reconmap\Services\ApplicationContainer;
 use Reconmap\Services\Logging\LoggingConfigurator;
+use Reconmap\Services\SearchListener;
 use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
 use Symfony\Component\DependencyInjection\Dumper\PhpDumper;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 use Symfony\Component\HttpFoundation\Response;
 
 $configFilePath = $applicationDir . '/config.json';
@@ -47,6 +50,12 @@
 $router = new ApiRouter();
 $router->mapRoutes($container, $config);
 
+/**
+ * @var EventDispatcher $eventDispatcher
+ */
+$eventDispatcher = $container->get(EventDispatcher::class);
+$eventDispatcher->addListener(SearchEvent::class, $container->get(SearchListener::class));
+
 $response = $router->dispatch($request);
 
 $httpFoundationFactory = new HttpFoundationFactory();

src/Controllers/Projects/GetProjectsController.php

@@ -6,14 +6,17 @@
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Reconmap\Controllers\Controller;
+use Reconmap\Events\SearchEvent;
 use Reconmap\Repositories\ProjectRepository;
 use Reconmap\Repositories\SearchCriterias\ProjectSearchCriteria;
 use Reconmap\Services\PaginationRequestHandler;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 
 class GetProjectsController extends Controller
 {
     public function __construct(private readonly ProjectRepository     $projectRepository,
-                                private readonly ProjectSearchCriteria $projectSearchCriteria)
+                                private readonly ProjectSearchCriteria $projectSearchCriteria,
+                                private readonly EventDispatcher       $eventDispatcher)
     {
     }
 
@@ -25,6 +28,7 @@ public function __invoke(ServerRequestInterface $request): ResponseInterface
 
         if (isset($params['keywords'])) {
             $this->projectSearchCriteria->addKeywordsCriterion($params['keywords']);
+            $this->eventDispatcher->dispatch(new SearchEvent($user->id, $params['keywords']));
         }
         if (isset($params['clientId'])) {
             $this->projectSearchCriteria->addClientCriterion(intval($params['clientId']));

src/Controllers/System/GetRecentSearchesController.php

@@ -19,7 +19,7 @@ protected function process(ApplicationRequest $request): ResponseInterface
         $userId = $request->getUser()->id;
         $setName = "recent-searches-user{$userId}";
 
-        $recentSearches = $this->redisServer->zRange($setName, 0, 10);
+        $recentSearches = $this->redisServer->zRevRange($setName, 0, 9);
 
         $response = $this->createOkResponse();
         $response->getBody()->write(json_encode($recentSearches));

src/Events/SearchEvent.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Reconmap\Events;
+
+use Symfony\Contracts\EventDispatcher\Event;
+
+class SearchEvent extends Event
+{
+    public function __construct(private readonly int $userId, private readonly string $keywords)
+    {
+    }
+
+    public function getUserId(): int
+    {
+        return $this->userId;
+    }
+
+    public function getKeywords(): string
+    {
+        return $this->keywords;
+    }
+}

src/Services/ApplicationContainer.php

@@ -12,6 +12,7 @@
 use Symfony\Component\DependencyInjection\Loader\Configurator\ContainerConfigurator;
 use Symfony\Component\DependencyInjection\Loader\PhpFileLoader;
 use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 use Symfony\Component\Filesystem\Filesystem;
 
 class ApplicationContainer extends ContainerBuilder
@@ -37,6 +38,7 @@ public static function initialise(ContainerInterface $container, ApplicationConf
         $container->set(Logger::class, $logger);
         $container->set(ProcessorFactory::class, new ProcessorFactory());
         $container->set(ContainerInterface::class, $container);
+        $container->set(EventDispatcher::class, new EventDispatcher());
     }
 
     private function configure(ContainerConfigurator $containerConfigurator): void
@@ -62,7 +64,9 @@ private function configure(ContainerConfigurator $containerConfigurator): void
             ->set(ApplicationConfig::class)->synthetic()
             ->set(ProcessorFactory::class)->synthetic()
             ->set(ContainerInterface::class)->synthetic()
+            ->set(EventDispatcher::class)->synthetic()
             ->set(\mysqli::class)->synthetic();
+
     }
 }
 

src/Services/AuditLogService.php

@@ -4,7 +4,7 @@
 
 use Reconmap\Repositories\AuditLogRepository;
 
-class AuditLogService
+readonly class AuditLogService
 {
     public function __construct(
         private AuditLogRepository $repository,

src/Services/SearchListener.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Reconmap\Services;
+
+use Reconmap\Events\SearchEvent;
+
+readonly class SearchListener
+{
+    public function __construct(private RedisServer $redisServer)
+    {
+
+    }
+
+    public function __invoke(SearchEvent $searchEvent): void
+    {
+        $setName = "recent-searches-user{$searchEvent->getUserId()}";
+        $this->redisServer->zAdd($setName, time(), $searchEvent->getKeywords());
+    }
+}

src/Tasks/EmailTaskProcessor.php

@@ -10,10 +10,10 @@
 use Symfony\Component\Mime\Address;
 use Symfony\Component\Mime\Email;
 
-class EmailTaskProcessor implements ItemProcessor
+readonly class EmailTaskProcessor implements ItemProcessor
 {
-    public function __construct(private readonly ApplicationConfig $config,
-                                private readonly Logger $logger)
+    public function __construct(private ApplicationConfig $config,
+                                private Logger            $logger)
     {
     }