Added exception handler for expired lighthouse token.

contract_api/exceptions.py

@@ -8,3 +8,8 @@ class InvalidFilePath(CustomException):
     def __init__(self, file_path=None):
         super().__init__(error_details=f"File not found in path {file_path}")
 
+class LighthouseInternalException(CustomException):
+    error_message = "LIGHTHOUSE_INTERNAL_SERVER_ERROR"
+
+    def __init__(self):
+        super().__init__({})

contract_api/infrastructure/storage_provider.py

@@ -9,6 +9,7 @@
 
 from common.exceptions import BadRequestException
 from contract_api.config import IPFS_URL
+from contract_api.exceptions import LighthouseInternalException
 from common.logger import get_logger
 
 import ipfshttpclient
@@ -82,7 +83,11 @@ def __upload_to_provider(self, file_path: str, provider_type: StorageProviderTyp
         if provider_type == StorageProviderType.IPFS:
             metadata_hash = self.__ipfs_util.write_file_in_ipfs(file_path)
         elif provider_type == StorageProviderType.FILECOIN:
-            metadata_hash = self.__lighthouse_client.upload(file_path)["data"]["Hash"]
+            try:
+                metadata_hash = self.__lighthouse_client.upload(file_path)["data"]["Hash"]
+            except Exception as e:
+                raise LighthouseInternalException(
+                    "Internal Lighthouse server error. Please check your Lighthouse token.")
         else:
             raise ValueError(f"Unsupported provider type: {provider_type}")
         return self.hash_to_uri(metadata_hash, provider_type)

registry/exceptions.py

@@ -128,9 +128,16 @@ def __init__(self):
             http_code=HTTPStatus.FORBIDDEN
         )
 
+class LighthouseInternalException(CustomException):
+    error_message = "LIGHTHOUSE_INTERNAL_SERVER_ERROR"
+
+    def __init__(self):
+        super().__init__({})
+
 EXCEPTIONS = (BadRequestException, OrganizationNotFoundException, InvalidOriginException, MethodNotImplemented,
               InvalidOrganizationStateException, InvalidMetadataException, InvalidServiceStateException,
               ServiceProtoNotFoundException, OrganizationNotPublishedException, ForbiddenException,
               ServiceNotFoundException, ServiceGroupNotFoundException, EnvironmentNotFoundException,
               InvalidSlackUserException, InvalidSlackChannelException, InvalidSlackSignatureException,
-              InvalidFileTypeException, FileNotFoundException, OperationNotAllowed, InvalidOrganizationType)
+              InvalidFileTypeException, FileNotFoundException, OperationNotAllowed, InvalidOrganizationType,
+              LighthouseInternalException)

registry/infrastructure/storage_provider.py

@@ -8,6 +8,7 @@
 
 from common.exceptions import BadRequestException
 from registry.config import IPFS_URL
+from registry.exceptions import LighthouseInternalException
 from common.logger import get_logger
 
 import ipfshttpclient
@@ -77,7 +78,10 @@ def __upload_to_provider(self, file_path: str, provider_type: StorageProviderTyp
         if provider_type == StorageProviderType.IPFS:
             metadata_hash = self.__ipfs_util.write_file_in_ipfs(file_path)
         elif provider_type == StorageProviderType.FILECOIN:
-            metadata_hash = self.__lighthouse_client.upload(file_path)["data"]["Hash"]
+            try:
+                metadata_hash = self.__lighthouse_client.upload(file_path)["data"]["Hash"]
+            except Exception as e:
+                raise LighthouseInternalException("Internal Lighthouse server error. Please check your Lighthouse token.")
         else:
             raise ValueError(f"Unsupported provider type: {provider_type}")
         return self.hash_to_uri(metadata_hash, provider_type)