move inbox insert code to status saver main loop

This commit is contained in:
Evan Prodromou 2010-09-04 11:40:33 -04:00
parent 86e8af45a2
commit 60b1e4afb7
1 changed files with 6 additions and 5 deletions

View File

@ -222,7 +222,11 @@ class TwitterStatusFetcher extends ParallelizingDaemon
continue;
}
$this->saveStatus($status, $flink);
$notice = $this->saveStatus($status);
if (!empty($notice)) {
Inbox::insertNotice($flink->user_id, $notice->id);
}
}
// Okay, record the time we synced with Twitter for posterity
@ -231,7 +235,7 @@ class TwitterStatusFetcher extends ParallelizingDaemon
$flink->update();
}
function saveStatus($status, $flink=null)
function saveStatus($status)
{
$profile = $this->ensureProfile($status->user);
@ -320,9 +324,6 @@ class TwitterStatusFetcher extends ParallelizingDaemon
Event::handle('EndNoticeSave', array($notice));
}
if (!empty($flink)) {
Inbox::insertNotice($flink->user_id, $notice->id);
}
$notice->blowOnInsert();
return $notice;