1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
<?php
namespace Pheanstalk\Command;
use Pheanstalk\Exception;
use Pheanstalk\Response;
/**
* The 'peek', 'peek-ready', 'peek-delayed' and 'peek-buried' commands.
*
* The peek commands let the client inspect a job in the system. There are four
* variations. All but the first (peek) operate only on the currently used tube.
*
* @author Paul Annesley
* @package Pheanstalk
* @license http://www.opensource.org/licenses/mit-license.php
*/
class PeekCommand
extends AbstractCommand
implements \Pheanstalk\ResponseParser
{
const TYPE_ID = 'id';
const TYPE_READY = 'ready';
const TYPE_DELAYED = 'delayed';
const TYPE_BURIED = 'buried';
private $_subcommands = array(
self::TYPE_READY,
self::TYPE_DELAYED,
self::TYPE_BURIED,
);
private $_subcommand;
private $_jobId;
/**
* @param mixed $peekSubject Job ID or self::TYPE_*
*/
public function __construct($peekSubject)
{
if (is_int($peekSubject) || ctype_digit($peekSubject)) {
$this->_jobId = $peekSubject;
} elseif (in_array($peekSubject, $this->_subcommands)) {
$this->_subcommand = $peekSubject;
} else {
throw new Exception\CommandException(sprintf(
'Invalid peek subject: %s', $peekSubject
));
}
}
/* (non-phpdoc)
* @see Command::getCommandLine()
*/
public function getCommandLine()
{
return isset($this->_jobId) ?
sprintf('peek %u', $this->_jobId) :
sprintf('peek-%s', $this->_subcommand);
}
/* (non-phpdoc)
* @see ResponseParser::parseResponse()
*/
public function parseResponse($responseLine, $responseData)
{
if ($responseLine == Response::RESPONSE_NOT_FOUND) {
if (isset($this->_jobId)) {
$message = sprintf(
'%s: Job %u does not exist.',
$responseLine,
$this->_jobId
);
} else {
$message = sprintf(
"%s: There are no jobs in the '%s' status",
$responseLine,
$this->_subcommand
);
}
throw new Exception\ServerException($message);
} elseif (preg_match('#^FOUND (\d+) \d+$#', $responseLine, $matches)) {
return $this->_createResponse(
Response::RESPONSE_FOUND,
array(
'id' => (int) $matches[1],
'jobdata' => $responseData,
)
);
}
}
}
|
