Firesphere\SolrSearch\Helpers\SolrLogger

Complexity

Total Complexity

7

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setClient()	0	5	1
A	saveSolrLog()	0	25	3
A	getClient()	0	3	1
A	__construct()	0	13	2

<?php


namespace Firesphere\SolrSearch\Helpers;

use Firesphere\SolrSearch\Models\SolrLog;
use Firesphere\SolrSearch\Services\SolrCoreService;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use SilverStripe\ORM\ValidationException;

class SolrLogger
{
    /**
     * @var Client
     */
    protected $client;

    /**
     * SolrLogger constructor.
     */
    public function __construct($handler = null)
    {
        $config = SolrCoreService::config()->get('config');
        $endpoint = $config['endpoint'];
        $hostConfig = array_values($endpoint);
        $guzzleConfig = [
            'base_uri' => $hostConfig[0]['host'] . ':' . $hostConfig[0]['port']
        ];
        if ($handler) {
            $guzzleConfig['handler'] = $handler;
        }

        $this->client = new Client($guzzleConfig);
    }

    /**
     * @param string $type
     * @throws GuzzleException
     * @throws ValidationException
     */
    public function saveSolrLog($type = 'Query'): void
    {
        $response = $this->client->request('GET', 'solr/admin/info/logging', [
            'query' => [
                'since' => 0,
                'wt'    => 'json'
            ]
        ]);

        $arrayResponse = json_decode($response->getBody(), true);

        foreach ($arrayResponse['history']['docs'] as $error) {
            $filter = [
                'Timestamp' => $error['time'],
                'Level'     => $error['level'],
                'Index'     => $error['core'],
            ];
            if (!SolrLog::get()->filter($filter)->exists()) {
                SolrLog::create([
                    'Timestamp' => $error['time'],
                    'Message'   => $error['message'],
                    'Index'     => $error['core'],
                    'Type'      => $type,
                    'Level'     => $error['level'],
                ])->write();
            }
        }
    }

    /**
     * @return Client
     */
    public function getClient(): Client
    {
        return $this->client;
    }

    /**
     * @param Client $client
     * @return SolrLogger
     */
    public function setClient(Client $client): self
    {
        $this->client = $client;

        return $this;
    }
}