X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=xmppdaemon.php;h=d2e609b4407a31fdd2808523356e8e65bc113cfb;hb=5f79bcdf51e0cbc17f62c6899207813f26a29214;hp=26c395303a22aa641309b9d233cc6586f3e018a6;hpb=9942b4416b9bc3ea2e0d78f4d1ee46111aef61ac;p=quix0rs-gnu-social.git diff --git a/xmppdaemon.php b/xmppdaemon.php index 26c395303a..d2e609b440 100755 --- a/xmppdaemon.php +++ b/xmppdaemon.php @@ -18,6 +18,35 @@ * along with this program. If not, see . */ +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"; @@ -54,6 +83,7 @@ class XMPPDaemon { } function connect() { + $connect_to = ($this->host) ? $this->host : $this->server; $this->log(LOG_INFO, "Connecting to $connect_to on port $this->port"); @@ -63,7 +93,8 @@ class XMPPDaemon { if (!$this->conn) { return false; } - return !$this->conn->disconnected; + + return !$this->conn->isDisconnected(); } function handle() { @@ -71,7 +102,7 @@ class XMPPDaemon { static $parts = array('message', 'presence', 'end_stream', 'session_start'); - while(!$this->conn->disconnected) { + while(!$this->conn->isDisconnected()) { $payloads = $this->conn->processUntil($parts, 10); @@ -93,9 +124,15 @@ class XMPPDaemon { } $this->broadcast_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; @@ -132,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); @@ -164,7 +212,7 @@ class XMPPDaemon { $result = $user->update($orig); if (!$id) { $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError'); - $this->log(LOG_ERROR, + $this->log(LOG_ERR, 'Could not set notify flag to ' . $notify . ' for user ' . common_log_objstring($user) . ': ' . $last_error->message); @@ -176,14 +224,16 @@ class XMPPDaemon { function add_notice(&$user, &$pl) { $notice = new Notice(); + $notice->is_local = 1; $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(); if (!$id) { $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError'); - $this->log(LOG_ERROR, + $this->log(LOG_ERR, 'Could not insert ' . common_log_objstring($notice) . ' for user ' . common_log_objstring($user) . ': ' . $last_error->message); @@ -194,14 +244,15 @@ class XMPPDaemon { $result = $notice->update($orig); if (!$result) { $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError'); - $this->log(LOG_ERROR, + $this->log(LOG_ERR, 'Could not add URI to ' . common_log_objstring($notice) . ' for user ' . common_log_objstring($user) . ': ' . $last_error->message); return; } $notice->query('COMMIT'); - common_broadcast_notice($notice); + common_save_replies($notice); + common_real_broadcast($notice); $this->log(LOG_INFO, 'Added notice ' . $notice->id . ' from user ' . $user->nickname); } @@ -225,7 +276,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) { @@ -286,7 +337,7 @@ class XMPPDaemon { do { $qi = $this->top_queue_item(); if ($qi) { - $this->log(LOG_INFO, 'Got queue item #'.$in_a_row.' enqueued '.common_exact_date($qi->created)); + $this->log(LOG_INFO, 'Got item enqueued '.common_exact_date($qi->created)); $notice = Notice::staticGet($qi->notice_id); if ($notice) { $this->log(LOG_INFO, 'broadcasting notice ID = ' . $notice->id); @@ -312,7 +363,7 @@ class XMPPDaemon { function clear_old_claims() { $qi = new Queue_item(); - $qi->claimed = NULL; + $qi->claimed = NULL; $qi->whereAdd('now() - claimed > '.CLAIM_TIMEOUT); $qi->update(DB_DATAOBJECT_WHEREADD_ONLY); } @@ -321,6 +372,75 @@ class XMPPDaemon { $user = User::staticGet($notice->profile_id); return !$user; } + + function confirmation_queue() { + # $this->clear_old_confirm_claims(); + $this->log(LOG_INFO, 'checking for queued confirmations'); + do { + $confirm = $this->next_confirm(); + if ($confirm) { + $this->log(LOG_INFO, 'Sending confirmation for ' . $confirm->address); + $user = User::staticGet($confirm->user_id); + if (!$user) { + $this->log(LOG_WARNING, 'Confirmation for unknown user ' . $confirm->user_id); + continue; + } + $success = jabber_confirm_address($confirm->code, + $user->nickname, + $confirm->address); + if (!$success) { + $this->log(LOG_ERR, 'Confirmation failed for ' . $confirm->address); + # Just let the claim age out; hopefully things work then + continue; + } else { + $this->log(LOG_INFO, 'Confirmation sent for ' . $confirm->address); + # Mark confirmation sent + $original = clone($confirm); + $confirm->sent = $confirm->claimed; + $result = $confirm->update($original); + if (!$result) { + $this->log(LOG_ERR, 'Cannot mark sent for ' . $confirm->address); + # Just let the claim age out; hopefully things work then + continue; + } + } + } + } while ($confirm); + } + + 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); + # 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! '. $result); + return $confirm; + } else { + $this->log(LOG_INFO, 'Failed in claim!'); + return false; + } + } + return NULL; + } + + function clear_old_confirm_claims() { + $confirm = new Confirm(); + $confirm->claimed = NULL; + $confirm->whereAdd('now() - claimed > '.CLAIM_TIMEOUT); + $confirm->update(DB_DATAOBJECT_WHEREADD_ONLY); + } + } $resource = ($argc > 1) ? $argv[1] : NULL;