| Server IP : 78.140.185.180 / Your IP : 3.128.29.244 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/www/vendor/rackspace/php-opencloud/tests/OpenCloud/Tests/ |
Upload File : |
<?php
/**
* Copyright 2012-2014 Rackspace US, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
namespace OpenCloud\Tests;
use Guzzle\Common\Event;
use Guzzle\Http\Message\Request;
use Guzzle\Http\Message\Response;
use Guzzle\Plugin\Mock\MockPlugin;
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();
}
}
}