many jabber queue management changes

[quix0rs-gnu-social.git] / lib / util.php

diff --git a/lib/util.php b/lib/util.php
index f06f49d71be682e9660a962237a646ddc9115b3a..c6cdfbcb949ab0d447802ce55461f9b53cbd5fb3 100644 (file)
--- a/lib/util.php
+++ b/lib/util.php
@@ -1070,16 +1070,19 @@ function common_broadcast_notice($notice, $remote=false) {
 # Stick the notice on the queue
 
 function common_enqueue_notice($notice) {
-       $qi = new Queue_item();
-       $qi->notice_id = $notice->id;
-       $qi->created = $notice->created;
+       foreach (array('jabber', 'omb', 'sms', 'public') as $transport) {
+               $qi = new Queue_item();
+               $qi->notice_id = $notice->id;
+               $qi->transport = $transport;
+               $qi->created = $notice->created;
         $result = $qi->insert();
-       if (!$result) {
-           $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
-           common_log(LOG_ERR, 'DB error inserting queue item: ' . $last_error->message);
-           return false;
+               if (!$result) {
+                       $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
+                       common_log(LOG_ERR, 'DB error inserting queue item: ' . $last_error->message);
+                       return false;
+               }
+               common_log(LOG_DEBUG, 'complete queueing notice ID = ' . $notice->id . ' for ' . $transport);
        }
-       common_log(LOG_DEBUG, 'complete queueing notice ID = ' . $notice->id);
        return $result;
 }
 
@@ -1123,6 +1126,12 @@ function common_real_broadcast($notice, $remote=false) {
                        common_log(LOG_ERR, 'Error in sms broadcast for notice ' . $notice->id);
                }
        }
+       if ($success) {
+               $success = jabber_public_notice($notice);
+               if (!$success) {
+                       common_log(LOG_ERR, 'Error in public broadcast for notice ' . $notice->id);
+               }
+       }
        // XXX: broadcast notices to other IM
        return $success;
 }
@@ -1478,6 +1487,29 @@ function common_canonical_sms($sms) {
        return $sms;
 }
 
+function common_error_handler($errno, $errstr, $errfile, $errline, $errcontext) {
+    switch ($errno) {
+     case E_USER_ERROR:
+               echo "ERROR: [$errno] $errstr ($errfile:$errline)\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 ($errfile:$errline)\n";
+               break;
+
+     case E_USER_NOTICE:
+               echo "NOTICE [$errno] $errstr ($errfile:$errline)\n";
+               break;
+    }
+
+    /* Don't execute PHP internal error handler */
+    return true;
+}
+
 function common_session_token() {
        common_ensure_session();
        if (!array_key_exists('token', $_SESSION)) {