Add "CreateNewsInsightCase".

Author: metalwhale

chloria-backend/chloria-api/src/execution/cases/create_news_insight.rs

@@ -0,0 +1,48 @@
+use std::sync::Arc;
+
+use anyhow::Result;
+use async_trait::async_trait;
+
+use crate::execution::ports::repository::InsertNewsInsightInput;
+
+use super::{
+    super::{ports::repository::Repository, workshop::Workshop},
+    Case,
+};
+
+pub(crate) struct CreateNewsInsightCaseInput {
+    pub(crate) source_name: String,
+    pub(crate) article_id: String,
+    pub(crate) fields: String,
+}
+
+struct CreateNewsInsightCase {
+    repository: Arc<dyn Repository>,
+    input: CreateNewsInsightCaseInput,
+}
+
+impl Workshop {
+    pub(crate) async fn execute_create_news_insight_case(&self, input: CreateNewsInsightCaseInput) -> Result<()> {
+        let case = CreateNewsInsightCase {
+            repository: Arc::clone(&self.repository),
+            input,
+        };
+        self.run_case(case).await
+    }
+}
+
+#[async_trait]
+impl Case for CreateNewsInsightCase {
+    type Output = ();
+
+    async fn execute(self) -> Result<Self::Output> {
+        self.repository
+            .insert_news_insight(InsertNewsInsightInput {
+                source_name: self.input.source_name,
+                article_id: self.input.article_id,
+                fields: self.input.fields,
+            })
+            .await?;
+        Ok(())
+    }
+}

chloria-backend/chloria-api/src/execution/cases/mod.rs

@@ -1,4 +1,5 @@
 pub(crate) mod authenticate;
+pub(crate) mod create_news_insight;
 pub(crate) mod read_news;
 
 use anyhow::Result;

chloria-backend/chloria-api/src/execution/ports/repository.rs

@@ -17,9 +17,16 @@ pub(crate) struct SelectNewsOutput {
     pub(crate) image_path: Option<String>,
 }
 
+pub(crate) struct InsertNewsInsightInput {
+    pub(crate) source_name: String,
+    pub(crate) article_id: String,
+    pub(crate) fields: String,
+}
+
 #[async_trait]
 #[automock] // See: https://github.com/asomers/mockall/issues/189#issuecomment-689145249
 pub(crate) trait Repository: Send + Sync {
     async fn select_client_api_secret(&self, api_key_input: &str) -> Result<Option<String>>;
     async fn select_news(&self, input: SelectNewsInput) -> Result<Vec<SelectNewsOutput>>;
+    async fn insert_news_insight(&self, input: InsertNewsInsightInput) -> Result<()>;
 }

chloria-backend/chloria-api/src/infrastructure/repository/postgresql.rs

@@ -8,10 +8,11 @@ use diesel::{
 };
 
 use crate::{
-    execution::ports::repository::{Repository, SelectNewsInput, SelectNewsOutput},
+    execution::ports::repository::{InsertNewsInsightInput, Repository, SelectNewsInput, SelectNewsOutput},
     schema::{
         client_credentials::dsl::*,
         news::{self, dsl::*},
+        news_insights,
     },
 };
 
@@ -28,6 +29,14 @@ impl PostgresqlClient {
     }
 }
 
+#[derive(Insertable, AsChangeset)]
+#[diesel(table_name = news_insights)]
+struct InsertNewsInsightValue {
+    id: i32,
+    fields: String,
+    updated_at: DateTime<Local>,
+}
+
 #[async_trait]
 impl Repository for PostgresqlClient {
     async fn select_client_api_secret(&self, api_key_input: &str) -> Result<Option<String>> {
@@ -58,4 +67,23 @@ impl Repository for PostgresqlClient {
         }
         Ok(outputs)
     }
+
+    async fn insert_news_insight(&self, input: InsertNewsInsightInput) -> Result<()> {
+        let news_id: i32 = news
+            .filter(source_name.eq(input.source_name).and(article_id.eq(input.article_id)))
+            .select(news::id)
+            .first(&mut self.pool.get()?)?;
+        let value = InsertNewsInsightValue {
+            id: news_id,
+            fields: input.fields,
+            updated_at: Local::now(),
+        };
+        diesel::insert_into(news_insights::table)
+            .values(&value)
+            .on_conflict(news_insights::id)
+            .do_update()
+            .set(&value)
+            .execute(&mut self.pool.get()?)?;
+        Ok(())
+    }
 }

