Locastic\Loggastic\DataProvider\ActivityLogProvider

Complexity

Total Complexity

5

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getActivityLogsByIndexAndId()	0	21	1
A	getActivityLogsByClass()	0	15	1
A	__construct()	0	4	1
A	getActivityLogsByClassAndId()	0	23	1
A	getCurrentDataTrackerByClassAndId()	0	13	1

<?php

namespace Locastic\Loggastic\DataProvider;

use Locastic\Loggastic\Bridge\Elasticsearch\Context\ElasticsearchContextFactoryInterface;
use Locastic\Loggastic\Bridge\Elasticsearch\ElasticsearchService;
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 ElasticsearchContextFactoryInterface $elasticsearchContextFactory
    ) { }

    public function getActivityLogsByClass(string $className, array $sort = [], int $limit = 20, int $offset = 0): array
    {
        $elasticContext = $this->elasticsearchContextFactory->create($className);

        $body = [
            'sort' => $sort,
        ];

        // todo move class to config
        return $this->elasticsearchService->getCollection(
            $elasticContext->getActivityLogIndex(),
            ActivityLog::class,
            $body,
            $limit,
            $offset
        );
    }

    public function getCurrentDataTrackerByClassAndId(string $className, $objectId): ?array
    {
        $elasticContext = $this->elasticsearchContextFactory->create($className);

        $body = [
            'query' => ['term' => ['objectId' => $objectId]],
        ];

        // todo move class to config
        return $this->elasticsearchService->getItemByQuery(
            $elasticContext->getCurrentDataTrackerIndex(),
            CurrentDataTracker::class,
            $body
        );
    }

    public function getActivityLogsByClassAndId(
        string $className,
        mixed $objectId,
        array $sort = [],
        int $limit = 20,
        int $offset = 0
    ): array {
        $elasticContext = $this->elasticsearchContextFactory->create($className);

        $body = [
            'sort' => $sort,
            'query' => [
                'term' => ['objectId' => $objectId],
            ],
        ];

        // todo move class to config
        return $this->elasticsearchService->getCollection(
            $elasticContext->getActivityLogIndex(),
            ActivityLog::class,
            $body,
            $limit,
            $offset
        );
    }

    public function getActivityLogsByIndexAndId(
        string $index,
        $objectId,
        array $sort = [],
        int $limit = 20,
        int $offset = 0
    ): array {
        $body = [
            'sort' => $sort,
            'query' => [
                'term' => ['objectId' => $objectId],
            ],
        ];

        // todo move class to config
        return $this->elasticsearchService->getCollection(
            $index,
            ActivityLog::class,
            $body,
            $limit,
            $offset
        );
    }
}