Test Failed
Push — master ( 1352e7...0da4e2 )
by Esteban De La Fuente
03:30
created

LogComponent   A

Complexity

Total Complexity 13

Size/Duplication

Total Lines 100
Duplicated Lines 0 %

Test Coverage

Coverage 0%

Importance

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

6 Methods

Rating   Name   Duplication   Size   Complexity  
A getWorkers() 0 4 1
A __construct() 0 3 1
A getLogs() 0 22 6
A clearLogs() 0 19 3
A flushLogs() 0 8 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
    public function __construct(LoggerWorkerInterface $logger)
50
    {
51
        $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
    public function getLoggerWorker(): LoggerWorkerInterface
68
    {
69
        return $this->logger;
70
    }
71
72
    /**
73
     * {@inheritDoc}
74
     */
75
    public function getLogs(
76
        int|string|null $level = null,
77
        bool $newFirst = true
78
    ): array {
79
        $journal = $this->getLoggerWorker()->getJournal();
80
81
        // Obtener todos los logs.
82
        $records = $journal->all();
83
        if ($level === null) {
84
            return $newFirst ? array_reverse($records) : $records;
85
        }
86
87
        // Obtener logs de cierto nivel.
88
        $level = (new Level($level))->getCode();
89
        $filtered = [];
90
        foreach ($records as $record) {
91
            if ($record->level->value === $level) {
92
                $filtered[] = $record;
93
            }
94
        }
95
96
        return $newFirst ? array_reverse($filtered) : $filtered;
97
    }
98
99
    /**
100
     * {@inheritDoc}
101
     */
102
    public function clearLogs(int|string|null $level = null): void
103
    {
104
        $journal = $this->getLoggerWorker()->getJournal();
105
106
        // Borrar todos los logs.
107
        if ($level === null) {
108
            $journal->clear();
109
            return;
110
        }
111
112
        // Dejar todos los logs excepto los de cierto nivel (esos se borran).
113
        $level = (new Level($level))->getCode();
114
        $logs = array_filter(
115
            $journal->all(),
116
            fn ($log) => $log->level->value !== $level
117
        );
118
        $journal->clear();
119
        foreach ($logs as $logRecord) {
120
            $journal->add($logRecord);
121
        }
122
    }
123
124
    /**
125
     * {@inheritDoc}
126
     */
127
    public function flushLogs(
128
        int|string|null $level = null,
129
        bool $newFirst = true
130
    ): array {
131
        $logs = $this->getLogs($level, $newFirst);
132
        $this->clearLogs($level);
133
134
        return $logs;
135
    }
136
}
137