define syslog variables in common.php

[quix0rs-gnu-social.git] / xmppdaemon.php

diff --git a/xmppdaemon.php b/xmppdaemon.php
index 22b957c97199370ba0aa3925b54205ce25df19b5..e772ecc0895322a640c6d1ec4118e9767ff17d73 100755 (executable)
--- a/xmppdaemon.php
+++ b/xmppdaemon.php
@@ -18,6 +18,35 @@
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
 
+function xmppdaemon_error_handler($errno, $errstr, $errfile, $errline, $errcontext) {
+    switch ($errno) {
+     case E_USER_ERROR:
+       echo "ERROR: [$errno] $errstr\n";
+       echo "  Fatal error on line $errline in file $errfile";
+       echo ", PHP " . PHP_VERSION . " (" . PHP_OS . ")\n";
+       echo "Aborting...\n";
+       exit(1);
+       break;
+       
+     case E_USER_WARNING:
+       echo "WARNING [$errno] $errstr\n";
+       break;
+       
+     case E_USER_NOTICE:
+       echo "My NOTICE [$errno] $errstr\n";
+       break;
+       
+     default:
+       echo "Unknown error type: [$errno] $errstr\n";
+       break;
+    }
+    
+    /* Don't execute PHP internal error handler */
+    return true;
+}
+
+set_error_handler('xmppdaemon_error_handler');
+
 # Abort if called from a web server
 if (isset($_SERVER) && array_key_exists('REQUEST_METHOD', $_SERVER)) {
        print "This script must be run from the command line\n";
@@ -95,10 +124,15 @@ class XMPPDaemon {
                        }
 
                        $this->broadcast_queue();
-#                      $this->confirmation_queue();
+                       $this->confirmation_queue();
                }
        }
-
+       
+       function handle_session($pl) {
+               # XXX what to do here?
+               return true;
+       }
+       
        function get_user($from) {
                $user = User::staticGet('jabber', jabber_normalize_jid($from));
                return $user;
@@ -135,11 +169,22 @@ class XMPPDaemon {
                }
                if ($this->handle_command($user, $pl['body'])) {
                        return;
+               } else if ($this->is_autoreply($pl['body'])) {
+                       $this->log(LOG_INFO, 'Ignoring auto reply from ' . $from);
+                       return;
                } else {
                        $this->add_notice($user, $pl);
                }
        }
 
+       function is_autoreply($txt) {
+               if (preg_match('/[\[\(]?[Aa]uto-?[Rr]eply[\]\)]/', $txt)) {
+                       return true;
+               } else {
+                       return false;
+               }
+       }
+       
        function from_site($address, $msg) {
                $text = '['.common_config('site', 'name') . '] ' . $msg;
                jabber_send_message($address, $text);
@@ -181,6 +226,7 @@ class XMPPDaemon {
                $notice = new Notice();
                $notice->profile_id = $user->id;
                $notice->content = trim(substr($pl['body'], 0, 140));
+               $notice->rendered = common_render_content($notice->content, $notice);
                $notice->created = DB_DataObject_Cast::dateTime();
                $notice->query('BEGIN');
                $id = $notice->insert();
@@ -204,6 +250,7 @@ class XMPPDaemon {
                        return;
                }
                $notice->query('COMMIT');
+        common_save_replies($notice);  
                common_real_broadcast($notice);
                $this->log(LOG_INFO,
                                   'Added notice ' . $notice->id . ' from user ' . $user->nickname);
@@ -228,7 +275,7 @@ class XMPPDaemon {
                        if (!$pl['type']) {
                                $user = User::staticGet('jabber', $from);
                                if (!$user) {
-                                       $this->log(LOG_WARNING, 'Message from unknown user ' . $from);
+                                       $this->log(LOG_WARNING, 'Presence from unknown user ' . $from);
                                        return;
                                }
                                if ($user->updatefrompresence) {
@@ -315,6 +362,7 @@ class XMPPDaemon {
 
        function clear_old_claims() {
                $qi = new Queue_item();
+               $qi->claimed = NULL;
                $qi->whereAdd('now() - claimed > '.CLAIM_TIMEOUT);
                $qi->update(DB_DATAOBJECT_WHEREADD_ONLY);
        }
@@ -347,7 +395,7 @@ class XMPPDaemon {
                                        $this->log(LOG_INFO, 'Confirmation sent for ' . $confirm->address);
                                        # Mark confirmation sent
                                        $original = clone($confirm);
-                                       $confirm->sent = DB_DataObject_Cast::dateTime();
+                                       $confirm->sent = $confirm->claimed;
                                        $result = $confirm->update($original);
                                        if (!$result) {
                                                $this->log(LOG_ERROR, 'Cannot mark sent for ' . $confirm->address);
@@ -362,17 +410,20 @@ class XMPPDaemon {
        function next_confirm() {
                $confirm = new Confirm_address();
                $confirm->whereAdd('claimed IS NULL');
+               $confirm->whereAdd('sent IS NULL');
                # XXX: eventually we could do other confirmations in the queue, too
                $confirm->address_type = 'jabber';
                $confirm->orderBy('modified DESC');
                $confirm->limit(1);
                if ($confirm->find(TRUE)) {
                        $this->log(LOG_INFO, 'Claiming confirmation for ' . $confirm->address);
-                       $original = clone($confirm);
+                       # working around some weird DB_DataObject behaviour
+                       $confirm->whereAdd(''); # clears where stuff
+                       $original = clone($confirm);
                        $confirm->claimed = DB_DataObject_Cast::dateTime();
                        $result = $confirm->update($original);
                        if ($result) {
-                               $this->log(LOG_INFO, 'Succeeded in claim!');
+                               $this->log(LOG_INFO, 'Succeeded in claim! '. $result);
                                return $confirm;
                        } else {
                                $this->log(LOG_INFO, 'Failed in claim!');
@@ -384,6 +435,7 @@ class XMPPDaemon {
        
        function clear_old_confirm_claims() {
                $confirm = new Confirm();
+               $confirm->claimed = NULL;
                $confirm->whereAdd('now() - claimed > '.CLAIM_TIMEOUT);
                $confirm->update(DB_DATAOBJECT_WHEREADD_ONLY);
        }