We are no longer offering accounts on this server. Consider https://gitlab.freedesktop.org/ as a place to host projects.

Commit a2f0f68d authored by Brion Vibber's avatar Brion Vibber

fakestream.php can now take --all option to pull the latest messages from...

fakestream.php can now take --all option to pull the latest messages from multiple locally-authed accounts when generating simulated sitestreams info
parent 445b306b
......@@ -48,6 +48,8 @@ if (have_option('n')) {
$nickname = get_option_value('n');
} else if (have_option('nick')) {
$nickname = get_option_value('nickname');
} else if (have_option('all')) {
$nickname = null;
} else {
show_help($helptext);
exit(0);
......@@ -81,26 +83,65 @@ function twitterAuthForUser(User $user)
* @param mixed $data
*/
function dumpMessage($flink, $data)
{
$msg = prepMessage($flink, $data);
print json_encode($msg) . "\r\n";
}
function prepMessage($flink, $data)
{
$msg->for_user = $flink->foreign_id;
$msg->message = $data;
print json_encode($msg) . "\r\n";
return $msg;
}
if (have_option('all')) {
throw new Exception('--all not yet implemented');
$users = array();
$flink = new Foreign_link();
$flink->service = TWITTER_SERVICE;
$flink->find();
while ($flink->fetch()) {
if (($flink->noticesync & FOREIGN_NOTICE_RECV) ==
FOREIGN_NOTICE_RECV) {
$users[] = $flink->user_id;
}
}
} else {
$user = User::staticGet('nickname', $nickname);
$users = array($user->id);
}
$user = User::staticGet('nickname', $nickname);
$auth = twitterAuthForUser($user);
$flink = Foreign_link::getByUserID($user->id,
TWITTER_SERVICE);
$output = array();
foreach ($users as $id) {
$user = User::staticGet('id', $id);
if (!$user) {
throw new Exception("No user for id $id");
}
$auth = twitterAuthForUser($user);
$flink = Foreign_link::getByUserID($user->id,
TWITTER_SERVICE);
$friends->friends = $auth->friendsIds();
dumpMessage($flink, $friends);
$friends->friends = $auth->friendsIds();
dumpMessage($flink, $friends);
$timeline = $auth->statusesHomeTimeline();
foreach ($timeline as $status) {
dumpMessage($flink, $status);
$timeline = $auth->statusesHomeTimeline();
foreach ($timeline as $status) {
$output[] = prepMessage($flink, $status);
}
}
usort($output, function($a, $b) {
if ($a->message->id < $b->message->id) {
return -1;
} else if ($a->message->id == $b->message->id) {
return 0;
} else {
return 1;
}
});
foreach ($output as $msg) {
print json_encode($msg) . "\r\n";
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment