buildNode(...$data); } $stream = AssemblyStream::wrap($nodes); $content = stream_get_contents($stream); $this->assertEquals($expected, $content); } #[\PHPUnit\Framework\Attributes\DataProvider('providesNodes')] public function testGetContentsFread(string $expected, array $nodeData, int $chunkLength = 3): void { $nodes = []; foreach ($nodeData as $data) { $nodes[] = $this->buildNode(...$data); } $stream = AssemblyStream::wrap($nodes); $content = ''; while (!feof($stream)) { $chunk = fread($stream, $chunkLength); $content .= $chunk; if ($chunkLength !== 3) { $this->assertEquals($chunkLength, strlen($chunk)); } } $this->assertEquals($expected, $content); } #[\PHPUnit\Framework\Attributes\DataProvider('providesNodes')] public function testSeek(string $expected, array $nodeData): void { $nodes = []; foreach ($nodeData as $data) { $nodes[] = $this->buildNode(...$data); } $stream = AssemblyStream::wrap($nodes); $offset = floor(strlen($expected) * 0.6); if (fseek($stream, $offset) === -1) { $this->fail('fseek failed'); } $content = stream_get_contents($stream); $this->assertEquals(substr($expected, $offset), $content); } public static function providesNodes(): array { $data8k = self::makeData(8192); $dataLess8k = self::makeData(8191); $tonofnodes = []; $tonofdata = ''; for ($i = 0; $i < 101; $i++) { $thisdata = random_int(0, 100); // variable length and content $tonofdata .= $thisdata; $tonofnodes[] = [(string)$i, (string)$thisdata]; } return[ 'one node zero bytes' => [ '', [ ['0', ''], ]], 'one node only' => [ '1234567890', [ ['0', '1234567890'], ]], 'one node buffer boundary' => [ $data8k, [ ['0', $data8k], ]], 'two nodes' => [ '1234567890', [ ['1', '67890'], ['0', '12345'], ]], 'two nodes end on buffer boundary' => [ $data8k . $data8k, [ ['1', $data8k], ['0', $data8k], ]], 'two nodes with one on buffer boundary' => [ $data8k . $dataLess8k, [ ['1', $dataLess8k], ['0', $data8k], ]], 'two nodes on buffer boundary plus one byte' => [ $data8k . 'X' . $data8k, [ ['1', $data8k], ['0', $data8k . 'X'], ]], 'two nodes on buffer boundary plus one byte at the end' => [ $data8k . $data8k . 'X', [ ['1', $data8k . 'X'], ['0', $data8k], ]], 'a ton of nodes' => [ $tonofdata, $tonofnodes ], 'one read over multiple nodes' => [ '1234567890', [ ['0', '1234'], ['1', '5678'], ['2', '90'], ], 10], 'two reads over multiple nodes' => [ '1234567890', [ ['0', '1234'], ['1', '5678'], ['2', '90'], ], 5], ]; } private static function makeData(int $count): string { $data = ''; $base = '1234567890'; $j = 0; for ($i = 0; $i < $count; $i++) { $data .= $base[$j]; $j++; if (!isset($base[$j])) { $j = 0; } } return $data; } private function buildNode(string $name, string $data) { $node = $this->getMockBuilder(File::class) ->onlyMethods(['getName', 'get', 'getSize']) ->getMock(); $node->expects($this->any()) ->method('getName') ->willReturn($name); $node->expects($this->any()) ->method('get') ->willReturn($data); $node->expects($this->any()) ->method('getSize') ->willReturn(strlen($data)); return $node; } }