Delete recipe Impl

cdk/lib/pipeline.ts

@@ -4,7 +4,6 @@ import MealPlannerStage from './application-stage';
 import {
   CodePipeline,
   CodePipelineSource,
-  ManualApprovalStep,
   ShellStep,
 } from 'aws-cdk-lib/pipelines';
 import path = require('path');

lambda/src/lib.rs

@@ -9,4 +9,5 @@ pub mod services;
 pub trait Repository<T>: Send + Sync {
     fn find_by_id(&self, id: Uuid) -> impl Future<Output = Result<T, StatusCode>> + Send;
     fn save(&self, item: &T) -> impl Future<Output = Result<(), StatusCode>> + Send;
+    fn delete(&self, id: Uuid) -> impl Future<Output = Result<(), StatusCode>> + Send;
 }

lambda/src/recipe/repository.rs

@@ -1,5 +1,5 @@
 use aws_config::SdkConfig;
-use aws_sdk_dynamodb::operation::get_item::GetItemError;
+use aws_sdk_dynamodb::operation::{delete_item::DeleteItemError, get_item::GetItemError};
 use aws_sdk_dynamodb::types::AttributeValue;
 use aws_sdk_dynamodb::Client;
 use axum::http::StatusCode;
@@ -60,4 +60,19 @@ impl Repository<Recipe> for DynamoDbRecipe {
 
         Ok(())
     }
+
+    async fn delete(&self, id: Uuid) -> Result<(), StatusCode> {
+        self.client
+            .delete_item()
+            .table_name(&self.table_name)
+            .key("id", AttributeValue::S(id.as_hyphenated().to_string()))
+            .send()
+            .await
+            .map_err(|sdk_err| match sdk_err.into_service_error() {
+                DeleteItemError::ResourceNotFoundException(_) => StatusCode::NOT_FOUND,
+                _ => StatusCode::INTERNAL_SERVER_ERROR,
+            })?;
+
+        Ok(())
+    }
 }

lambda/src/services/mod.rs

@@ -1,5 +1,5 @@
 use aws_config::BehaviorVersion;
-use axum::routing::{get, post};
+use axum::routing::{delete, get, post};
 use axum::Router;
 use tracing::{info, instrument};
 
@@ -26,5 +26,6 @@ pub async fn recipes() -> Router {
     Router::new()
         .route("/:id", get(recipes::read_one::<DynamoDbRecipe>))
         .route("/", post(recipes::create::<DynamoDbRecipe>))
+        .route("/:id", delete(recipes::delete::<DynamoDbRecipe>))
         .with_state(recipe_context)
 }

lambda/src/services/recipes.rs

@@ -32,3 +32,15 @@ where
 
     Ok(Json(recipe))
 }
+
+pub(super) async fn delete<T>(
+    State(state): State<ApplicationContext<T>>,
+    Path(id): Path<Uuid>,
+) -> Result<StatusCode, StatusCode>
+where
+     T: Repository<Recipe>
+{
+    state.repo.delete(id).await?;
+
+    Ok(StatusCode::NO_CONTENT)
+}

playwright/tests/recipes.spec.ts

@@ -3,35 +3,50 @@ import { test, expect } from '@playwright/test';
 const data = {
   name: 'Playwright Recipe',
 };
+const NIL_UUID = '00000000-0000-0000-0000-000000000000';
 
 let recipeUuid: string;
 
-test.beforeAll('Create Recipe', async ({ request }) => {
-  const response = await request.post('./recipes', { data });
+test.describe('Happy Path', () => {
+  test.beforeAll('Create Recipe', async ({ request }) => {
+    const response = await request.post('./recipes', { data });
 
-  expect(response.ok()).toBeTruthy();
+    expect(response.ok()).toBeTruthy();
 
-  const responseBody = await response.json();
-  expect(responseBody).toEqual({
-    // eslint-disable-next-line max-len
-    id: expect.stringMatching(/^[0-9a-fA-F]{8}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{12}$/),
-    ...data,
+    const responseBody = await response.json();
+    expect(responseBody).toEqual({
+      // eslint-disable-next-line max-len
+      id: expect.stringMatching(/^[0-9a-fA-F]{8}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{12}$/),
+      ...data,
+    });
+    recipeUuid = responseBody.id;
+  });
+
+  test('Read Recipe', async ({ request }) => {
+    const response = await request.get(`./recipes/${recipeUuid}`);
+
+    expect(response.ok()).toBeTruthy();
+    expect(await response.json()).toEqual({
+      id: recipeUuid,
+      ...data,
+    });
   });
-  recipeUuid = responseBody.id;
-});
 
-test('Read Recipe', async ({ request }) => {
-  const response = await request.get(`./recipes/${recipeUuid}`);
+  test.afterAll('Delete Recipe', async ({ request }) => {
+    const response = await request.delete(`./recipes/${recipeUuid}`);
 
-  expect(response.ok()).toBeTruthy();
-  expect(await response.json()).toEqual({
-    id: recipeUuid,
-    ...data,
+    expect(response.status()).toEqual(204);
   });
 });
 
-test.afterAll('Delete Recipe', async ({ request }) => {
-  const response = await request.delete(`./recipes/${recipeUuid}`);
+test('Read Non-existent Recipe', async ({ request }) => {
+  const response = await request.get(`./recipes/${NIL_UUID}`);
+
+  expect(response.status()).toEqual(404);
+});
+
+test('Delete Non-existent Recipe', async ({ request }) => {
+  const response = await request.delete(`./recipes/${NIL_UUID}`);
 
-  expect(response.ok()).toBeTruthy();
+  expect(response.status()).toEqual(404);
 });