Configuration is now stored in the "channel" section

[friendica.git] / src / Model / Post / Delivery.php

diff --git a/src/Model/Post/Delivery.php b/src/Model/Post/Delivery.php
index 52c1bf8e0ee979c9d29c3f0fd9af65dcd8dd2906..c53014fa516ff8ee6fbcfaeacedf428c72db4fed 100644 (file)
--- a/src/Model/Post/Delivery.php
+++ b/src/Model/Post/Delivery.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
  *
@@ -78,12 +78,12 @@ class Delivery
         */
        public static function incrementFailed(int $uri_id, string $inbox)
        {
-               return DBA::e('UPDATE `post-delivery` SET `failed` = `failed` + 1 WHERE `uri-id` = ? AND `inbox-id` = ?', $uri_id, ItemURI::getIdByURI($inbox));
+               return DBA::update('post-delivery', ["`failed` = `failed` + 1"], ['uri-id' => $uri_id, 'inbox-id' => ItemURI::getIdByURI($inbox)]);
        }
 
        public static function selectForInbox(string $inbox)
        {
-               $rows = DBA::select('post-delivery', [], ['inbox-id' => ItemURI::getIdByURI($inbox)], ['order' => ['created']]);
+               $rows = DBA::select('post-delivery', [], ["`inbox-id` = ? AND `failed` < ?", ItemURI::getIdByURI($inbox), DI::config()->get('system', 'worker_defer_limit')], ['order' => ['created']]);
                $deliveries = [];
                while ($row = DBA::fetch($rows)) {
                        if (!empty($row['receivers'])) {