feat: POST /v1/links support

Cargo.toml

@@ -10,16 +10,18 @@ publish = false
 
 [dependencies]
 axum = "0.7.2"
+chrono = { version = "0.4.31", default-features = false, features=["clock", "serde"] }
 http-body-util = "0.1.0"
 #lambda_http = "0.8.3"
 lambda_http = { git = "https://github.com/awslabs/aws-lambda-rust-runtime", branch = "hyper1_upgrade" }
 lambda_runtime = "0.8.3"
-serde = { version = "1.0.193", features = [ "derive" ] }
+serde = { version = "1.0.193", features = ["derive"] }
 serde_json = "1.0.108"
 tokio = { version = "1", features = ["macros"] }
 tower = "0.4.13"
 tracing = { version = "0.1", features = ["log"] }
 tracing-subscriber = { version = "0.3", default-features = false, features = ["fmt"] }
+uuid = { version = "1.6.1", features = ["v4", "serde"] }
 
 [dev-dependencies]
 mockall = "0.12.0"

src/controller/links.rs

@@ -1,12 +1,12 @@
 use axum::{
-    extract::{Path, State},
+    extract::{self, Path, State},
     http::StatusCode,
-    response::{IntoResponse, Json},
-    routing, Router,
+    response::IntoResponse,
+    routing, Json, Router,
 };
 use serde_json::json;
 
-use crate::types::state::Router as RouterState;
+use crate::types::{request::PostLink as PostLinkRequest, state::Router as RouterState};
 
 const LINKS_ROUTE: &str = "/v1/links";
 const LINKS_ID_ROUTE: &str = "/v1/links/:id";
@@ -35,10 +35,17 @@ async fn list(State(app_state): State<RouterState>) -> impl IntoResponse {
     }
 }
 
-async fn post(State(app_state): State<RouterState>) -> impl IntoResponse {
+async fn post(
+    State(app_state): State<RouterState>,
+    Json(payload): extract::Json<PostLinkRequest>,
+) -> impl IntoResponse {
     let links_service = app_state.get_links_service();
-    match links_service.post(&app_state).await {
-        Ok(link) => Json(link).into_response(),
+
+    match links_service
+        .post(&app_state, &payload.to_string().into())
+        .await
+    {
+        Ok(link) => (StatusCode::CREATED, Json(link)).into_response(),
         Err(e) => {
             tracing::error!("Error: {}", e);
             (
@@ -131,10 +138,12 @@ mod tests {
     async fn test_get_links_non_empty() {
         let mut mock_links_service = MockService::new();
         let mock_links_repo = MockRepository::new();
+        let item: LinkItem = "http://link".into();
+
         mock_links_service
             .expect_list()
             .times(1)
-            .returning(|_| Ok(vec![LinkItem::new("http://link")]));
+            .returning(move |_| Ok(vec![item.clone()]));
 
         let app_state = RouterState::new(Arc::new(mock_links_service), Arc::new(mock_links_repo));
 

src/repository/links.rs

@@ -13,8 +13,8 @@ impl Links for Repository {
         Ok(vec![])
     }
 
-    async fn post(&self) -> Result<LinkItem> {
-        Err("Not implemented".into())
+    async fn post(&self, item: &LinkItem) -> Result<LinkItem> {
+        Ok(item.clone())
     }
 
     async fn get(&self, _id: &str) -> Result<LinkItem> {

src/service/links.rs

@@ -15,9 +15,9 @@ impl Links for Service {
         links_repo.list().await
     }
 
-    async fn post<'a>(&self, app_state: &'a state::Router) -> Result<LinkItem> {
+    async fn post<'a>(&self, app_state: &'a state::Router, item: &LinkItem) -> Result<LinkItem> {
         let links_repo = app_state.get_links_repo();
-        links_repo.post().await
+        links_repo.post(item).await
     }
 
     async fn get<'a>(&self, id: &str, app_state: &'a state::Router) -> Result<LinkItem> {
@@ -69,12 +69,14 @@ mod tests {
     async fn test_get_links_non_empty() {
         let mock_links_service = MockService::new();
         let mut mock_links_repo = MockRepository::new();
+
+        let item: LinkItem = "http://link".into();
+        let expected_items = vec![item.clone()];
+
         mock_links_repo
             .expect_list()
             .times(1)
-            .returning(|| Ok(vec![LinkItem::new("http://link")]));
-
-        let expected_items = vec![LinkItem::new("http://link")];
+            .returning(move || Ok(vec![item.clone()]));
 
         let app_state = RouterState::new(Arc::new(mock_links_service), Arc::new(mock_links_repo));
 

src/types.rs

@@ -1,4 +1,5 @@
 pub mod links;
 pub mod repository;
+pub mod request;
 pub mod service;
 pub mod state;

src/types/links.rs

@@ -1,6 +1,8 @@
+use chrono::Utc;
 use serde::{Deserialize, Serialize};
+use uuid::Uuid;
 
-#[derive(Debug, Default, Serialize, Deserialize, PartialEq, Eq)]
+#[derive(Clone, Debug, Default, Serialize, Deserialize, PartialEq, Eq)]
 pub struct LinkItem {
     id: String,
     owner: String,
@@ -11,11 +13,12 @@ pub struct LinkItem {
     updated_at: String,
 }
 
-impl LinkItem {
-    #[allow(dead_code)]
-    pub fn new(url: &str) -> Self {
+impl<T: ToString> From<T> for LinkItem {
+    fn from(link_url: T) -> Self {
         Self {
-            url: url.to_string(),
+            url: link_url.to_string(),
+            id: Uuid::new_v4().to_string(),
+            created_at: Utc::now().to_rfc3339(),
             ..Default::default()
         }
     }