LogComponent   A
last analyzed

Complexity

Total Complexity 13

Size/Duplication

Total Lines 100
Duplicated Lines 0 %

Test Coverage

Coverage 88.89%

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 30
c 1
b 0
f 0
dl 0
loc 100
ccs 32
cts 36
cp 0.8889
rs 10
wmc 13

6 Methods

Rating   Name   Duplication   Size   Complexity  
A __construct() 0 3 1
A getLogs() 0 22 6
A clearLogs() 0 19 3
A flushLogs() 0 8 1
A getWorkers() 0 4 1
A getLoggerWorker() 0 3 1
1
<?php
2
3
declare(strict_types=1);
4
5
/**
6
 * Derafu: Biblioteca PHP (Núcleo).
7
 * Copyright (C) Derafu <https://www.derafu.org>
8
 *
9
 * Este programa es software libre: usted puede redistribuirlo y/o modificarlo
10
 * bajo los términos de la Licencia Pública General Affero de GNU publicada por
11
 * la Fundación para el Software Libre, ya sea la versión 3 de la Licencia, o
12
 * (a su elección) cualquier versión posterior de la misma.
13
 *
14
 * Este programa se distribuye con la esperanza de que sea útil, pero SIN
15
 * GARANTÍA ALGUNA; ni siquiera la garantía implícita MERCANTIL o de APTITUD
16
 * PARA UN PROPÓSITO DETERMINADO. Consulte los detalles de la Licencia Pública
17
 * General Affero de GNU para obtener una información más detallada.
18
 *
19
 * Debería haber recibido una copia de la Licencia Pública General Affero de GNU
20
 * junto a este programa.
21
 *
22
 * En caso contrario, consulte <http://www.gnu.org/licenses/agpl.html>.
23
 */
24
25
namespace Derafu\Lib\Core\Package\Prime\Component\Log;
26
27
use Derafu\Lib\Core\Foundation\Abstract\AbstractComponent;
28
use Derafu\Lib\Core\Package\Prime\Component\Log\Contract\LogComponentInterface;
29
use Derafu\Lib\Core\Package\Prime\Component\Log\Contract\LoggerWorkerInterface;
30
use Derafu\Lib\Core\Package\Prime\Component\Log\Entity\Level;
31
32
/**
33
 * Servicio de registro de bitácora (logging).
34
 */
35
class LogComponent extends AbstractComponent implements LogComponentInterface
36
{
37
    /**
38
     * Worker para escribir en la bitácora de registros.
39
     *
40
     * @var LoggerWorkerInterface
41
     */
42
    private LoggerWorkerInterface $logger;
43
44
    /**
45
     * Constructor del componente.
46
     *
47
     * @param LoggerWorkerInterface $logger
48
     */
49 38
    public function __construct(LoggerWorkerInterface $logger)
50
    {
51 38
        $this->logger = $logger;
52
    }
53
54
    /**
55
     * {@inheritDoc}
56
     */
57
    public function getWorkers(): array
58
    {
59
        return [
60
            'logger' => $this->logger,
61
        ];
62
    }
63
64
    /**
65
     * {@inheritDoc}
66
     */
67 38
    public function getLoggerWorker(): LoggerWorkerInterface
68
    {
69 38
        return $this->logger;
70
    }
71
72
    /**
73
     * {@inheritDoc}
74
     */
75 38
    public function getLogs(
76
        int|string|null $level = null,
77
        bool $newFirst = true
78
    ): array {
79 38
        $journal = $this->getLoggerWorker()->getJournal();
80
81
        // Obtener todos los logs.
82 38
        $records = $journal->all();
83 38
        if ($level === null) {
84 9
            return $newFirst ? array_reverse($records) : $records;
85
        }
86
87
        // Obtener logs de cierto nivel.
88 29
        $level = (new Level($level))->getCode();
89 29
        $filtered = [];
90 29
        foreach ($records as $record) {
91 28
            if ($record->level->value === $level) {
92 28
                $filtered[] = $record;
93
            }
94
        }
95
96 29
        return $newFirst ? array_reverse($filtered) : $filtered;
97
    }
98
99
    /**
100
     * {@inheritDoc}
101
     */
102 4
    public function clearLogs(int|string|null $level = null): void
103
    {
104 4
        $journal = $this->getLoggerWorker()->getJournal();
105
106
        // Borrar todos los logs.
107 4
        if ($level === null) {
108 1
            $journal->clear();
109 1
            return;
110
        }
111
112
        // Dejar todos los logs excepto los de cierto nivel (esos se borran).
113 3
        $level = (new Level($level))->getCode();
114 3
        $logs = array_filter(
115 3
            $journal->all(),
116 3
            fn ($log) => $log->level->value !== $level
117 3
        );
118 3
        $journal->clear();
119 3
        foreach ($logs as $logRecord) {
120 2
            $journal->add($logRecord);
121
        }
122
    }
123
124
    /**
125
     * {@inheritDoc}
126
     */
127 2
    public function flushLogs(
128
        int|string|null $level = null,
129
        bool $newFirst = true
130
    ): array {
131 2
        $logs = $this->getLogs($level, $newFirst);
132 2
        $this->clearLogs($level);
133
134 2
        return $logs;
135
    }
136
}
137