scratch

Subversion Repositories:
Compare Path: Rev
With Path: Rev
?path1? @ 86  →  ?path2? @ 87
/vendor/guzzlehttp/streams/tests/CachingStreamTest.php
@@ -0,0 +1,137 @@
<?php
namespace GuzzleHttp\Tests\Stream;
 
use GuzzleHttp\Stream\Stream;
use GuzzleHttp\Stream\CachingStream;
use GuzzleHttp\Stream\Utils;
 
/**
* @covers GuzzleHttp\Stream\CachingStream
*/
class CachingStreamTest extends \PHPUnit_Framework_TestCase
{
/** @var CachingStream */
protected $body;
 
/** @var Stream */
protected $decorated;
 
public function setUp()
{
$this->decorated = Stream::factory('testing');
$this->body = new CachingStream($this->decorated);
}
 
public function tearDown()
{
$this->decorated->close();
$this->body->close();
}
 
public function testUsesRemoteSizeIfPossible()
{
$body = Stream::factory('test');
$caching = new CachingStream($body);
$this->assertEquals(4, $caching->getSize());
}
 
/**
* @expectedException \RuntimeException
* @expectedExceptionMessage Cannot seek to byte 10
*/
public function testCannotSeekPastWhatHasBeenRead()
{
$this->body->seek(10);
}
 
public function testCannotUseSeekEnd()
{
$this->assertFalse($this->body->seek(2, SEEK_END));
}
 
public function testRewindUsesSeek()
{
$a = Stream::factory('foo');
$d = $this->getMockBuilder('GuzzleHttp\Stream\CachingStream')
->setMethods(array('seek'))
->setConstructorArgs(array($a))
->getMock();
$d->expects($this->once())
->method('seek')
->with(0)
->will($this->returnValue(true));
$d->seek(0);
}
 
public function testCanSeekToReadBytes()
{
$this->assertEquals('te', $this->body->read(2));
$this->body->seek(0);
$this->assertEquals('test', $this->body->read(4));
$this->assertEquals(4, $this->body->tell());
$this->body->seek(2);
$this->assertEquals(2, $this->body->tell());
$this->body->seek(2, SEEK_CUR);
$this->assertEquals(4, $this->body->tell());
$this->assertEquals('ing', $this->body->read(3));
}
 
public function testWritesToBufferStream()
{
$this->body->read(2);
$this->body->write('hi');
$this->body->seek(0);
$this->assertEquals('tehiing', (string) $this->body);
}
 
public function testSkipsOverwrittenBytes()
{
$decorated = Stream::factory(
implode("\n", array_map(function ($n) {
return str_pad($n, 4, '0', STR_PAD_LEFT);
}, range(0, 25))),
true
);
 
$body = new CachingStream($decorated);
 
$this->assertEquals("0000\n", Utils::readline($body));
$this->assertEquals("0001\n", Utils::readline($body));
// Write over part of the body yet to be read, so skip some bytes
$this->assertEquals(5, $body->write("TEST\n"));
$this->assertEquals(5, $this->readAttribute($body, 'skipReadBytes'));
// Read, which skips bytes, then reads
$this->assertEquals("0003\n", Utils::readline($body));
$this->assertEquals(0, $this->readAttribute($body, 'skipReadBytes'));
$this->assertEquals("0004\n", Utils::readline($body));
$this->assertEquals("0005\n", Utils::readline($body));
 
// Overwrite part of the cached body (so don't skip any bytes)
$body->seek(5);
$this->assertEquals(5, $body->write("ABCD\n"));
$this->assertEquals(0, $this->readAttribute($body, 'skipReadBytes'));
$this->assertEquals("TEST\n", Utils::readline($body));
$this->assertEquals("0003\n", Utils::readline($body));
$this->assertEquals("0004\n", Utils::readline($body));
$this->assertEquals("0005\n", Utils::readline($body));
$this->assertEquals("0006\n", Utils::readline($body));
$this->assertEquals(5, $body->write("1234\n"));
$this->assertEquals(5, $this->readAttribute($body, 'skipReadBytes'));
 
// Seek to 0 and ensure the overwritten bit is replaced
$body->seek(0);
$this->assertEquals("0000\nABCD\nTEST\n0003\n0004\n0005\n0006\n1234\n0008\n0009\n", $body->read(50));
 
// Ensure that casting it to a string does not include the bit that was overwritten
$this->assertContains("0000\nABCD\nTEST\n0003\n0004\n0005\n0006\n1234\n0008\n0009\n", (string) $body);
}
 
public function testClosesBothStreams()
{
$s = fopen('php://temp', 'r');
$a = Stream::factory($s);
$d = new CachingStream($a);
$d->close();
$this->assertFalse(is_resource($s));
}
}