From: Brion Vibber Date: Tue, 2 Nov 2010 23:27:14 +0000 (-0700) Subject: fakestream.php: script to build an emulated Twitter Site Stream from live Twitter... X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=445b306b5494210f119525a13c4148024a6c5576;p=quix0rs-gnu-social.git fakestream.php: script to build an emulated Twitter Site Stream from live Twitter data, for testing. --- diff --git a/plugins/TwitterBridge/scripts/fakestream.php b/plugins/TwitterBridge/scripts/fakestream.php new file mode 100644 index 0000000000..cdb56d4910 --- /dev/null +++ b/plugins/TwitterBridge/scripts/fakestream.php @@ -0,0 +1,106 @@ +. + * + * @category Plugin + * @package StatusNet + * @author Brion Vibber + * @copyright 2010 StatusNet, Inc. + * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0 + * @link http://status.net/ + */ + +define('INSTALLDIR', realpath(dirname(__FILE__) . '/../../..')); + +$shortoptions = 'n:'; +$longoptions = array('nick=','import','all'); + +$helptext = << + + -n --nick= Local user whose Twitter timeline to watch + --import Experimental: run incoming messages through import + --all Experimental: run multiuser; requires nick be the app owner + +Attempts a User Stream connection to Twitter as the given user, dumping +data as it comes. + +ENDOFHELP; + +require_once INSTALLDIR.'/scripts/commandline.inc'; + +if (have_option('n')) { + $nickname = get_option_value('n'); +} else if (have_option('nick')) { + $nickname = get_option_value('nickname'); +} else { + show_help($helptext); + exit(0); +} + +/** + * + * @param User $user + * @return TwitterOAuthClient + */ +function twitterAuthForUser(User $user) +{ + $flink = Foreign_link::getByUserID($user->id, + TWITTER_SERVICE); + if (!$flink) { + throw new ServerException("No Twitter config for this user."); + } + + $token = TwitterOAuthClient::unpackToken($flink->credentials); + if (!$token) { + throw new ServerException("No Twitter OAuth credentials for this user."); + } + + return new TwitterOAuthClient($token->key, $token->secret); +} + +/** + * Emulate the line-by-line output... + * + * @param Foreign_link $flink + * @param mixed $data + */ +function dumpMessage($flink, $data) +{ + $msg->for_user = $flink->foreign_id; + $msg->message = $data; + print json_encode($msg) . "\r\n"; +} + +if (have_option('all')) { + throw new Exception('--all not yet implemented'); +} + +$user = User::staticGet('nickname', $nickname); +$auth = twitterAuthForUser($user); +$flink = Foreign_link::getByUserID($user->id, + TWITTER_SERVICE); + +$friends->friends = $auth->friendsIds(); +dumpMessage($flink, $friends); + +$timeline = $auth->statusesHomeTimeline(); +foreach ($timeline as $status) { + dumpMessage($flink, $status); +} +