feat: elastic bridge - interfaces

src/Bridge/Elasticsearch/ElasticsearchClient.php

@@ -5,7 +5,7 @@
 use Elasticsearch\Client;
 use Elasticsearch\ClientBuilder;
 
-final class ElasticsearchClient
+final class ElasticsearchClient implements ElasticsearchClientInterface
 {
     public function __construct(private readonly string $activityLogElasticHost)
     {

src/Bridge/Elasticsearch/ElasticsearchClientInterface.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Locastic\Loggastic\Bridge\Elasticsearch;
+
+use Elasticsearch\Client;
+
+interface ElasticsearchClientInterface
+{
+    public function getClient(): Client;
+}

src/Bridge/Elasticsearch/ElasticsearchService.php

@@ -7,12 +7,15 @@
 use Symfony\Component\Serializer\Normalizer\DenormalizerInterface;
 use Symfony\Component\Serializer\Normalizer\NormalizerInterface;
 
-final class ElasticsearchService
+final class ElasticsearchService implements ElasticsearchServiceInterface
 {
     use ElasticNormalizationContextTrait;
 
-    public function __construct(private readonly ElasticsearchClient $elasticsearchClient, private readonly NormalizerInterface $normalizer, private readonly DenormalizerInterface $denormalizer)
-    {
+    public function __construct(
+        private readonly ElasticsearchClientInterface $elasticsearchClient,
+        private readonly NormalizerInterface $normalizer,
+        private readonly DenormalizerInterface $denormalizer
+    ) {
     }
 
     public function createItem($item, string $index, array $groups = []): void

src/Bridge/Elasticsearch/ElasticsearchServiceInterface.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Locastic\Loggastic\Bridge\Elasticsearch;
+
+interface ElasticsearchServiceInterface
+{
+    public function createItem($item, string $index, array $groups = []): void;
+
+    public function bulkCreate(array $items, string $index, array $groups = []): void;
+
+    public function getItemById($id, string $index, string $denormalizeToClass): mixed;
+
+    public function getItemByQuery(string $index, string $denormalizeToClass, array $body = []): mixed;
+
+    public function updateItem($id, $item, string $index, array $groups = []): void;
+
+    public function getCollection(string $index, string $denormalizeToClass, array $body = [], $limit = 20, $offset = 0): array;
+}

src/Bridge/Elasticsearch/Index/ElasticsearchIndexFactory.php

@@ -3,12 +3,15 @@
 namespace Locastic\Loggastic\Bridge\Elasticsearch\Index;
 
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
-use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClient;
+use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClientInterface;
 
 final class ElasticsearchIndexFactory implements ElasticsearchIndexFactoryInterface
 {
-    public function __construct(private readonly ElasticsearchClient $elasticsearchClient, private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory, private readonly ElasticsearchIndexConfigurationInterface $elasticsearchIndexConfiguration)
-    {
+    public function __construct(
+        private readonly ElasticsearchClientInterface $elasticsearchClient,
+        private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory,
+        private readonly ElasticsearchIndexConfigurationInterface $elasticsearchIndexConfiguration
+    ) {
     }
 
     public function recreateActivityLogIndex(string $className): void

src/DataProcessor/ActivityLogProcessor.php

@@ -4,7 +4,7 @@
 
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\Traits\ElasticNormalizationContextTrait;
-use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService;
+use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface;
 use Locastic\Loggastic\Factory\ActivityLogInputFactoryInterface;
 use Locastic\Loggastic\Factory\CurrentDataTrackerInputFactoryInterface;
 use Locastic\Loggastic\Message\CreateActivityLogMessageInterface;
@@ -22,7 +22,7 @@ final class ActivityLogProcessor implements ActivityLogProcessorInterface
     public function __construct(
         private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory,
         private readonly NormalizerInterface $objectNormalizer,
-        private readonly ElasticsearchService $elasticService,
+        private readonly ElasticsearchServiceInterface $elasticService,
         private readonly ActivityLogInputFactoryInterface $activityLogInputFactory,
         private readonly CurrentDataTrackerInputFactoryInterface $currentDataTrackerInputFactory,
         private readonly LoggableContextFactoryInterface $loggableContextFactory

src/DataProvider/ActivityLogProvider.php

@@ -3,14 +3,14 @@
 namespace Locastic\Loggastic\DataProvider;
 
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
-use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService;
+use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface;
 use Locastic\Loggastic\Model\Output\ActivityLog;
 use Locastic\Loggastic\Model\Output\CurrentDataTracker;
 
 final class ActivityLogProvider implements ActivityLogProviderInterface
 {
     public function __construct(
-        private readonly ElasticsearchService $elasticsearchService,
+        private readonly ElasticsearchServiceInterface $elasticsearchService,
         private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory
     ) { }
 

src/DataProvider/CurrentDataTrackerProvider.php

@@ -3,14 +3,16 @@
 namespace Locastic\Loggastic\DataProvider;
 
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
-use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService;
+use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface;
 use Locastic\Loggastic\Model\Output\CurrentDataTracker;
 use Locastic\Loggastic\Model\Output\CurrentDataTrackerInterface;
 
 final class CurrentDataTrackerProvider implements CurrentDataTrackerProviderInterface
 {
-    public function __construct(private readonly ElasticsearchService $elasticsearchService, private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory)
-    {
+    public function __construct(
+        private readonly ElasticsearchServiceInterface $elasticsearchService,
+        private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory
+    ) {
     }
 
     public function getCurrentDataTrackerByClassAndId(string $className, $objectId): ?CurrentDataTrackerInterface

src/MessageHandler/PopulateCurrentDataTrackersHandler.php

@@ -5,7 +5,7 @@
 use Doctrine\Persistence\ManagerRegistry;
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
 use Locastic\Loggastic\Bridge\Elasticsearch\Context\Traits\ElasticNormalizationContextTrait;
-use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService;
+use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface;
 use Locastic\Loggastic\Factory\CurrentDataTrackerInputFactoryInterface;
 use Locastic\Loggastic\Message\PopulateCurrentDataTrackersMessage;
 use Symfony\Component\Messenger\Attribute\AsMessageHandler;
@@ -16,8 +16,13 @@ final class PopulateCurrentDataTrackersHandler
 {
     use ElasticNormalizationContextTrait;
 
-    public function __construct(private readonly ManagerRegistry $managerRegistry, private readonly CurrentDataTrackerInputFactoryInterface $currentDataTrackerInputFactory, private readonly NormalizerInterface $objectNormalizer, private readonly ElasticsearchService $elasticService, private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory)
-    {
+    public function __construct(
+        private readonly ManagerRegistry $managerRegistry,
+        private readonly CurrentDataTrackerInputFactoryInterface $currentDataTrackerInputFactory,
+        private readonly NormalizerInterface $objectNormalizer,
+        private readonly ElasticsearchServiceInterface $elasticService,
+        private readonly ElasticsearchContextFactoryInterface $elasticsearchContextFactory
+    ) {
     }
 
     public function __invoke(PopulateCurrentDataTrackersMessage $message): void

src/Resources/config/elastic.yaml

@@ -1,11 +1,17 @@
 services:
+    Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClientInterface:
+        alias: 'Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClient'
+
     Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClient:
         arguments:
             $activityLogElasticHost: '%locastic_activity_log.elasticsearch_host%'
 
+    Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface:
+        alias: 'Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService'
+
     Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService:
         arguments:
-            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClient'
+            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchClientInterface'
             - '@serializer.normalizer.object'
             - '@serializer'
 

src/Resources/config/logger.yaml

@@ -26,7 +26,7 @@ services:
         arguments:
             - '@Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface'
             - '@serializer.normalizer.object'
-            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService'
+            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface'
             - '@Locastic\Loggastic\Factory\ActivityLogInputFactoryInterface'
             - '@Locastic\Loggastic\Factory\CurrentDataTrackerInputFactoryInterface'
             - '@Locastic\Loggastic\Metadata\LoggableContext\Factory\LoggableContextFactoryInterface'

src/Resources/config/message_handlers.yaml

@@ -19,7 +19,7 @@ services:
             - '@Doctrine\Persistence\ManagerRegistry'
             - '@Locastic\Loggastic\Factory\CurrentDataTrackerInputFactoryInterface'
             - '@serializer.normalizer.object'
-            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService'
+            - '@Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchServiceInterface'
             - '@Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface'
         tags:
             - { name: messenger.message_handler }