summaryrefslogtreecommitdiff
path: root/xmppdaemon.php
diff options
context:
space:
mode:
authorMike Cochrane <mikec@mikenz.geek.nz>2008-07-20 01:57:02 -0400
committerMike Cochrane <mikec@mikenz.geek.nz>2008-07-20 01:57:02 -0400
commit5d84485001ace75c49cdc295b4ed3540db83e988 (patch)
tree4100b04f90ecfecf95082c5fc2472bd7707e28f3 /xmppdaemon.php
parente4f1d6f50444cf2ca6e9aaf7116d40eaa17b0f1c (diff)
First cut at hastags support.
darcs-hash:20080720055702-533db-193ed842b0d0a952bef71a3c5287213ada0ef15c.gz
Diffstat (limited to 'xmppdaemon.php')
-rwxr-xr-xxmppdaemon.php27
1 files changed, 14 insertions, 13 deletions
diff --git a/xmppdaemon.php b/xmppdaemon.php
index d2e609b44..91ea833ce 100755
--- a/xmppdaemon.php
+++ b/xmppdaemon.php
@@ -27,20 +27,20 @@ function xmppdaemon_error_handler($errno, $errstr, $errfile, $errline, $errconte
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;
}
@@ -93,7 +93,7 @@ class XMPPDaemon {
if (!$this->conn) {
return false;
}
-
+
return !$this->conn->isDisconnected();
}
@@ -127,12 +127,12 @@ class XMPPDaemon {
$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;
@@ -184,7 +184,7 @@ class XMPPDaemon {
return false;
}
}
-
+
function from_site($address, $msg) {
$text = '['.common_config('site', 'name') . '] ' . $msg;
jabber_send_message($address, $text);
@@ -251,7 +251,8 @@ class XMPPDaemon {
return;
}
$notice->query('COMMIT');
- common_save_replies($notice);
+ common_save_replies($notice);
+ $notice->saveTags();
common_real_broadcast($notice);
$this->log(LOG_INFO,
'Added notice ' . $notice->id . ' from user ' . $user->nickname);
@@ -372,7 +373,7 @@ 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');
@@ -407,7 +408,7 @@ class XMPPDaemon {
}
} while ($confirm);
}
-
+
function next_confirm() {
$confirm = new Confirm_address();
$confirm->whereAdd('claimed IS NULL');
@@ -433,14 +434,14 @@ class XMPPDaemon {
}
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;