dbesc($item_id),
dbesc($contact_id)
);
- if (!count($r)) {
+ if (!dbm::is_result($r)) {
continue;
}
- if (App::maxload_reached())
+ if ($a->maxload_reached())
return;
// It's ours to deliver. Remove it from the queue.
intval($item_id)
);
- if ((!count($r)) || (!intval($r[0]['parent']))) {
+ if ((!dbm::is_result($r)) || (!intval($r[0]['parent']))) {
continue;
}
intval($uid)
);
- if (!count($r))
+ if (!dbm::is_result($r))
continue;
$owner = $r[0];
intval($contact_id)
);
- if (count($r))
+ if (dbm::is_result($r))
$contact = $r[0];
if ($contact['self'])
if ($deliver_status == (-1)) {
logger('notifier: delivery failed: queuing message');
add_to_queue($contact['id'],NETWORK_DFRN,$atom);
+
+ // The message could not be delivered. We mark the contact as "dead"
+ mark_for_death($contact);
+ } else {
+ // We successfully delivered a message, the contact is alive
+ unmark_for_death($contact);
}
+
break;
case NETWORK_OSTATUS:
intval($argv[2]),
intval($uid)
);
- if (count($r))
+ if (dbm::is_result($r))
$it = $r[0];
}
if (!$it)
dbesc($it['parent-uri']),
intval($uid));
- if (count($r) AND ($r[0]['title'] != ''))
+ if (dbm::is_result($r) AND ($r[0]['title'] != ''))
$subject = $r[0]['title'];
else {
$r = q("SELECT `title` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d LIMIT 1",
dbesc($it['parent-uri']),
intval($uid));
- if (count($r) AND ($r[0]['title'] != ''))
+ if (dbm::is_result($r) AND ($r[0]['title'] != ''))
$subject = $r[0]['title'];
}
}