ComplianceTestTest

src/Kir/Streams/RandomAccessStream.php

@@ -2,5 +2,4 @@
 namespace Kir\Streams;
 
 interface RandomAccessStream extends InputStream, OutputStream, SeekableStream {
-
-} 
+}

tests/Kir/Streams/Helper/ClosureStreamFactory.php → src/Kir/Streams/Tests/Helper/ClosureStreamFactory.php

@@ -1,5 +1,5 @@
 <?php
-namespace Kir\Streams\Helper;
+namespace Kir\Streams\Tests\Helper;
 
 use Closure;
 use Kir\Streams\Stream;
@@ -19,7 +19,7 @@ public function __construct(Closure $callback) {
 	/**
 	 * @return Stream
 	 */
-	public function getStream() {
+	public function createStream() {
 		return call_user_func($this->callback);
 	}
 }

tests/Kir/Streams/Helper/MemoryStream.php → src/Kir/Streams/Tests/Helper/MemoryStream.php

@@ -1,5 +1,5 @@
 <?php
-namespace Kir\Streams\Helper;
+namespace Kir\Streams\Tests\Helper;
 
 class MemoryStream extends ResourceStream {
 	/**

tests/Kir/Streams/Helper/NondestructiveReadWriteStream.php → src/Kir/Streams/Tests/Helper/NondestructiveReadWriteStream.php

@@ -1,10 +1,11 @@
 <?php
-namespace Kir\Streams\Helper;
+namespace Kir\Streams\Tests\Helper;
 
 use Kir\Streams\Exceptions\IOException;
 use Kir\Streams\RandomAccessStream;
+use Kir\Streams\TruncatableStream;
 
-class NondestructiveReadWriteStream implements RandomAccessStream {
+class NondestructiveReadWriteStream implements RandomAccessStream, TruncatableStream {
 	/**
 	 * @var RandomAccessStream
 	 */
@@ -89,4 +90,12 @@ public function rewind() {
 	public function getSize() {
 		return $this->stream->getSize();
 	}
+
+	/**
+	 * @throws IOException
+	 * @return $this
+	 */
+	public function truncate() {
+		$this->stream->truncate();
+	}
 }

tests/Kir/Streams/Helper/ResourceStream.php → src/Kir/Streams/Tests/Helper/ResourceStream.php

@@ -1,11 +1,12 @@
 <?php
-namespace Kir\Streams\Helper;
+namespace Kir\Streams\Tests\Helper;
 
 use Kir\Streams\Exceptions\InvalidStreamOperationException;
 use Kir\Streams\Exceptions\IOException;
 use Kir\Streams\RandomAccessStream;
+use Kir\Streams\TruncatableStream;
 
-class ResourceStream implements RandomAccessStream {
+class ResourceStream implements RandomAccessStream, TruncatableStream {
 	/**
 	 * @var resource
 	 */
@@ -26,7 +27,8 @@ class ResourceStream implements RandomAccessStream {
 	 * @param string $mode
 	 */
 	public function __construct($filename, $mode) {
-		$this->res = fopen($filename, $mode);
+		$res = fopen($filename, $mode);
+		$this->setResource($res);
 	}
 
 	/**
@@ -149,11 +151,10 @@ public function getSize() {
 	}
 
 	/**
-	 * @param int $size
 	 * @return $this
 	 */
-	public function truncate($size = 0) {
-		ftruncate($this->res, $size);
+	public function truncate() {
+		ftruncate($this->res, 0);
 		$this->rewind();
 		return $this;
 	}
@@ -162,7 +163,7 @@ public function truncate($size = 0) {
 	 * @return bool
 	 */
 	protected function isSeekable() {
-		return !!$this->getMetaValue('seekable');
+		return !!$this->getMetaValue('seekable', false);
 	}
 
 	/**
@@ -186,4 +187,16 @@ protected function setResource($resource) {
 	private function updateSize() {
 		$this->size = max(ftell($this->res), $this->size);
 	}
+
+	/**
+	 * @param string $string
+	 * @param mixed $default
+	 * @return mixed
+	 */
+	private function getMetaValue($string, $default) {
+		if(array_key_exists($string, $this->meta)) {
+			return $this->meta[$string];
+		}
+		return $default;
+	}
 }

tests/Kir/Streams/Helper/StreamFactory.php → src/Kir/Streams/Tests/Helper/StreamFactory.php

@@ -1,11 +1,11 @@
 <?php
-namespace Kir\Streams\Helper;
+namespace Kir\Streams\Tests\Helper;
 
 use Kir\Streams\Stream;
 
 interface StreamFactory {
 	/**
 	 * @return Stream
 	 */
-	public function getStream();
+	public function createStream();
 } 

tests/Kir/Streams/ResourceStreamTest.php → src/Kir/Streams/Tests/ResourceStreamTest.php

@@ -1,56 +1,55 @@
 <?php
-namespace Kir\Streams;
+namespace Kir\Streams\Tests;
 
-class ResourceStreamTest {
-	/**
-	 * @var Helper\StreamFactory
-	 */
-	private $factory = null;
+use Kir\Streams\Tests\Helper;
+use Kir\Streams\RandomAccessStream;
+use Kir\Streams\TruncatableStream;
 
+class ResourceStreamTest extends \PHPUnit_Framework_TestCase {
 	/**
-	 * @var Helper\NondestructiveReadWriteStream
+	 * @var Helper\StreamFactory
 	 */
-	private $referenceResource;
+	private $subjectFactory = null;
 
 	/**
 	 */
-	public function __construct(Helper\StreamFactory $factory) {
-		$this->factory = $factory;
-
-		$sourceStream = new Helper\ResourceStream(__DIR__.'/../../assets/test-data.txt', 'r');
-		$this->referenceResource = new Helper\NondestructiveReadWriteStream($sourceStream);
+	protected function setUp(Helper\StreamFactory $factory) {
+		parent::setUp();
+		$this->subjectFactory = $factory;
 	}
 
 	/**
 	 */
 	public function testRead() {
-		$stream = $this->createStream();
-		$data = $stream->read(7);
-		\PHPUnit_Framework_Assert::assertEquals('This is', $data);
+		$stream = $this->createSubject();
+		$data = $stream->read(26);
+		\PHPUnit_Framework_Assert::assertEquals('Lorem ipsum dolor sit amet', $data);
 	}
 
 	/**
 	 */
 	public function testReadAll() {
-		$stream = $this->createStream();
+		$stream = $this->createSubject();
 		$data = $stream->read();
-		\PHPUnit_Framework_Assert::assertEquals('This is a test', $data);
+		$hash = md5($data);
+		\PHPUnit_Framework_Assert::assertEquals('cbdd94ceda68ce93d86bc5c84c2537d6', $hash);
 	}
 
 	/**
 	 */
 	public function testWrite() {
-		$stream = $this->createStream();
+		$stream = $this->createSubject();
+		$stream->rewind();
 		$stream->write('ABCDEFG');
 		$stream->rewind();
-		$data = $stream->read();
+		$data = $stream->read(7);
 		\PHPUnit_Framework_Assert::assertEquals('ABCDEFG', $data);
 	}
 
 	/**
 	 */
 	public function testPositioning() {
-		$stream = $this->createStream();
+		$stream = $this->createSubject();
 		$stream->write('0987654321');
 		$stream->setPosition(0);
 		\PHPUnit_Framework_Assert::assertEquals(0, $stream->getPosition(), 'Set position to stream start');
@@ -62,23 +61,26 @@ public function testPositioning() {
 	/**
 	 */
 	public function testTruncate() {
-		$stream = $this->createStream();
+		$stream = $this->createSubject();
 
 		$this->truncateStream($stream);
 		$stream->write('This is a test');
 		$this->truncateStream($stream);
 		\PHPUnit_Framework_Assert::assertEquals(0, $stream->getPosition());
 	}
 
+	/**
+	 * @param TruncatableStream $stream
+	 */
 	private function truncateStream(TruncatableStream $stream) {
 		$stream->truncate();
 	}
 
 	/**
 	 * @return RandomAccessStream
 	 */
-	private function createStream() {
-		return $this->factory->getStream();
+	private function createSubject() {
+		return $this->subjectFactory->createStream();
 	}
 }
 

tests.xml

@@ -6,9 +6,7 @@
 		 timeoutForSmallTests="5">
 	<testsuites>
 		<testsuite name="Streams">
-			<file>tests/Kir/Streams/Impl/ResourceStreamTest.php</file>
-			<file>tests/Kir/Streams/Impl/StringStreamTest.php</file>
-			<file>tests/Kir/Streams/Impl/PhpStreamTest.php</file>
+			<file>tests/Kir/Streams/Tests/RandomAccessStreamTestTest.php</file>
 		</testsuite>
 	</testsuites>
 </phpunit>

tests/Kir/Streams/Tests/RandomAccessStreamTestTest.php

@@ -0,0 +1,18 @@
+<?php
+namespace Kir\Streams\Tests;
+
+use Kir\Streams\Tests\Helper\ClosureStreamFactory;
+use Kir\Streams\Tests\Helper\NondestructiveReadWriteStream;
+use Kir\Streams\Tests\Helper\ResourceStream;
+
+class RandomAccessStreamTestTest extends ResourceStreamTest {
+	protected function setUp() {
+		$factory = new ClosureStreamFactory(function () {
+			$stream = new ResourceStream(__DIR__.'/../../../../tests/assets/test-data.txt', 'r');
+			$stream = new NondestructiveReadWriteStream($stream);
+			return $stream;
+		});
+		parent::setUp($factory);
+	}
+}
+