Notify.php

diff --git a/Notify.php b/Notify.php
index e69de29..7a41894 100644 (file)
--- a/Notify.php
+++ b/Notify.php
@@ -0,0 +1,103 @@
+<?php
+require_once 'Pman.php';
+
+/**
+ * notification script runner
+ *
+ * This does not actualy send stuf out, it only starts the NotifySend/{id}
+ * which does the actuall notifcations.
+ *
+ * It manages a pool of notifiers.
+ * 
+ * 
+ */
+
+
+class Pman_Core_Notify extends Pman
+{
+    
+    var $table = 'core_notify';
+    var $target = 'Core/NotifySend';
+    
+    function getAuth()
+    {
+        $ff = HTML_FlexyFramework::get();
+        if (!$ff->cli) {
+            die("access denied");
+        }
+        HTML_FlexyFramework::ensureSingle(__FILE__, $this);
+        return true;
+        
+    }
+    
+    var $pool = array();
+    
+    function get()    
+    {
+        DB_DataObject::debugLevel(1);
+        //date_default_timezone_set('UTC');
+       // phpinfo();exit;
+        
+        $w = DB_DataObject::factory($this->table);
+        $w->whereAdd('act_when > sent'); // eg.. sent is not valid..
+        $w->whereAdd('act_when > NOW()'); // eg.. not if future..
+
+        $w->orderBy('act_when ASC'); // oldest first.
+        $w->limit(1000); // we can run 1000 ...
+        $ar = $w->fetchAll('id');
+        
+        while (true) {
+            if (empty($ar)) {
+                break;
+            }
+            if (!$this->poolfree()) {
+                sleep(3);
+                continue;
+            }
+            $p = array_shift($ar);
+            $this->run($p);
+        }
+        while(count($this->pool)) {
+            $this->poolfree();
+            sleep(3);
+        }
+        
+        die("DONE\n");
+    }
+    
+    function run($id)
+    {
+        $descriptorspec = array(
+            0 => array("file", "/dev/null", 'r'),  // stdin is a pipe that the child will read from
+            1 => array("file", "/dev/null", 'a'),  // stdout is a pipe that the child will write to
+            2 => array("file", "/dev/null", "a") // stderr is a file to write to
+         );
+        $php = $_SERVER["_"];
+        $cwd = getcwd(); // same as run on.. (so script should end up being same relatively..)
+        $app = $cwd . '/'. $_SERVER["SCRIPT_NAME"] . '  ' . $this->target . '/'. $id;
+        $cmd = $php . ' ' . $app;
+        echo $cmd . "\n";
+        $pipe = array();
+        $p = proc_open($cmd, $descriptorspec, $pipes, $cwd );
+        $this->pool[] = $p;
+    }
+    
+    function poolfree() {
+        $pool = array();
+        foreach($this->pool as $p) {
+            $ar = proc_get_Status($p);
+            //var_dump($ar);
+            if ($p['running']) {
+                $pool[] = $p;
+            }
+        }
+        $this->pool = $pool;
+        if (count($pool) < 10) {
+            return true;
+        }
+        return false;
+        
+    }
+    
+    
+}
\ No newline at end of file