mirror of
https://github.com/Seldaek/monolog.git
synced 2025-08-13 08:34:12 +02:00
Merge branch '1.x'
This commit is contained in:
Jordi Boggiano
165
tests/Monolog/Handler/DeduplicationHandlerTest.php
Normal file
165
tests/Monolog/Handler/DeduplicationHandlerTest.php
Normal file
@@ -0,0 +1,165 @@
|
||||
<?php
|
||||
|
||||
/*
|
||||
* This file is part of the Monolog package.
|
||||
*
|
||||
* (c) Jordi Boggiano <j.boggiano@seld.be>
|
||||
*
|
||||
* For the full copyright and license information, please view the LICENSE
|
||||
* file that was distributed with this source code.
|
||||
*/
|
||||
|
||||
namespace Monolog\Handler;
|
||||
|
||||
use Monolog\TestCase;
|
||||
use Monolog\Logger;
|
||||
|
||||
class DeduplicationHandlerTest extends TestCase
|
||||
{
|
||||
/**
|
||||
* @covers Monolog\Handler\DeduplicationHandler::flush
|
||||
*/
|
||||
public function testFlushPassthruIfAllRecordsUnderTrigger()
|
||||
{
|
||||
$test = new TestHandler();
|
||||
@unlink(sys_get_temp_dir().'/monolog_dedup.log');
|
||||
$handler = new DeduplicationHandler($test, sys_get_temp_dir().'/monolog_dedup.log', 0);
|
||||
|
||||
$handler->handle($this->getRecord(Logger::DEBUG));
|
||||
$handler->handle($this->getRecord(Logger::INFO));
|
||||
|
||||
$handler->flush();
|
||||
|
||||
$this->assertTrue($test->hasInfoRecords());
|
||||
$this->assertTrue($test->hasDebugRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
}
|
||||
|
||||
/**
|
||||
* @covers Monolog\Handler\DeduplicationHandler::flush
|
||||
* @covers Monolog\Handler\DeduplicationHandler::appendRecord
|
||||
*/
|
||||
public function testFlushPassthruIfEmptyLog()
|
||||
{
|
||||
$test = new TestHandler();
|
||||
@unlink(sys_get_temp_dir().'/monolog_dedup.log');
|
||||
$handler = new DeduplicationHandler($test, sys_get_temp_dir().'/monolog_dedup.log', 0);
|
||||
|
||||
$handler->handle($this->getRecord(Logger::ERROR, 'Foo:bar'));
|
||||
$handler->handle($this->getRecord(Logger::CRITICAL, "Foo\nbar"));
|
||||
|
||||
$handler->flush();
|
||||
|
||||
$this->assertTrue($test->hasErrorRecords());
|
||||
$this->assertTrue($test->hasCriticalRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
}
|
||||
|
||||
/**
|
||||
* @covers Monolog\Handler\DeduplicationHandler::flush
|
||||
* @covers Monolog\Handler\DeduplicationHandler::appendRecord
|
||||
* @covers Monolog\Handler\DeduplicationHandler::isDuplicate
|
||||
* @depends testFlushPassthruIfEmptyLog
|
||||
*/
|
||||
public function testFlushSkipsIfLogExists()
|
||||
{
|
||||
$test = new TestHandler();
|
||||
$handler = new DeduplicationHandler($test, sys_get_temp_dir().'/monolog_dedup.log', 0);
|
||||
|
||||
$handler->handle($this->getRecord(Logger::ERROR, 'Foo:bar'));
|
||||
$handler->handle($this->getRecord(Logger::CRITICAL, "Foo\nbar"));
|
||||
|
||||
$handler->flush();
|
||||
|
||||
$this->assertFalse($test->hasErrorRecords());
|
||||
$this->assertFalse($test->hasCriticalRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
}
|
||||
|
||||
/**
|
||||
* @covers Monolog\Handler\DeduplicationHandler::flush
|
||||
* @covers Monolog\Handler\DeduplicationHandler::appendRecord
|
||||
* @covers Monolog\Handler\DeduplicationHandler::isDuplicate
|
||||
* @depends testFlushPassthruIfEmptyLog
|
||||
*/
|
||||
public function testFlushPassthruIfLogTooOld()
|
||||
{
|
||||
$test = new TestHandler();
|
||||
$handler = new DeduplicationHandler($test, sys_get_temp_dir().'/monolog_dedup.log', 0);
|
||||
|
||||
$record = $this->getRecord(Logger::ERROR);
|
||||
$record['datetime']->modify('+62seconds');
|
||||
$handler->handle($record);
|
||||
$record = $this->getRecord(Logger::CRITICAL);
|
||||
$record['datetime']->modify('+62seconds');
|
||||
$handler->handle($record);
|
||||
|
||||
$handler->flush();
|
||||
|
||||
$this->assertTrue($test->hasErrorRecords());
|
||||
$this->assertTrue($test->hasCriticalRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
}
|
||||
|
||||
/**
|
||||
* @covers Monolog\Handler\DeduplicationHandler::flush
|
||||
* @covers Monolog\Handler\DeduplicationHandler::appendRecord
|
||||
* @covers Monolog\Handler\DeduplicationHandler::isDuplicate
|
||||
* @covers Monolog\Handler\DeduplicationHandler::collectLogs
|
||||
*/
|
||||
public function testGcOldLogs()
|
||||
{
|
||||
$test = new TestHandler();
|
||||
@unlink(sys_get_temp_dir().'/monolog_dedup.log');
|
||||
$handler = new DeduplicationHandler($test, sys_get_temp_dir().'/monolog_dedup.log', 0);
|
||||
|
||||
// handle two records from yesterday, and one recent
|
||||
$record = $this->getRecord(Logger::ERROR);
|
||||
$record['datetime']->modify('-1day -10seconds');
|
||||
$handler->handle($record);
|
||||
$record2 = $this->getRecord(Logger::CRITICAL);
|
||||
$record2['datetime']->modify('-1day -10seconds');
|
||||
$handler->handle($record2);
|
||||
$record3 = $this->getRecord(Logger::CRITICAL);
|
||||
$record3['datetime']->modify('-30seconds');
|
||||
$handler->handle($record3);
|
||||
|
||||
// log is written as none of them are duplicate
|
||||
$handler->flush();
|
||||
$this->assertSame(
|
||||
$record['datetime']->getTimestamp() . ":ERROR:test\n" .
|
||||
$record2['datetime']->getTimestamp() . ":CRITICAL:test\n" .
|
||||
$record3['datetime']->getTimestamp() . ":CRITICAL:test\n",
|
||||
file_get_contents(sys_get_temp_dir() . '/monolog_dedup.log')
|
||||
);
|
||||
$this->assertTrue($test->hasErrorRecords());
|
||||
$this->assertTrue($test->hasCriticalRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
|
||||
// clear test handler
|
||||
$test->clear();
|
||||
$this->assertFalse($test->hasErrorRecords());
|
||||
$this->assertFalse($test->hasCriticalRecords());
|
||||
|
||||
// log new records, duplicate log gets GC'd at the end of this flush call
|
||||
$handler->handle($record = $this->getRecord(Logger::ERROR));
|
||||
$handler->handle($record2 = $this->getRecord(Logger::CRITICAL));
|
||||
$handler->flush();
|
||||
|
||||
// log should now contain the new errors and the previous one that was recent enough
|
||||
$this->assertSame(
|
||||
$record3['datetime']->getTimestamp() . ":CRITICAL:test\n" .
|
||||
$record['datetime']->getTimestamp() . ":ERROR:test\n" .
|
||||
$record2['datetime']->getTimestamp() . ":CRITICAL:test\n",
|
||||
file_get_contents(sys_get_temp_dir() . '/monolog_dedup.log')
|
||||
);
|
||||
$this->assertTrue($test->hasErrorRecords());
|
||||
$this->assertTrue($test->hasCriticalRecords());
|
||||
$this->assertFalse($test->hasWarningRecords());
|
||||
}
|
||||
|
||||
public static function tearDownAfterClass()
|
||||
{
|
||||
@unlink(sys_get_temp_dir().'/monolog_dedup.log');
|
||||
}
|
||||
}
|
||||
@@ -96,4 +96,16 @@ class NativeMailerHandlerTest extends TestCase
|
||||
$this->assertSame("From: $from\r\nContent-type: text/plain; charset=utf-8\r\n", $params[3]);
|
||||
$this->assertSame('', $params[4]);
|
||||
}
|
||||
|
||||
public function testMessageSubjectFormatting()
|
||||
{
|
||||
$mailer = new NativeMailerHandler('to@example.org', 'Alert: %level_name% %message%', 'from@example.org');
|
||||
$mailer->handle($this->getRecord(Logger::ERROR, "Foo\nBar\r\n\r\nBaz"));
|
||||
$this->assertNotEmpty($GLOBALS['mail']);
|
||||
$this->assertInternalType('array', $GLOBALS['mail']);
|
||||
$this->assertArrayHasKey('0', $GLOBALS['mail']);
|
||||
$params = $GLOBALS['mail'][0];
|
||||
$this->assertCount(5, $params);
|
||||
$this->assertSame('Alert: ERROR Foo Bar Baz', $params[1]);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -72,6 +72,30 @@ class SwiftMailerHandlerTest extends TestCase
|
||||
$handler->handleBatch($records);
|
||||
}
|
||||
|
||||
public function testMessageSubjectFormatting()
|
||||
{
|
||||
// Wire Mailer to expect a specific Swift_Message with a customized Subject
|
||||
$messageTemplate = new \Swift_Message();
|
||||
$messageTemplate->setSubject('Alert: %level_name% %message%');
|
||||
$receivedMessage = null;
|
||||
|
||||
$this->mailer->expects($this->once())
|
||||
->method('send')
|
||||
->with($this->callback(function ($value) use (&$receivedMessage) {
|
||||
$receivedMessage = $value;
|
||||
return true;
|
||||
}));
|
||||
|
||||
$handler = new SwiftMailerHandler($this->mailer, $messageTemplate);
|
||||
|
||||
$records = array(
|
||||
$this->getRecord(Logger::EMERGENCY),
|
||||
);
|
||||
$handler->handleBatch($records);
|
||||
|
||||
$this->assertEquals('Alert: EMERGENCY test', $receivedMessage->getSubject());
|
||||
}
|
||||
|
||||
public function testMessageHaveUniqueId()
|
||||
{
|
||||
$messageTemplate = \Swift_Message::newInstance();
|
||||
|
||||
Reference in New Issue
Block a user