]> git.mxchange.org Git - friendica.git/commitdiff
Don't look at the command when archiving an inbox
authorMichael Vogel <icarus@dabo.de>
Fri, 13 May 2022 02:24:22 +0000 (04:24 +0200)
committerMichael Vogel <icarus@dabo.de>
Fri, 13 May 2022 02:24:22 +0000 (04:24 +0200)
src/Worker/APDelivery.php

index 3fb389313ff1d88c40b9d5539c507278f13929f0..641f27fce42afabf063e3dd132cd779b5c1decbb 100644 (file)
@@ -48,22 +48,20 @@ class APDelivery
        {
                if (ActivityPub\Transmitter::archivedInbox($inbox)) {
                        Logger::info('Inbox is archived', ['cmd' => $cmd, 'inbox' => $inbox, 'id' => $item_id, 'uri-id' => $uri_id, 'uid' => $uid]);
-                       if (in_array($cmd, [Delivery::POST])) {
-                               if (empty($uri_id) && !empty($item_id)) {
-                                       $item = Post::selectFirst(['uri-id'], ['id' => $item_id]);
-                                       $uri_id = $item['uri-id'] ?? 0;
-                               }
-                               if (empty($uri_id)) {
-                                       $posts   = Post\Delivery::selectForInbox($inbox);
-                                       $uri_ids = array_column($posts, 'uri-id');
-                               } else {
-                                       $uri_ids = [$uri_id];
-                               }
-               
-                               foreach ($uri_ids as $uri_id) {
-                                       Post\Delivery::remove($uri_id, $inbox);
-                                       Post\DeliveryData::incrementQueueFailed($uri_id);
-                               }
+                       if (empty($uri_id) && !empty($item_id)) {
+                               $item = Post::selectFirst(['uri-id'], ['id' => $item_id]);
+                               $uri_id = $item['uri-id'] ?? 0;
+                       }
+                       if (empty($uri_id)) {
+                               $posts   = Post\Delivery::selectForInbox($inbox);
+                               $uri_ids = array_column($posts, 'uri-id');
+                       } else {
+                               $uri_ids = [$uri_id];
+                       }
+
+                       foreach ($uri_ids as $uri_id) {
+                               Post\Delivery::remove($uri_id, $inbox);
+                               Post\DeliveryData::incrementQueueFailed($uri_id);
                        }
                        return;
                }
@@ -79,7 +77,7 @@ class APDelivery
                        $uri_ids = [$uri_id];
                }
 
-               if (!$success && !Worker::defer() && in_array($cmd, [Delivery::POST])) {
+               if (!$success && !Worker::defer() && !empty($uri_ids)) {
                        foreach ($uri_ids as $uri_id) {
                                Post\Delivery::remove($uri_id, $inbox);
                                Post\DeliveryData::incrementQueueFailed($uri_id);