chloria-backend/chloria-api/src/interface/adapters/mod.rs

@@ -1,5 +1,5 @@
 pub(super) mod auth;
-pub(super) mod read_news;
+pub(super) mod news;
 
 use serde::Serialize;
 use serde_json::Value;

chloria-backend/chloria-api/src/interface/adapters/read_news.rs renamed to chloria-backend/chloria-api/src/interface/adapters/news.rs

@@ -9,7 +9,7 @@ use chrono::NaiveDate;
 use serde::Deserialize;
 
 use super::{super::state::RouterState, ErrorResponse};
-use crate::execution::cases::read_news::ReadNewsCaseInput;
+use crate::execution::cases::{create_news_insight::CreateNewsInsightCaseInput, read_news::ReadNewsCaseInput};
 
 #[derive(Deserialize)]
 pub(in super::super) struct ReadNewsRequest {
@@ -34,3 +34,26 @@ pub(in super::super) async fn read_news(
     ];
     Ok((headers, body))
 }
+
+#[derive(Deserialize)]
+pub(in super::super) struct CreateNewsInsightRequest {
+    source_name: String,
+    article_id: String,
+    fields: String,
+}
+
+pub(in super::super) async fn create_news_insight(
+    State(state): State<RouterState>,
+    Json(request): Json<CreateNewsInsightRequest>,
+) -> Result<(), (StatusCode, Json<ErrorResponse>)> {
+    state
+        .workshop
+        .execute_create_news_insight_case(CreateNewsInsightCaseInput {
+            source_name: request.source_name,
+            article_id: request.article_id,
+            fields: request.fields,
+        })
+        .await
+        .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, Json(e.to_string().into())))?;
+    Ok(())
+}

chloria-backend/chloria-api/src/interface/router.rs

@@ -9,7 +9,7 @@ use tower::ServiceBuilder;
 use super::{
     adapters::{
         auth::{authenticate, authorize},
-        read_news::read_news,
+        news::{create_news_insight, read_news},
     },
     state::{RouterState, RouterStateJwt},
 };
@@ -34,6 +34,7 @@ pub(crate) fn new(config: RouterConfig, workshop: Workshop) -> Router {
         .with_state(state.clone());
     let authorized_router = Router::new()
         .route("/news", get(read_news))
+        .route("/news_insight", post(create_news_insight))
         .route_layer(ServiceBuilder::new().layer(middleware::from_fn_with_state(state.clone(), authorize)))
         .with_state(state.clone());
     let router = Router::new().merge(public_router).merge(authorized_router);

chloria-backend/chloria-api/src/schema.rs

@@ -36,6 +36,16 @@ diesel::table! {
     }
 }
 
+diesel::table! {
+    news_insights (id) {
+        id -> Int4,
+        fields -> Nullable<Text>,
+        created_at -> Timestamptz,
+        updated_at -> Timestamptz,
+    }
+}
+
 diesel::joinable!(client_credentials -> clients (id));
+diesel::joinable!(news_insights -> news (id));
 
-diesel::allow_tables_to_appear_in_same_query!(client_credentials, clients, news,);
+diesel::allow_tables_to_appear_in_same_query!(client_credentials, clients, news, news_insights,);

chloria-backend/chloria-job/src/schema.rs

@@ -15,3 +15,16 @@ diesel::table! {
         updated_at -> Timestamptz,
     }
 }
+
+diesel::table! {
+    news_insights (id) {
+        id -> Int4,
+        fields -> Nullable<Text>,
+        created_at -> Timestamptz,
+        updated_at -> Timestamptz,
+    }
+}
+
+diesel::joinable!(news_insights -> news (id));
+
+diesel::allow_tables_to_appear_in_same_query!(news, news_insights,);

chloria-backend/migrations/2025-03-29-042604_create_news_insights/down.sql

@@ -0,0 +1,3 @@
+-- This file should undo anything in `up.sql`
+
+DROP TABLE news_insights;