1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
<?php
namespace GuzzleHttp\Tests\Subscriber\LogSubscriber;
use GuzzleHttp\Client;
use GuzzleHttp\Subscriber\Log\Formatter;
use GuzzleHttp\Subscriber\Log\LogSubscriber;
use GuzzleHttp\Subscriber\Log\SimpleLogger;
use GuzzleHttp\Subscriber\Mock;
use GuzzleHttp\Message\Response;
/**
* @covers GuzzleHttp\Subscriber\Log\LogSubscriber
*/
class LogSubscriberTest extends \PHPUnit_Framework_TestCase
{
public function testUsesSimpleLogger()
{
$s = new LogSubscriber();
$this->assertInstanceOf('GuzzleHttp\\Subscriber\\Log\\SimpleLogger', $this->readAttribute($s, 'logger'));
$s = new LogSubscriber(function () {});
$this->assertInstanceOf('GuzzleHttp\\Subscriber\\Log\\SimpleLogger', $this->readAttribute($s, 'logger'));
$r = fopen('php://temp', 'r+');
$s = new LogSubscriber($r);
$this->assertInstanceOf('GuzzleHttp\\Subscriber\\Log\\SimpleLogger', $this->readAttribute($s, 'logger'));
fclose($r);
}
public function testUsesLogger()
{
$logger = new SimpleLogger();
$log = new LogSubscriber($logger);
$this->assertSame($logger, $this->readAttribute($log, 'logger'));
}
public function testUsesFormatString()
{
$log = new LogSubscriber(null, '{test}');
$formatter = $this->readAttribute($log, 'formatter');
$this->assertEquals('{test}', $this->readAttribute($formatter, 'template'));
}
public function testUsesFormatter()
{
$formatter = new Formatter();
$log = new LogSubscriber(null, $formatter);
$this->assertSame($formatter, $this->readAttribute($log, 'formatter'));
}
public function testLogsAfterSending()
{
$resource = fopen('php://temp', 'r+');
$logger = new LogSubscriber($resource, '{code}');
$client = new Client();
$client->getEmitter()->attach($logger);
$client->getEmitter()->attach(new Mock([new Response(200)]));
$client->get('http://httbin.org/get');
rewind($resource);
$this->assertEquals("[info] 200\n", stream_get_contents($resource));
fclose($resource);
}
public function testLogsAfterError()
{
$resource = fopen('php://temp', 'r+');
$logger = new LogSubscriber($resource, '{code}');
$client = new Client();
$client->getEmitter()->attach($logger);
$client->getEmitter()->attach(new Mock([new Response(500)]));
try {
$client->get('http://httbin.org/get');
} catch (\Exception $e) {}
rewind($resource);
$this->assertEquals("[critical] 500\n", stream_get_contents($resource));
fclose($resource);
}
}
|
