MockSubscriber.php
1.96 KB
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
<?php
/**
* PHP OpenCloud library.
*
* @copyright 2014 Rackspace Hosting, Inc. See LICENSE for information.
* @license https://www.apache.org/licenses/LICENSE-2.0
* @author Jamie Hannaford <jamie.hannaford@rackspace.com>
*/
namespace OpenCloud\Tests;
use Guzzle\Common\Event;
use Guzzle\Plugin\Mock\MockPlugin;
use Guzzle\Http\Message\Request;
use Guzzle\Http\Message\Response;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
class MockSubscriber extends MockPlugin implements EventSubscriberInterface
{
public static function getSubscribedEvents()
{
return array(
'request.before_send' => array(
array('onRequestBeforeSend', -999),
array('onBeforeSendFallback', -1000)
)
);
}
public function onBeforeSendFallback(Event $event)
{
if (strpos($event['request']->getUrl(), 'tokens') !== false) {
// auth request must pass
$message = file_get_contents(__DIR__ . '/_response/Auth.resp');
$response = Response::fromMessage($message);
$event['request']->setResponse($response)->setState(Request::STATE_COMPLETE);
$event->stopPropagation();
} else {
// default fallback is a 404
$response = new Response(200);
$event['request']->setResponse($response)->setState(Request::STATE_COMPLETE);
$event->stopPropagation();
}
}
public function onRequestBeforeSend(Event $event)
{
if ($this->queue) {
$request = $event['request'];
$this->received[] = $request;
// Detach the filter from the client so it's a one-time use
if ($this->temporary && count($this->queue) == 1 && $request->getClient()) {
$request->getClient()->getEventDispatcher()->removeSubscriber($this);
}
$this->dequeue($request);
$event->stopPropagation();
}
}
}