*/
namespace Friendica\Worker;
-use Friendica\BaseObject;
use Friendica\Core\Logger;
use Friendica\Core\Worker;
use Friendica\Model\ItemDeliveryData;
use Friendica\Protocol\ActivityPub;
use Friendica\Util\HTTPSignature;
-class APDelivery extends BaseObject
+class APDelivery
{
/**
* @brief Delivers ActivityPub messages
$data = ActivityPub\Transmitter::createCachedActivityFromItem($target_id);
if (!empty($data)) {
$success = HTTPSignature::transmit($data, $inbox, $uid);
- if ($success && in_array($cmd, [Delivery::POST, Delivery::COMMENT])) {
- ItemDeliveryData::incrementQueueDone($target_id);
- }
}
}
- if (!$success) {
- Worker::defer();
+ if (!$success && !Worker::defer() && in_array($cmd, [Delivery::POST])) {
+ ItemDeliveryData::incrementQueueFailed($target_id);
+ } elseif ($success && in_array($cmd, [Delivery::POST])) {
+ ItemDeliveryData::incrementQueueDone($target_id, ItemDeliveryData::ACTIVITYPUB);
}
}
}