DataObjects/Core_watch.php

[Pman.Core] / DataObjects / Events.php

diff --git a/DataObjects/Events.php b/DataObjects/Events.php
index 5406401..426e87b 100644 (file)
--- a/DataObjects/Events.php
+++ b/DataObjects/Events.php
@@ -33,7 +33,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
     
     
     //  ------------ROO HOOKS------------------------------------
-    function applyFilters($q, $au)
+    function applyFilters($q, $au ,$roo)
     {
         $tn = $this->tableName();
         if (!empty($q['query']['from'])) {
@@ -81,7 +81,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
             $this->selectAdd("count($tn.id) as qty");
             $this->selectAdd("count( distinct $tn.on_id) as uqty");
             $this->whereAdd('LENGTH(join_person_id_id.name) > 0 ');
-            $this->groupBy('person_id');
+            $this->groupBy('person_id,join_person_id_id.name,join_person_id_id.email');
         }
          if (isset($q['query']['table_sum'])) {
             //DB_DataObject::debugLevel(1);
@@ -156,6 +156,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
         
         if (isset($q['_related_on_id']) && isset($q['_related_on_table'])) {
             // example: sales order - has invoices,
+            ///DB_DataObject::DebugLevel(1);
             $ev  =$this->factory('Events');
             $ev->setFrom(array(
                 'on_id' => $q['_related_on_id'],
@@ -163,6 +164,13 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
                                ));
             $obj = $ev->object();
             
+            if (!$obj) {
+                $roo->jerr("ontable is invalid");
+            }
+            if (!method_exists($obj,'relatedWhere')) {
+                $roo->jerr( $q['_related_on_table'] . " Does not have method relatedWhere :" .
+                           implode(',', get_class_methods($obj)));
+            }
             if ($obj && method_exists($obj,'relatedWhere')) {
                 $ar = $obj->relatedWhere();
                 $tn = $this->tableName();
@@ -190,8 +198,9 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
             
         }
         // since roo does not support autojoin yet..
-        $this->autoJoinExtra();
-        
+        if (!isset($q['_distinct'])) {
+            $this->autoJoinExtra();
+        }
         
         
         
@@ -201,9 +210,11 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
     function autoJoinExtra()
     {
         //$ret = parent::autoJoin();
-         DB_DataObject::debugLevel(1);
+        // DB_DataObject::debugLevel(1);
         
         // now try and magically join person_table to the right table..
+        return;
+        // this does not work on postgres.. 
         $tn = $this->tableName();
         $pt = DB_DataObject::Factory($this->tableName());
         $pt->selectAdD();
@@ -361,6 +372,12 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
      */
     function auditField($name, $ov, $nv, $old=false )
     {
+        // hack..
+        if (is_object($nv)) {
+            return;
+        
+        }
+        
         $x = DB_DataObject::factory('core_event_audit');
         $x->setFrom(array(
             'event_id' => $this->id,
@@ -372,4 +389,65 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
         $x->insert();
     
     }
+    
+    
+    
+    function onInsert($request,$roo)
+    {
+        $this->writeEventLog();
+    }
+    
+    function writeEventLog()
+    {
+        $ff  = HTML_FlexyFramework::get();
+        if (empty($ff->Pman['event_log_dir'])) {
+            return false;
+        }
+        
+        // add user (eg. www-data or local user if not..)
+        if (function_exists('posix_getpwuid')) {
+            $uinfo = posix_getpwuid( posix_getuid () ); 
+         
+            $user = $uinfo['name'];
+        } else {
+            $user = getenv('USERNAME'); // windows.
+        }
+        //print_r($this);
+        $file = $ff->Pman['event_log_dir']. '/'. $user. date('/Y/m/d/'). $this->id . ".json";
+        if (!file_exists(dirname($file))) {
+            mkdir(dirname($file),0700,true);
+        }
+        
+        // Remove all the password from logs...
+        $p =  empty($_POST) ? array() : $_POST;
+        foreach(array('passwd', 'password', 'passwd2', 'password2') as $rm) {
+            if (isset($p[$rm])) {
+                $p['passwd'] = '******';
+            }
+        }
+        $i=0;
+        $files = array();
+        foreach ($_FILES as $k=>$f){
+            if (empty($f['tmp_name']) || !file_exists($f['tmp_name'])) {
+                continue;
+            }
+            $i++;
+            $files[$k] = $f;
+            $files[$k]['tmp_name'] = $this->id . '.file_'. $i.'.jpg';
+            $nf = $ff->Pman['event_log_dir']. '/'. $this->id . ".file_$i.jpg";
+            if (!copy($f['tmp_name'], $nf)) {
+                print_r("failed to copy {$f['tmp_name']}...\n");
+            }
+        }
+        
+        file_put_contents($file, json_encode(array(
+            'REQUEST_URI' => empty($_SERVER['REQUEST_URI']) ? 'cli' : $_SERVER['REQUEST_URI'],
+            'GET' => empty($_GET) ? array() : $_GET,
+            'POST' =>$p,
+            'FILES' => $files,
+        )));
+        
+    }
+    
+    
 }