Incoviba/oficial
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Deprecated log table #32

Merged
aldarien merged 1 commits from feature/skip-deprecated into develop 2025-09-11 17:36:57 -03:00
Conversation 0 Commits 1 Files Changed 1 +47 -1
1 changed files with 47 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
app/common/Implement/Log/Handler/MySQL.php
View File

@ -11,8 +11,10 @@ class MySQL extends AbstractProcessingHandler
{
private bool $initialized = false;
private PDOStatement $statement;
private PDOStatement $statementDeprecated;
public function __construct(protected Connection $connection, protected int $retainDays = 90, int|string|Level $level = Level::Debug, bool $bubble = true)
public function __construct(protected Connection $connection, protected int $retainDays = 90,
int|string|Level $level = Level::Debug, bool $bubble = true)
{
parent::__construct($level, $bubble);
}
@ -22,9 +24,24 @@ class MySQL extends AbstractProcessingHandler
if (!$this->checkTableExists()) {
$this->createTable();
}
if (!$this->checkTableDeprecatedExists()) {
$this->createTableDeprecated();
}
$this->cleanup();
$this->cleanupDeprecated();
$this->initialized();
}
if (str_contains(strtolower($record->message), 'deprecated:')) {
$this->statementDeprecated->execute([
'channel' => $record->channel,
'level' => $record->level->getName(),
'message' => $record->formatted,
'time' => $record->datetime->format('Y-m-d H:i:s.u'),
'context' => (count($record->context) > 0) ? json_encode($record->context, JSON_UNESCAPED_SLASHES) : '',
'extra' => (count($record->extra) > 0) ? json_encode($record->extra, JSON_UNESCAPED_SLASHES) : ''
]);
return;
}
$this->statement->execute([
'channel' => $record->channel,
'level' => $record->level->getName(),
@ -42,6 +59,11 @@ INSERT INTO monolog (channel, level, message, time, context, extra)
VALUES (:channel, :level, :message, :time, :context, :extra)
QUERY;
$this->statement = $this->connection->getPDO()->prepare($query);
$query = <<<QUERY
INSERT INTO monolog_deprecated (channel, level, message, time, context, extra)
VALUES (:channel, :level, :message, :time, :context, :extra)
QUERY;
$this->statementDeprecated = $this->connection->getPDO()->prepare($query);
$this->initialized = true;
}
private function checkTableExists(): bool
@ -50,6 +72,12 @@ QUERY;
$result = $this->connection->query($query);
return $result->rowCount() > 0;
}
private function checkTableDeprecatedExists(): bool
{
$query = "SHOW TABLES LIKE 'monolog_deprecated'";
$result = $this->connection->query($query);
return $result->rowCount() > 0;
}
private function createTable(): void
{
$query = <<<QUERY
@ -64,9 +92,27 @@ CREATE TABLE IF NOT EXISTS monolog (
QUERY;
$this->connection->getPDO()->exec($query);
}
private function createTableDeprecated(): void
{
$query = <<<QUERY
CREATE TABLE IF NOT EXISTS monolog_deprecated (
channel VARCHAR(255),
level VARCHAR(100),
message LONGTEXT,
time DATETIME,
context LONGTEXT,
extra LONGTEXT
)
QUERY;
}
private function cleanup(): void
{
$query = "DELETE FROM monolog WHERE time < DATE_SUB(CURDATE(), INTERVAL {$this->retainDays} DAY)";
$this->connection->query($query);
}
private function cleanupDeprecated(): void
{
$query = "DELETE FROM monolog_deprecated WHERE time < DATE_SUB(CURDATE(), INTERVAL {$this->retainDays} DAY)";
}
}