X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FQueue.php;h=b27a776c7a9e65b7a62a93208a2db98f52699ea9;hb=de8787dd5bb9fadd6388c050bad35ec4c0332e08;hp=1a344ac541352e17ca7b475b0d4beb9f93526482;hpb=ecea7425f8ad11ace4af39d476919e3203bff44f;p=friendica.git diff --git a/src/Worker/Queue.php b/src/Worker/Queue.php index 1a344ac541..b27a776c7a 100644 --- a/src/Worker/Queue.php +++ b/src/Worker/Queue.php @@ -7,8 +7,10 @@ namespace Friendica\Worker; use Friendica\Core\Addon; use Friendica\Core\Cache; use Friendica\Core\Config; +use Friendica\Core\Protocol; use Friendica\Core\Worker; use Friendica\Database\DBA; +use Friendica\Model\Contact; use Friendica\Model\PushSubscriber; use Friendica\Model\Queue as QueueModel; use Friendica\Model\User; @@ -109,7 +111,7 @@ class Queue $deliver_status = 0; switch ($contact['network']) { - case NETWORK_DFRN: + case Protocol::DFRN: logger('queue: dfrndelivery: item ' . $q_item['id'] . ' for ' . $contact['name'] . ' <' . $contact['url'] . '>'); $deliver_status = DFRN::deliver($owner, $contact, $data); @@ -120,7 +122,8 @@ class Queue Cache::set($cachekey_deadguy . $contact['notify'], true, CACHE_MINUTE); } break; - case NETWORK_OSTATUS: + + case Protocol::OSTATUS: logger('queue: slapdelivery: item ' . $q_item['id'] . ' for ' . $contact['name'] . ' <' . $contact['url'] . '>'); $deliver_status = Salmon::slapper($owner, $contact['notify'], $data); @@ -131,12 +134,13 @@ class Queue QueueModel::removeItem($q_item['id']); } break; - case NETWORK_DIASPORA: + + case Protocol::DIASPORA: logger('queue: diaspora_delivery: item ' . $q_item['id'] . ' for ' . $contact['name'] . ' <' . $contact['url'] . '>'); $deliver_status = Diaspora::transmit($owner, $contact, $data, $public, true, 'Queue:' . $q_item['id'], true); if ((($deliver_status >= 200) && ($deliver_status <= 299)) || - ($contact['contact-type'] == ACCOUNT_TYPE_RELAY)) { + ($contact['contact-type'] == Contact::ACCOUNT_TYPE_RELAY)) { QueueModel::removeItem($q_item['id']); } else { QueueModel::updateTime($q_item['id']);