BLOG-43 Post related api endpoints #55
12
.vscode/settings.json
vendored
Normal file
12
.vscode/settings.json
vendored
Normal file
@ -0,0 +1,12 @@
|
||||
{
|
||||
"cSpell.words": [
|
||||
"actix",
|
||||
"chrono",
|
||||
"dotenv",
|
||||
"rustls",
|
||||
"serde",
|
||||
"sqlx",
|
||||
"squidspirit"
|
||||
]
|
||||
}
|
||||
|
@ -3,7 +3,7 @@
|
||||
## Development
|
||||
|
||||
- Frontend: Next.js
|
||||
- Backend: Go (gin)
|
||||
- Backend: Rust actix-web
|
||||
|
||||
Despite Next.js being a full-stack framework, I still decided to adopt a separate front-end and back-end architecture for this blog project. I believe that this separation makes the project cleaner, reduces coupling, and aligns with modern development practices. Furthermore, I wanted to practice developing a purely back-end API.
|
||||
|
||||
|
3
backend/.gitignore
vendored
Normal file
3
backend/.gitignore
vendored
Normal file
@ -0,0 +1,3 @@
|
||||
.env
|
||||
/.sqlx
|
||||
/target
|
2823
backend/Cargo.lock
generated
Normal file
2823
backend/Cargo.lock
generated
Normal file
File diff suppressed because it is too large
Load Diff
27
backend/Cargo.toml
Normal file
27
backend/Cargo.toml
Normal file
@ -0,0 +1,27 @@
|
||||
[workspace]
|
||||
members = ["feature/post", "server"]
|
||||
resolver = "2"
|
||||
|
||||
[workspace.package]
|
||||
version = "0.1.1"
|
||||
edition = "2024"
|
||||
|
||||
[workspace.dependencies]
|
||||
actix-web = "4.10.2"
|
||||
async-trait = "0.1.88"
|
||||
chrono = "0.4.41"
|
||||
dotenv = "0.15.0"
|
||||
env_logger = "0.11.8"
|
||||
futures = "0.3.31"
|
||||
log = "0.4.27"
|
||||
serde = { version = "1.0.219", features = ["derive"] }
|
||||
sqlx = { version = "0.8.5", features = [
|
||||
"chrono",
|
||||
"macros",
|
||||
"postgres",
|
||||
"runtime-tokio-rustls",
|
||||
] }
|
||||
tokio = { version = "1.45.0", features = ["full"] }
|
||||
|
||||
server.path = "server"
|
||||
post.path = "feature/post"
|
42
backend/README.md
Normal file
42
backend/README.md
Normal file
@ -0,0 +1,42 @@
|
||||
# Backend
|
||||
|
||||
## Development
|
||||
|
||||
### SQL Migration
|
||||
|
||||
1. Install sqlx
|
||||
|
||||
```bash
|
||||
cargo install sqlx-cli
|
||||
```
|
||||
|
||||
2. Run migration
|
||||
|
||||
```bash
|
||||
sqlx migrate run
|
||||
```
|
||||
|
||||
### Run Project
|
||||
|
||||
1. Prepare for sql schema setup
|
||||
|
||||
```bash
|
||||
cargo sqlx prepare --workspace
|
||||
```
|
||||
|
||||
2. Run the server
|
||||
|
||||
```bash
|
||||
RUST_LOG=debug cargo run
|
||||
```
|
||||
|
||||
3. (Optional) Hot restart
|
||||
|
||||
1. Install `watchexec`
|
||||
|
||||
2. Run the server with `watchexec`
|
||||
|
||||
```bash
|
||||
RUST_LOG=debug watchexec -e rs -r 'cargo run'
|
||||
```
|
||||
|
5
backend/build.rs
Normal file
5
backend/build.rs
Normal file
@ -0,0 +1,5 @@
|
||||
// generated by `sqlx migrate build-script`
|
||||
fn main() {
|
||||
// trigger recompilation when a new migration is added
|
||||
println!("cargo:rerun-if-changed=migrations");
|
||||
}
|
12
backend/feature/post/Cargo.toml
Normal file
12
backend/feature/post/Cargo.toml
Normal file
@ -0,0 +1,12 @@
|
||||
[package]
|
||||
name = "post"
|
||||
version.workspace = true
|
||||
edition.workspace = true
|
||||
|
||||
[dependencies]
|
||||
actix-web.workspace = true
|
||||
async-trait.workspace = true
|
||||
chrono.workspace = true
|
||||
log.workspace = true
|
||||
serde.workspace = true
|
||||
sqlx.workspace = true
|
2
backend/feature/post/src/adapter.rs
Normal file
2
backend/feature/post/src/adapter.rs
Normal file
@ -0,0 +1,2 @@
|
||||
pub mod delivery;
|
||||
pub mod gateway;
|
5
backend/feature/post/src/adapter/delivery.rs
Normal file
5
backend/feature/post/src/adapter/delivery.rs
Normal file
@ -0,0 +1,5 @@
|
||||
pub mod label_response_dto;
|
||||
pub mod post_controller;
|
||||
pub mod post_info_query_dto;
|
||||
pub mod post_info_response_dto;
|
||||
pub mod post_response_dto;
|
@ -0,0 +1,20 @@
|
||||
use serde::Serialize;
|
||||
|
||||
use crate::domain::entity::label::Label;
|
||||
|
||||
#[derive(Serialize)]
|
||||
pub struct LabelResponseDto {
|
||||
pub id: i32,
|
||||
pub name: String,
|
||||
pub color: String,
|
||||
}
|
||||
|
||||
impl From<Label> for LabelResponseDto {
|
||||
fn from(entity: Label) -> Self {
|
||||
Self {
|
||||
id: entity.id,
|
||||
name: entity.name,
|
||||
color: format!("#{:08X}", entity.color),
|
||||
}
|
||||
}
|
||||
}
|
65
backend/feature/post/src/adapter/delivery/post_controller.rs
Normal file
65
backend/feature/post/src/adapter/delivery/post_controller.rs
Normal file
@ -0,0 +1,65 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::application::{
|
||||
error::post_error::PostError,
|
||||
use_case::{
|
||||
get_all_post_info_use_case::GetAllPostInfoUseCase,
|
||||
get_full_post_use_case::GetFullPostUseCase,
|
||||
},
|
||||
};
|
||||
|
||||
use super::{post_info_response_dto::PostInfoResponseDto, post_response_dto::PostResponseDto};
|
||||
|
||||
#[async_trait]
|
||||
pub trait PostController: Send + Sync {
|
||||
async fn get_all_post_info(
|
||||
&self,
|
||||
is_published_only: bool,
|
||||
) -> Result<Vec<PostInfoResponseDto>, PostError>;
|
||||
|
||||
async fn get_full_post(&self, id: i32) -> Result<PostResponseDto, PostError>;
|
||||
}
|
||||
|
||||
pub struct PostControllerImpl {
|
||||
get_all_post_info_use_case: Arc<dyn GetAllPostInfoUseCase>,
|
||||
get_full_post_use_case: Arc<dyn GetFullPostUseCase>,
|
||||
}
|
||||
|
||||
impl PostControllerImpl {
|
||||
pub fn new(
|
||||
get_all_post_info_use_case: Arc<dyn GetAllPostInfoUseCase>,
|
||||
get_full_post_use_case: Arc<dyn GetFullPostUseCase>,
|
||||
) -> Self {
|
||||
Self {
|
||||
get_all_post_info_use_case,
|
||||
get_full_post_use_case,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
impl PostController for PostControllerImpl {
|
||||
async fn get_all_post_info(
|
||||
&self,
|
||||
is_published_only: bool,
|
||||
) -> Result<Vec<PostInfoResponseDto>, PostError> {
|
||||
let result = self.get_all_post_info_use_case.execute(is_published_only).await;
|
||||
|
||||
result.map(|post_info_list| {
|
||||
let post_info_response_dto_list: Vec<PostInfoResponseDto> = post_info_list
|
||||
.into_iter()
|
||||
.map(|post_info| PostInfoResponseDto::from(post_info))
|
||||
.collect();
|
||||
|
||||
post_info_response_dto_list
|
||||
})
|
||||
}
|
||||
|
||||
async fn get_full_post(&self, id: i32) -> Result<PostResponseDto, PostError> {
|
||||
let result = self.get_full_post_use_case.execute(id).await;
|
||||
|
||||
result.map(PostResponseDto::from)
|
||||
}
|
||||
}
|
@ -0,0 +1,6 @@
|
||||
use serde::Deserialize;
|
||||
|
||||
#[derive(Deserialize)]
|
||||
pub struct PostQueryDto {
|
||||
pub is_published_only: Option<bool>,
|
||||
}
|
@ -0,0 +1,34 @@
|
||||
use serde::Serialize;
|
||||
|
||||
use crate::domain::entity::post_info::PostInfo;
|
||||
|
||||
use super::label_response_dto::LabelResponseDto;
|
||||
|
||||
#[derive(Serialize)]
|
||||
pub struct PostInfoResponseDto {
|
||||
pub id: i32,
|
||||
pub title: String,
|
||||
pub description: String,
|
||||
pub preview_image_url: String,
|
||||
pub labels: Vec<LabelResponseDto>,
|
||||
pub published_time: Option<i64>,
|
||||
}
|
||||
|
||||
impl From<PostInfo> for PostInfoResponseDto {
|
||||
fn from(entity: PostInfo) -> Self {
|
||||
Self {
|
||||
id: entity.id,
|
||||
title: entity.title,
|
||||
description: entity.description,
|
||||
preview_image_url: entity.preview_image_url,
|
||||
labels: entity
|
||||
.labels
|
||||
.into_iter()
|
||||
.map(LabelResponseDto::from)
|
||||
.collect(),
|
||||
published_time: entity
|
||||
.published_time
|
||||
.map(|datetime| datetime.timestamp_micros()),
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,22 @@
|
||||
use serde::Serialize;
|
||||
|
||||
use crate::domain::entity::post::Post;
|
||||
|
||||
use super::post_info_response_dto::PostInfoResponseDto;
|
||||
|
||||
#[derive(Serialize)]
|
||||
pub struct PostResponseDto {
|
||||
pub id: i32,
|
||||
pub info: PostInfoResponseDto,
|
||||
pub content: String,
|
||||
}
|
||||
|
||||
impl From<Post> for PostResponseDto {
|
||||
fn from(entity: Post) -> Self {
|
||||
Self {
|
||||
id: entity.id,
|
||||
info: PostInfoResponseDto::from(entity.info),
|
||||
content: entity.content,
|
||||
}
|
||||
}
|
||||
}
|
2
backend/feature/post/src/adapter/gateway.rs
Normal file
2
backend/feature/post/src/adapter/gateway.rs
Normal file
@ -0,0 +1,2 @@
|
||||
pub mod post_db_service;
|
||||
pub mod post_repository_impl;
|
12
backend/feature/post/src/adapter/gateway/post_db_service.rs
Normal file
12
backend/feature/post/src/adapter/gateway/post_db_service.rs
Normal file
@ -0,0 +1,12 @@
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::{
|
||||
application::error::post_error::PostError,
|
||||
domain::entity::{post::Post, post_info::PostInfo},
|
||||
};
|
||||
|
||||
#[async_trait]
|
||||
pub trait PostDbService: Send + Sync {
|
||||
async fn get_all_post_info(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError>;
|
||||
async fn get_full_post(&self, id: i32) -> Result<Post, PostError>;
|
||||
}
|
@ -0,0 +1,31 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::{
|
||||
application::{error::post_error::PostError, gateway::post_repository::PostRepository},
|
||||
domain::entity::{post::Post, post_info::PostInfo},
|
||||
};
|
||||
|
||||
use super::post_db_service::PostDbService;
|
||||
|
||||
pub struct PostRepositoryImpl {
|
||||
post_db_service: Arc<dyn PostDbService>,
|
||||
}
|
||||
|
||||
impl PostRepositoryImpl {
|
||||
pub fn new(post_db_service: Arc<dyn PostDbService>) -> Self {
|
||||
Self { post_db_service }
|
||||
}
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
impl PostRepository for PostRepositoryImpl {
|
||||
async fn get_all_post_info(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError> {
|
||||
self.post_db_service.get_all_post_info(is_published_only).await
|
||||
}
|
||||
|
||||
async fn get_full_post(&self, id: i32) -> Result<Post, PostError> {
|
||||
self.post_db_service.get_full_post(id).await
|
||||
}
|
||||
}
|
3
backend/feature/post/src/application.rs
Normal file
3
backend/feature/post/src/application.rs
Normal file
@ -0,0 +1,3 @@
|
||||
pub mod error;
|
||||
pub mod gateway;
|
||||
pub mod use_case;
|
1
backend/feature/post/src/application/error.rs
Normal file
1
backend/feature/post/src/application/error.rs
Normal file
@ -0,0 +1 @@
|
||||
pub mod post_error;
|
5
backend/feature/post/src/application/error/post_error.rs
Normal file
5
backend/feature/post/src/application/error/post_error.rs
Normal file
@ -0,0 +1,5 @@
|
||||
#[derive(Debug, PartialEq)]
|
||||
pub enum PostError {
|
||||
DatabaseError(String),
|
||||
NotFound,
|
||||
}
|
1
backend/feature/post/src/application/gateway.rs
Normal file
1
backend/feature/post/src/application/gateway.rs
Normal file
@ -0,0 +1 @@
|
||||
pub mod post_repository;
|
@ -0,0 +1,12 @@
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::{
|
||||
application::error::post_error::PostError,
|
||||
domain::entity::{post::Post, post_info::PostInfo},
|
||||
};
|
||||
|
||||
#[async_trait]
|
||||
pub trait PostRepository: Send + Sync {
|
||||
async fn get_all_post_info(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError>;
|
||||
async fn get_full_post(&self, id: i32) -> Result<Post, PostError>;
|
||||
}
|
2
backend/feature/post/src/application/use_case.rs
Normal file
2
backend/feature/post/src/application/use_case.rs
Normal file
@ -0,0 +1,2 @@
|
||||
pub mod get_all_post_info_use_case;
|
||||
pub mod get_full_post_use_case;
|
@ -0,0 +1,30 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::{
|
||||
application::{error::post_error::PostError, gateway::post_repository::PostRepository},
|
||||
domain::entity::post_info::PostInfo,
|
||||
};
|
||||
|
||||
#[async_trait]
|
||||
pub trait GetAllPostInfoUseCase: Send + Sync {
|
||||
async fn execute(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError>;
|
||||
}
|
||||
|
||||
pub struct GetAllPostInfoUseCaseImpl {
|
||||
post_repository: Arc<dyn PostRepository>,
|
||||
}
|
||||
|
||||
impl GetAllPostInfoUseCaseImpl {
|
||||
pub fn new(post_repository: Arc<dyn PostRepository>) -> Self {
|
||||
Self { post_repository }
|
||||
}
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
impl GetAllPostInfoUseCase for GetAllPostInfoUseCaseImpl {
|
||||
async fn execute(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError> {
|
||||
self.post_repository.get_all_post_info(is_published_only).await
|
||||
}
|
||||
}
|
@ -0,0 +1,30 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use async_trait::async_trait;
|
||||
|
||||
use crate::{
|
||||
application::{error::post_error::PostError, gateway::post_repository::PostRepository},
|
||||
domain::entity::post::Post,
|
||||
};
|
||||
|
||||
#[async_trait]
|
||||
pub trait GetFullPostUseCase: Send + Sync {
|
||||
async fn execute(&self, id: i32) -> Result<Post, PostError>;
|
||||
}
|
||||
|
||||
pub struct GetFullPostUseCaseImpl {
|
||||
post_repository: Arc<dyn PostRepository>,
|
||||
}
|
||||
|
||||
impl GetFullPostUseCaseImpl {
|
||||
pub fn new(post_repository: Arc<dyn PostRepository>) -> Self {
|
||||
Self { post_repository }
|
||||
}
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
impl GetFullPostUseCase for GetFullPostUseCaseImpl {
|
||||
async fn execute(&self, id: i32) -> Result<Post, PostError> {
|
||||
self.post_repository.get_full_post(id).await
|
||||
}
|
||||
}
|
1
backend/feature/post/src/domain.rs
Normal file
1
backend/feature/post/src/domain.rs
Normal file
@ -0,0 +1 @@
|
||||
pub mod entity;
|
3
backend/feature/post/src/domain/entity.rs
Normal file
3
backend/feature/post/src/domain/entity.rs
Normal file
@ -0,0 +1,3 @@
|
||||
pub mod label;
|
||||
pub mod post_info;
|
||||
pub mod post;
|
5
backend/feature/post/src/domain/entity/label.rs
Normal file
5
backend/feature/post/src/domain/entity/label.rs
Normal file
@ -0,0 +1,5 @@
|
||||
pub struct Label {
|
||||
pub id: i32,
|
||||
pub name: String,
|
||||
pub color: u32,
|
||||
}
|
7
backend/feature/post/src/domain/entity/post.rs
Normal file
7
backend/feature/post/src/domain/entity/post.rs
Normal file
@ -0,0 +1,7 @@
|
||||
use super::post_info::PostInfo;
|
||||
|
||||
pub struct Post {
|
||||
pub id: i32,
|
||||
pub info: PostInfo,
|
||||
pub content: String,
|
||||
}
|
12
backend/feature/post/src/domain/entity/post_info.rs
Normal file
12
backend/feature/post/src/domain/entity/post_info.rs
Normal file
@ -0,0 +1,12 @@
|
||||
use chrono::{DateTime, Utc};
|
||||
|
||||
use super::label::Label;
|
||||
|
||||
pub struct PostInfo {
|
||||
pub id: i32,
|
||||
pub title: String,
|
||||
pub description: String,
|
||||
pub preview_image_url: String,
|
||||
pub labels: Vec<Label>,
|
||||
pub published_time: Option<DateTime<Utc>>,
|
||||
}
|
2
backend/feature/post/src/framework.rs
Normal file
2
backend/feature/post/src/framework.rs
Normal file
@ -0,0 +1,2 @@
|
||||
pub mod db;
|
||||
pub mod web;
|
4
backend/feature/post/src/framework/db.rs
Normal file
4
backend/feature/post/src/framework/db.rs
Normal file
@ -0,0 +1,4 @@
|
||||
pub mod post_db_service_impl;
|
||||
|
||||
mod post_info_with_label_record;
|
||||
mod post_with_label_record;
|
168
backend/feature/post/src/framework/db/post_db_service_impl.rs
Normal file
168
backend/feature/post/src/framework/db/post_db_service_impl.rs
Normal file
@ -0,0 +1,168 @@
|
||||
use std::{collections::HashMap, sync::Arc};
|
||||
|
||||
use async_trait::async_trait;
|
||||
use chrono::{DateTime, Utc};
|
||||
use sqlx::{Pool, Postgres};
|
||||
|
||||
use crate::{
|
||||
adapter::gateway::post_db_service::PostDbService,
|
||||
application::error::post_error::PostError,
|
||||
domain::entity::{label::Label, post::Post, post_info::PostInfo},
|
||||
};
|
||||
|
||||
use super::{
|
||||
post_info_with_label_record::PostInfoWithLabelRecord,
|
||||
post_with_label_record::PostWithLabelRecord,
|
||||
};
|
||||
|
||||
pub struct PostDbServiceImpl {
|
||||
db_pool: Arc<Pool<Postgres>>,
|
||||
}
|
||||
|
||||
impl PostDbServiceImpl {
|
||||
pub fn new(db_pool: Arc<Pool<Postgres>>) -> Self {
|
||||
Self { db_pool }
|
||||
}
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
impl PostDbService for PostDbServiceImpl {
|
||||
async fn get_all_post_info(&self, is_published_only: bool) -> Result<Vec<PostInfo>, PostError> {
|
||||
let mut query_builder = sqlx::QueryBuilder::new(
|
||||
r#"
|
||||
SELECT
|
||||
p.id AS post_id,
|
||||
p.title,
|
||||
p.description,
|
||||
p.preview_image_url,
|
||||
p.published_time,
|
||||
l.id AS label_id,
|
||||
l.name AS label_name,
|
||||
l.color AS label_color
|
||||
FROM
|
||||
post p
|
||||
LEFT JOIN
|
||||
post_label pl ON p.id = pl.post_id
|
||||
LEFT JOIN
|
||||
label l ON pl.label_id = l.id AND l.deleted_time IS NULL
|
||||
WHERE
|
||||
p.deleted_time IS NULL
|
||||
"#,
|
||||
);
|
||||
|
||||
if is_published_only {
|
||||
query_builder.push(r#" AND p.published_time IS NOT NULL"#);
|
||||
}
|
||||
|
||||
query_builder.push(r#" ORDER BY p.id"#);
|
||||
|
||||
let records = query_builder
|
||||
.build_query_as::<PostInfoWithLabelRecord>()
|
||||
.fetch_all(&*self.db_pool)
|
||||
.await
|
||||
.map_err(|err| PostError::DatabaseError(err.to_string()))?;
|
||||
|
||||
let mut post_info_map = HashMap::<i32, PostInfo>::new();
|
||||
|
||||
for record in records {
|
||||
let post_info = post_info_map
|
||||
.entry(record.post_id)
|
||||
.or_insert_with(|| PostInfo {
|
||||
id: record.post_id,
|
||||
title: record.title,
|
||||
description: record.description,
|
||||
preview_image_url: record.preview_image_url,
|
||||
labels: Vec::new(),
|
||||
published_time: record
|
||||
.published_time
|
||||
.map(|dt| DateTime::<Utc>::from_naive_utc_and_offset(dt, Utc)),
|
||||
});
|
||||
|
||||
if let (Some(label_id), Some(label_name), Some(label_color)) =
|
||||
(record.label_id, record.label_name, record.label_color)
|
||||
{
|
||||
post_info.labels.push(Label {
|
||||
id: label_id,
|
||||
name: label_name,
|
||||
color: label_color as u32,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
Ok(post_info_map.into_values().collect())
|
||||
}
|
||||
|
||||
async fn get_full_post(&self, id: i32) -> Result<Post, PostError> {
|
||||
let mut query_builder = sqlx::QueryBuilder::new(
|
||||
r#"
|
||||
SELECT
|
||||
p.id AS post_id,
|
||||
p.title,
|
||||
p.description,
|
||||
p.preview_image_url,
|
||||
p.content,
|
||||
p.published_time,
|
||||
l.id AS label_id,
|
||||
l.name AS label_name,
|
||||
l.color AS label_color
|
||||
FROM
|
||||
post p
|
||||
LEFT JOIN
|
||||
post_label pl ON p.id = pl.post_id
|
||||
LEFT JOIN
|
||||
label l ON pl.label_id = l.id AND l.deleted_time IS NULL
|
||||
WHERE
|
||||
p.deleted_time IS NULL AND p.id =
|
||||
"#,
|
||||
);
|
||||
|
||||
query_builder.push_bind(id);
|
||||
query_builder.push(r#" ORDER BY p.id"#);
|
||||
|
||||
let records = query_builder
|
||||
.build_query_as::<PostWithLabelRecord>()
|
||||
.fetch_all(&*self.db_pool)
|
||||
.await
|
||||
.map_err(|err| PostError::DatabaseError(err.to_string()))?;
|
||||
|
||||
if records.is_empty() {
|
||||
return Err(PostError::NotFound);
|
||||
}
|
||||
|
||||
let mut post_map = HashMap::<i32, Post>::new();
|
||||
|
||||
for record in records {
|
||||
let post = post_map.entry(record.post_id).or_insert_with(|| Post {
|
||||
id: record.post_id,
|
||||
info: PostInfo {
|
||||
id: record.post_id,
|
||||
title: record.title,
|
||||
description: record.description,
|
||||
preview_image_url: record.preview_image_url,
|
||||
labels: Vec::new(),
|
||||
published_time: record
|
||||
.published_time
|
||||
.map(|dt| DateTime::<Utc>::from_naive_utc_and_offset(dt, Utc)),
|
||||
},
|
||||
content: record.content,
|
||||
});
|
||||
|
||||
if let (Some(label_id), Some(label_name), Some(label_color)) =
|
||||
(record.label_id, record.label_name, record.label_color)
|
||||
{
|
||||
post.info.labels.push(Label {
|
||||
id: label_id,
|
||||
name: label_name,
|
||||
color: label_color as u32,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
let post = post_map.into_values().next();
|
||||
|
||||
match post {
|
||||
Some(v) => Ok(v),
|
||||
None => Err(PostError::NotFound),
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,14 @@
|
||||
use chrono::NaiveDateTime;
|
||||
|
||||
#[derive(sqlx::FromRow)]
|
||||
pub struct PostInfoWithLabelRecord {
|
||||
pub post_id: i32,
|
||||
pub title: String,
|
||||
pub description: String,
|
||||
pub preview_image_url: String,
|
||||
pub published_time: Option<NaiveDateTime>,
|
||||
|
||||
pub label_id: Option<i32>,
|
||||
pub label_name: Option<String>,
|
||||
pub label_color: Option<i64>,
|
||||
}
|
@ -0,0 +1,15 @@
|
||||
use chrono::NaiveDateTime;
|
||||
|
||||
#[derive(sqlx::FromRow, Debug)]
|
||||
pub struct PostWithLabelRecord {
|
||||
pub post_id: i32,
|
||||
pub title: String,
|
||||
pub description: String,
|
||||
pub preview_image_url: String,
|
||||
pub content: String,
|
||||
pub published_time: Option<NaiveDateTime>,
|
||||
|
||||
pub label_id: Option<i32>,
|
||||
pub label_name: Option<String>,
|
||||
pub label_color: Option<i64>,
|
||||
}
|
1
backend/feature/post/src/framework/web.rs
Normal file
1
backend/feature/post/src/framework/web.rs
Normal file
@ -0,0 +1 @@
|
||||
pub mod post_web_routes;
|
49
backend/feature/post/src/framework/web/post_web_routes.rs
Normal file
49
backend/feature/post/src/framework/web/post_web_routes.rs
Normal file
@ -0,0 +1,49 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use actix_web::{HttpResponse, Responder, web};
|
||||
|
||||
use crate::{
|
||||
adapter::delivery::{post_controller::PostController, post_info_query_dto::PostQueryDto},
|
||||
application::error::post_error::PostError,
|
||||
};
|
||||
|
||||
pub fn configure_post_routes(cfg: &mut web::ServiceConfig) {
|
||||
cfg.service(web::resource("/post_info").route(web::get().to(get_all_post_info)));
|
||||
cfg.service(web::resource("/post/{id}").route(web::get().to(get_full_post)));
|
||||
}
|
||||
|
||||
async fn get_all_post_info(
|
||||
post_controller: web::Data<Arc<dyn PostController>>,
|
||||
query: web::Query<PostQueryDto>,
|
||||
) -> impl Responder {
|
||||
let is_published_only = query.is_published_only.unwrap_or_else(|| true);
|
||||
let result = post_controller.get_all_post_info(is_published_only).await;
|
||||
|
||||
match result {
|
||||
Ok(post_info_list) => HttpResponse::Ok().json(post_info_list),
|
||||
Err(e) => {
|
||||
log::error!("{e:?}");
|
||||
HttpResponse::InternalServerError().finish()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
async fn get_full_post(
|
||||
post_controller: web::Data<Arc<dyn PostController>>,
|
||||
path: web::Path<i32>,
|
||||
) -> impl Responder {
|
||||
let id = path.into_inner();
|
||||
let result = post_controller.get_full_post(id).await;
|
||||
|
||||
match result {
|
||||
Ok(post) => HttpResponse::Ok().json(post),
|
||||
Err(e) => {
|
||||
if e == PostError::NotFound {
|
||||
HttpResponse::NotFound().finish()
|
||||
} else {
|
||||
log::error!("{e:?}");
|
||||
HttpResponse::InternalServerError().finish()
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
4
backend/feature/post/src/lib.rs
Normal file
4
backend/feature/post/src/lib.rs
Normal file
@ -0,0 +1,4 @@
|
||||
pub mod adapter;
|
||||
pub mod application;
|
||||
pub mod domain;
|
||||
pub mod framework;
|
51
backend/migrations/20250505012740_v0.1.1.sql
Normal file
51
backend/migrations/20250505012740_v0.1.1.sql
Normal file
@ -0,0 +1,51 @@
|
||||
-- Add migration script here
|
||||
|
||||
CREATE TABLE "post" (
|
||||
"id" SERIAL PRIMARY KEY NOT NULL,
|
||||
"title" TEXT NOT NULL,
|
||||
"description" TEXT NOT NULL,
|
||||
"preview_image_url" TEXT NOT NULL,
|
||||
"content" TEXT NOT NULL,
|
||||
"published_time" TIMESTAMP,
|
||||
"deleted_time" TIMESTAMP,
|
||||
"created_time" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
||||
"updated_time" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
|
||||
);
|
||||
|
||||
CREATE TABLE "label" (
|
||||
"id" SERIAL PRIMARY KEY NOT NULL,
|
||||
"name" TEXT NOT NULL,
|
||||
"color" BIGINT NOT NULL CHECK ("color" >= 0 AND "color" <= 4294967295),
|
||||
"deleted_time" TIMESTAMP,
|
||||
"created_time" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
||||
"updated_time" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
|
||||
);
|
||||
|
||||
CREATE TABLE "post_label" (
|
||||
"post_id" INTEGER NOT NULL,
|
||||
"label_id" INTEGER NOT NULL,
|
||||
PRIMARY KEY ("post_id", "label_id"),
|
||||
FOREIGN KEY ("post_id") REFERENCES "post" ("id") ON DELETE CASCADE,
|
||||
FOREIGN KEY ("label_id") REFERENCES "label" ("id") ON DELETE CASCADE
|
||||
);
|
||||
|
||||
|
||||
-- Auto update `updated_time` trigger
|
||||
|
||||
CREATE FUNCTION update_updated_time_column() RETURNS TRIGGER AS $$
|
||||
BEGIN
|
||||
NEW.updated_time = CURRENT_TIMESTAMP;
|
||||
return NEW;
|
||||
END;
|
||||
$$ LANGUAGE 'plpgsql';
|
||||
|
||||
CREATE TRIGGER "update_post_updated_time"
|
||||
BEFORE UPDATE ON "post"
|
||||
FOR EACH ROW
|
||||
EXECUTE FUNCTION update_updated_time_column();
|
||||
|
||||
CREATE TRIGGER "update_label_updated_time"
|
||||
BEFORE UPDATE ON "label"
|
||||
FOR EACH ROW
|
||||
EXECUTE FUNCTION update_updated_time_column();
|
||||
|
12
backend/server/Cargo.toml
Normal file
12
backend/server/Cargo.toml
Normal file
@ -0,0 +1,12 @@
|
||||
[package]
|
||||
name = "server"
|
||||
version.workspace = true
|
||||
edition.workspace = true
|
||||
|
||||
[dependencies]
|
||||
actix-web.workspace = true
|
||||
dotenv.workspace = true
|
||||
env_logger.workspace = true
|
||||
sqlx.workspace = true
|
||||
|
||||
post.workspace = true
|
37
backend/server/src/container.rs
Normal file
37
backend/server/src/container.rs
Normal file
@ -0,0 +1,37 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use post::{
|
||||
adapter::{
|
||||
delivery::post_controller::{PostController, PostControllerImpl},
|
||||
gateway::post_repository_impl::PostRepositoryImpl,
|
||||
},
|
||||
application::use_case::{
|
||||
get_all_post_info_use_case::GetAllPostInfoUseCaseImpl,
|
||||
get_full_post_use_case::GetFullPostUseCaseImpl,
|
||||
},
|
||||
framework::db::post_db_service_impl::PostDbServiceImpl,
|
||||
};
|
||||
use sqlx::{Pool, Postgres};
|
||||
|
||||
pub struct Container {
|
||||
pub post_controller: Arc<dyn PostController>,
|
||||
}
|
||||
|
||||
impl Container {
|
||||
pub fn new(db_pool: Arc<Pool<Postgres>>) -> Self {
|
||||
let post_db_service = Arc::new(PostDbServiceImpl::new(db_pool));
|
||||
|
||||
let post_repository = Arc::new(PostRepositoryImpl::new(post_db_service.clone()));
|
||||
|
||||
let get_all_post_info_use_case =
|
||||
Arc::new(GetAllPostInfoUseCaseImpl::new(post_repository.clone()));
|
||||
let get_full_post_use_case = Arc::new(GetFullPostUseCaseImpl::new(post_repository.clone()));
|
||||
|
||||
let post_controller = Arc::new(PostControllerImpl::new(
|
||||
get_all_post_info_use_case,
|
||||
get_full_post_use_case,
|
||||
));
|
||||
|
||||
Self { post_controller }
|
||||
}
|
||||
}
|
1
backend/server/src/lib.rs
Normal file
1
backend/server/src/lib.rs
Normal file
@ -0,0 +1 @@
|
||||
pub mod container;
|
60
backend/server/src/main.rs
Normal file
60
backend/server/src/main.rs
Normal file
@ -0,0 +1,60 @@
|
||||
use actix_web::{
|
||||
App, Error, HttpServer,
|
||||
body::MessageBody,
|
||||
dev::{ServiceFactory, ServiceRequest, ServiceResponse},
|
||||
web,
|
||||
};
|
||||
use post::framework::web::post_web_routes::configure_post_routes;
|
||||
use server::container::Container;
|
||||
use sqlx::{Pool, Postgres, postgres::PgPoolOptions};
|
||||
use std::{env, sync::Arc};
|
||||
|
||||
#[actix_web::main]
|
||||
async fn main() -> std::io::Result<()> {
|
||||
dotenv::dotenv().ok();
|
||||
env_logger::init();
|
||||
|
||||
let db_pool = init_database().await;
|
||||
|
||||
HttpServer::new(move || create_app(db_pool.clone()))
|
||||
.bind(("127.0.0.1", 8080))?
|
||||
.run()
|
||||
.await
|
||||
}
|
||||
|
||||
async fn init_database() -> Arc<Pool<Postgres>> {
|
||||
let database_url = env::var("DATABASE_URL")
|
||||
.unwrap_or_else(|_| "postgres://postgres@localhost:5432/postgres".to_string());
|
||||
|
||||
let db_pool = PgPoolOptions::new()
|
||||
.max_connections(5)
|
||||
.connect(&database_url)
|
||||
.await
|
||||
.expect("Failed to create database connection pool");
|
||||
|
||||
sqlx::migrate!("../migrations")
|
||||
.run(&db_pool)
|
||||
.await
|
||||
.expect("Failed to run database migrations");
|
||||
|
||||
Arc::new(db_pool)
|
||||
}
|
||||
|
||||
fn create_app(
|
||||
db_pool: Arc<Pool<Postgres>>,
|
||||
) -> App<
|
||||
impl ServiceFactory<
|
||||
ServiceRequest,
|
||||
Response = ServiceResponse<impl MessageBody>,
|
||||
Config = (),
|
||||
InitError = (),
|
||||
Error = Error,
|
||||
>,
|
||||
> {
|
||||
let container = Container::new(db_pool.clone());
|
||||
|
||||
App::new()
|
||||
.app_data(web::Data::new(db_pool))
|
||||
.app_data(web::Data::new(container.post_controller))
|
||||
.configure(configure_post_routes)
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user