]> git.mxchange.org Git - quix0rs-gnu-social.git/blobdiff - scripts/ombqueuehandler.php
Twitter-compatible API - removed debugging statement
[quix0rs-gnu-social.git] / scripts / ombqueuehandler.php
index 28c76db9a6fa4ab11e760f23d63c2ac9e91ae176..1df816d1403e2b49566313a8b57a048623a9ce1f 100755 (executable)
@@ -40,12 +40,13 @@ class OmbQueueHandler extends QueueHandler {
        }
        
        function start() {
+               $this->log(LOG_INFO, "INITIALIZE");
                return true;
        }
 
        function handle_notice($notice) {
                if ($this->is_remote($notice)) {
-                       # It's fine, we're done with it.
+                       $this->log(LOG_DEBUG, 'Ignoring remote notice ' . $notice->id);
                        return true;
                } else {
                        return omb_broadcast_remote_subscribers($notice);
@@ -57,18 +58,17 @@ class OmbQueueHandler extends QueueHandler {
 
        function is_remote($notice) {
                $user = User::staticGet($notice->profile_id);
-               return !$user;
+               return is_null($user);
        }
 }
 
+ini_set("max_execution_time", "0");
+ini_set("max_input_time", "0");
+set_time_limit(0);
 mb_internal_encoding('UTF-8');
 
 $id = ($argc > 1) ? $argv[1] : NULL;
 
 $handler = new OmbQueueHandler($id);
 
-if ($handler->start()) {
-       $handler->handle_queue();
-}
-
-$handler->finish();
+$handler->runOnce();