X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FBulkDelivery.php;h=4ac77b21376fc1c09c809a767ed37645fae3b094;hb=08dafd6d7071df90f0a2d29039623470b95b055a;hp=0799b9ba73c0bc555f35cd4b8d471ecffff68d28;hpb=8e397b5849136b4acee2f67aeb10be0ecb8335af;p=friendica.git

diff --git a/src/Worker/BulkDelivery.php b/src/Worker/BulkDelivery.php
index 0799b9ba73..4ac77b2137 100644
--- a/src/Worker/BulkDelivery.php
+++ b/src/Worker/BulkDelivery.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * @copyright Copyright (C) 2010-2022, the Friendica project
+ * @copyright Copyright (C) 2010-2023, the Friendica project
  *
  * @license GNU AGPL version 3 or any later version
  *
@@ -23,6 +23,7 @@ namespace Friendica\Worker;
 
 use Friendica\Core\Logger;
 use Friendica\Core\Worker;
+use Friendica\DI;
 use Friendica\Model\GServer;
 use Friendica\Protocol\Delivery as ProtocolDelivery;
 
@@ -33,19 +34,19 @@ class BulkDelivery
 		$server_failure   = false;
 		$delivery_failure = false;
 
-		$posts = ProtocolDelivery::selectQueueForServer($gsid);
-		foreach ($posts as $post) {
-			if (!$server_failure && ProtocolDelivery::deliver($post['command'], $post['uri-id'], $post['cid'], $post['uid'])) {
-				ProtocolDelivery::removeQueue($post['uri-id'], $post['gsid']);
-				Logger::debug('Delivery successful', $post);
+		$deliveryQueueItems = DI::deliveryQueueItemRepo()->selectByServerId($gsid, DI::config()->get('system', 'worker_defer_limit'));
+		foreach ($deliveryQueueItems as $deliveryQueueItem) {
+			if (!$server_failure && ProtocolDelivery::deliver($deliveryQueueItem->command, $deliveryQueueItem->postUriId, $deliveryQueueItem->targetContactId, $deliveryQueueItem->senderUserId)) {
+				DI::deliveryQueueItemRepo()->remove($deliveryQueueItem);
+				Logger::debug('Delivery successful', $deliveryQueueItem->toArray());
 			} else {
-				ProtocolDelivery::incrementFailedQueue($post['uri-id'], $post['gsid']);
+				DI::deliveryQueueItemRepo()->incrementFailed($deliveryQueueItem);
 				$delivery_failure = true;
 
 				if (!$server_failure) {
 					$server_failure = !GServer::isReachableById($gsid);
 				}
-				Logger::debug('Delivery failed', ['server_failure' => $server_failure, 'post' => $post]);
+				Logger::debug('Delivery failed', ['server_failure' => $server_failure, 'post' => $deliveryQueueItem]);
 			}
 		}
 
@@ -54,7 +55,7 @@ class BulkDelivery
 		}
 
 		if ($delivery_failure) {
-			ProtocolDelivery::removeFailedQueue($gsid);
+			DI::deliveryQueueItemRepo()->removeFailedByServerId($gsid, DI::config()->get('system', 'worker_defer_limit'));
 		}
 	}
 }