123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123 |
- <?php
- namespace Predis\Protocol\Text;
- use PredisTestCase;
- class ResponseReaderTest extends PredisTestCase
- {
-
- public function testDefaultHandlers()
- {
- $reader = new ResponseReader();
- $this->assertInstanceOf('Predis\Protocol\Text\Handler\StatusResponse', $reader->getHandler('+'));
- $this->assertInstanceOf('Predis\Protocol\Text\Handler\ErrorResponse', $reader->getHandler('-'));
- $this->assertInstanceOf('Predis\Protocol\Text\Handler\IntegerResponse', $reader->getHandler(':'));
- $this->assertInstanceOf('Predis\Protocol\Text\Handler\BulkResponse', $reader->getHandler('$'));
- $this->assertInstanceOf('Predis\Protocol\Text\Handler\MultiBulkResponse', $reader->getHandler('*'));
- $this->assertNull($reader->getHandler('!'));
- }
-
- public function testReplaceHandler()
- {
- $handler = $this->getMock('Predis\Protocol\Text\Handler\ResponseHandlerInterface');
- $reader = new ResponseReader();
- $reader->setHandler('+', $handler);
- $this->assertSame($handler, $reader->getHandler('+'));
- }
-
- public function testReadResponse()
- {
- $reader = new ResponseReader();
- $protocol = new CompositeProtocolProcessor();
- $protocol->setResponseReader($reader);
- $connection = $this->getMock('Predis\Connection\CompositeConnectionInterface');
- $connection->expects($this->at(0))
- ->method('readLine')
- ->will($this->returnValue('+OK'));
- $connection->expects($this->at(1))
- ->method('readLine')
- ->will($this->returnValue('-ERR error message'));
- $connection->expects($this->at(2))
- ->method('readLine')
- ->will($this->returnValue(':2'));
- $connection->expects($this->at(3))
- ->method('readLine')
- ->will($this->returnValue('$-1'));
- $connection->expects($this->at(4))
- ->method('readLine')
- ->will($this->returnValue('*-1'));
- $this->assertEquals('OK', $reader->read($connection));
- $this->assertEquals('ERR error message', $reader->read($connection));
- $this->assertSame(2, $reader->read($connection));
- $this->assertNull($reader->read($connection));
- $this->assertNull($reader->read($connection));
- }
-
- public function testEmptyResponseHeader()
- {
- $reader = new ResponseReader();
- $connection = $this->getMock('Predis\Connection\CompositeConnectionInterface');
- $connection->expects($this->once())
- ->method('readLine')
- ->will($this->returnValue(''));
- $reader->read($connection);
- }
-
- public function testUnknownResponsePrefix()
- {
- $reader = new ResponseReader();
- $connection = $this->getMock('Predis\Connection\CompositeConnectionInterface');
- $connection->expects($this->once())
- ->method('readLine')
- ->will($this->returnValue('!'));
- $reader->read($connection);
- }
- }
|