adding delete_thumbnail endpoint

Author: Gpetrak

geonode/base/api/views.py

@@ -57,7 +57,7 @@
 from geonode.base.models import Configuration, ExtraMetadata, LinkedResource
 from geonode.thumbs.exceptions import ThumbnailError
 from geonode.thumbs.thumbnails import create_thumbnail
-from geonode.thumbs.utils import _decode_base64, BASE64_PATTERN
+from geonode.thumbs.utils import _decode_base64, BASE64_PATTERN, remove_thumb
 from geonode.groups.conf import settings as groups_settings
 from geonode.base.models import HierarchicalKeyword, Region, ResourceBase, TopicCategory, ThesaurusKeyword
 from geonode.base.api.filters import (
@@ -721,6 +721,60 @@ def set_thumbnail_from_bbox(self, request, resource_id, *args, **kwargs):
             logger.error(e)
             return Response(data={"message": e.args[0], "success": False}, status=500, exception=True)
 
+    @extend_schema(
+        methods=["post"],
+        responses={200},
+        description="API endpoint allowing to delete a thumbnail for an existing dataset.",
+    )
+    @action(
+        detail=False,
+        url_path="(?P<resource_id>\d+)/delete_thumbnail",  # noqa
+        url_name="delete-thumbnail",
+        methods=["post"],
+        permission_classes=[IsAuthenticated, UserHasPerms(perms_dict={"default": {"POST": ["base.add_resourcebase"]}})],
+    )
+
+    def delete_thumbnail(self, request, resource_id, *args, **kwargs):
+        
+        try:
+            resource = ResourceBase.objects.get(id=int(resource_id))
+
+            if not isinstance(resource.get_real_instance(), (Dataset, Map)):
+                return Response(
+                {"message": "Endpoint only available for Datasets and Maps.", "success": False},
+                status=status.HTTP_400_BAD_REQUEST
+            )
+
+            # Check if thumbnail exists
+            if not resource.thumbnail_url:
+                return Response(
+                    {"message": "The thumbnail URL field is already empty.", "success": False},
+                    status=status.HTTP_200_OK
+                )
+
+            # request_body = request.data if request.data else json.loads(request.body)
+            thumb_parsed_url = urlparse(resource.thumbnail_url)
+            thumb_filename = thumb_parsed_url.path.split("/")[-1]
+            # remove_thumb will call the thumb_path function and then the storage_manager which will delete it
+            remove_thumb(thumb_filename)
+
+            # Clear the field in the database
+            resource.thumbnail_url = ""
+            resource.save(update_fields=["thumbnail_url"])
+
+            return Response(
+                    {"message": "Thumbnail deleted successfully.", "success": True}, status=status.HTTP_200_OK
+            )
+
+        except ResourceBase.DoesNotExist:
+            return Response({"message": "Resource not found.", "success": False}, status=status.HTTP_404_NOT_FOUND)
+        except ValueError:
+            return Response({"message": "Invalid resource ID.", "success": False}, status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            logger.error(e)
+            return Response({"message": "Unexpected error occurred.", "success": False}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
+    
     @extend_schema(
         methods=["post"], responses={200}, description="Instructs the Async dispatcher to execute a 'INGEST' operation."
     )