add delete endpoint.

plugins/basicmessage_storage/basicmessage_storage/v1_0/models.py

@@ -5,6 +5,7 @@
     INDY_ISO8601_DATETIME_VALIDATE,
 )
 from marshmallow import fields
+from aries_cloudagent.storage.base import BaseStorage
 
 
 class BasicMessageRecord(BaseRecord):
@@ -61,6 +62,25 @@ def record_tags(self) -> dict:
         """Get tags for record."""
         return {"connection_id": self.connection_id, "message_id": self.message_id}
 
+
+    async def delete_record(self, session: ProfileSession):
+        """Perform connection record deletion actions.
+
+        Args:
+            session (ProfileSession): session
+
+        """
+        await super().delete_record(session)
+
+        # Delete metadata
+        if self.message_id:
+            storage = session.inject(BaseStorage)
+            await storage.delete_all_records(
+                self.RECORD_TYPE,
+                {"message_id": self.message_id},
+            )
+
+
     @classmethod
     async def retrieve_by_message_id(
         cls, session: ProfileSession, message_id: str

plugins/basicmessage_storage/basicmessage_storage/v1_0/routes.py

@@ -14,6 +14,7 @@
 from aries_cloudagent.messaging.models.base import BaseModelError
 from aries_cloudagent.messaging.models.openapi import OpenAPISchema
 from aries_cloudagent.messaging.util import time_now, str_to_epoch
+from aries_cloudagent.messaging.valid import UUID4_EXAMPLE
 from aries_cloudagent.multitenant.error import WalletKeyMissingError
 from aries_cloudagent.protocols.basicmessage.v1_0.message_types import SPEC_URI
 from aries_cloudagent.protocols.basicmessage.v1_0.routes import (
@@ -55,6 +56,19 @@ class BasicMessageListSchema(OpenAPISchema):
         description="List of basic message records",
     )
 
+class BasicMessageIdMatchInfoSchema(OpenAPISchema):
+    """Path parameters and validators for request taking connection id."""
+
+    message_id = fields.Str(
+        required=True,
+        metadata={"description": "Message identifier", "example": UUID4_EXAMPLE},
+    )
+
+
+class DeleteResponseSchema(OpenAPISchema):
+    """Response schema for DELETE endpoint."""
+
+
 
 class BasicMessageListQueryStringSchema(OpenAPISchema):
     connection_id = fields.Str(
@@ -162,6 +176,40 @@ async def all_messages_list(request: web.BaseRequest):
     return web.json_response({"results": results})
 
 
+@docs(
+    tags=["basicmessage"],
+    summary="delete stored message by message_id",
+)
+@match_info_schema(BasicMessageIdMatchInfoSchema())
+@response_schema(DeleteResponseSchema(), 200, description="")
+@error_handler
+async def delete_message(request: web.BaseRequest):
+    """
+    Request handler for searching basic message records from All agents/connections.
+
+    Args:
+        request: aiohttp request object
+
+    Returns:
+        The message list response
+
+    """
+    context: AdminRequestContext = request["context"]
+    profile = context.profile
+    message_id = request.match_info["message_id"]
+    try:
+        async with profile.session() as session:
+            record = await BasicMessageRecord.retrieve_by_message_id(session, message_id)
+        await record.delete_record(session)
+
+    except StorageNotFoundError as err:
+        raise web.HTTPNotFound(reason=err.roll_up) from err
+    except (StorageError, BaseModelError) as err:
+        raise web.HTTPBadRequest(reason=err.roll_up) from err
+    return web.json_response({})
+
+
+
 async def register(app: web.Application):
     """Register routes."""
     # we want to save messages when sent, so replace the default send message endpoint
@@ -195,6 +243,7 @@ async def register(app: web.Application):
 
     # add in the message list(s) route
     app.add_routes([web.get("/basicmessages", all_messages_list, allow_head=False)])
+    app.add_routes([web.delete("/basicmessages/{message_id}", delete_message)])
 
 
 def post_process_routes(app: web.Application):