summaryrefslogtreecommitdiff
path: root/plugins/TwitterBridge/tweetctlqueuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2010-11-14 06:49:43 -0500
committerEvan Prodromou <evan@status.net>2010-11-14 06:49:43 -0500
commit01f32e3998b8d031d2a39e2d0506253142b6632e (patch)
tree952174eeb2fa746c97b9884cf4797ffa3f9870ce /plugins/TwitterBridge/tweetctlqueuehandler.php
parentc4b8f68a1a3ed6422a2ed1cb7a8b5b5c65011b5f (diff)
parentb716d01a41c54c06676a1e54a48c36e05755a247 (diff)
Merge remote branch 'gitorious/1.0.x' into 1.0.x
Conflicts: actions/urlsettings.php
Diffstat (limited to 'plugins/TwitterBridge/tweetctlqueuehandler.php')
-rw-r--r--plugins/TwitterBridge/tweetctlqueuehandler.php59
1 files changed, 59 insertions, 0 deletions
diff --git a/plugins/TwitterBridge/tweetctlqueuehandler.php b/plugins/TwitterBridge/tweetctlqueuehandler.php
new file mode 100644
index 000000000..4c8bef463
--- /dev/null
+++ b/plugins/TwitterBridge/tweetctlqueuehandler.php
@@ -0,0 +1,59 @@
+<?php
+/*
+ * StatusNet - the distributed open-source microblogging tool
+ * Copyright (C) 2010, StatusNet, Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
+
+require_once INSTALLDIR . '/plugins/TwitterBridge/twitter.php';
+
+/**
+ * Queue handler to deal with incoming Twitter status updates, as retrieved by
+ * TwitterDaemon (twitterdaemon.php).
+ *
+ * The queue handler passes the status through TwitterImporter for import into the
+ * local database (if necessary), then adds the imported notice to the local inbox
+ * of the attached Twitter user.
+ *
+ * Warning: the way we do inbox distribution manually means that realtime, XMPP, etc
+ * don't work on Twitter-borne messages. When TwitterImporter is changed to handle
+ * that correctly, we'll only need to do this once...?
+ */
+class TweetCtlQueueHandler extends QueueHandler
+{
+ function transport()
+ {
+ return 'tweetctl';
+ }
+
+ function handle($data)
+ {
+ // A user has activated or deactivated their Twitter bridge
+ // import status.
+ $action = $data['action'];
+ $userId = $data['for_user'];
+
+ $tm = TwitterManager::get();
+ if ($action == 'start') {
+ $tm->startTwitterUser($userId);
+ } else if ($action == 'stop') {
+ $tm->stopTwitterUser($userId);
+ }
+
+ return true;
+ }
+}