scratch – Rev 87
?pathlinks?
<?php
// Override curl_setopt_array() to get the last set curl options
namespace GuzzleHttp\Adapter\Curl
{
function curl_setopt_array($handle, array $options)
{
if (array_values($options) != [null, null, null, null]) {
$_SERVER['last_curl'] = $options;
}
\curl_setopt_array($handle, $options);
}
}
namespace GuzzleHttp\Tests\Adapter\Curl {
use GuzzleHttp\Adapter\Curl\CurlFactory;
use GuzzleHttp\Adapter\Curl\MultiAdapter;
use GuzzleHttp\Adapter\Transaction;
use GuzzleHttp\Client;
use GuzzleHttp\Event\BeforeEvent;
use GuzzleHttp\Exception\ServerException;
use GuzzleHttp\Message\MessageFactory;
use GuzzleHttp\Message\Request;
use GuzzleHttp\Message\RequestInterface;
use GuzzleHttp\Stream\Stream;
use GuzzleHttp\Tests\Server;
/**
* @covers GuzzleHttp\Adapter\Curl\CurlFactory
*/
class CurlFactoryTest extends \PHPUnit_Framework_TestCase
{
/** @var \GuzzleHttp\Tests\Server */
static $server;
public static function setUpBeforeClass()
{
unset($_SERVER['last_curl']);
}
public static function tearDownAfterClass()
{
unset($_SERVER['last_curl']);
}
public function testCreatesCurlHandle()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nFoo: Bar\r\n Baz: bam\r\nContent-Length: 2\r\n\r\nhi"]);
$request = new Request(
'PUT',
Server::$url . 'haha',
['Hi' => ' 123'],
Stream::factory('testing')
);
$stream = Stream::factory();
$request->getConfig()->set('save_to', $stream);
$request->getConfig()->set('verify', true);
$this->emit($request);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
$this->assertInternalType('resource', $h);
curl_exec($h);
$response = $t->getResponse();
$this->assertInstanceOf('GuzzleHttp\Message\ResponseInterface', $response);
$this->assertEquals('hi', $response->getBody());
$this->assertEquals('Bar', $response->getHeader('Foo'));
$this->assertEquals('bam', $response->getHeader('Baz'));
curl_close($h);
$sent = Server::received(true)[0];
$this->assertEquals('PUT', $sent->getMethod());
$this->assertEquals('/haha', $sent->getPath());
$this->assertEquals('123', $sent->getHeader('Hi'));
$this->assertEquals('7', $sent->getHeader('Content-Length'));
$this->assertEquals('testing', $sent->getBody());
$this->assertEquals('1.1', $sent->getProtocolVersion());
$this->assertEquals('hi', (string) $stream);
$this->assertEquals(true, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYPEER]);
$this->assertEquals(2, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYHOST]);
}
public function testSendsHeadRequests()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 2\r\n\r\n"]);
$request = new Request('HEAD', Server::$url);
$this->emit($request);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$response = $t->getResponse();
$this->assertEquals('2', $response->getHeader('Content-Length'));
$this->assertEquals('', $response->getBody());
$sent = Server::received(true)[0];
$this->assertEquals('HEAD', $sent->getMethod());
$this->assertEquals('/', $sent->getPath());
}
public function testSendsPostRequestWithNoBody()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 0\r\n\r\n"]);
$request = new Request('POST', Server::$url);
$this->emit($request);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(true)[0];
$this->assertEquals('POST', $sent->getMethod());
$this->assertEquals('', $sent->getBody());
}
public function testSendsChunkedRequests()
{
$stream = $this->getMockBuilder('GuzzleHttp\Stream\Stream')
->setConstructorArgs([fopen('php://temp', 'r+')])
->setMethods(['getSize'])
->getMock();
$stream->expects($this->any())
->method('getSize')
->will($this->returnValue(null));
$stream->write('foo');
$stream->seek(0);
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 0\r\n\r\n"]);
$request = new Request('PUT', Server::$url, [], $stream);
$this->emit($request);
$this->assertNull($request->getBody()->getSize());
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(false)[0];
$this->assertContains('PUT / HTTP/1.1', $sent);
$this->assertContains('transfer-encoding: chunked', strtolower($sent));
$this->assertContains("\r\n\r\nfoo", $sent);
}
public function testDecodesGzippedResponses()
{
Server::flush();
$content = gzencode('test');
$message = "HTTP/1.1 200 OK\r\n"
. "Content-Encoding: gzip\r\n"
. "Content-Length: " . strlen($content) . "\r\n\r\n"
. $content;
Server::enqueue($message);
$client = new Client();
$request = $client->createRequest('GET', Server::$url);
$this->emit($request);
$t = new Transaction($client, $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(true)[0];
$this->assertSame('', $sent->getHeader('Accept-Encoding'));
$this->assertEquals('test', (string) $t->getResponse()->getBody());
}
public function testDecodesWithCustomAcceptHeader()
{
Server::flush();
$content = gzencode('test');
$message = "HTTP/1.1 200 OK\r\n"
. "Content-Encoding: gzip\r\n"
. "Content-Length: " . strlen($content) . "\r\n\r\n"
. $content;
Server::enqueue($message);
$client = new Client();
$request = $client->createRequest('GET', Server::$url, [
'decode_content' => 'gzip'
]);
$this->emit($request);
$t = new Transaction($client, $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(true)[0];
$this->assertSame('gzip', $sent->getHeader('Accept-Encoding'));
$this->assertEquals('test', (string) $t->getResponse()->getBody());
}
public function testDoesNotForceDecode()
{
Server::flush();
$content = gzencode('test');
$message = "HTTP/1.1 200 OK\r\n"
. "Content-Encoding: gzip\r\n"
. "Content-Length: " . strlen($content) . "\r\n\r\n"
. $content;
Server::enqueue($message);
$client = new Client();
$request = $client->createRequest('GET', Server::$url, [
'headers' => ['Accept-Encoding' => 'gzip'],
'decode_content' => false
]);
$this->emit($request);
$t = new Transaction($client, $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(true)[0];
$this->assertSame('gzip', $sent->getHeader('Accept-Encoding'));
$this->assertSame($content, (string) $t->getResponse()->getBody());
}
public function testAddsDebugInfoToBuffer()
{
$r = fopen('php://temp', 'r+');
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nfoo"]);
$request = new Request('GET', Server::$url);
$request->getConfig()->set('debug', $r);
$this->emit($request);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
rewind($r);
$this->assertNotEmpty(stream_get_contents($r));
}
public function testAddsProxyOptions()
{
$request = new Request('GET', Server::$url);
$this->emit($request);
$request->getConfig()->set('proxy', '123');
$request->getConfig()->set('connect_timeout', 1);
$request->getConfig()->set('timeout', 2);
$request->getConfig()->set('cert', __FILE__);
$request->getConfig()->set('ssl_key', [__FILE__, '123']);
$request->getConfig()->set('verify', false);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
curl_close($f($t, new MessageFactory()));
$this->assertEquals('123', $_SERVER['last_curl'][CURLOPT_PROXY]);
$this->assertEquals(1000, $_SERVER['last_curl'][CURLOPT_CONNECTTIMEOUT_MS]);
$this->assertEquals(2000, $_SERVER['last_curl'][CURLOPT_TIMEOUT_MS]);
$this->assertEquals(__FILE__, $_SERVER['last_curl'][CURLOPT_SSLCERT]);
$this->assertEquals(__FILE__, $_SERVER['last_curl'][CURLOPT_SSLKEY]);
$this->assertEquals('123', $_SERVER['last_curl'][CURLOPT_SSLKEYPASSWD]);
$this->assertEquals(0, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYHOST]);
$this->assertEquals(false, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYPEER]);
}
/**
* @expectedException \RuntimeException
*/
public function testEnsuresCertExists()
{
$request = new Request('GET', Server::$url);
$this->emit($request);
$request->getConfig()->set('cert', __FILE__ . 'ewfwef');
$f = new CurlFactory();
$f(new Transaction(new Client(), $request), new MessageFactory());
}
/**
* @expectedException \RuntimeException
*/
public function testEnsuresKeyExists()
{
$request = new Request('GET', Server::$url);
$this->emit($request);
$request->getConfig()->set('ssl_key', __FILE__ . 'ewfwef');
$f = new CurlFactory();
$f(new Transaction(new Client(), $request), new MessageFactory());
}
/**
* @expectedException \RuntimeException
*/
public function testEnsuresCacertExists()
{
$request = new Request('GET', Server::$url);
$this->emit($request);
$request->getConfig()->set('verify', __FILE__ . 'ewfwef');
$f = new CurlFactory();
$f(new Transaction(new Client(), $request), new MessageFactory());
}
public function testClientUsesSslByDefault()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nfoo"]);
$f = new CurlFactory();
$client = new Client([
'base_url' => Server::$url,
'adapter' => new MultiAdapter(new MessageFactory(), ['handle_factory' => $f])
]);
$client->get();
$this->assertEquals(2, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYHOST]);
$this->assertEquals(true, $_SERVER['last_curl'][CURLOPT_SSL_VERIFYPEER]);
$this->assertFileExists($_SERVER['last_curl'][CURLOPT_CAINFO]);
}
public function testConvertsConstantNameKeysToValues()
{
$request = new Request('GET', Server::$url);
$request->getConfig()->set('curl', ['CURLOPT_USERAGENT' => 'foo']);
$this->emit($request);
$f = new CurlFactory();
curl_close($f(new Transaction(new Client(), $request), new MessageFactory()));
$this->assertEquals('foo', $_SERVER['last_curl'][CURLOPT_USERAGENT]);
}
public function testStripsFragment()
{
$request = new Request('GET', Server::$url . '#foo');
$this->emit($request);
$f = new CurlFactory();
curl_close($f(new Transaction(new Client(), $request), new MessageFactory()));
$this->assertEquals(Server::$url, $_SERVER['last_curl'][CURLOPT_URL]);
}
public function testDoesNotSendSizeTwice()
{
$request = new Request('PUT', Server::$url, [], Stream::factory(str_repeat('a', 32769)));
$this->emit($request);
$f = new CurlFactory();
curl_close($f(new Transaction(new Client(), $request), new MessageFactory()));
$this->assertEquals(32769, $_SERVER['last_curl'][CURLOPT_INFILESIZE]);
$this->assertNotContains('Content-Length', implode(' ', $_SERVER['last_curl'][CURLOPT_HTTPHEADER]));
}
public function testCanSendPayloadWithGet()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\n\r\n"]);
$request = new Request(
'GET',
Server::$url,
[],
Stream::factory('foo')
);
$this->emit($request);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$h = $f($t, new MessageFactory());
curl_exec($h);
curl_close($h);
$sent = Server::received(true)[0];
$this->assertEquals('foo', (string) $sent->getBody());
$this->assertEquals(3, (string) $sent->getHeader('Content-Length'));
}
private function emit(RequestInterface $request)
{
$event = new BeforeEvent(new Transaction(new Client(), $request));
$request->getEmitter()->emit('before', $event);
}
public function testDoesNotAlwaysAddContentType()
{
Server::flush();
Server::enqueue(["HTTP/1.1 200 OK\r\nContent-Length: 0\r\n\r\n"]);
$client = new Client();
$client->put(Server::$url . '/foo', ['body' => 'foo']);
$request = Server::received(true)[0];
$this->assertEquals('', $request->getHeader('Content-Type'));
}
/**
* @expectedException \GuzzleHttp\Exception\AdapterException
*/
public function testThrowsForStreamOption()
{
$request = new Request('GET', Server::$url . 'haha');
$request->getConfig()->set('stream', true);
$t = new Transaction(new Client(), $request);
$f = new CurlFactory();
$f($t, new MessageFactory());
}
}
}