define('INSTALLDIR', realpath(dirname(__FILE__) . '/../../..'));
$shortoptions = 'n:';
-$longoptions = array('nick=','import','all');
+$longoptions = array('nick=','import','all','apiroot=');
$helptext = <<<ENDOFHELP
USAGE: streamtest.php -n <username>
-n --nick=<username> Local user whose Twitter timeline to watch
--import Experimental: run incoming messages through import
--all Experimental: run multiuser; requires nick be the app owner
+ --apiroot=<url> Provide alternate streaming API root URL
Attempts a User Stream connection to Twitter as the given user, dumping
data as it comes.
ENDOFHELP;
require_once INSTALLDIR.'/scripts/commandline.inc';
-require_once dirname(dirname(__FILE__)) . '/jsonstreamreader.php';
-require_once dirname(dirname(__FILE__)) . '/twitterstreamreader.php';
+require_once dirname(dirname(__FILE__)) . '/lib/jsonstreamreader.php';
+require_once dirname(dirname(__FILE__)) . '/lib/twitterstreamreader.php';
if (have_option('n')) {
$nickname = get_option_value('n');
*/
function twitterAuthForUser(User $user)
{
- $flink = Foreign_link::getByUserID($user->id,
- TWITTER_SERVICE);
- if (!$flink) {
- throw new ServerException("No Twitter config for this user.");
- }
-
+ $flink = Foreign_link::getByUserID($user->id, TWITTER_SERVICE);
$token = TwitterOAuthClient::unpackToken($flink->credentials);
if (!$token) {
throw new ServerException("No Twitter OAuth credentials for this user.");
{
// The user we auth as must be the owner of the application.
$auth = twitterAuthForUser($user);
- $stream = new TwitterSiteStream($auth);
+
+ if (have_option('apiroot')) {
+ $stream = new TwitterSiteStream($auth, get_option_value('apiroot'));
+ } else {
+ $stream = new TwitterSiteStream($auth);
+ }
// Pull Twitter user IDs for all users we want to pull data for
$userIds = array();
}
-$user = User::staticGet('nickname', $nickname);
+$user = User::getKV('nickname', $nickname);
global $myuser;
$myuser = $user;
$importer = new TwitterImport();
printf("\timporting...");
$notice = $importer->importStatus($data);
- if ($notice) {
- global $myuser;
- Inbox::insertNotice($myuser->id, $notice->id);
- printf(" %s\n", $notice->id);
- } else {
+ if (!$notice instanceof Notice) {
printf(" FAIL\n");
}
}