<?php defined('PHPREDIS_TESTRUN') or die("Use TestRedis.php to run tests!\n");

require_once(dirname($_SERVER['PHP_SELF'])."/TestSuite.php");

class Redis_Test extends TestSuite

{

/* City lat/long */

protected $cities = [

'Chico' => [-121.837478, 39.728494],

'Sacramento' => [-121.494400, 38.581572],

'Gridley' => [-121.693583, 39.363777],

'Marysville' => [-121.591355, 39.145725],

'Cupertino' => [-122.032182, 37.322998]

];

protected $serializers = [

Redis::SERIALIZER_NONE,

Redis::SERIALIZER_PHP,

];

/**

* @var Redis

*/

public $redis;

/**

* @var string

*/

protected $sessionPrefix = 'PHPREDIS_SESSION:';

/**

* @var string

*/

protected $sessionSaveHandler = 'redis';

public function setUp() {

$this->redis = $this->newInstance();

$info = $this->redis->info();

$this->version = (isset($info['redis_version'])?$info['redis_version']:'0.0.0');

if (defined('Redis::SERIALIZER_IGBINARY')) {

$this->serializers[] = Redis::SERIALIZER_IGBINARY;

}

}

protected function minVersionCheck($version) {

return version_compare($this->version, $version) >= 0;

}

protected function mstime() {

return round(microtime(true)*1000);

}

protected function getAuthParts(&$user, &$pass) {

$user = $pass = NULL;

$auth = $this->getAuth();

if ( ! $auth)

return;

if (is_array($auth)) {

if (count($auth) > 1) {

list($user, $pass) = $auth;

} else {

$pass = $auth[0];

}

} else {

$pass = $auth;

}

}

protected function getAuthFragment() {

static $_authidx = 0;

$_authidx++;

$this->getAuthParts($user, $pass);

if ($user && $pass) {

if ($_authidx % 2 == 0)

return "auth[user]=$user&auth[pass]=$pass";

else

return "auth[]=$user&auth[]=$pass";

} else if ($pass) {

if ($_authidx % 3 == 0)

return "auth[pass]=$pass";

if ($_authidx % 2 == 0)

return "auth[]=$pass";

else

return "auth=$pass";

} else {

return NULL;

}

}

protected function getFullHostPath()

{

$fullHostPath = parent::getFullHostPath();

$authFragment = $this->getAuthFragment();

if (isset($fullHostPath) && $authFragment) {

$fullHostPath .= "?$authFragment";

}

return $fullHostPath;

}

protected function newInstance() {

$r = new Redis([

'host' => $this->getHost(),

'port' => $this->getPort(),

]);

if($this->getAuth()) {

$this->assertTrue($r->auth($this->getAuth()));

}

return $r;

}

public function tearDown() {

if($this->redis) {

$this->redis->close();

}

}

public function reset()

{

$this->setUp();

$this->tearDown();

}

/* Helper function to determine if the clsas has pipeline support */

protected function havePipeline() {

$str_constant = get_class($this->redis) . '::PIPELINE';

return defined($str_constant);

}

public function testMinimumVersion()

{

// Minimum server version required for tests

$this->assertTrue(version_compare($this->version, "2.4.0") >= 0);

}

public function testPing() {

/* Reply literal off */

$this->assertTrue($this->redis->ping());

$this->assertTrue($this->redis->ping(NULL));

$this->assertEquals('BEEP', $this->redis->ping('BEEP'));

/* Make sure we're good in MULTI mode */

$this->redis->multi();

$this->redis->ping();

$this->redis->ping('BEEP');

$this->assertEquals([true, 'BEEP'], $this->redis->exec());

}

public function testPipelinePublish() {

if (!$this->havePipeline()) {

$this->markTestSkipped();

}

$ret = $this->redis->pipeline()

->publish('chan', 'msg')

->exec();

$this->assertTrue(is_array($ret) && count($ret) === 1 && $ret[0] >= 0);

}

// Run some simple tests against the PUBSUB command. This is problematic, as we

// can't be sure what's going on in the instance, but we can do some things.

public function testPubSub() {

// Only available since 2.8.0

if (version_compare($this->version, "2.8.0") < 0) {

$this->markTestSkipped();

return;

}

// PUBSUB CHANNELS ...

$result = $this->redis->pubsub("channels", "*");

$this->assertTrue(is_array($result));

$result = $this->redis->pubsub("channels");

$this->assertTrue(is_array($result));

// PUBSUB NUMSUB

$c1 = uniqid() . '-' . rand(1,100);

$c2 = uniqid() . '-' . rand(1,100);

$result = $this->redis->pubsub("numsub", [$c1, $c2]);

// Should get an array back, with two elements

$this->assertTrue(is_array($result));

$this->assertEquals(count($result), 2);

// Make sure the elements are correct, and have zero counts

foreach([$c1,$c2] as $channel) {

$this->assertTrue(isset($result[$channel]));

$this->assertEquals($result[$channel], 0);

}

// PUBSUB NUMPAT

$result = $this->redis->pubsub("numpat");

$this->assertTrue(is_int($result));

// Invalid calls

$this->assertFalse(@$this->redis->pubsub("notacommand"));

$this->assertFalse(@$this->redis->pubsub("numsub", "not-an-array"));

}

/* These test cases were generated randomly. We're just trying to test

that PhpRedis handles all combination of arguments correctly. */

public function testBitcount() {

/* key */

$this->redis->set('bitcountkey', hex2bin('bd906b854ca76cae'));

$this->assertEquals(33, $this->redis->bitcount('bitcountkey'));

/* key, start */

$this->redis->set('bitcountkey', hex2bin('400aac171382a29bebaab554f178'));

$this->assertEquals(4, $this->redis->bitcount('bitcountkey', 13));

/* key, start, end */

$this->redis->set('bitcountkey', hex2bin('b1f32405'));

$this->assertEquals(2, $this->redis->bitcount('bitcountkey', 3, 3));

/* key, start, end BYTE */

$this->redis->set('bitcountkey', hex2bin('10eb8939e68bfdb640260f0629f3'));

$this->assertEquals(1, $this->redis->bitcount('bitcountkey', 8, 8, false));

/* key, start, end, BIT */

$this->redis->set('bitcountkey', hex2bin('cd0e4c80f9e4590d888a10'));

$this->assertEquals(5, $this->redis->bitcount('bitcountkey', 0, 9, true));

}

public function testBitop() {

if (!$this->minVersionCheck('2.6.0'))

$this->markTestSkipped();

$this->redis->set("{key}1", "foobar");

$this->redis->set("{key}2", "abcdef");

// Regression test for GitHub issue #2210

$this->assertEquals(6, $this->redis->bitop('AND', '{key}1', '{key}2'));

// Make sure RedisCluster doesn't even send the command. We don't care

// about what Redis returns

@$this->redis->bitop('AND', 'key1', 'key2', 'key3');

$this->assertEquals(NULL, $this->redis->getLastError());

$this->redis->del('{key}1', '{key}2');

}

public function testBitsets() {

$this->redis->del('key');

$this->assertEquals(0, $this->redis->getBit('key', 0));

$this->assertEquals(FALSE, $this->redis->getBit('key', -1));

$this->assertEquals(0, $this->redis->getBit('key', 100000));

$this->redis->set('key', "\xff");

for($i = 0; $i < 8; $i++) {

$this->assertEquals(1, $this->redis->getBit('key', $i));

}

$this->assertEquals(0, $this->redis->getBit('key', 8));

// change bit 0

$this->assertEquals(1, $this->redis->setBit('key', 0, 0));

$this->assertEquals(0, $this->redis->setBit('key', 0, 0));

$this->assertEquals(0, $this->redis->getBit('key', 0));

$this->assertEquals("\x7f", $this->redis->get('key'));

// change bit 1

$this->assertEquals(1, $this->redis->setBit('key', 1, 0));

$this->assertEquals(0, $this->redis->setBit('key', 1, 0));

$this->assertEquals(0, $this->redis->getBit('key', 1));

$this->assertEquals("\x3f", $this->redis->get('key'));

// change bit > 1

$this->assertEquals(1, $this->redis->setBit('key', 2, 0));

$this->assertEquals(0, $this->redis->setBit('key', 2, 0));

$this->assertEquals(0, $this->redis->getBit('key', 2));

$this->assertEquals("\x1f", $this->redis->get('key'));

// values above 1 are changed to 1 but don't overflow on bits to the right.

$this->assertEquals(0, $this->redis->setBit('key', 0, 0xff));

$this->assertEquals("\x9f", $this->redis->get('key'));

// Verify valid offset ranges

$this->assertFalse($this->redis->getBit('key', -1));

$this->redis->setBit('key', 0x7fffffff, 1);

$this->assertEquals(1, $this->redis->getBit('key', 0x7fffffff));

}

public function testLcs() {

$key1 = '{lcs}1'; $key2 = '{lcs}2';

$this->assertTrue($this->redis->set($key1, '12244447777777'));

$this->assertTrue($this->redis->set($key2, '6666662244441'));

$this->assertEquals('224444', $this->redis->lcs($key1, $key2));

$this->assertEquals(

['matches', [[[1, 6], [6, 11]]], 'len', 6],

$this->redis->lcs($key1, $key2, ['idx'])

);

$this->assertEquals(

['matches', [[[1, 6], [6, 11], 6]], 'len', 6],

$this->redis->lcs($key1, $key2, ['idx', 'withmatchlen'])

);

$this->assertEquals(6, $this->redis->lcs($key1, $key2, ['len']));

$this->redis->del([$key1, $key2]);

}

public function testLmpop() {

if(version_compare($this->version, "7.0.0") < 0) {

$this->markTestSkipped();

}

$key1 = '{l}1';

$key2 = '{l}2';

$this->assertTrue($this->redis->del($key1, $key2) !== false);

$this->assertEquals(6, $this->redis->rpush($key1, 'A', 'B', 'C', 'D', 'E', 'F'));

$this->assertEquals(6, $this->redis->rpush($key2, 'F', 'E', 'D', 'C', 'B', 'A'));

$this->assertEquals([$key1, ['A']], $this->redis->lmpop([$key1, $key2], 'LEFT'));

$this->assertEquals([$key1, ['F']], $this->redis->lmpop([$key1, $key2], 'RIGHT'));

$this->assertEquals([$key1, ['B', 'C', 'D']], $this->redis->lmpop([$key1, $key2], 'LEFT', 3));

$this->assertEquals(2, $this->redis->del($key1, $key2));

}

public function testBLmpop() {

if(version_compare($this->version, "7.0.0") < 0) {

$this->markTestSkipped();

}

$key1 = '{bl}1';

$key2 = '{bl}2';

$this->assertTrue($this->redis->del($key1, $key2) !== false);

$this->assertEquals(2, $this->redis->rpush($key1, 'A', 'B'));

$this->assertEquals(2, $this->redis->rpush($key2, 'C', 'D'));

$this->assertEquals([$key1, ['B', 'A']], $this->redis->blmpop(.2, [$key1, $key2], 'RIGHT', 2));

$this->assertEquals([$key2, ['C']], $this->redis->blmpop(.2, [$key1, $key2], 'LEFT'));

$this->assertEquals([$key2, ['D']], $this->redis->blmpop(.2, [$key1, $key2], 'LEFT'));

$st = microtime(true);

$this->assertFalse($this->redis->blmpop(.2, [$key1, $key2], 'LEFT'));

$et = microtime(true);

$this->assertTrue($et - $st >= .2);

}

function testZmpop() {

if(version_compare($this->version, "7.0.0") < 0) {

$this->markTestSkipped();

}

$key1 = '{z}1';

$key2 = '{z}2';

$this->assertTrue($this->redis->del($key1, $key2) !== false);

$this->assertEquals(4, $this->redis->zadd($key1, 0, 'zero', 2, 'two', 4, 'four', 6, 'six'));

$this->assertEquals(4, $this->redis->zadd($key2, 1, 'one', 3, 'three', 5, 'five', 7, 'seven'));

$this->assertEquals([$key1, ['zero' => 0.0]], $this->redis->zmpop([$key1, $key2], 'MIN'));

$this->assertEquals([$key1, ['six' => 6.0]], $this->redis->zmpop([$key1, $key2], 'MAX'));

$this->assertEquals([$key1, ['two' => 2.0, 'four' => 4.0]], $this->redis->zmpop([$key1, $key2], 'MIN', 3));

$this->assertEquals(

[$key2, ['one' => 1.0, 'three' => 3.0, 'five' => 5.0, 'seven' => 7.0]],

$this->redis->zmpop([$key1, $key2], 'MIN', 128)

);

$this->assertFalse($this->redis->zmpop([$key1, $key2], 'MIN'));

$this->redis->setOption(Redis::OPT_NULL_MULTIBULK_AS_NULL, true);

$this->assertEquals(NULL, $this->redis->zmpop([$key1, $key2], 'MIN'));

$this->redis->setOption(Redis::OPT_NULL_MULTIBULK_AS_NULL, false);

}

function testBZmpop() {

if(version_compare($this->version, "7.0.0") < 0) {

$this->markTestSkipped();

}

$key1 = '{z}1';

$key2 = '{z}2';

$this->assertTrue($this->redis->del($key1, $key2) !== false);

$this->assertEquals(2, $this->redis->zadd($key1, 0, 'zero', 2, 'two'));

$this->assertEquals(2, $this->redis->zadd($key2, 1, 'one', 3, 'three'));

$this->assertEquals(

[$key1, ['zero' => 0.0, 'two' => 2.0]],

$this->redis->bzmpop(.1, [$key1, $key2], 'MIN', 2)

);

$this->assertEquals([$key2, ['three' => 3.0]], $this->redis->bzmpop(.1, [$key1, $key2], 'MAX'));

$this->assertEquals([$key2, ['one' => 1.0]], $this->redis->bzmpop(.1, [$key1, $key2], 'MAX'));

$st = microtime(true);

$this->assertFalse($this->redis->bzmpop(.2, [$key1, $key2], 'MIN'));

$et = microtime(true);

$this->assertTrue($et - $st >= .2);

}

public function testBitPos() {

if (version_compare($this->version, "2.8.7") < 0) {

$this->MarkTestSkipped();

return;

}

$this->redis->del('bpkey');

$this->redis->set('bpkey', "\xff\xf0\x00");

$this->assertEquals($this->redis->bitpos('bpkey', 0), 12);

$this->redis->set('bpkey', "\x00\xff\xf0");

$this->assertEquals($this->redis->bitpos('bpkey', 1, 0), 8);

$this->assertEquals($this->redis->bitpos('bpkey', 1, 1), 8);

$this->redis->set('bpkey', "\x00\x00\x00");

$this->assertEquals($this->redis->bitpos('bpkey', 1), -1);

if (!$this->minVersionCheck("7.0.0"))

return;

$this->redis->set('bpkey', "\xF");

$this->assertEquals(4, $this->redis->bitpos('bpkey', 1, 0, -1, true));

$this->assertEquals(-1, $this->redis->bitpos('bpkey', 1, 1, -1));

$this->assertEquals(-1, $this->redis->bitpos('bpkey', 1, 1, -1, false));

}

public function test1000() {

$s = str_repeat('A', 1000);

$this->redis->set('x', $s);

$this->assertEquals($s, $this->redis->get('x'));

$s = str_repeat('A', 1000000);

$this->redis->set('x', $s);

$this->assertEquals($s, $this->redis->get('x'));

}

public function testEcho() {

$this->assertEquals($this->redis->echo("hello"), "hello");

$this->assertEquals($this->redis->echo(""), "");

$this->assertEquals($this->redis->echo(" 0123 "), " 0123 ");

}

public function testErr() {

$this->redis->set('x', '-ERR');

$this->assertEquals($this->redis->get('x'), '-ERR');

}

public function testSet()

{

$this->assertEquals(TRUE, $this->redis->set('key', 'nil'));

$this->assertEquals('nil', $this->redis->get('key'));

$this->assertEquals(TRUE, $this->redis->set('key', 'val'));

$this->assertEquals('val', $this->redis->get('key'));

$this->assertEquals('val', $this->redis->get('key'));

$this->redis->del('keyNotExist');

$this->assertEquals(FALSE, $this->redis->get('keyNotExist'));

$this->redis->set('key2', 'val');

$this->assertEquals('val', $this->redis->get('key2'));

$value = 'AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA';

$this->redis->set('key2', $value);

$this->assertEquals($value, $this->redis->get('key2'));

$this->assertEquals($value, $this->redis->get('key2'));

$this->redis->del('key');

$this->redis->del('key2');

$i = 66000;

$value2 = 'X';

while($i--) {

$value2 .= 'A';

}

$value2 .= 'X';

$this->redis->set('key', $value2);

$this->assertEquals($value2, $this->redis->get('key'));

$this->redis->del('key');

$this->assertEquals(False, $this->redis->get('key'));

$data = gzcompress('42');

$this->assertEquals(True, $this->redis->set('key', $data));

$this->assertEquals('42', gzuncompress($this->redis->get('key')));

$this->redis->del('key');

$data = gzcompress('value1');

$this->assertEquals(True, $this->redis->set('key', $data));

$this->assertEquals('value1', gzuncompress($this->redis->get('key')));

$this->redis->del('key');

$this->assertEquals(TRUE, $this->redis->set('key', 0));

$this->assertEquals('0', $this->redis->get('key'));

$this->assertEquals(TRUE, $this->redis->set('key', 1));

$this->assertEquals('1', $this->redis->get('key'));

$this->assertEquals(TRUE, $this->redis->set('key', 0.1));

$this->assertEquals('0.1', $this->redis->get('key'));

$this->assertEquals(TRUE, $this->redis->set('key', '0.1'));

$this->assertEquals('0.1', $this->redis->get('key'));

$this->assertEquals(TRUE, $this->redis->set('key', TRUE));

$this->assertEquals('1', $this->redis->get('key'));

$this->assertEquals(True, $this->redis->set('key', ''));

$this->assertEquals('', $this->redis->get('key'));

$this->assertEquals(True, $this->redis->set('key', NULL));

$this->assertEquals('', $this->redis->get('key'));

$this->assertEquals(True, $this->redis->set('key', gzcompress('42')));

$this->assertEquals('42', gzuncompress($this->redis->get('key')));

}

/* Extended SET options for Redis >= 2.6.12 */

public function testExtendedSet() {

// Skip the test if we don't have a new enough version of Redis

if (version_compare($this->version, '2.6.12') < 0) {

$this->markTestSkipped();

return;

}

/* Legacy SETEX redirection */

$this->redis->del('foo');

$this->assertTrue($this->redis->set('foo','bar', 20));

$this->assertEquals($this->redis->get('foo'), 'bar');

$this->assertEquals($this->redis->ttl('foo'), 20);

/* Should coerce doubles into long */

$this->assertTrue($this->redis->set('foo', 'bar-20.5', 20.5));

$this->assertEquals($this->redis->ttl('foo'), 20);

$this->assertEquals($this->redis->get('foo'), 'bar-20.5');

/* Invalid third arguments */

$this->assertFalse(@$this->redis->set('foo','bar','baz'));

$this->assertFalse(@$this->redis->set('foo','bar',new StdClass()));

/* Set if not exist */

$this->redis->del('foo');

$this->assertTrue($this->redis->set('foo','bar', ['nx']));

$this->assertEquals($this->redis->get('foo'), 'bar');

$this->assertFalse($this->redis->set('foo','bar', ['nx']));

/* Set if exists */

$this->assertTrue($this->redis->set('foo','bar', ['xx']));

$this->assertEquals($this->redis->get('foo'), 'bar');

$this->redis->del('foo');

$this->assertFalse($this->redis->set('foo','bar', ['xx']));

/* Set with a TTL */

$this->assertTrue($this->redis->set('foo','bar', ['ex'=>100]));

$this->assertEquals($this->redis->ttl('foo'), 100);

/* Set with a PTTL */

$this->assertTrue($this->redis->set('foo','bar',['px'=>100000]));

$this->assertTrue(100000 - $this->redis->pttl('foo') < 1000);

/* Set if exists, with a TTL */

$this->assertTrue($this->redis->set('foo','bar',['xx','ex'=>105]));

$this->assertEquals($this->redis->ttl('foo'), 105);

$this->assertEquals($this->redis->get('foo'), 'bar');

/* Set if not exists, with a TTL */

$this->redis->del('foo');

$this->assertTrue($this->redis->set('foo','bar', ['nx', 'ex'=>110]));

$this->assertEquals($this->redis->ttl('foo'), 110);

$this->assertEquals($this->redis->get('foo'), 'bar');

$this->assertFalse($this->redis->set('foo','bar', ['nx', 'ex'=>110]));

/* Throw some nonsense into the array, and check that the TTL came through */

$this->redis->del('foo');

$this->assertTrue($this->redis->set('foo','barbaz', ['not-valid','nx','invalid','ex'=>200]));

$this->assertEquals($this->redis->ttl('foo'), 200);

$this->assertEquals($this->redis->get('foo'), 'barbaz');

/* Pass NULL as the optional arguments which should be ignored */

$this->redis->del('foo');

$this->redis->set('foo','bar', NULL);

$this->assertEquals($this->redis->get('foo'), 'bar');

$this->assertTrue($this->redis->ttl('foo')<0);

/* Make sure we ignore bad/non-string options (regression test for #1835) */

$this->assertTrue($this->redis->set('foo', 'bar', [NULL, 'EX' => 60]));

$this->assertTrue($this->redis->set('foo', 'bar', [NULL, new stdClass(), 'EX' => 60]));

$this->assertFalse(@$this->redis->set('foo', 'bar', [NULL, 'EX' => []]));

if (version_compare($this->version, "6.0.0") < 0)

return;

/* KEEPTTL works by itself */

$this->redis->set('foo', 'bar', ['EX' => 100]);

$this->redis->set('foo', 'bar', ['KEEPTTL']);

$this->assertTrue($this->redis->ttl('foo') > -1);

/* Works with other options */

$this->redis->set('foo', 'bar', ['XX', 'KEEPTTL']);

$this->assertTrue($this->redis->ttl('foo') > -1);

$this->redis->set('foo', 'bar', ['XX']);

$this->assertTrue($this->redis->ttl('foo') == -1);

if (version_compare($this->version, "6.2.0") < 0)

return;

$this->assertTrue($this->redis->set('foo', 'baz', ['GET']) === 'bar');

}

public function testGetSet() {

$this->redis->del('key');

$this->assertTrue($this->redis->getSet('key', '42') === FALSE);

$this->assertTrue($this->redis->getSet('key', '123') === '42');

$this->assertTrue($this->redis->getSet('key', '123') === '123');

}

public function testRandomKey() {

for($i = 0; $i < 1000; $i++) {

$k = $this->redis->randomKey();

$this->assertEquals($this->redis->exists($k), 1);

}

}

public function testRename() {

// strings

$this->redis->del('{key}0');

$this->redis->set('{key}0', 'val0');

$this->redis->rename('{key}0', '{key}1');

$this->assertEquals(FALSE, $this->redis->get('{key}0'));

$this->assertEquals('val0', $this->redis->get('{key}1'));

}

public function testRenameNx() {

// strings

$this->redis->del('{key}0', '{key}1');

$this->redis->set('{key}0', 'val0');

$this->redis->set('{key}1', 'val1');

$this->assertTrue($this->redis->renameNx('{key}0', '{key}1') === FALSE);

$this->assertTrue($this->redis->get('{key}0') === 'val0');

$this->assertTrue($this->redis->get('{key}1') === 'val1');

// lists

$this->redis->del('{key}0');

$this->redis->del('{key}1');

$this->redis->lPush('{key}0', 'val0');

$this->redis->lPush('{key}0', 'val1');

$this->redis->lPush('{key}1', 'val1-0');

$this->redis->lPush('{key}1', 'val1-1');

$this->assertTrue($this->redis->renameNx('{key}0', '{key}1') === FALSE);

$this->assertTrue($this->redis->lRange('{key}0', 0, -1) === ['val1', 'val0']);

$this->assertTrue($this->redis->lRange('{key}1', 0, -1) === ['val1-1', 'val1-0']);

$this->redis->del('{key}2');

$this->assertTrue($this->redis->renameNx('{key}0', '{key}2') === TRUE);

$this->assertTrue($this->redis->lRange('{key}0', 0, -1) === []);

$this->assertTrue($this->redis->lRange('{key}2', 0, -1) === ['val1', 'val0']);

}

public function testMultiple() {

$this->redis->del('k1');

$this->redis->del('k2');

$this->redis->del('k3');

$this->redis->set('k1', 'v1');

$this->redis->set('k2', 'v2');

$this->redis->set('k3', 'v3');

$this->redis->set(1, 'test');

$this->assertEquals(['v1'], $this->redis->mget(['k1']));

$this->assertEquals(['v1', 'v3', false], $this->redis->mget(['k1', 'k3', 'NoKey']));

$this->assertEquals(['v1', 'v2', 'v3'], $this->redis->mget(['k1', 'k2', 'k3']));

$this->assertEquals(['v1', 'v2', 'v3'], $this->redis->mget(['k1', 'k2', 'k3']));

$this->redis->set('k5', '$1111111111');

$this->assertEquals([0 => '$1111111111'], $this->redis->mget(['k5']));

$this->assertEquals([0 => 'test'], $this->redis->mget([1])); // non-string

}

public function testMultipleBin() {

$this->redis->del('k1');

$this->redis->del('k2');

$this->redis->del('k3');

$this->redis->set('k1', gzcompress('v1'));

$this->redis->set('k2', gzcompress('v2'));

$this->redis->set('k3', gzcompress('v3'));

$this->assertEquals([gzcompress('v1'), gzcompress('v2'), gzcompress('v3')], $this->redis->mget(['k1', 'k2', 'k3']));

$this->assertEquals([gzcompress('v1'), gzcompress('v2'), gzcompress('v3')], $this->redis->mget(['k1', 'k2', 'k3']));

}

public function testSetTimeout() {

$this->redis->del('key');

$this->redis->set('key', 'value');

$this->assertEquals('value', $this->redis->get('key'));

$this->redis->expire('key', 1);

$this->assertEquals('value', $this->redis->get('key'));

sleep(2);

$this->assertEquals(False, $this->redis->get('key'));

}

/* This test is prone to failure in the Travis container, so attempt to mitigate this by running more than once */

public function testExpireAt() {

$success = false;

for ($i = 0; !$success && $i < 3; $i++) {

$this->redis->del('key');

$this->redis->set('key', 'value');

$this->redis->expireAt('key', time() + 1);

usleep(1500000);

$success = FALSE === $this->redis->get('key');

}

$this->assertTrue($success);

}

function testExpireOptions() {

if (!$this->minVersionCheck('7.0.0'))

return;

$this->redis->set('eopts', 'value');

/* NX -- Only if expiry isn't set so success, then failure */

$this->assertTrue($this->redis->expire('eopts', 1000, 'NX'));

$this->assertFalse($this->redis->expire('eopts', 1000, 'NX'));

/* XX -- Only set if the key has an existing expiry */

$this->assertTrue($this->redis->expire('eopts', 1000, 'XX'));

$this->assertTrue($this->redis->persist('eopts'));

$this->assertFalse($this->redis->expire('eopts', 1000, 'XX'));

/* GT -- Only set when new expiry > current expiry */

$this->assertTrue($this->redis->expire('eopts', 200));

$this->assertTrue($this->redis->expire('eopts', 300, 'GT'));

$this->assertFalse($this->redis->expire('eopts', 100, 'GT'));

/* LT -- Only set when expiry < current expiry */

$this->assertTrue($this->redis->expire('eopts', 200));

$this->assertTrue($this->redis->expire('eopts', 100, 'LT'));

$this->assertFalse($this->redis->expire('eopts', 300, 'LT'));

/* Sending a nonsensical mode fails without sending a command */

$this->redis->clearLastError();

$this->assertFalse(@$this->redis->expire('eopts', 999, 'nonsense'));

$this->assertEquals(NULL, $this->redis->getLastError());

$this->redis->del('eopts');

}

public function testExpiretime() {

if(version_compare($this->version, "7.0.0") < 0) {

$this->markTestSkipped();

}

$now = time();

$this->assertTrue($this->redis->set('key1', 'value'));

$this->assertTrue($this->redis->expireat('key1', $now + 10));

$this->assertEquals($now + 10, $this->redis->expiretime('key1'));

$this->assertEquals(1000 * ($now + 10), $this->redis->pexpiretime('key1'));

$this->redis->del('key1');

}

public function testSetEx() {

$this->redis->del('key');

$this->assertTrue($this->redis->setex('key', 7, 'val') === TRUE);

$this->assertTrue($this->redis->ttl('key') ===7);

$this->assertTrue($this->redis->get('key') === 'val');

}

public function testPSetEx() {

$this->redis->del('key');

$this->assertTrue($this->redis->psetex('key', 7 * 1000, 'val') === TRUE);

$this->assertTrue($this->redis->ttl('key') ===7);

$this->assertTrue($this->redis->get('key') === 'val');

}

public function testSetNX() {

$this->redis->set('key', 42);

$this->assertTrue($this->redis->setnx('key', 'err') === FALSE);

$this->assertTrue($this->redis->get('key') === '42');

$this->redis->del('key');

$this->assertTrue($this->redis->setnx('key', '42') === TRUE);

$this->assertTrue($this->redis->get('key') === '42');

}

public function testExpireAtWithLong() {

if (PHP_INT_SIZE != 8) {

$this->markTestSkipped('64 bits only');

}

$longExpiryTimeExceedingInt = 3153600000;

$this->redis->del('key');

$this->assertTrue($this->redis->setex('key', $longExpiryTimeExceedingInt, 'val') === TRUE);

$this->assertTrue($this->redis->ttl('key') === $longExpiryTimeExceedingInt);

}

public function testIncr()

{

$this->redis->set('key', 0);

$this->redis->incr('key');

$this->assertEquals(1, (int)$this->redis->get('key'));

$this->redis->incr('key');

$this->assertEquals(2, (int)$this->redis->get('key'));

$this->redis->incrBy('key', 3);

$this->assertEquals(5, (int)$this->redis->get('key'));

$this->redis->incrBy('key', 1);

$this->assertEquals(6, (int)$this->redis->get('key'));

$this->redis->incrBy('key', -1);

$this->assertEquals(5, (int)$this->redis->get('key'));

$this->redis->incr('key', 5);

$this->assertEquals(10, (int)$this->redis->get('key'));

$this->redis->del('key');

$this->redis->set('key', 'abc');

$this->redis->incr('key');

$this->assertTrue("abc" === $this->redis->get('key'));

$this->redis->incr('key');

$this->assertTrue("abc" === $this->redis->get('key'));

$this->redis->set('key', 0);

$this->assertEquals(PHP_INT_MAX, $this->redis->incrby('key', PHP_INT_MAX));

}

public function testIncrByFloat()

{

// incrbyfloat is new in 2.6.0

if (version_compare($this->version, "2.5.0") < 0) {

$this->markTestSkipped();

}

$this->redis->del('key');

$this->redis->set('key', 0);

$this->redis->incrbyfloat('key', 1.5);

$this->assertEquals('1.5', $this->redis->get('key'));

$this->redis->incrbyfloat('key', 2.25);

$this->assertEquals('3.75', $this->redis->get('key'));

$this->redis->incrbyfloat('key', -2.25);

$this->assertEquals('1.5', $this->redis->get('key'));

$this->redis->set('key', 'abc');

$this->redis->incrbyfloat('key', 1.5);

$this->assertTrue("abc" === $this->redis->get('key'));

$this->redis->incrbyfloat('key', -1.5);

$this->assertTrue("abc" === $this->redis->get('key'));

// Test with prefixing

$this->redis->setOption(Redis::OPT_PREFIX, 'someprefix:');

$this->redis->del('key');

$this->redis->incrbyfloat('key',1.8);

$this->assertEquals(1.8, floatval($this->redis->get('key'))); // convert to float to avoid rounding issue on arm

$this->redis->setOption(Redis::OPT_PREFIX, '');

$this->assertEquals(1, $this->redis->exists('someprefix:key'));

$this->redis->del('someprefix:key');

}

public function testDecr()

{

$this->redis->set('key', 5);

$this->redis->decr('key');

$this->assertEquals(4, (int)$this->redis->get('key'));

$this->redis->decr('key');

$this->assertEquals(3, (int)$this->redis->get('key'));

$this->redis->decrBy('key', 2);

$this->assertEquals(1, (int)$this->redis->get('key'));

$this->redis->decrBy('key', 1);

$this->assertEquals(0, (int)$this->redis->get('key'));

$this->redis->decrBy('key', -10);

$this->assertEquals(10, (int)$this->redis->get('key'));

$this->redis->decr('key', 10);

$this->assertEquals(0, (int)$this->redis->get('key'));

}

public function testExists() {

/* Single key */

$this->redis->del('key');

$this->assertEquals(0, $this->redis->exists('key'));

$this->redis->set('key', 'val');

$this->assertEquals(1, $this->redis->exists('key'));

/* Add multiple keys */

$mkeys = [];

for ($i = 0; $i < 10; $i++) {

if (rand(1, 2) == 1) {

$mkey = "{exists}key:$i";

$this->redis->set($mkey, $i);

$mkeys[] = $mkey;

}

}

/* Test passing an array as well as the keys variadic */

$this->assertEquals(count($mkeys), $this->redis->exists($mkeys));

$this->assertEquals(count($mkeys), $this->redis->exists(...$mkeys));

}

public function testTouch() {

if (!$this->minVersionCheck('3.2.1'))

$this->markTestSkipped();

$this->redis->del('notakey');

$this->assertTrue($this->redis->mset(['{idle}1' => 'beep', '{idle}2' => 'boop']));

usleep(1100000);

$this->assertTrue($this->redis->object('idletime', '{idle}1') >= 1);

$this->assertTrue($this->redis->object('idletime', '{idle}2') >= 1);

$this->assertEquals(2, $this->redis->touch('{idle}1', '{idle}2', '{idle}notakey'));

$this->assertTrue($this->redis->object('idletime', '{idle}1') == 0);

$this->assertTrue($this->redis->object('idletime', '{idle}2') == 0);

}

public function testKeys()

{

$pattern = 'keys-test-';

for($i = 1; $i < 10; $i++) {

$this->redis->set($pattern.$i, $i);

}

$this->redis->del($pattern.'3');

$keys = $this->redis->keys($pattern.'*');

$this->redis->set($pattern.'3', 'something');

$keys2 = $this->redis->keys($pattern.'*');

$this->assertEquals((count($keys) + 1), count($keys2));

// empty array when no key matches

$this->assertEquals([], $this->redis->keys(rand().rand().rand().'*'));

}

protected function genericDelUnlink($cmd) {

$key = 'key' . rand();

$this->redis->set($key, 'val');

$this->assertEquals('val', $this->redis->get($key));

$this->assertEquals(1, $this->redis->$cmd($key));

$this->assertEquals(false, $this->redis->get($key));

// multiple, all existing

$this->redis->set('x', 0);

$this->redis->set('y', 1);

$this->redis->set('z', 2);

$this->assertEquals(3, $this->redis->$cmd('x', 'y', 'z'));

$this->assertEquals(false, $this->redis->get('x'));

$this->assertEquals(false, $this->redis->get('y'));

$this->assertEquals(false, $this->redis->get('z'));

// multiple, none existing

$this->assertEquals(0, $this->redis->$cmd('x', 'y', 'z'));

$this->assertEquals(false, $this->redis->get('x'));

$this->assertEquals(false, $this->redis->get('y'));

$this->assertEquals(false, $this->redis->get('z'));

// multiple, some existing

$this->redis->set('y', 1);

$this->assertEquals(1, $this->redis->$cmd('x', 'y', 'z'));

$this->assertEquals(false, $this->redis->get('y'));

$this->redis->set('x', 0);

$this->redis->set('y', 1);