mirror of
https://github.com/shufflingpixels/php-io.git
synced 2026-08-15 19:58:14 +02:00
Henrik Hautakoski
07ec405512
Replace PSR-7 StreamInterface with a set of small, composable interfaces (ReaderInterface, WriterInterface, SeekerInterface and their combinations). BinaryReader now depends only on ReaderInterface, BinaryWriter on WriterInterface, making both easy to satisfy with any byte source or sink. Buffer and Resource are simplified — no capability flags, no detach/close lifecycle, no PSR-7 metadata methods. LimitedResource is replaced by LimitedReader, a lightweight reader that enforces a byte count limit. BinaryReader::read() is renamed to readExact() for clarity. Tests updated throughout to match the new APIs.
86 lines
2.2 KiB
PHP
86 lines
2.2 KiB
PHP
<?php
|
|
|
|
use Shufflingpixels\IO\Buffer;
|
|
|
|
it('reads, seeks and tracks position', function () {
|
|
$buffer = new Buffer('abcdef');
|
|
|
|
expect($buffer->length())->toBe(6)
|
|
->and($buffer->tell())->toBe(0)
|
|
->and($buffer->eof())->toBeFalse();
|
|
|
|
expect($buffer->read(2))->toBe('ab')
|
|
->and($buffer->tell())->toBe(2);
|
|
|
|
$buffer->seek(-1, SEEK_END);
|
|
|
|
expect($buffer->tell())->toBe(5)
|
|
->and($buffer->read(1))->toBe('f')
|
|
->and($buffer->eof())->toBeTrue();
|
|
});
|
|
|
|
it('supports relative seek modes', function () {
|
|
$buffer = new Buffer('abcdef');
|
|
|
|
$buffer->seek(3);
|
|
$buffer->seek(-2, SEEK_CUR);
|
|
|
|
expect($buffer->tell())->toBe(1)
|
|
->and($buffer->read(2))->toBe('bc');
|
|
});
|
|
|
|
it('throws for out of bounds seek', function () {
|
|
$buffer = new Buffer('abc');
|
|
|
|
expect(fn () => $buffer->seek(4))->toThrow(OutOfBoundsException::class);
|
|
});
|
|
|
|
it('throws for negative read length', function () {
|
|
$buffer = new Buffer('abc');
|
|
|
|
expect(fn () => $buffer->read(-1))->toThrow(InvalidArgumentException::class);
|
|
});
|
|
|
|
it('returns available bytes when reading beyond end of stream', function () {
|
|
$buffer = new Buffer('abc');
|
|
|
|
expect($buffer->read(4))->toBe('abc')
|
|
->and($buffer->eof())->toBeTrue();
|
|
});
|
|
|
|
it('returns false when reading at end of stream', function () {
|
|
$buffer = new Buffer('a');
|
|
$buffer->read(1);
|
|
|
|
expect($buffer->read(1))->toBeFalse();
|
|
});
|
|
|
|
it('writes at current position and updates contents', function () {
|
|
$buffer = new Buffer('abcdef');
|
|
$buffer->seek(2);
|
|
|
|
expect($buffer->write('XY'))->toBe(2)
|
|
->and($buffer->tell())->toBe(4);
|
|
|
|
$buffer->seek(0);
|
|
|
|
expect($buffer->read(6))->toBe('abXYef');
|
|
});
|
|
|
|
it('writes nothing for empty payload', function () {
|
|
$buffer = new Buffer('abc');
|
|
|
|
expect($buffer->write(''))->toBe(0)
|
|
->and($buffer->tell())->toBe(0)
|
|
->and($buffer->length())->toBe(3);
|
|
});
|
|
|
|
it('reads remaining bytes from cursor to end', function () {
|
|
$buffer = new Buffer('abcdef');
|
|
$buffer->seek(2);
|
|
|
|
$remaining = $buffer->read($buffer->length() - $buffer->tell());
|
|
|
|
expect($remaining)->toBe('cdef')
|
|
->and($buffer->eof())->toBeTrue();
|
|
});
|