Add endpoint to delete PIPE status

Author: timbeccue

README.md

@@ -346,6 +346,8 @@ The PIPE Queue service provides FIFO (First-In-First-Out) queues and status trac
 | POST | `/pipe/status` | Set status for a PIPE machine | `{"pipe_id": "string", "status": "string", "details": {}}` | Status details |
 | GET | `/pipe/status/{pipe_id}` | Get status of a specific PIPE machine | N/A | Status details |
 | GET | `/pipe/statuses` | Get status of all PIPE machines | N/A | Array of statuses |
+| DELETE | `/pipe/status/{pipe_id}` | Delete status of a specific PIPE machine | N/A | `{"message": "Status deleted for PIPE: pipe_id"}` |
+
 
 ### Example Usage
 

api/pipe_queue.py

@@ -427,6 +427,37 @@ def set_pipe_status(event, context):
 
     return http_response(HTTPStatus.OK, status_info)
 
+def delete_pipe_status(event, context):
+    """Deletes the status of a PIPE machine.
+
+    Args:
+        event.pathParameters.pipe_id (str): Identifier for the PIPE machine
+
+    Returns:
+        200 status code if successful or if the PIPE status doesn't exist
+        400 status code if the pipe_id is missing
+    """
+    pipe_id = event['pathParameters']['pipe_id']
+
+    if not pipe_id:
+        log.error("Missing required field: pipe_id")
+        return http_response(
+            HTTPStatus.BAD_REQUEST,
+            "Missing required field: pipe_id"
+        )
+
+    # Delete the status item
+    PIPE_QUEUE_TABLE.delete_item(
+        Key={
+            'pk': f"STATUS#{pipe_id}",
+            'sk': 'INFO'
+        }
+    )
+
+    return http_response(
+        HTTPStatus.OK,
+        {"message": f"Status deleted for PIPE: {pipe_id}"}
+    )
 
 def get_pipe_status_handler(event, context):
     """Gets the status of a PIPE machine.
@@ -456,4 +487,4 @@ def get_all_pipe_statuses_handler(event, context):
         200 status code with status information for all PIPE machines
     """
     statuses = get_all_pipe_statuses()
-    return http_response(HTTPStatus.OK, statuses)
+    return http_response(HTTPStatus.OK, statuses)

serverless.yml

@@ -452,6 +452,14 @@ functions:
           method: post
           cors: true
 
+  deletePipeStatus:
+    handler: api/pipe_queue.delete_pipe_status
+    events:
+      - http:
+          path: /pipe/status/{pipe_id}
+          method: delete
+          cors: true
+
   getPipeStatus:
     handler: api/pipe_queue.get_pipe_status_handler
     events: