DataObjects/Core_event_audit.php

[Pman.Core] / Notify.php

diff --git a/Notify.php b/Notify.php
index f24746f..dc3558c 100644 (file)
--- a/Notify.php
+++ b/Notify.php
@@ -42,7 +42,14 @@ class Pman_Core_Notify extends Pman
             'min' => 0,
             'max' => 0,
             
-        )
+        ),
+         'force' => array(
+            'desc' => 'Force redelivery, even if it has been sent before or not queued...',
+            'default' => 0,
+            'short' => 'f',
+            'min' => 0,
+            'max' => 0,
+        ),
     );
     
     
@@ -78,12 +85,21 @@ class Pman_Core_Notify extends Pman
             $opts['list'] = 1; // force listing..
         }
         
+        $this->force = empty($opts['force']) ? 0 : 1;
+     
+        if (!empty($opts['send-to'])) {
+            $this->send_to = $opts['send-to'];
+        }
+     
         
         $w = DB_DataObject::factory($this->table);
         
         if (!$showold) {
             $w->whereAdd('act_when > sent'); // eg.. sent is not valid..
-            $w->whereAdd('act_when < NOW()'); // eg.. not if future..
+            
+            if (!$this->force) {
+                $w->whereAdd('act_when < NOW()'); // eg.. not if future..
+            }
     
             $w->orderBy('act_when ASC'); // oldest first.
             $w->limit(1000); // we can run 1000 ...
@@ -159,7 +175,14 @@ class Pman_Core_Notify extends Pman
         
         $cwd = $sn[0] == '/' ? dirname($sn) : dirname(realpath(getcwd() . $sn)); // same as run on.. (so script should end up being same relatively..)
         $app = $cwd . '/' . basename($_SERVER["SCRIPT_NAME"]) . '  ' . $this->target . '/'. $id;
+        if ($this->force) {
+            $app .= ' -f';
+        }
+        if (!empty($this->send_to)) {
+            $app .= ' --sent-to='.escapeshellarg($this->send_to);
+        }
         $cmd = $php . ' ' . $app. ' &';
+        
         echo $cmd . "\n";
         $pipe = array();
         $p = proc_open($cmd, $descriptorspec, $pipes, $cwd );