diff options
author | Evan Prodromou <evan@status.net> | 2010-11-14 06:49:43 -0500 |
---|---|---|
committer | Evan Prodromou <evan@status.net> | 2010-11-14 06:49:43 -0500 |
commit | 01f32e3998b8d031d2a39e2d0506253142b6632e (patch) | |
tree | 952174eeb2fa746c97b9884cf4797ffa3f9870ce /plugins/TwitterBridge/tweetctlqueuehandler.php | |
parent | c4b8f68a1a3ed6422a2ed1cb7a8b5b5c65011b5f (diff) | |
parent | b716d01a41c54c06676a1e54a48c36e05755a247 (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.php | 59 |
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; + } +} |