PhpiredisStreamConnectionTest.php 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. <?php
  2. /*
  3. * This file is part of the Predis package.
  4. *
  5. * (c) Daniele Alessandri <suppakilla@gmail.com>
  6. *
  7. * For the full copyright and license information, please view the LICENSE
  8. * file that was distributed with this source code.
  9. */
  10. namespace Predis\Connection;
  11. /**
  12. * @group ext-phpiredis
  13. */
  14. class PhpiredisStreamConnectionTest extends PredisConnectionTestCase
  15. {
  16. /**
  17. * @group disconnected
  18. */
  19. public function testConstructorDoesNotOpenConnection()
  20. {
  21. $connection = new PhpiredisStreamConnection($this->getParameters());
  22. $this->assertFalse($connection->isConnected());
  23. }
  24. /**
  25. * @group disconnected
  26. */
  27. public function testSupportsSchemeTCP()
  28. {
  29. $parameters = $this->getParameters(array('scheme' => 'tcp'));
  30. $connection = new PhpiredisStreamConnection($parameters);
  31. $this->assertInstanceOf('Predis\Connection\NodeConnectionInterface', $connection);
  32. }
  33. /**
  34. * @group disconnected
  35. */
  36. public function testSupportsSchemeRedis()
  37. {
  38. $parameters = $this->getParameters(array('scheme' => 'redis'));
  39. $connection = new PhpiredisStreamConnection($parameters);
  40. $this->assertInstanceOf('Predis\Connection\NodeConnectionInterface', $connection);
  41. }
  42. /**
  43. * @group disconnected
  44. */
  45. public function testSupportsSchemeUnix()
  46. {
  47. $parameters = $this->getParameters(array('scheme' => 'unix'));
  48. $connection = new PhpiredisStreamConnection($parameters);
  49. $this->assertInstanceOf('Predis\Connection\NodeConnectionInterface', $connection);
  50. }
  51. /**
  52. * @group disconnected
  53. * @expectedException \InvalidArgumentException
  54. * @expectedExceptionMessage Invalid scheme: 'udp'.
  55. */
  56. public function testThrowsExceptionOnInvalidScheme()
  57. {
  58. $parameters = $this->getParameters(array('scheme' => 'udp'));
  59. new PhpiredisStreamConnection($parameters);
  60. }
  61. /**
  62. * @group disconnected
  63. */
  64. public function testExposesParameters()
  65. {
  66. $parameters = $this->getParameters();
  67. $connection = new PhpiredisStreamConnection($parameters);
  68. $this->assertSame($parameters, $connection->getParameters());
  69. }
  70. /**
  71. * @group disconnected
  72. */
  73. public function testCanBeSerialized()
  74. {
  75. $parameters = $this->getParameters(array('alias' => 'redis', 'read_write_timeout' => 10));
  76. $connection = new PhpiredisStreamConnection($parameters);
  77. $unserialized = unserialize(serialize($connection));
  78. $this->assertInstanceOf('Predis\Connection\PhpiredisStreamConnection', $unserialized);
  79. $this->assertEquals($parameters, $unserialized->getParameters());
  80. }
  81. // ******************************************************************** //
  82. // ---- INTEGRATION TESTS --------------------------------------------- //
  83. // ******************************************************************** //
  84. /**
  85. * @group connected
  86. */
  87. public function testAcceptsTcpNodelayParameter()
  88. {
  89. if (!version_compare(PHP_VERSION, '5.4.0', '>=')) {
  90. $this->markTestSkipped('Setting TCP_NODELAY on PHP socket streams works on PHP >= 5.4.0');
  91. }
  92. $connection = new PhpiredisStreamConnection($this->getParameters(array('tcp_nodelay' => false)));
  93. $connection->connect();
  94. $this->assertTrue($connection->isConnected());
  95. $connection = new PhpiredisStreamConnection($this->getParameters(array('tcp_nodelay' => true)));
  96. $connection->connect();
  97. $this->assertTrue($connection->isConnected());
  98. }
  99. /**
  100. * @group connected
  101. */
  102. public function testExecutesCommandsOnServer()
  103. {
  104. $connection = $this->getConnection($profile, true);
  105. $cmdPing = $profile->createCommand('ping');
  106. $cmdEcho = $profile->createCommand('echo', array('echoed'));
  107. $cmdGet = $profile->createCommand('get', array('foobar'));
  108. $cmdRpush = $profile->createCommand('rpush', array('metavars', 'foo', 'hoge', 'lol'));
  109. $cmdLrange = $profile->createCommand('lrange', array('metavars', 0, -1));
  110. $this->assertEquals('PONG', $connection->executeCommand($cmdPing));
  111. $this->assertSame('echoed', $connection->executeCommand($cmdEcho));
  112. $this->assertNull($connection->executeCommand($cmdGet));
  113. $this->assertSame(3, $connection->executeCommand($cmdRpush));
  114. $this->assertSame(array('foo', 'hoge', 'lol'), $connection->executeCommand($cmdLrange));
  115. }
  116. /**
  117. * @medium
  118. * @group connected
  119. * @expectedException \Predis\Protocol\ProtocolException
  120. * @expectedExceptionMessage Protocol error, got "P" as reply type byte
  121. */
  122. public function testThrowsExceptionOnProtocolDesynchronizationErrors()
  123. {
  124. $connection = $this->getConnection($profile);
  125. $socket = $connection->getResource();
  126. $connection->writeRequest($profile->createCommand('ping'));
  127. fread($socket, 1);
  128. $connection->read();
  129. }
  130. // ******************************************************************** //
  131. // ---- HELPER METHODS ------------------------------------------------ //
  132. // ******************************************************************** //
  133. /**
  134. * {@inheritdoc}
  135. */
  136. protected function getConnection(&$profile = null, $initialize = false, array $parameters = array())
  137. {
  138. $parameters = $this->getParameters($parameters);
  139. $profile = $this->getProfile();
  140. $connection = new PhpiredisStreamConnection($parameters);
  141. if ($initialize) {
  142. $connection->addConnectCommand(
  143. $profile->createCommand('select', array($parameters->database))
  144. );
  145. $connection->addConnectCommand(
  146. $profile->createCommand('flushdb')
  147. );
  148. }
  149. return $connection;
  150. }
  151. }