<?php

use Mockery as m;

class QueueListenerTest extends PHPUnit_Framework_TestCase {

	public function tearDown()
	{
		m::close();
	}


	public function testRunProcessCallsProcess()
	{
		$process = m::mock('Symfony\Component\Process\Process')->makePartial();
		$process->shouldReceive('run')->once();
		$listener = m::mock('Illuminate\Queue\Listener')->makePartial();
		$listener->shouldReceive('memoryExceeded')->once()->with(1)->andReturn(false);

		$listener->runProcess($process, 1);
	}


	public function testListenerStopsWhenMemoryIsExceeded()
	{
		$process = m::mock('Symfony\Component\Process\Process')->makePartial();
		$process->shouldReceive('run')->once();
		$listener = m::mock('Illuminate\Queue\Listener')->makePartial();
		$listener->shouldReceive('memoryExceeded')->once()->with(1)->andReturn(true);
		$listener->shouldReceive('stop')->once();

		$listener->runProcess($process, 1);
	}


	public function testMakeProcessCorrectlyFormatsCommandLine()
	{
		$listener = new Illuminate\Queue\Listener(__DIR__);
		$process = $listener->makeProcess('connection', 'queue', 1, 2, 3);

		$this->assertInstanceOf('Symfony\Component\Process\Process', $process);
		$this->assertEquals(__DIR__, $process->getWorkingDirectory());
		$this->assertEquals(3, $process->getTimeout());
		$this->assertEquals('php artisan queue:work connection --queue="queue" --delay=1 --memory=2 --sleep=3 --tries=0', $process->getCommandLine());
	}

}