<?php

use Mockery as m;

class QueueRedisQueueTest extends PHPUnit_Framework_TestCase {

	public function tearDown()
	{
		m::close();
	}


	public function testPushProperlyPushesJobOntoRedis()
	{
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getRandomId'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->expects($this->once())->method('getRandomId')->will($this->returnValue('foo'));
		$redis->shouldReceive('rpush')->once()->with('queues:default', json_encode(array('job' => 'foo', 'data' => array('data'), 'id' => 'foo', 'attempts' => 1)));

		$id = $queue->push('foo', array('data'));
		$this->assertEquals('foo', $id);
	}


	public function testDelayedPushProperlyPushesJobOntoRedis()
	{
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getSeconds', 'getTime', 'getRandomId'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->expects($this->once())->method('getRandomId')->will($this->returnValue('foo'));
		$queue->expects($this->once())->method('getSeconds')->with(1)->will($this->returnValue(1));
		$queue->expects($this->once())->method('getTime')->will($this->returnValue(1));

		$redis->shouldReceive('zadd')->once()->with(
			'queues:default:delayed',
			2,
			json_encode(array('job' => 'foo', 'data' => array('data'), 'id' => 'foo', 'attempts' => 1))
		);

		$id = $queue->later(1, 'foo', array('data'));
		$this->assertEquals('foo', $id);
	}


	public function testDelayedPushWithDateTimeProperlyPushesJobOntoRedis()
	{
		$date = m::mock('DateTime');
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getSeconds', 'getTime', 'getRandomId'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->expects($this->once())->method('getRandomId')->will($this->returnValue('foo'));
		$queue->expects($this->once())->method('getSeconds')->with($date)->will($this->returnValue(1));
		$queue->expects($this->once())->method('getTime')->will($this->returnValue(1));

		$redis->shouldReceive('zadd')->once()->with(
			'queues:default:delayed',
			2,
			json_encode(array('job' => 'foo', 'data' => array('data'), 'id' => 'foo', 'attempts' => 1))
		);

		$queue->later($date, 'foo', array('data'));
	}


	public function testPopProperlyPopsJobOffOfRedis()
	{
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getTime', 'migrateAllExpiredJobs'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->setContainer(m::mock('Illuminate\Container\Container'));
		$queue->expects($this->once())->method('getTime')->will($this->returnValue(1));
		$queue->expects($this->once())->method('migrateAllExpiredJobs')->with($this->equalTo('queues:default'));
		$redis->shouldReceive('lpop')->once()->with('queues:default')->andReturn('foo');
		$redis->shouldReceive('zadd')->once()->with('queues:default:reserved', 61, 'foo');

		$result = $queue->pop();

		$this->assertInstanceOf('Illuminate\Queue\Jobs\RedisJob', $result);
	}


	public function testReleaseMethod()
	{
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getTime'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->expects($this->once())->method('getTime')->will($this->returnValue(1));
		$redis->shouldReceive('zadd')->once()->with('queues:default:delayed', 2, json_encode(array('attempts' => 2)));

		$queue->release('default', json_encode(array('attempts' => 1)), 1, 2);
	}


	public function testMigrateExpiredJobs()
	{
		$queue = $this->getMock('Illuminate\Queue\RedisQueue', array('getTime'), array($redis = m::mock('Illuminate\Redis\Database'), 'default'));
		$queue->expects($this->once())->method('getTime')->will($this->returnValue(1));
		$redis->shouldReceive('zrangebyscore')->once()->with('from', '-inf', 1)->andReturn(array('foo', 'bar'));
		$redis->shouldReceive('zremrangebyscore')->once()->with('from', '-inf', 1);
		$redis->shouldReceive('rpush')->once()->with('to', 'foo', 'bar');

		$queue->migrateExpiredJobs('from', 'to');
	}

}