$fsuggest = false;
$relocate = false;
$top_level = false;
- $recipients = array();
- $url_recipients = array();
+ $recipients = [];
+ $url_recipients = [];
$normal_mode = true;
FROM `item` LEFT JOIN `sign` ON `sign`.`iid` = `item`.`id` WHERE `parent` = %d AND visible AND NOT moderated ORDER BY `id` ASC",
intval($parent_id)
);
-logger('Blubb: a-'.$item_id);
if (!count($items)) {
return;
}
-logger('Blubb: b-'.$item_id);
// avoid race condition with deleting entries
if ($items[0]['deleted']) {
$top_level = true;
}
}
-logger('Blubb: 0-'.$item_id.' - '.$uid);
$owner = User::getOwnerDataById($uid);
if (!$owner) {
return;
}
-logger('Blubb: 1-'.$item_id);
$walltowall = ($top_level && ($owner['id'] != $items[0]['contact-id']) ? true : false);
// fill this in with a single salmon slap if applicable
$slap = '';
-logger('Blubb: 2-'.$item_id);
if (! ($mail || $fsuggest || $relocate)) {
$slap = OStatus::salmon($target_item, $owner);
$parent = $items[0];
-logger('Blubb: 3-'.$item_id);
$thr_parent = q("SELECT `network`, `author-link`, `owner-link` FROM `item` WHERE `uri` = '%s' AND `uid` = %d",
dbesc($target_item["thr-parent"]), intval($target_item["uid"]));
($owner['id'] != $target_item['contact-id']) &&
($target_item['uri'] === $target_item['parent-uri'])) {
- $fields = array('forum', 'prv');
- $condition = array('id' => $target_item['contact-id']);
- $contact = dba::select('contact', $fields, $condition, array('limit' => 1));
+ $fields = ['forum', 'prv'];
+ $condition = ['id' => $target_item['contact-id']];
+ $contact = dba::selectFirst('contact', $fields, $condition);
if (!DBM::is_result($contact)) {
// Should never happen
return false;
$followup = true;
$public_message = false; // not public
$conversant_str = dbesc($parent['contact-id']);
- $recipients = array($parent['contact-id']);
- $recipients_followup = array($parent['contact-id']);
+ $recipients = [$parent['contact-id']];
+ $recipients_followup = [$parent['contact-id']];
logger('notifier: followup '.$target_item["guid"].' to '.$conversant_str, LOGGER_DEBUG);
Worker::add($a->queue['priority'], 'Notifier', 'uplink', $item_id);
}
- $conversants = array();
+ $conversants = [];
foreach ($items as $item) {
$recipients[] = $item['contact-id'];
}
logger("Deliver ".$target_item["guid"]." to ".$contact['url']." via network ".$contact['network'], LOGGER_DEBUG);
- Worker::add(array('priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true),
+ Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true],
'Delivery', $cmd, $item_id, (int)$contact['id']);
}
}
if ($public_message) {
- $r0 = array();
- $r1 = array();
+ $r0 = [];
+ $r1 = [];
if ($diaspora_delivery) {
if (!$followup) {
intval($owner['uid']),
intval(CONTACT_IS_SHARING)
);
+
+ // Fetch the participation list
+ // The function will ensure that there are no duplicates
+ $r1 = Diaspora::participantsForThread($item_id, $r1);
+
}
$r2 = q("SELECT `id`, `name`,`network` FROM `contact`
intval(CONTACT_IS_SHARING)
);
- $r = array_merge($r2,$r1,$r0);
+
+ $r = array_merge($r2, $r1, $r0);
if (DBM::is_result($r)) {
logger('pubdeliver '.$target_item["guid"].': '.print_r($r,true), LOGGER_DEBUG);
if (!$mail && !$fsuggest && !$followup) {
logger('notifier: delivery agent: '.$rr['name'].' '.$rr['id'].' '.$rr['network'].' '.$target_item["guid"]);
- Worker::add(array('priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true),
+ Worker::add(['priority' => $a->queue['priority'], 'created' => $a->queue['created'], 'dont_fork' => true],
'Delivery', $cmd, $item_id, (int)$rr['id']);
}
}
logger('Activating internal PuSH for item '.$item_id, LOGGER_DEBUG);
// Handling the pubsubhubbub requests
- Worker::add(array('priority' => PRIORITY_HIGH, 'created' => $a->queue['created'], 'dont_fork' => true),
+ Worker::add(['priority' => PRIORITY_HIGH, 'created' => $a->queue['created'], 'dont_fork' => true],
'PubSubPublish');
}