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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
<?php
namespace Guzzle\Tests\Plugin\Async;
use Guzzle\Plugin\Async\AsyncPlugin;
use Guzzle\Http\Message\RequestInterface;
use Guzzle\Http\Message\RequestFactory;
use Guzzle\Http\Curl\CurlHandle;
use Guzzle\Http\Exception\CurlException;
use Guzzle\Common\Event;
use Guzzle\Http\Client;
/**
* @covers Guzzle\Plugin\Async\AsyncPlugin
*/
class AsyncPluginTest extends \Guzzle\Tests\GuzzleTestCase
{
public function testSubscribesToEvents()
{
$events = AsyncPlugin::getSubscribedEvents();
$this->assertArrayHasKey('request.before_send', $events);
$this->assertArrayHasKey('request.exception', $events);
$this->assertArrayHasKey('curl.callback.progress', $events);
}
public function testEnablesProgressCallbacks()
{
$p = new AsyncPlugin();
$request = RequestFactory::getInstance()->create('PUT', 'http://www.example.com');
$event = new Event(array(
'request' => $request
));
$p->onBeforeSend($event);
$this->assertEquals(true, $request->getCurlOptions()->get('progress'));
}
public function testAddsTimesOutAfterSending()
{
$p = new AsyncPlugin();
$request = RequestFactory::getInstance()->create('PUT', 'http://www.example.com');
$handle = CurlHandle::factory($request);
$event = new Event(array(
'request' => $request,
'handle' => $handle->getHandle(),
'uploaded' => 10,
'upload_size' => 10,
'downloaded' => 0
));
$p->onCurlProgress($event);
}
public function testEnsuresRequestIsSet()
{
$p = new AsyncPlugin();
$event = new Event(array(
'uploaded' => 10,
'upload_size' => 10,
'downloaded' => 0
));
$p->onCurlProgress($event);
}
public function testMasksCurlExceptions()
{
$p = new AsyncPlugin();
$request = RequestFactory::getInstance()->create('PUT', 'http://www.example.com');
$e = new CurlException('Error');
$event = new Event(array(
'request' => $request,
'exception' => $e
));
$p->onRequestTimeout($event);
$this->assertEquals(RequestInterface::STATE_COMPLETE, $request->getState());
$this->assertEquals(200, $request->getResponse()->getStatusCode());
$this->assertTrue($request->getResponse()->hasHeader('X-Guzzle-Async'));
}
public function testEnsuresIntegration()
{
$this->getServer()->flush();
$this->getServer()->enqueue("HTTP/1.1 204 FOO\r\nContent-Length: 4\r\n\r\ntest");
$client = new Client($this->getServer()->getUrl());
$request = $client->post('/', null, array(
'foo' => 'bar'
));
$request->getEventDispatcher()->addSubscriber(new AsyncPlugin());
$request->send();
$this->assertEquals('', $request->getResponse()->getBody(true));
$this->assertTrue($request->getResponse()->hasHeader('X-Guzzle-Async'));
$received = $this->getServer()->getReceivedRequests(true);
$this->assertEquals('POST', $received[0]->getMethod());
}
}
|
