diff options
author | Evan Prodromou <evan@status.net> | 2010-09-04 11:40:33 -0400 |
---|---|---|
committer | Evan Prodromou <evan@status.net> | 2010-09-04 11:40:33 -0400 |
commit | 60b1e4afb7c8c78463119b7d2424c861816f57be (patch) | |
tree | 17ac0ce01ec9353a81bb771f33328f08b9137873 | |
parent | 86e8af45a241c6cddffc8fe8789048e3933f5bd3 (diff) |
move inbox insert code to status saver main loop
-rwxr-xr-x | plugins/TwitterBridge/daemons/twitterstatusfetcher.php | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/plugins/TwitterBridge/daemons/twitterstatusfetcher.php b/plugins/TwitterBridge/daemons/twitterstatusfetcher.php index 9892ffc05..e3f9553ff 100755 --- a/plugins/TwitterBridge/daemons/twitterstatusfetcher.php +++ b/plugins/TwitterBridge/daemons/twitterstatusfetcher.php @@ -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; |