summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2010-09-04 11:40:33 -0400
committerEvan Prodromou <evan@status.net>2010-09-04 11:40:33 -0400
commit60b1e4afb7c8c78463119b7d2424c861816f57be (patch)
tree17ac0ce01ec9353a81bb771f33328f08b9137873
parent86e8af45a241c6cddffc8fe8789048e3933f5bd3 (diff)
move inbox insert code to status saver main loop
-rwxr-xr-xplugins/TwitterBridge/daemons/twitterstatusfetcher.php11
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;