Fix: Solve issue with not rejecting messages that it's content doesn't exist on IPFS.

Author: nesitor

src/aleph/services/ipfs/service.py

@@ -10,7 +10,7 @@
 
 from aleph.services.ipfs.common import make_ipfs_client
 from aleph.services.utils import get_IP
-from aleph.types.message_status import FileUnavailable
+from aleph.types.message_status import FileContentUnavailable, FileUnavailable
 from aleph.utils import run_in_executor
 
 LOGGER = logging.getLogger(__name__)
@@ -113,8 +113,9 @@ async def get_ipfs_size(
                 await asyncio.sleep(0.5)
                 continue
             except asyncio.TimeoutError:
-                result = None
-                await asyncio.sleep(0.5)
+                raise FileContentUnavailable(
+                    "Could not retrieve IPFS content at this time"
+                )
             except (
                 concurrent.futures.CancelledError,
                 aiohttp.client_exceptions.ClientConnectorError,

src/aleph/types/message_status.py

@@ -169,6 +169,16 @@ def __init__(self, file_hash: str):
         super().__init__(f"File not found: {file_hash}")
 
 
+class FileContentNotFoundException(RetryMessageException):
+    """
+    A file required to process the message could not be found, locally and/or
+    on the network.
+    """
+
+    def __init__(self, file_hash: str):
+        super().__init__(f"File content not found: {file_hash}")
+
+
 class MessageContentUnavailable(FileNotFoundException):
     """
     The message content is not available at the moment (storage/IPFS item types).
@@ -185,6 +195,14 @@ class FileUnavailable(FileNotFoundException):
     error_code = ErrorCode.FILE_UNAVAILABLE
 
 
+class FileContentUnavailable(FileContentNotFoundException):
+    """
+    A file pointed to by the message is not available at the moment.
+    """
+
+    error_code = ErrorCode.FILE_UNAVAILABLE
+
+
 class NoAmendTarget(InvalidMessageException):
     """
     A POST with type = amend does not specify a value in the ref field.