),
'old' => array(
- 'desc' => 'Show old messages..',
+ 'desc' => 'Show old messages.. (and new messages...)',
'default' => 0,
'short' => 'o',
'min' => 0,
var $pool = array();
- function get($r,$opts)
+ function parseArgs(&$opts)
{
if ($opts['debug']) {
DB_DataObject::debugLevel($opts['debug']);
if (empty($opts['limit'])) {
$opts['limit'] = '1000'; // not sure why it's not picking up the defautl..
}
- //date_default_timezone_set('UTC');
- // phpinfo();exit;
- $showold = !empty($opts['old']);
+
if (!empty($opts['old'])) {
$opts['list'] = 1; // force listing..
}
if (!empty($opts['send-to'])) {
$this->send_to = $opts['send-to'];
}
+ }
+
+
+ function get($r,$opts)
+ {
+ $this->parseArgs($opts);
+
+ //date_default_timezone_set('UTC');
+ // phpinfo();exit;
+
$w = DB_DataObject::factory('core_notify_recur');
//DB_DataObject::debugLevel(1);
$w = DB_DataObject::factory($this->table);
-
- if (!$showold) {
+ if (!empty($opts['old'])) {
+ // show old and new...
+ $w->orderBy('act_when DESC'); // latest first
+ $w->limit($opts['limit']); // we can run
+
+ } else {
// standard
//$w->whereAdd('act_when > sent'); // eg.. sent is not valid..
$this->logecho("QUEUE is {$w->count()}");
- $w->limit($opts['limit']); // we can run 1000 ...
- } else {
- $w->orderBy('act_when DESC'); // latest first
$w->limit($opts['limit']); // we can run 1000 ...
}
+
if (!empty($this->evtype)) {
$w->evtype = $this->evtype;
}
$ar = $w->fetchAll();
- print_r($ar);exit;
-
if (!empty($opts['list'])) {
if (empty($ar)) {
die("Nothing in Queue\n");
'cmd' => $cmd,
'email' => $email,
'pipes' => $pipes,
+ 'notify_id' => $id,
'started' => time()
$this->logecho("TERMINATING: ({$p['pid']}) " . $p['cmd'] . " : " . file_get_contents($p['out']));
@unlink($p['out']);
+ $w = DB_DataObject::factory($this->table);
+ $w->get($p['notify_id']);
+ $ww = clone($w);
+ $this->addEvent('NOTIFY', $w, 'TERMINATED - TIMEOUT');
+ $w->act_when = date('Y-m-d H:i:s', strtotime('NOW + 30 MINUTES'));
+ $w->update($ww);
+
+
continue;
}