summaryrefslogtreecommitdiff
path: root/plugins/OStatus/lib/ostatusqueuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2010-09-02 16:58:55 -0400
committerEvan Prodromou <evan@status.net>2010-09-02 16:58:55 -0400
commit82b1d6daefc29c870ea71b29ab851153642f270b (patch)
tree61db5e4fcee85ae0b2e94563e50c78ca794bcf4f /plugins/OStatus/lib/ostatusqueuehandler.php
parent7517409bf16137a9d8a420b7358f30fa55945ba0 (diff)
parentebcd8644a51b66d73971d581789e7c70b82007b2 (diff)
Merge branch 'swat0' into 0.9.x
Diffstat (limited to 'plugins/OStatus/lib/ostatusqueuehandler.php')
-rw-r--r--plugins/OStatus/lib/ostatusqueuehandler.php13
1 files changed, 12 insertions, 1 deletions
diff --git a/plugins/OStatus/lib/ostatusqueuehandler.php b/plugins/OStatus/lib/ostatusqueuehandler.php
index 8905d2e21..5e318116a 100644
--- a/plugins/OStatus/lib/ostatusqueuehandler.php
+++ b/plugins/OStatus/lib/ostatusqueuehandler.php
@@ -67,6 +67,17 @@ class OStatusQueueHandler extends QueueHandler
}
}
+ if (!empty($this->notice->reply_to)) {
+ $replyTo = Notice::staticGet('id', $this->notice->reply_to);
+ if (!empty($replyTo)) {
+ foreach($replyTo->getReplies() as $profile_id) {
+ $oprofile = Ostatus_profile::staticGet('profile_id', $profile_id);
+ if ($oprofile) {
+ $this->pingReply($oprofile);
+ }
+ }
+ }
+ }
return true;
}
@@ -161,7 +172,7 @@ class OStatusQueueHandler extends QueueHandler
* Queue up direct feed update pushes to subscribers on our internal hub.
* If there are a large number of subscriber sites, intermediate bulk
* distribution triggers may be queued.
- *
+ *
* @param string $atom update feed, containing only new/changed items
* @param HubSub $sub open query of subscribers
*/