GKaszewski/movies-diary
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: refactor user profile handling and integrate ApProfileField structure

Browse Source
This commit is contained in:
Gabriel Kaszewski
2026-05-13 22:59:38 +02:00
parent 815178e6a4
commit fdd61ae701
11 changed files with 94 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/adapters/activitypub-base/src/actors.rs
View File

@@ -13,6 +13,7 @@ use url::Url;
use crate::data::FederationData;
use crate::error::Error;
use crate::repository::RemoteActor;
use crate::user::ApProfileField;
#[derive(Debug, Clone)]
pub struct DbActor {
@@ -31,7 +32,7 @@ pub struct DbActor {
pub banner_url: Option<Url>,
pub also_known_as: Option<String>,
pub profile_url: Option<Url>,
pub attachment: Vec<domain::models::ProfileField>,
pub attachment: Vec<ApProfileField>,
}
#[derive(Debug, Clone, Deserialize, Serialize)]

2
crates/adapters/activitypub-base/src/lib.rs
View File

@@ -24,4 +24,4 @@ pub use repository::{
BlockedDomain, FederationRepository, Follower, FollowerStatus, FollowingStatus, RemoteActor,
};
pub use service::ActivityPubService;
pub use user::{ApUser, ApUserRepository};
pub use user::{ApProfileField, ApUser, ApUserRepository};

8
crates/adapters/activitypub-base/src/user.rs
View File

@@ -1,6 +1,12 @@
use async_trait::async_trait;
use url::Url;
#[derive(Debug, Clone)]
pub struct ApProfileField {
pub name: String,
pub value: String,
}
#[derive(Debug, Clone)]
pub struct ApUser {
pub id: uuid::Uuid,
@@ -10,7 +16,7 @@ pub struct ApUser {
pub banner_url: Option<Url>,
pub also_known_as: Option<String>,
pub profile_url: Option<Url>,
pub attachment: Vec<domain::models::ProfileField>,
pub attachment: Vec<ApProfileField>,
}
#[async_trait]

3
crates/adapters/activitypub/src/lib.rs
View File

@@ -31,7 +31,6 @@ pub async fn wire(
review_store: std::sync::Arc<dyn RemoteReviewRepository>,
remote_watchlist_repo: std::sync::Arc<dyn domain::ports::RemoteWatchlistRepository>,
user_repo: std::sync::Arc<dyn domain::ports::UserRepository>,
profile_fields_repo: std::sync::Arc<dyn domain::ports::UserProfileFieldsRepository>,
movie_repo: std::sync::Arc<dyn domain::ports::MovieRepository>,
review_repo: std::sync::Arc<dyn domain::ports::ReviewRepository>,
diary_repo: std::sync::Arc<dyn domain::ports::DiaryRepository>,
@@ -67,7 +66,7 @@ pub async fn wire(
let concrete = std::sync::Arc::new(
ActivityPubService::new(
federation_repo,
std::sync::Arc::new(DomainUserRepoAdapter::new(user_repo, profile_fields_repo, base_url.clone())),
std::sync::Arc::new(DomainUserRepoAdapter::new(user_repo, base_url.clone())),
composite,
base_url.clone(),
allow_registration,

19
crates/adapters/activitypub/src/user_adapter.rs
View File

@@ -1,30 +1,27 @@
use std::sync::Arc;
use activitypub_base::{ApUser, ApUserRepository};
use activitypub_base::{ApProfileField, ApUser, ApUserRepository};
use async_trait::async_trait;
use domain::{
models::ProfileField,
ports::{UserProfileFieldsRepository, UserRepository},
ports::UserRepository,
value_objects::UserId,
};
use url::Url;
pub struct DomainUserRepoAdapter {
pub repo: Arc<dyn UserRepository>,
pub fields_repo: Arc<dyn UserProfileFieldsRepository>,
pub base_url: String,
}
impl DomainUserRepoAdapter {
pub fn new(
repo: Arc<dyn UserRepository>,
fields_repo: Arc<dyn UserProfileFieldsRepository>,
base_url: String,
) -> Self {
Self { repo, fields_repo, base_url }
Self { repo, base_url }
}
fn build_user(&self, u: &domain::models::User, fields: Vec<ProfileField>) -> ApUser {
fn build_user(&self, u: &domain::models::User) -> ApUser {
let avatar_url = u.avatar_path().and_then(|p| {
Url::parse(&format!("{}/images/{}", self.base_url, p)).ok()
});
@@ -40,7 +37,7 @@ impl DomainUserRepoAdapter {
banner_url,
also_known_as: u.also_known_as().map(|s| s.to_string()),
profile_url,
attachment: fields,
attachment: u.profile_fields().iter().map(|f| ApProfileField { name: f.name.clone(), value: f.value.clone() }).collect(),
}
}
}
@@ -53,8 +50,7 @@ impl ApUserRepository for DomainUserRepoAdapter {
Some(u) => u,
None => return Ok(None),
};
let fields = self.fields_repo.get_fields(&user_id).await.unwrap_or_default();
Ok(Some(self.build_user(&user, fields)))
Ok(Some(self.build_user(&user)))
}
async fn find_by_username(&self, username: &str) -> anyhow::Result<Option<ApUser>> {
@@ -64,8 +60,7 @@ impl ApUserRepository for DomainUserRepoAdapter {
Some(u) => u,
None => return Ok(None),
};
let fields = self.fields_repo.get_fields(user.id()).await.unwrap_or_default();
Ok(Some(self.build_user(&user, fields)))
Ok(Some(self.build_user(&user)))
}
async fn count_users(&self) -> anyhow::Result<usize> {

47
crates/adapters/postgres/src/users.rs
View File

@@ -4,7 +4,7 @@ use sqlx::PgPool;
use domain::{
errors::DomainError,
models::{User, UserRole},
models::{ProfileField, User, UserRole},
ports::UserRepository,
value_objects::{Email, PasswordHash, UserId, Username},
};
@@ -42,6 +42,7 @@ impl PostgresUserRepository {
avatar_path: Option<String>,
banner_path: Option<String>,
also_known_as: Option<String>,
profile_fields: Vec<ProfileField>,
) -> Result<User, DomainError> {
let id = uuid::Uuid::parse_str(&id_str)
.map_err(|e| DomainError::InfrastructureError(e.to_string()))?;
@@ -61,6 +62,7 @@ impl PostgresUserRepository {
avatar_path,
banner_path,
also_known_as,
profile_fields,
))
}
}
@@ -99,6 +101,7 @@ impl UserRepository for PostgresUserRepository {
r.avatar_path,
r.banner_path,
r.also_known_as,
vec![],
)
})
.transpose()
@@ -136,6 +139,7 @@ impl UserRepository for PostgresUserRepository {
r.avatar_path,
r.banner_path,
r.also_known_as,
vec![],
)
})
.transpose()
@@ -200,20 +204,33 @@ impl UserRepository for PostgresUserRepository {
.fetch_optional(&self.pool)
.await
.map_err(Self::map_err)?;
row.map(|r| {
Self::row_to_user(
r.id,
r.email,
r.username,
r.password_hash,
Self::parse_role(&r.role),
r.bio,
r.avatar_path,
r.banner_path,
r.also_known_as,
)
})
.transpose()
let Some(r) = row else { return Ok(None) };
#[derive(sqlx::FromRow)]
struct FieldRow { name: String, value: String }
let field_rows = sqlx::query_as::<_, FieldRow>(
"SELECT name, value FROM user_profile_fields WHERE user_id = $1 ORDER BY position ASC",
)
.bind(&id_str)
.fetch_all(&self.pool)
.await
.map_err(|e| DomainError::InfrastructureError(e.to_string()))?;
let profile_fields = field_rows.into_iter().map(|f| ProfileField { name: f.name, value: f.value }).collect();
Self::row_to_user(
r.id,
r.email,
r.username,
r.password_hash,
Self::parse_role(&r.role),
r.bio,
r.avatar_path,
r.banner_path,
r.also_known_as,
profile_fields,
).map(Some)
}
async fn update_profile(

6
crates/adapters/sqlite/src/tests/users.rs
View File

@@ -11,6 +11,12 @@ async fn setup() -> (SqlitePool, SqliteUserRepository) {
.execute(&pool)
.await
.unwrap();
sqlx::query(
"CREATE TABLE user_profile_fields (id TEXT PRIMARY KEY, user_id TEXT NOT NULL, name TEXT NOT NULL, value TEXT NOT NULL, position INTEGER NOT NULL DEFAULT 0)"
)
.execute(&pool)
.await
.unwrap();
let repo = SqliteUserRepository::new(pool.clone());
(pool, repo)
}

44
crates/adapters/sqlite/src/users.rs
View File

@@ -5,7 +5,7 @@ use sqlx::SqlitePool;
use super::models::UserSummaryRow;
use domain::{
errors::DomainError,
models::{User, UserRole},
models::{ProfileField, User, UserRole},
ports::UserRepository,
value_objects::{Email, PasswordHash, UserId, Username},
};
@@ -41,6 +41,7 @@ impl SqliteUserRepository {
avatar_path: Option<String>,
banner_path: Option<String>,
also_known_as: Option<String>,
profile_fields: Vec<ProfileField>,
) -> Result<User, DomainError> {
let id = uuid::Uuid::parse_str(&id_str)
.map_err(|e| DomainError::InfrastructureError(e.to_string()))?;
@@ -60,6 +61,7 @@ impl SqliteUserRepository {
avatar_path,
banner_path,
also_known_as,
profile_fields,
))
}
}
@@ -87,6 +89,7 @@ impl UserRepository for SqliteUserRepository {
r.avatar_path,
r.banner_path,
r.also_known_as,
vec![],
)
})
.transpose()
@@ -113,6 +116,7 @@ impl UserRepository for SqliteUserRepository {
r.avatar_path,
r.banner_path,
r.also_known_as,
vec![],
)
})
.transpose()
@@ -163,20 +167,30 @@ impl UserRepository for SqliteUserRepository {
.await
.map_err(Self::map_err)?;
row.map(|r| {
Self::row_to_user(
r.id.unwrap_or_default(),
r.email,
r.username,
r.password_hash,
Self::parse_role(&r.role),
r.bio,
r.avatar_path,
r.banner_path,
r.also_known_as,
)
})
.transpose()
let Some(r) = row else { return Ok(None) };
let field_rows = sqlx::query!(
"SELECT name, value FROM user_profile_fields WHERE user_id = ? ORDER BY position ASC",
id_str
)
.fetch_all(&self.pool)
.await
.map_err(|e| DomainError::InfrastructureError(e.to_string()))?;
let profile_fields = field_rows.into_iter().map(|f| ProfileField { name: f.name, value: f.value }).collect();
Self::row_to_user(
r.id.unwrap_or_default(),
r.email,
r.username,
r.password_hash,
Self::parse_role(&r.role),
r.bio,
r.avatar_path,
r.banner_path,
r.also_known_as,
profile_fields,
).map(Some)
}
async fn update_profile(