use Friendica\Core\Config;
use Friendica\Core\Worker;
+use Friendica\Database\DBM;
use Friendica\Protocol\Diaspora;
-use Friendica\Protocol\Dfrn;
+use Friendica\Protocol\DFRN;
require_once 'include/queue_fn.php';
require_once 'include/datetime.php';
INNER JOIN `contact` ON `queue`.`cid` = `contact`.`id`
WHERE `queue`.`created` < UTC_TIMESTAMP() - INTERVAL 3 DAY");
- if (dbm::is_result($r)) {
+ if (DBM::is_result($r)) {
foreach ($r as $rr) {
logger('Removing expired queue item for ' . $rr['name'] . ', uid=' . $rr['uid']);
logger('Expired queue data: ' . $rr['content'], LOGGER_DATA);
call_hooks('queue_predeliver', $a, $r);
- if (dbm::is_result($r)) {
+ if (DBM::is_result($r)) {
foreach ($r as $q_item) {
logger('Call queue for id '.$q_item['id']);
Worker::add(array('priority' => PRIORITY_LOW, 'dont_fork' => true), "queue", (int)$q_item['id']);
$r = q("SELECT * FROM `queue` WHERE `id` = %d LIMIT 1",
intval($queue_id));
- if (!dbm::is_result($r)) {
+ if (!DBM::is_result($r)) {
return;
}
intval($q_item['cid'])
);
- if (!dbm::is_result($c)) {
+ if (!DBM::is_result($c)) {
remove_queue_item($q_item['id']);
return;
}
FROM `user` WHERE `uid` = %d LIMIT 1",
intval($c[0]['uid'])
);
- if (!dbm::is_result($u)) {
+ if (!DBM::is_result($u)) {
remove_queue_item($q_item['id']);
return;
}
switch ($contact['network']) {
case NETWORK_DFRN:
logger('queue: dfrndelivery: item '.$q_item['id'].' for '.$contact['name'].' <'.$contact['url'].'>');
- $deliver_status = Dfrn::deliver($owner, $contact, $data);
+ $deliver_status = DFRN::deliver($owner, $contact, $data);
if ($deliver_status == (-1)) {
update_queue_time($q_item['id']);