Cleaning the code.

This commit is contained in:
Michael Vogel 2015-05-30 21:00:38 +02:00
parent e66489d67f
commit 4750775752
2 changed files with 29 additions and 42 deletions

View file

@ -98,13 +98,15 @@ function delivery_run(&$argv, &$argc){
continue; continue;
} }
else { else {
// find ancestors // find ancestors
$r = q("SELECT * FROM `item` WHERE `id` = %d and visible = 1 and moderated = 0 LIMIT 1", $r = q("SELECT * FROM `item` WHERE `id` = %d and visible = 1 and moderated = 0 LIMIT 1",
intval($item_id) intval($item_id)
); );
if((! count($r)) || (! intval($r[0]['parent']))) if((! count($r)) || (! intval($r[0]['parent']))) {
continue; continue;
}
$target_item = $r[0]; $target_item = $r[0];
$parent_id = intval($r[0]['parent']); $parent_id = intval($r[0]['parent']);
@ -121,8 +123,9 @@ function delivery_run(&$argv, &$argc){
intval($parent_id) intval($parent_id)
); );
if(! count($items)) if(! count($items)) {
continue; continue;
}
$icontacts = null; $icontacts = null;
$contacts_arr = array(); $contacts_arr = array();
@ -198,13 +201,6 @@ function delivery_run(&$argv, &$argc){
if(strpos($localhost,':')) if(strpos($localhost,':'))
$localhost = substr($localhost,0,strpos($localhost,':')); $localhost = substr($localhost,0,strpos($localhost,':'));
$r = q("SELECT * FROM `contact` WHERE `id` = %d AND `blocked` = 0 AND `pending` = 0",
intval($contact_id)
);
if(count($r))
$contact = $r[0];
/** /**
* *
* Be VERY CAREFUL if you make any changes to the following line. Seemingly innocuous changes * Be VERY CAREFUL if you make any changes to the following line. Seemingly innocuous changes
@ -213,7 +209,7 @@ function delivery_run(&$argv, &$argc){
* *
*/ */
if(!$top_level && ($parent["network"] != NETWORK_OSTATUS) && ($parent['wall'] == 0) && (! $expire) && (stristr($target_item['uri'],$localhost))) { if((! $top_level) && ($parent['wall'] == 0) && (! $expire) && (stristr($target_item['uri'],$localhost))) {
logger('relay denied for delivery agent.'); logger('relay denied for delivery agent.');
/* no relay allowed for direct contact delivery */ /* no relay allowed for direct contact delivery */
@ -227,6 +223,13 @@ function delivery_run(&$argv, &$argc){
$public_message = false; // private recipients, not public $public_message = false; // private recipients, not public
} }
$r = q("SELECT * FROM `contact` WHERE `id` = %d AND `blocked` = 0 AND `pending` = 0",
intval($contact_id)
);
if(count($r))
$contact = $r[0];
$hubxml = feed_hublinks(); $hubxml = feed_hublinks();
logger('notifier: slaps: ' . print_r($slaps,true), LOGGER_DATA); logger('notifier: slaps: ' . print_r($slaps,true), LOGGER_DATA);
@ -387,15 +390,11 @@ function delivery_run(&$argv, &$argc){
if(! $item_contact) if(! $item_contact)
continue; continue;
// For OStatus don't notify all contacts in the thread if(($top_level) && ($public_message) && ($item['author-link'] === $item['owner-link']) && (! $expire))
if (!$top_level AND ($parent["network"] == NETWORK_OSTATUS) AND ($item["id"] != $item_id))
continue;
if(($top_level OR ($parent["network"] == NETWORK_OSTATUS)) && ($public_message) && ($item['author-link'] === $item['owner-link']) && (! $expire))
$slaps[] = atom_entry($item,'html',null,$owner,true); $slaps[] = atom_entry($item,'html',null,$owner,true);
} }
logger('slapdelivery item '.$item_id.' to ' . $contact['name']); logger('notifier: slapdelivery: ' . $contact['name']);
foreach($slaps as $slappy) { foreach($slaps as $slappy) {
if($contact['notify']) { if($contact['notify']) {
if(! was_recently_delayed($contact['id'])) if(! was_recently_delayed($contact['id']))

View file

@ -227,9 +227,6 @@ function notifier_run(&$argv, &$argc){
// fill this in with a single salmon slap if applicable // fill this in with a single salmon slap if applicable
$slap = ''; $slap = '';
// List of OStatus receiptians of follow up messages
$ostatus_recip_str = "";
if(! ($mail || $fsuggest || $relocate)) { if(! ($mail || $fsuggest || $relocate)) {
require_once('include/group.php'); require_once('include/group.php');
@ -303,17 +300,8 @@ function notifier_run(&$argv, &$argc){
$push_notify = true; $push_notify = true;
/* $ostatus_recipients = array(); // Check if the recipient isn't in your contact list, try to slap it
// This doesn't seem to work correctly by now
$r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `network` = '%s'", intval($uid), dbesc(NETWORK_OSTATUS));
if(count($r)) {
foreach($r as $rr)
$ostatus_recipients[] = $rr['id'];
$ostatus_recip_str = ", ".implode(', ', $ostatus_recipients);
}
*/
// Check if the recipient isn't in your contact list
$r = q("SELECT `url` FROM `contact` WHERE `id` = %d", $parent['contact-id']); $r = q("SELECT `url` FROM `contact` WHERE `id` = %d", $parent['contact-id']);
if (count($r)) { if (count($r)) {
$url_recipients = array(); $url_recipients = array();
@ -570,7 +558,7 @@ function notifier_run(&$argv, &$argc){
} }
if($followup) if($followup)
$recip_str = $parent['contact-id'].$ostatus_recip_str; $recip_str = $parent['contact-id'];
else else
$recip_str = implode(', ', $recipients); $recip_str = implode(', ', $recipients);
@ -591,7 +579,7 @@ function notifier_run(&$argv, &$argc){
if(count($r)) { if(count($r)) {
foreach($r as $contact) { foreach($r as $contact) {
if((! $mail) && (! $fsuggest) && (!$followup OR ($parent['contact-id'] != $contact['id'])) && (!$relocate) && (! $contact['self'])) { if((! $mail) && (! $fsuggest) && (! $followup) && (!$relocate) && (! $contact['self'])) {
if(($contact['network'] === NETWORK_DIASPORA) && ($public_message)) if(($contact['network'] === NETWORK_DIASPORA) && ($public_message))
continue; continue;
q("insert into deliverq ( `cmd`,`item`,`contact` ) values ('%s', %d, %d )", q("insert into deliverq ( `cmd`,`item`,`contact` ) values ('%s', %d, %d )",
@ -630,7 +618,7 @@ function notifier_run(&$argv, &$argc){
// potentially more than one recipient. Start a new process and space them out a bit. // potentially more than one recipient. Start a new process and space them out a bit.
// we will deliver single recipient types of message and email recipients here. // we will deliver single recipient types of message and email recipients here.
if((! $mail) && (! $fsuggest) && (!$relocate) && (!$followup OR ($parent['contact-id'] != $contact['id']))) { if((! $mail) && (! $fsuggest) && (!$relocate) && (! $followup)) {
$this_batch[] = $contact['id']; $this_batch[] = $contact['id'];
@ -957,7 +945,7 @@ function notifier_run(&$argv, &$argc){
// throw everything into the queue in case we get killed // throw everything into the queue in case we get killed
foreach($r as $rr) { foreach($r as $rr) {
if((! $mail) && (! $fsuggest) && (!$followup OR ($parent['contact-id'] != $contact['id']))) { if((! $mail) && (! $fsuggest) && (! $followup)) {
q("insert into deliverq ( `cmd`,`item`,`contact` ) values ('%s', %d, %d )", q("insert into deliverq ( `cmd`,`item`,`contact` ) values ('%s', %d, %d )",
dbesc($cmd), dbesc($cmd),
intval($item_id), intval($item_id),