diff --git a/README.md b/README.md
index 311fecc..b3e979a 100644
--- a/README.md
+++ b/README.md
@@ -18,6 +18,7 @@ A self-hosted, server-side rendered movie logging system with a full REST API. B
- User profiles — display name, bio, avatar, banner, custom profile fields; editable via HTML settings page or REST API
- Jellyfin/Plex auto-import — media server sends a webhook on playback stop, movies land in a watch queue; review and confirm with a rating to create diary entries; per-user webhook tokens with SHA-256 auth; setup UI at `/settings/integrations`
- Annual Wrap-Up — Spotify Wrapped for movies: per-user and instance-wide year-in-review with stats (top directors, actors, genres, rating distribution, watch time, rewatches, budget analysis), shareable HTML page at `/wrapups/{user_id}/{year}`, downloadable MP4 video with branded slides; admin-triggered or auto-generated in January
+- Goals — set a "watch N movies in YEAR" target with a progress bar; progress computed from existing reviews (backwards compatible); per-user federation toggle in settings; displayed on profile (SPA: interactive with create/edit/delete, classic HTML: read-only glassmorphic card)
- CSV and JSON diary export
- File importer: upload CSV, TSV, JSON, or XLSX from any source (Letterboxd, IMDb, etc.), map columns to domain fields via a step-by-step wizard or REST API, save mapping profiles for repeat imports
- REST API v1 (`/api/v1/`) with full feature parity with the HTML interface
diff --git a/architecture.mmd b/architecture.mmd
index 149c14b..e17a919 100644
--- a/architecture.mmd
+++ b/architecture.mmd
@@ -19,6 +19,7 @@ graph TB
UC_USERS["users
get_users, get_profile,
update_profile"]
UC_WATCHLIST["watchlist
add, remove, get"]
UC_WRAPUP["wrapup
generate, compute,
list, delete"]
+ UC_GOALS["goals
create, update, delete,
get, list"]
UC_INTEGRATIONS["integrations
webhooks, watch_queue,
confirm, dismiss"]
UC_SEARCH["search
execute"]
UC_PERSON["person
get, get_credits"]
@@ -47,16 +48,17 @@ graph TB
M_USER["User, UserSummary"]
M_PERSON["Person, PersonId,
PersonCredits"]
M_WATCHLIST["WatchlistEntry,
WatchEvent"]
+ M_GOAL["Goal, GoalWithProgress,
UserSettings, RemoteGoalEntry"]
M_WRAPUP["WrapUpReport,
MovieRef, PersonStat"]
M_SEARCH["SearchQuery,
SearchResults"]
end
subgraph Ports["Port Traits (Interfaces)"]
- P_REPOS["MovieRepository
ReviewRepository
DiaryRepository
UserRepository
WatchlistRepository
WatchEventRepository
WebhookTokenRepository
ImportSessionRepository
MovieProfileRepository
WrapUpRepository"]
+ P_REPOS["MovieRepository
ReviewRepository
DiaryRepository
UserRepository
WatchlistRepository
WatchEventRepository
WebhookTokenRepository
ImportSessionRepository
MovieProfileRepository
WrapUpRepository
GoalRepository
UserSettingsRepository"]
P_SERVICES["AuthService
MetadataClient
PosterFetcherClient
ObjectStorage
EventPublisher
EventConsumer
PasswordHasher
DiaryExporter
DocumentParser"]
P_SEARCH["SearchPort
SearchCommand
PersonQuery
PersonCommand"]
- P_FEDERATION["SocialQueryPort
LocalApContentQuery
RemoteWatchlistRepository"]
+ P_FEDERATION["SocialQueryPort
LocalApContentQuery
RemoteWatchlistRepository
RemoteGoalRepository"]
end
- EVENTS["DomainEvent enum
ReviewLogged, MovieDiscovered,
SearchReindexRequested, ..."]
+ EVENTS["DomainEvent enum
ReviewLogged, MovieDiscovered,
GoalCreated, GoalUpdated,
SearchReindexRequested, ..."]
VO["Value Objects
MovieId, UserId, Rating,
Email, Username, ..."]
end
diff --git a/crates/domain/src/testing.rs b/crates/domain/src/testing.rs
deleted file mode 100644
index bc82deb..0000000
--- a/crates/domain/src/testing.rs
+++ /dev/null
@@ -1,1309 +0,0 @@
-#![cfg(any(test, feature = "test-helpers"))]
-
-use std::collections::HashMap;
-use std::sync::{Arc, Mutex};
-
-use async_trait::async_trait;
-use chrono::Utc;
-use uuid::Uuid;
-
-use crate::{
- errors::DomainError,
- events::DomainEvent,
- models::{
- AnnotatedRow, DiaryEntry, DiaryFilter, EntityType, ExportFormat, ExternalPersonId,
- FeedEntry, FieldMapping, FileFormat, ImportError, ImportProfile, ImportSession,
- IndexableDocument, Movie, MovieFilter, MovieProfile, MovieStats, MovieSummary, ParsedFile,
- Person, PersonCredits, PersonId, Review, ReviewHistory, SearchQuery, SearchResults, User,
- UserStats, UserSummary, UserTrends, WatchlistEntry, WatchlistWithMovie,
- collections::{PageParams, Paginated},
- },
- ports::{
- AuthService, DiaryExporter, DiaryRepository, DocumentParser, EventPublisher, FeedSortBy,
- FollowingFilter, GeneratedToken, ImportProfileRepository, ImportSessionRepository,
- MetadataClient, MetadataSearchCriteria, MovieProfileRepository, MovieRepository,
- ObjectStorage, PasswordHasher, PersonCommand, PersonQuery, PosterFetcherClient,
- ReviewRepository, SearchCommand, SearchPort, StatsRepository, UserProfileFieldsRepository,
- UserRepository, WatchlistRepository, WrapUpRepository,
- },
- value_objects::{
- Email, ExternalMetadataId, ImportProfileId, ImportSessionId, MovieId, MovieTitle,
- PasswordHash, PosterUrl, ReleaseYear, ReviewId, UserId, Username, WrapUpId,
- },
-};
-
-// ── InMemoryMovieRepository ───────────────────────────────────────────────────
-
-pub struct InMemoryMovieRepository {
- pub store: Mutex>,
-}
-
-impl InMemoryMovieRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- store: Mutex::new(HashMap::new()),
- })
- }
-
- pub fn count(&self) -> usize {
- self.store.lock().unwrap().len()
- }
-}
-
-#[async_trait]
-impl MovieRepository for InMemoryMovieRepository {
- async fn get_movie_by_external_id(
- &self,
- external_metadata_id: &ExternalMetadataId,
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .values()
- .find(|m| {
- m.external_metadata_id()
- .map(|e| e.value() == external_metadata_id.value())
- .unwrap_or(false)
- })
- .cloned())
- }
-
- async fn get_movie_by_id(&self, movie_id: &MovieId) -> Result, DomainError> {
- Ok(self.store.lock().unwrap().get(&movie_id.value()).cloned())
- }
-
- async fn get_movies_by_title_and_year(
- &self,
- title: &MovieTitle,
- year: &ReleaseYear,
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .values()
- .filter(|m| m.title() == title && m.release_year() == year)
- .cloned()
- .collect())
- }
-
- async fn upsert_movie(&self, movie: &Movie) -> Result<(), DomainError> {
- self.store
- .lock()
- .unwrap()
- .insert(movie.id().value(), movie.clone());
- Ok(())
- }
-
- async fn delete_movie(&self, movie_id: &MovieId) -> Result<(), DomainError> {
- self.store.lock().unwrap().remove(&movie_id.value());
- Ok(())
- }
-
- async fn existing_external_ids(
- &self,
- ids: &[ExternalMetadataId],
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- let known: std::collections::HashSet = store
- .values()
- .filter_map(|m| m.external_metadata_id().map(|e| e.value().to_string()))
- .collect();
- Ok(ids
- .iter()
- .map(|id| id.value().to_string())
- .filter(|v| known.contains(v))
- .collect())
- }
-
- async fn existing_title_year_pairs(
- &self,
- pairs: &[(MovieTitle, ReleaseYear)],
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- let known: std::collections::HashSet<(String, u16)> = store
- .values()
- .map(|m| (m.title().value().to_string(), m.release_year().value()))
- .collect();
- Ok(pairs
- .iter()
- .map(|(t, y)| (t.value().to_string(), y.value()))
- .filter(|p| known.contains(p))
- .collect())
- }
-
- async fn list_movies(
- &self,
- _page: &crate::models::collections::PageParams,
- _filter: &MovieFilter,
- ) -> Result, DomainError> {
- Ok(Paginated {
- items: vec![],
- total_count: 0,
- limit: 10,
- offset: 0,
- })
- }
-}
-
-// ── InMemoryReviewRepository ──────────────────────────────────────────────────
-
-pub struct InMemoryReviewRepository {
- store: Mutex>,
-}
-
-impl InMemoryReviewRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- store: Mutex::new(HashMap::new()),
- })
- }
-
- pub fn count(&self) -> usize {
- self.store.lock().unwrap().len()
- }
-}
-
-#[async_trait]
-impl ReviewRepository for InMemoryReviewRepository {
- async fn save_review(&self, review: &Review) -> Result {
- self.store
- .lock()
- .unwrap()
- .insert(review.id().value(), review.clone());
- Ok(DomainEvent::ReviewLogged {
- review_id: review.id().clone(),
- movie_id: review.movie_id().clone(),
- user_id: review.user_id().clone(),
- rating: review.rating().clone(),
- watched_at: *review.watched_at(),
- })
- }
-
- async fn get_review_by_id(&self, review_id: &ReviewId) -> Result, DomainError> {
- Ok(self.store.lock().unwrap().get(&review_id.value()).cloned())
- }
-
- async fn delete_review(&self, review_id: &ReviewId) -> Result<(), DomainError> {
- self.store.lock().unwrap().remove(&review_id.value());
- Ok(())
- }
-
- async fn get_all_reviews_for_user(&self, user_id: &UserId) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .values()
- .filter(|r| r.user_id() == user_id)
- .cloned()
- .collect())
- }
-}
-
-// ── InMemoryUserRepository ────────────────────────────────────────────────────
-
-pub struct InMemoryUserRepository {
- pub store: Mutex>,
-}
-
-impl InMemoryUserRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- store: Mutex::new(HashMap::new()),
- })
- }
-
- pub fn count(&self) -> usize {
- self.store.lock().unwrap().len()
- }
-}
-
-#[async_trait]
-impl UserRepository for InMemoryUserRepository {
- async fn find_by_email(&self, email: &Email) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .values()
- .find(|u| u.email().value() == email.value())
- .cloned())
- }
-
- async fn find_by_username(&self, username: &Username) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .values()
- .find(|u| u.username().value() == username.value())
- .cloned())
- }
-
- async fn save(&self, user: &User) -> Result<(), DomainError> {
- self.store
- .lock()
- .unwrap()
- .insert(user.id().value(), user.clone());
- Ok(())
- }
-
- async fn find_by_id(&self, id: &UserId) -> Result, DomainError> {
- Ok(self.store.lock().unwrap().get(&id.value()).cloned())
- }
-
- async fn list_with_stats(&self) -> Result, DomainError> {
- Ok(vec![])
- }
-
- async fn update_profile(
- &self,
- _user_id: &UserId,
- _profile: &crate::models::UserProfile,
- ) -> Result<(), DomainError> {
- Ok(())
- }
-}
-
-// ── InMemoryWatchlistRepository ───────────────────────────────────────────────
-
-pub struct InMemoryWatchlistRepository {
- store: Mutex>,
-}
-
-impl InMemoryWatchlistRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- store: Mutex::new(HashMap::new()),
- })
- }
-
- pub fn count(&self) -> usize {
- self.store.lock().unwrap().len()
- }
-}
-
-#[async_trait]
-impl WatchlistRepository for InMemoryWatchlistRepository {
- async fn add(&self, entry: &WatchlistEntry) -> Result<(), DomainError> {
- let key = (entry.user_id.value(), entry.movie_id.value());
- self.store
- .lock()
- .unwrap()
- .entry(key)
- .or_insert_with(|| entry.clone());
- Ok(())
- }
-
- async fn remove(&self, user_id: &UserId, movie_id: &MovieId) -> Result<(), DomainError> {
- let key = (user_id.value(), movie_id.value());
- self.store
- .lock()
- .unwrap()
- .remove(&key)
- .ok_or_else(|| DomainError::NotFound("watchlist entry".into()))?;
- Ok(())
- }
-
- async fn remove_if_present(
- &self,
- user_id: &UserId,
- movie_id: &MovieId,
- ) -> Result {
- let key = (user_id.value(), movie_id.value());
- Ok(self.store.lock().unwrap().remove(&key).is_some())
- }
-
- async fn get_for_user(
- &self,
- _user_id: &UserId,
- _page: &PageParams,
- ) -> Result, DomainError> {
- Ok(Paginated {
- items: vec![],
- total_count: 0,
- limit: 10,
- offset: 0,
- })
- }
-
- async fn contains(&self, user_id: &UserId, movie_id: &MovieId) -> Result {
- let key = (user_id.value(), movie_id.value());
- Ok(self.store.lock().unwrap().contains_key(&key))
- }
-}
-
-// ── NoopEventPublisher ────────────────────────────────────────────────────────
-
-pub struct NoopEventPublisher {
- pub events: Mutex>,
-}
-
-impl NoopEventPublisher {
- pub fn new() -> Arc {
- Arc::new(Self {
- events: Mutex::new(vec![]),
- })
- }
-
- pub fn published(&self) -> Vec {
- self.events.lock().unwrap().clone()
- }
-}
-
-#[async_trait]
-impl EventPublisher for NoopEventPublisher {
- async fn publish(&self, event: &DomainEvent) -> Result<(), DomainError> {
- self.events.lock().unwrap().push(event.clone());
- Ok(())
- }
-}
-
-// ── NoopObjectStorage ──────────────────────────────────────────────────────────
-
-pub struct NoopObjectStorage;
-
-#[async_trait]
-impl ObjectStorage for NoopObjectStorage {
- async fn store(&self, key: &str, _image_bytes: &[u8]) -> Result {
- Ok(format!("noop://{key}"))
- }
-
- async fn get(&self, _key: &str) -> Result, DomainError> {
- Ok(vec![])
- }
-
- async fn get_stream(
- &self,
- _key: &str,
- ) -> Result>, DomainError>
- {
- Ok(Box::pin(futures::stream::empty()))
- }
-
- async fn delete(&self, _key: &str) -> Result<(), DomainError> {
- Ok(())
- }
-}
-
-// ── FakeAuthService ───────────────────────────────────────────────────────────
-
-pub struct FakeAuthService;
-
-#[async_trait]
-impl AuthService for FakeAuthService {
- async fn generate_token(&self, user_id: &UserId) -> Result {
- Ok(GeneratedToken {
- token: user_id.value().to_string(),
- expires_at: Utc::now() + chrono::Duration::hours(24),
- })
- }
-
- async fn validate_token(&self, token: &str) -> Result {
- Uuid::parse_str(token)
- .map(UserId::from_uuid)
- .map_err(|_| DomainError::Unauthorized("invalid token".into()))
- }
-}
-
-// ── FakePasswordHasher ────────────────────────────────────────────────────────
-
-pub struct FakePasswordHasher;
-
-#[async_trait]
-impl PasswordHasher for FakePasswordHasher {
- async fn hash(&self, plain_password: &str) -> Result {
- PasswordHash::new(format!("hashed:{plain_password}"))
- }
-
- async fn verify(&self, plain_password: &str, hash: &PasswordHash) -> Result {
- Ok(hash.value() == format!("hashed:{plain_password}"))
- }
-}
-
-// ── FakeMetadataClient ────────────────────────────────────────────────────────
-
-pub struct FakeMetadataClient;
-
-#[async_trait]
-impl MetadataClient for FakeMetadataClient {
- async fn fetch_movie_metadata(
- &self,
- _criteria: &MetadataSearchCriteria,
- ) -> Result {
- Err(DomainError::InfrastructureError(
- "fake metadata client".into(),
- ))
- }
-
- async fn get_poster_url(
- &self,
- _external_metadata_id: &ExternalMetadataId,
- ) -> Result, DomainError> {
- Ok(None)
- }
-}
-
-// ── FakeDiaryRepository ───────────────────────────────────────────────────────
-
-pub struct FakeDiaryRepository {
- histories: Mutex)>>,
-}
-
-impl FakeDiaryRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- histories: Mutex::new(HashMap::new()),
- })
- }
-
- pub fn seed_history(&self, movie: Movie, reviews: Vec) {
- self.histories
- .lock()
- .unwrap()
- .insert(movie.id().value(), (movie, reviews));
- }
-}
-
-#[async_trait]
-impl DiaryRepository for FakeDiaryRepository {
- async fn query_diary(
- &self,
- _filter: &DiaryFilter,
- ) -> Result, DomainError> {
- unimplemented!("FakeDiaryRepository::query_diary")
- }
-
- async fn query_activity_feed(
- &self,
- _page: &PageParams,
- ) -> Result, DomainError> {
- unimplemented!("FakeDiaryRepository::query_activity_feed")
- }
-
- async fn query_activity_feed_filtered(
- &self,
- _page: &PageParams,
- _sort_by: &FeedSortBy,
- _search: Option<&str>,
- _following: Option<&FollowingFilter>,
- ) -> Result, DomainError> {
- unimplemented!("FakeDiaryRepository::query_activity_feed_filtered")
- }
-
- async fn get_review_history(&self, movie_id: &MovieId) -> Result {
- let histories = self.histories.lock().unwrap();
- let (movie, reviews) = histories
- .get(&movie_id.value())
- .ok_or_else(|| DomainError::NotFound(format!("movie {}", movie_id.value())))?;
- Ok(ReviewHistory::new(movie.clone(), reviews.clone()))
- }
-
- async fn get_user_history(&self, _user_id: &UserId) -> Result, DomainError> {
- unimplemented!("FakeDiaryRepository::get_user_history")
- }
-
- async fn get_movie_stats(&self, _movie_id: &MovieId) -> Result {
- unimplemented!("FakeDiaryRepository::get_movie_stats")
- }
-
- async fn get_movie_social_feed(
- &self,
- _movie_id: &MovieId,
- _page: &PageParams,
- ) -> Result, DomainError> {
- unimplemented!("FakeDiaryRepository::get_movie_social_feed")
- }
-
- async fn count_local_posts(&self) -> Result {
- unimplemented!("FakeDiaryRepository::count_local_posts")
- }
-}
-
-// ── PanicDiaryRepository ──────────────────────────────────────────────────────
-
-pub struct PanicDiaryRepository;
-
-#[async_trait]
-impl DiaryRepository for PanicDiaryRepository {
- async fn query_diary(
- &self,
- _filter: &DiaryFilter,
- ) -> Result, DomainError> {
- panic!("PanicDiaryRepository called")
- }
-
- async fn query_activity_feed(
- &self,
- _page: &PageParams,
- ) -> Result, DomainError> {
- panic!("PanicDiaryRepository called")
- }
-
- async fn query_activity_feed_filtered(
- &self,
- _page: &PageParams,
- _sort_by: &FeedSortBy,
- _search: Option<&str>,
- _following: Option<&FollowingFilter>,
- ) -> Result, DomainError> {
- panic!("PanicDiaryRepository called")
- }
-
- async fn get_review_history(&self, _movie_id: &MovieId) -> Result {
- panic!("PanicDiaryRepository called")
- }
-
- async fn get_user_history(&self, _user_id: &UserId) -> Result, DomainError> {
- panic!("PanicDiaryRepository called")
- }
-
- async fn get_movie_stats(&self, _movie_id: &MovieId) -> Result {
- panic!("PanicDiaryRepository called")
- }
-
- async fn get_movie_social_feed(
- &self,
- _movie_id: &MovieId,
- _page: &PageParams,
- ) -> Result, DomainError> {
- panic!("PanicDiaryRepository called")
- }
-
- async fn count_local_posts(&self) -> Result {
- panic!("PanicDiaryRepository called")
- }
-}
-
-// ── PanicStatsRepository ──────────────────────────────────────────────────────
-
-pub struct PanicStatsRepository;
-
-#[async_trait]
-impl StatsRepository for PanicStatsRepository {
- async fn get_user_stats(&self, _user_id: &UserId) -> Result {
- panic!("PanicStatsRepository called")
- }
-
- async fn get_user_trends(&self, _user_id: &UserId) -> Result {
- panic!("PanicStatsRepository called")
- }
-}
-
-// ── PanicImportSessionRepository ──────────────────────────────────────────────
-
-pub struct PanicImportSessionRepository;
-
-#[async_trait]
-impl ImportSessionRepository for PanicImportSessionRepository {
- async fn create(&self, _session: &ImportSession) -> Result<(), DomainError> {
- panic!("PanicImportSessionRepository called")
- }
-
- async fn get(
- &self,
- _id: &ImportSessionId,
- _user_id: &UserId,
- ) -> Result, DomainError> {
- panic!("PanicImportSessionRepository called")
- }
-
- async fn update(&self, _session: &ImportSession) -> Result<(), DomainError> {
- panic!("PanicImportSessionRepository called")
- }
-
- async fn delete(&self, _id: &ImportSessionId) -> Result<(), DomainError> {
- panic!("PanicImportSessionRepository called")
- }
-
- async fn delete_expired(&self) -> Result {
- panic!("PanicImportSessionRepository called")
- }
-
- async fn delete_expired_for_user(&self, _user_id: &UserId) -> Result<(), DomainError> {
- panic!("PanicImportSessionRepository called")
- }
-}
-
-// ── PanicImportProfileRepository ──────────────────────────────────────────────
-
-pub struct PanicImportProfileRepository;
-
-#[async_trait]
-impl ImportProfileRepository for PanicImportProfileRepository {
- async fn save(&self, _profile: &ImportProfile) -> Result<(), DomainError> {
- panic!("PanicImportProfileRepository called")
- }
-
- async fn list_for_user(&self, _user_id: &UserId) -> Result, DomainError> {
- panic!("PanicImportProfileRepository called")
- }
-
- async fn get(
- &self,
- _id: &ImportProfileId,
- _user_id: &UserId,
- ) -> Result, DomainError> {
- panic!("PanicImportProfileRepository called")
- }
-
- async fn delete(&self, _id: &ImportProfileId) -> Result<(), DomainError> {
- panic!("PanicImportProfileRepository called")
- }
-}
-
-// ── PanicMovieProfileRepository ───────────────────────────────────────────────
-
-pub struct PanicMovieProfileRepository;
-
-#[async_trait]
-impl MovieProfileRepository for PanicMovieProfileRepository {
- async fn upsert(&self, _profile: &MovieProfile) -> Result<(), DomainError> {
- panic!("PanicMovieProfileRepository called")
- }
-
- async fn get_by_movie_id(&self, _id: &MovieId) -> Result, DomainError> {
- panic!("PanicMovieProfileRepository called")
- }
-
- async fn list_stale(&self) -> Result, DomainError> {
- panic!("PanicMovieProfileRepository called")
- }
-}
-
-// ── PanicPersonCommand ────────────────────────────────────────────────────────
-
-pub struct PanicPersonCommand;
-
-#[async_trait]
-impl PersonCommand for PanicPersonCommand {
- async fn upsert_batch(&self, _persons: &[Person]) -> Result<(), DomainError> {
- panic!("PanicPersonCommand called")
- }
- async fn backfill_from_credits_batch(
- &self,
- _batch_size: u32,
- ) -> Result<(u64, bool), DomainError> {
- panic!("PanicPersonCommand called")
- }
-}
-
-// ── PanicPersonQuery ──────────────────────────────────────────────────────────
-
-pub struct PanicPersonQuery;
-
-#[async_trait]
-impl PersonQuery for PanicPersonQuery {
- async fn get_by_id(&self, _id: &PersonId) -> Result, DomainError> {
- panic!("PanicPersonQuery called")
- }
-
- async fn get_by_external_id(
- &self,
- _id: &ExternalPersonId,
- ) -> Result, DomainError> {
- panic!("PanicPersonQuery called")
- }
-
- async fn get_credits(&self, _id: &PersonId) -> Result {
- panic!("PanicPersonQuery called")
- }
-
- async fn list_orphaned_persons(&self) -> Result, DomainError> {
- panic!("PanicPersonQuery called")
- }
-
- async fn list_page(&self, _limit: u32, _offset: u32) -> Result, DomainError> {
- panic!("PanicPersonQuery called")
- }
-}
-
-// ── PanicSearchPort ───────────────────────────────────────────────────────────
-
-pub struct PanicSearchPort;
-
-#[async_trait]
-impl SearchPort for PanicSearchPort {
- async fn search(&self, _query: &SearchQuery) -> Result {
- Ok(SearchResults {
- movies: Paginated {
- items: vec![],
- total_count: 0,
- limit: 10,
- offset: 0,
- },
- people: Paginated {
- items: vec![],
- total_count: 0,
- limit: 10,
- offset: 0,
- },
- })
- }
-}
-
-// ── PanicSearchCommand ────────────────────────────────────────────────────────
-
-pub struct PanicSearchCommand;
-
-#[async_trait]
-impl SearchCommand for PanicSearchCommand {
- async fn index(&self, _doc: IndexableDocument) -> Result<(), DomainError> {
- panic!("PanicSearchCommand called")
- }
-
- async fn remove(&self, _entity_type: EntityType, _id: &str) -> Result<(), DomainError> {
- panic!("PanicSearchCommand called")
- }
-}
-
-// ── PanicPosterFetcher ────────────────────────────────────────────────────────
-
-pub struct PanicPosterFetcher;
-
-#[async_trait]
-impl PosterFetcherClient for PanicPosterFetcher {
- async fn fetch_poster_bytes(&self, _poster_url: &PosterUrl) -> Result, DomainError> {
- panic!("PanicPosterFetcher called")
- }
-}
-
-// ── PanicDiaryExporter ────────────────────────────────────────────────────────
-
-pub struct PanicDiaryExporter;
-
-#[async_trait]
-impl DiaryExporter for PanicDiaryExporter {
- async fn serialize_entries(
- &self,
- _entries: &[crate::models::DiaryEntry],
- _format: ExportFormat,
- ) -> Result, DomainError> {
- panic!("PanicDiaryExporter called")
- }
-}
-
-// ── PanicDocumentParser ───────────────────────────────────────────────────────
-
-pub struct PanicDocumentParser;
-
-impl DocumentParser for PanicDocumentParser {
- fn parse(&self, _bytes: &[u8], _format: FileFormat) -> Result {
- panic!("PanicDocumentParser called")
- }
-
- fn apply_mapping(&self, _file: &ParsedFile, _mappings: &[FieldMapping]) -> Vec {
- panic!("PanicDocumentParser called")
- }
-}
-
-// ── PanicProfileFieldsRepo ────────────────────────────────────────────────────
-
-pub struct PanicRemoteWatchlistRepository;
-
-#[async_trait]
-impl crate::ports::RemoteWatchlistRepository for PanicRemoteWatchlistRepository {
- async fn save(&self, _: crate::models::RemoteWatchlistEntry) -> Result<(), DomainError> {
- panic!("PanicRemoteWatchlistRepository called")
- }
- async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
- panic!("PanicRemoteWatchlistRepository called")
- }
- async fn get_by_actor_url(
- &self,
- _: &str,
- ) -> Result, DomainError> {
- panic!("PanicRemoteWatchlistRepository called")
- }
- async fn remove_all_by_actor(&self, _: &str) -> Result<(), DomainError> {
- panic!("PanicRemoteWatchlistRepository called")
- }
- async fn get_by_derived_uuid(
- &self,
- _: uuid::Uuid,
- ) -> Result, DomainError> {
- panic!("PanicRemoteWatchlistRepository called")
- }
-}
-
-pub struct NoopRemoteWatchlistRepository;
-
-#[async_trait]
-impl crate::ports::RemoteWatchlistRepository for NoopRemoteWatchlistRepository {
- async fn save(&self, _: crate::models::RemoteWatchlistEntry) -> Result<(), DomainError> {
- Ok(())
- }
- async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
- Ok(())
- }
- async fn get_by_actor_url(
- &self,
- _: &str,
- ) -> Result, DomainError> {
- Ok(vec![])
- }
- async fn remove_all_by_actor(&self, _: &str) -> Result<(), DomainError> {
- Ok(())
- }
- async fn get_by_derived_uuid(
- &self,
- _: uuid::Uuid,
- ) -> Result, DomainError> {
- Ok(vec![])
- }
-}
-
-pub struct PanicProfileFieldsRepo;
-
-#[async_trait]
-impl UserProfileFieldsRepository for PanicProfileFieldsRepo {
- async fn get_fields(
- &self,
- _user_id: &UserId,
- ) -> Result, DomainError> {
- panic!("PanicProfileFieldsRepo called")
- }
-
- async fn set_fields(
- &self,
- _user_id: &UserId,
- _fields: Vec,
- ) -> Result<(), DomainError> {
- panic!("PanicProfileFieldsRepo called")
- }
-}
-
-pub struct PanicSocialQueryPort;
-
-#[async_trait]
-impl crate::ports::SocialQueryPort for PanicSocialQueryPort {
- async fn get_accepted_following_urls(&self, _: uuid::Uuid) -> Result, DomainError> {
- panic!("PanicSocialQueryPort called")
- }
- async fn list_all_followed_remote_actors(
- &self,
- ) -> Result, DomainError> {
- panic!("PanicSocialQueryPort called")
- }
- async fn count_following(&self, _: uuid::Uuid) -> Result {
- panic!("PanicSocialQueryPort called")
- }
- async fn count_accepted_followers(&self, _: uuid::Uuid) -> Result {
- panic!("PanicSocialQueryPort called")
- }
- async fn get_pending_followers(
- &self,
- _: uuid::Uuid,
- ) -> Result, DomainError> {
- panic!("PanicSocialQueryPort called")
- }
-}
-
-pub struct NoopSocialQueryPort;
-
-#[async_trait]
-impl crate::ports::SocialQueryPort for NoopSocialQueryPort {
- async fn get_accepted_following_urls(&self, _: uuid::Uuid) -> Result, DomainError> {
- Ok(vec![])
- }
- async fn list_all_followed_remote_actors(
- &self,
- ) -> Result, DomainError> {
- Ok(vec![])
- }
- async fn count_following(&self, _: uuid::Uuid) -> Result {
- Ok(0)
- }
- async fn count_accepted_followers(&self, _: uuid::Uuid) -> Result {
- Ok(0)
- }
- async fn get_pending_followers(
- &self,
- _: uuid::Uuid,
- ) -> Result, DomainError> {
- Ok(vec![])
- }
-}
-
-// ── PanicWatchEventRepository ────────────────────────────────────────────────
-
-pub struct PanicWatchEventRepository;
-
-#[async_trait]
-impl crate::ports::WatchEventRepository for PanicWatchEventRepository {
- async fn save(&self, _: &crate::models::WatchEvent) -> Result<(), DomainError> {
- panic!("PanicWatchEventRepository called")
- }
- async fn update_status(
- &self,
- _: &crate::value_objects::WatchEventId,
- _: crate::models::WatchEventStatus,
- ) -> Result<(), DomainError> {
- panic!("PanicWatchEventRepository called")
- }
- async fn list_pending(
- &self,
- _: &UserId,
- ) -> Result, DomainError> {
- panic!("PanicWatchEventRepository called")
- }
- async fn get_by_id(
- &self,
- _: &crate::value_objects::WatchEventId,
- ) -> Result, DomainError> {
- panic!("PanicWatchEventRepository called")
- }
- async fn get_by_ids(
- &self,
- _: &[crate::value_objects::WatchEventId],
- ) -> Result, DomainError> {
- panic!("PanicWatchEventRepository called")
- }
- async fn update_status_batch(
- &self,
- _: &[crate::value_objects::WatchEventId],
- _: crate::models::WatchEventStatus,
- ) -> Result {
- panic!("PanicWatchEventRepository called")
- }
- async fn find_duplicate(
- &self,
- _: &UserId,
- _: &str,
- _: chrono::NaiveDateTime,
- ) -> Result {
- panic!("PanicWatchEventRepository called")
- }
- async fn delete_non_pending_older_than(
- &self,
- _: chrono::NaiveDateTime,
- ) -> Result {
- panic!("PanicWatchEventRepository called")
- }
-}
-
-// ── PanicWebhookTokenRepository ──────────────────────────────────────────────
-
-pub struct PanicWebhookTokenRepository;
-
-#[async_trait]
-impl crate::ports::WebhookTokenRepository for PanicWebhookTokenRepository {
- async fn save(&self, _: &crate::models::WebhookToken) -> Result<(), DomainError> {
- panic!("PanicWebhookTokenRepository called")
- }
- async fn find_by_token_hash(
- &self,
- _: &str,
- ) -> Result, DomainError> {
- panic!("PanicWebhookTokenRepository called")
- }
- async fn list_by_user(
- &self,
- _: &UserId,
- ) -> Result, DomainError> {
- panic!("PanicWebhookTokenRepository called")
- }
- async fn delete(
- &self,
- _: &crate::value_objects::WebhookTokenId,
- _: &UserId,
- ) -> Result<(), DomainError> {
- panic!("PanicWebhookTokenRepository called")
- }
- async fn touch_last_used(
- &self,
- _: &crate::value_objects::WebhookTokenId,
- ) -> Result<(), DomainError> {
- panic!("PanicWebhookTokenRepository called")
- }
-}
-
-// ── PanicWrapUpStatsQuery ───────────────────────────────────────────────────
-
-pub struct PanicWrapUpStatsQuery;
-
-#[async_trait]
-impl crate::ports::WrapUpStatsQuery for PanicWrapUpStatsQuery {
- async fn get_reviews_with_profiles(
- &self,
- _scope: &crate::models::wrapup::WrapUpScope,
- _range: &crate::models::wrapup::DateRange,
- ) -> Result, DomainError> {
- unimplemented!("WrapUpStatsQuery not wired")
- }
-}
-
-// ── InMemoryWrapUpStatsQuery ────────────────────────────────────────────────
-
-pub struct InMemoryWrapUpStatsQuery {
- pub rows: Mutex>,
-}
-
-impl InMemoryWrapUpStatsQuery {
- pub fn new() -> Arc {
- Arc::new(Self {
- rows: Mutex::new(Vec::new()),
- })
- }
-
- pub fn with_rows(rows: Vec) -> Arc {
- Arc::new(Self {
- rows: Mutex::new(rows),
- })
- }
-}
-
-#[async_trait]
-impl crate::ports::WrapUpStatsQuery for InMemoryWrapUpStatsQuery {
- async fn get_reviews_with_profiles(
- &self,
- scope: &crate::models::wrapup::WrapUpScope,
- range: &crate::models::wrapup::DateRange,
- ) -> Result, DomainError> {
- let rows = self.rows.lock().unwrap();
- let filtered: Vec<_> = rows
- .iter()
- .filter(|r| {
- let date = r.watched_at.date();
- date >= range.start() && date < range.end()
- })
- .filter(|r| match scope {
- crate::models::wrapup::WrapUpScope::User(uid) => r.user_id == *uid,
- crate::models::wrapup::WrapUpScope::Global => true,
- })
- .cloned()
- .collect();
- Ok(filtered)
- }
-}
-
-// ── InMemoryWrapUpRepository ────────────────────────────────────────────────
-
-pub struct InMemoryWrapUpRepository {
- pub store: Mutex>,
-}
-
-impl InMemoryWrapUpRepository {
- pub fn new() -> Arc {
- Arc::new(Self {
- store: Mutex::new(Vec::new()),
- })
- }
-}
-
-#[async_trait]
-impl WrapUpRepository for InMemoryWrapUpRepository {
- async fn create(
- &self,
- record: &crate::models::wrapup::WrapUpRecord,
- ) -> Result<(), DomainError> {
- self.store.lock().unwrap().push(record.clone());
- Ok(())
- }
-
- async fn update_status(
- &self,
- id: &WrapUpId,
- status: &crate::models::wrapup::WrapUpStatus,
- error: Option<&str>,
- ) -> Result<(), DomainError> {
- let mut store = self.store.lock().unwrap();
- if let Some(rec) = store.iter_mut().find(|r| r.id == *id) {
- rec.status = status.clone();
- rec.error_message = error.map(|s| s.to_string());
- Ok(())
- } else {
- Err(DomainError::NotFound("wrapup record".into()))
- }
- }
-
- async fn set_complete(
- &self,
- id: &WrapUpId,
- report: &crate::models::wrapup::WrapUpReport,
- ) -> Result<(), DomainError> {
- let mut store = self.store.lock().unwrap();
- if let Some(rec) = store.iter_mut().find(|r| r.id == *id) {
- rec.status = crate::models::wrapup::WrapUpStatus::Ready;
- rec.report = Some(report.clone());
- rec.completed_at = Some(chrono::Utc::now().naive_utc());
- Ok(())
- } else {
- Err(DomainError::NotFound("wrapup record".into()))
- }
- }
-
- async fn get_by_id(
- &self,
- id: &WrapUpId,
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store.iter().find(|r| r.id == *id).cloned())
- }
-
- async fn list_for_user(
- &self,
- user_id: Uuid,
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .iter()
- .filter(|r| r.user_id == Some(user_id))
- .cloned()
- .collect())
- }
-
- async fn list_global(&self) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .iter()
- .filter(|r| r.user_id.is_none())
- .cloned()
- .collect())
- }
-
- async fn find_existing(
- &self,
- user_id: Option,
- start: chrono::NaiveDate,
- end: chrono::NaiveDate,
- ) -> Result, DomainError> {
- let store = self.store.lock().unwrap();
- Ok(store
- .iter()
- .find(|r| r.user_id == user_id && r.start_date == start && r.end_date == end)
- .cloned())
- }
-
- async fn delete(&self, id: &WrapUpId) -> Result<(), DomainError> {
- let mut store = self.store.lock().unwrap();
- store.retain(|r| r.id != *id);
- Ok(())
- }
-
- async fn delete_failed_older_than(
- &self,
- before: chrono::NaiveDateTime,
- ) -> Result {
- let mut store = self.store.lock().unwrap();
- let before_len = store.len();
- store.retain(|r| {
- !(r.status == crate::models::wrapup::WrapUpStatus::Failed && r.created_at < before)
- });
- Ok((before_len - store.len()) as u64)
- }
-}
-
-// ── PanicWrapUpRepository ──────────────────────────────────────────────────
-
-pub struct PanicWrapUpRepository;
-
-#[async_trait]
-impl WrapUpRepository for PanicWrapUpRepository {
- async fn create(&self, _: &crate::models::wrapup::WrapUpRecord) -> Result<(), DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn update_status(
- &self,
- _: &WrapUpId,
- _: &crate::models::wrapup::WrapUpStatus,
- _: Option<&str>,
- ) -> Result<(), DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn set_complete(
- &self,
- _: &WrapUpId,
- _: &crate::models::wrapup::WrapUpReport,
- ) -> Result<(), DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn get_by_id(
- &self,
- _: &WrapUpId,
- ) -> Result, DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn list_for_user(
- &self,
- _: Uuid,
- ) -> Result, DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn list_global(&self) -> Result, DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn find_existing(
- &self,
- _: Option,
- _: chrono::NaiveDate,
- _: chrono::NaiveDate,
- ) -> Result, DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn delete(&self, _: &WrapUpId) -> Result<(), DomainError> {
- panic!("PanicWrapUpRepository called")
- }
- async fn delete_failed_older_than(&self, _: chrono::NaiveDateTime) -> Result {
- panic!("PanicWrapUpRepository called")
- }
-}
-
-// ── Noop Goal/Settings repos ────────────────────────────────────────────────
-
-pub struct NoopGoalRepository;
-
-#[async_trait]
-impl crate::ports::GoalRepository for NoopGoalRepository {
- async fn save(&self, _: &crate::models::Goal) -> Result<(), DomainError> {
- Ok(())
- }
- async fn update(&self, _: &crate::models::Goal) -> Result<(), DomainError> {
- Ok(())
- }
- async fn delete(
- &self,
- _: &crate::value_objects::GoalId,
- _: &UserId,
- ) -> Result<(), DomainError> {
- Ok(())
- }
- async fn find_by_user_and_year(
- &self,
- _: &UserId,
- _: u16,
- ) -> Result, DomainError> {
- Ok(None)
- }
- async fn list_for_user(&self, _: &UserId) -> Result, DomainError> {
- Ok(vec![])
- }
- async fn count_reviews_in_year(&self, _: &UserId, _: u16) -> Result {
- Ok(0)
- }
-}
-
-pub struct NoopUserSettingsRepository;
-
-#[async_trait]
-impl crate::ports::UserSettingsRepository for NoopUserSettingsRepository {
- async fn get(&self, user_id: &UserId) -> Result {
- Ok(crate::models::UserSettings::new(user_id.clone()))
- }
- async fn save(&self, _: &crate::models::UserSettings) -> Result<(), DomainError> {
- Ok(())
- }
-}
-
-pub struct NoopRemoteGoalRepository;
-
-#[async_trait]
-impl crate::ports::RemoteGoalRepository for NoopRemoteGoalRepository {
- async fn save(&self, _: crate::models::RemoteGoalEntry) -> Result<(), DomainError> {
- Ok(())
- }
- async fn update_by_ap_id(&self, _: &str, _: u32, _: u32) -> Result<(), DomainError> {
- Ok(())
- }
- async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
- Ok(())
- }
- async fn get_by_actor_url(
- &self,
- _: &str,
- ) -> Result, DomainError> {
- Ok(vec![])
- }
-}
diff --git a/crates/domain/src/testing/fakes.rs b/crates/domain/src/testing/fakes.rs
new file mode 100644
index 0000000..7e701c0
--- /dev/null
+++ b/crates/domain/src/testing/fakes.rs
@@ -0,0 +1,153 @@
+use std::collections::HashMap;
+use std::sync::{Arc, Mutex};
+
+use async_trait::async_trait;
+use chrono::Utc;
+use uuid::Uuid;
+
+use crate::{
+ errors::DomainError,
+ models::{
+ DiaryEntry, DiaryFilter, FeedEntry, Movie, MovieStats, Review, ReviewHistory,
+ collections::{PageParams, Paginated},
+ },
+ ports::{
+ AuthService, DiaryRepository, FeedSortBy, FollowingFilter, GeneratedToken, MetadataClient,
+ MetadataSearchCriteria, PasswordHasher,
+ },
+ value_objects::{ExternalMetadataId, MovieId, PasswordHash, PosterUrl, UserId},
+};
+
+// ── FakeAuthService ───────────────────────────────────────────────────────────
+
+pub struct FakeAuthService;
+
+#[async_trait]
+impl AuthService for FakeAuthService {
+ async fn generate_token(&self, user_id: &UserId) -> Result {
+ Ok(GeneratedToken {
+ token: user_id.value().to_string(),
+ expires_at: Utc::now() + chrono::Duration::hours(24),
+ })
+ }
+
+ async fn validate_token(&self, token: &str) -> Result {
+ Uuid::parse_str(token)
+ .map(UserId::from_uuid)
+ .map_err(|_| DomainError::Unauthorized("invalid token".into()))
+ }
+}
+
+// ── FakePasswordHasher ────────────────────────────────────────────────────────
+
+pub struct FakePasswordHasher;
+
+#[async_trait]
+impl PasswordHasher for FakePasswordHasher {
+ async fn hash(&self, plain_password: &str) -> Result {
+ PasswordHash::new(format!("hashed:{plain_password}"))
+ }
+
+ async fn verify(&self, plain_password: &str, hash: &PasswordHash) -> Result {
+ Ok(hash.value() == format!("hashed:{plain_password}"))
+ }
+}
+
+// ── FakeMetadataClient ────────────────────────────────────────────────────────
+
+pub struct FakeMetadataClient;
+
+#[async_trait]
+impl MetadataClient for FakeMetadataClient {
+ async fn fetch_movie_metadata(
+ &self,
+ _criteria: &MetadataSearchCriteria,
+ ) -> Result {
+ Err(DomainError::InfrastructureError(
+ "fake metadata client".into(),
+ ))
+ }
+
+ async fn get_poster_url(
+ &self,
+ _external_metadata_id: &ExternalMetadataId,
+ ) -> Result, DomainError> {
+ Ok(None)
+ }
+}
+
+// ── FakeDiaryRepository ───────────────────────────────────────────────────────
+
+pub struct FakeDiaryRepository {
+ histories: Mutex)>>,
+}
+
+impl FakeDiaryRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ histories: Mutex::new(HashMap::new()),
+ })
+ }
+
+ pub fn seed_history(&self, movie: Movie, reviews: Vec) {
+ self.histories
+ .lock()
+ .unwrap()
+ .insert(movie.id().value(), (movie, reviews));
+ }
+}
+
+#[async_trait]
+impl DiaryRepository for FakeDiaryRepository {
+ async fn query_diary(
+ &self,
+ _filter: &DiaryFilter,
+ ) -> Result, DomainError> {
+ unimplemented!("FakeDiaryRepository::query_diary")
+ }
+
+ async fn query_activity_feed(
+ &self,
+ _page: &PageParams,
+ ) -> Result, DomainError> {
+ unimplemented!("FakeDiaryRepository::query_activity_feed")
+ }
+
+ async fn query_activity_feed_filtered(
+ &self,
+ _page: &PageParams,
+ _sort_by: &FeedSortBy,
+ _search: Option<&str>,
+ _following: Option<&FollowingFilter>,
+ ) -> Result, DomainError> {
+ unimplemented!("FakeDiaryRepository::query_activity_feed_filtered")
+ }
+
+ async fn get_review_history(&self, movie_id: &MovieId) -> Result {
+ let histories = self.histories.lock().unwrap();
+ let (movie, reviews) = histories
+ .get(&movie_id.value())
+ .ok_or_else(|| DomainError::NotFound(format!("movie {}", movie_id.value())))?;
+ Ok(ReviewHistory::new(movie.clone(), reviews.clone()))
+ }
+
+ async fn get_user_history(&self, _user_id: &UserId) -> Result, DomainError> {
+ unimplemented!("FakeDiaryRepository::get_user_history")
+ }
+
+ async fn get_movie_stats(&self, _movie_id: &MovieId) -> Result {
+ unimplemented!("FakeDiaryRepository::get_movie_stats")
+ }
+
+ async fn get_movie_social_feed(
+ &self,
+ _movie_id: &MovieId,
+ _page: &PageParams,
+ ) -> Result, DomainError> {
+ unimplemented!("FakeDiaryRepository::get_movie_social_feed")
+ }
+
+ async fn count_local_posts(&self) -> Result {
+ unimplemented!("FakeDiaryRepository::count_local_posts")
+ }
+}
diff --git a/crates/domain/src/testing/in_memory.rs b/crates/domain/src/testing/in_memory.rs
new file mode 100644
index 0000000..7028578
--- /dev/null
+++ b/crates/domain/src/testing/in_memory.rs
@@ -0,0 +1,312 @@
+use std::collections::HashMap;
+use std::sync::{Arc, Mutex};
+
+use async_trait::async_trait;
+use uuid::Uuid;
+
+use crate::{
+ errors::DomainError,
+ events::DomainEvent,
+ models::{
+ Movie, MovieFilter, MovieSummary, Review, User, UserSummary, WatchlistEntry,
+ WatchlistWithMovie,
+ collections::{PageParams, Paginated},
+ },
+ ports::{MovieRepository, ReviewRepository, UserRepository, WatchlistRepository},
+ value_objects::{
+ Email, ExternalMetadataId, MovieId, MovieTitle, ReleaseYear, ReviewId, UserId, Username,
+ },
+};
+
+// ── InMemoryMovieRepository ───────────────────────────────────────────────────
+
+pub struct InMemoryMovieRepository {
+ pub store: Mutex>,
+}
+
+impl InMemoryMovieRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ store: Mutex::new(HashMap::new()),
+ })
+ }
+
+ pub fn count(&self) -> usize {
+ self.store.lock().unwrap().len()
+ }
+}
+
+#[async_trait]
+impl MovieRepository for InMemoryMovieRepository {
+ async fn get_movie_by_external_id(
+ &self,
+ external_metadata_id: &ExternalMetadataId,
+ ) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ Ok(store
+ .values()
+ .find(|m| {
+ m.external_metadata_id()
+ .map(|e| e.value() == external_metadata_id.value())
+ .unwrap_or(false)
+ })
+ .cloned())
+ }
+
+ async fn get_movie_by_id(&self, movie_id: &MovieId) -> Result, DomainError> {
+ Ok(self.store.lock().unwrap().get(&movie_id.value()).cloned())
+ }
+
+ async fn get_movies_by_title_and_year(
+ &self,
+ title: &MovieTitle,
+ year: &ReleaseYear,
+ ) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ Ok(store
+ .values()
+ .filter(|m| m.title() == title && m.release_year() == year)
+ .cloned()
+ .collect())
+ }
+
+ async fn upsert_movie(&self, movie: &Movie) -> Result<(), DomainError> {
+ self.store
+ .lock()
+ .unwrap()
+ .insert(movie.id().value(), movie.clone());
+ Ok(())
+ }
+
+ async fn delete_movie(&self, movie_id: &MovieId) -> Result<(), DomainError> {
+ self.store.lock().unwrap().remove(&movie_id.value());
+ Ok(())
+ }
+
+ async fn existing_external_ids(
+ &self,
+ ids: &[ExternalMetadataId],
+ ) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ let known: std::collections::HashSet = store
+ .values()
+ .filter_map(|m| m.external_metadata_id().map(|e| e.value().to_string()))
+ .collect();
+ Ok(ids
+ .iter()
+ .map(|id| id.value().to_string())
+ .filter(|v| known.contains(v))
+ .collect())
+ }
+
+ async fn existing_title_year_pairs(
+ &self,
+ pairs: &[(MovieTitle, ReleaseYear)],
+ ) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ let known: std::collections::HashSet<(String, u16)> = store
+ .values()
+ .map(|m| (m.title().value().to_string(), m.release_year().value()))
+ .collect();
+ Ok(pairs
+ .iter()
+ .map(|(t, y)| (t.value().to_string(), y.value()))
+ .filter(|p| known.contains(p))
+ .collect())
+ }
+
+ async fn list_movies(
+ &self,
+ _page: &PageParams,
+ _filter: &MovieFilter,
+ ) -> Result, DomainError> {
+ Ok(Paginated {
+ items: vec![],
+ total_count: 0,
+ limit: 10,
+ offset: 0,
+ })
+ }
+}
+
+// ── InMemoryReviewRepository ──────────────────────────────────────────────────
+
+pub struct InMemoryReviewRepository {
+ store: Mutex>,
+}
+
+impl InMemoryReviewRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ store: Mutex::new(HashMap::new()),
+ })
+ }
+
+ pub fn count(&self) -> usize {
+ self.store.lock().unwrap().len()
+ }
+}
+
+#[async_trait]
+impl ReviewRepository for InMemoryReviewRepository {
+ async fn save_review(&self, review: &Review) -> Result {
+ self.store
+ .lock()
+ .unwrap()
+ .insert(review.id().value(), review.clone());
+ Ok(DomainEvent::ReviewLogged {
+ review_id: review.id().clone(),
+ movie_id: review.movie_id().clone(),
+ user_id: review.user_id().clone(),
+ rating: review.rating().clone(),
+ watched_at: *review.watched_at(),
+ })
+ }
+
+ async fn get_review_by_id(&self, review_id: &ReviewId) -> Result, DomainError> {
+ Ok(self.store.lock().unwrap().get(&review_id.value()).cloned())
+ }
+
+ async fn delete_review(&self, review_id: &ReviewId) -> Result<(), DomainError> {
+ self.store.lock().unwrap().remove(&review_id.value());
+ Ok(())
+ }
+
+ async fn get_all_reviews_for_user(&self, user_id: &UserId) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ Ok(store
+ .values()
+ .filter(|r| r.user_id() == user_id)
+ .cloned()
+ .collect())
+ }
+}
+
+// ── InMemoryUserRepository ────────────────────────────────────────────────────
+
+pub struct InMemoryUserRepository {
+ pub store: Mutex>,
+}
+
+impl InMemoryUserRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ store: Mutex::new(HashMap::new()),
+ })
+ }
+
+ pub fn count(&self) -> usize {
+ self.store.lock().unwrap().len()
+ }
+}
+
+#[async_trait]
+impl UserRepository for InMemoryUserRepository {
+ async fn find_by_email(&self, email: &Email) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ Ok(store
+ .values()
+ .find(|u| u.email().value() == email.value())
+ .cloned())
+ }
+
+ async fn find_by_username(&self, username: &Username) -> Result, DomainError> {
+ let store = self.store.lock().unwrap();
+ Ok(store
+ .values()
+ .find(|u| u.username().value() == username.value())
+ .cloned())
+ }
+
+ async fn save(&self, user: &User) -> Result<(), DomainError> {
+ self.store
+ .lock()
+ .unwrap()
+ .insert(user.id().value(), user.clone());
+ Ok(())
+ }
+
+ async fn find_by_id(&self, id: &UserId) -> Result, DomainError> {
+ Ok(self.store.lock().unwrap().get(&id.value()).cloned())
+ }
+
+ async fn list_with_stats(&self) -> Result, DomainError> {
+ Ok(vec![])
+ }
+
+ async fn update_profile(
+ &self,
+ _user_id: &UserId,
+ _profile: &crate::models::UserProfile,
+ ) -> Result<(), DomainError> {
+ Ok(())
+ }
+}
+
+// ── InMemoryWatchlistRepository ───────────────────────────────────────────────
+
+pub struct InMemoryWatchlistRepository {
+ store: Mutex>,
+}
+
+impl InMemoryWatchlistRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ store: Mutex::new(HashMap::new()),
+ })
+ }
+
+ pub fn count(&self) -> usize {
+ self.store.lock().unwrap().len()
+ }
+}
+
+#[async_trait]
+impl WatchlistRepository for InMemoryWatchlistRepository {
+ async fn add(&self, entry: &WatchlistEntry) -> Result<(), DomainError> {
+ let key = (entry.user_id.value(), entry.movie_id.value());
+ self.store
+ .lock()
+ .unwrap()
+ .entry(key)
+ .or_insert_with(|| entry.clone());
+ Ok(())
+ }
+
+ async fn remove(&self, user_id: &UserId, movie_id: &MovieId) -> Result<(), DomainError> {
+ let key = (user_id.value(), movie_id.value());
+ self.store
+ .lock()
+ .unwrap()
+ .remove(&key)
+ .ok_or_else(|| DomainError::NotFound("watchlist entry".into()))?;
+ Ok(())
+ }
+
+ async fn remove_if_present(
+ &self,
+ user_id: &UserId,
+ movie_id: &MovieId,
+ ) -> Result {
+ let key = (user_id.value(), movie_id.value());
+ Ok(self.store.lock().unwrap().remove(&key).is_some())
+ }
+
+ async fn get_for_user(
+ &self,
+ _user_id: &UserId,
+ _page: &PageParams,
+ ) -> Result, DomainError> {
+ Ok(Paginated {
+ items: vec![],
+ total_count: 0,
+ limit: 10,
+ offset: 0,
+ })
+ }
+
+ async fn contains(&self, user_id: &UserId, movie_id: &MovieId) -> Result {
+ let key = (user_id.value(), movie_id.value());
+ Ok(self.store.lock().unwrap().contains_key(&key))
+ }
+}
diff --git a/crates/domain/src/testing/mod.rs b/crates/domain/src/testing/mod.rs
new file mode 100644
index 0000000..fb38fdf
--- /dev/null
+++ b/crates/domain/src/testing/mod.rs
@@ -0,0 +1,11 @@
+mod fakes;
+mod in_memory;
+mod noops;
+mod panics;
+mod wrapup;
+
+pub use fakes::*;
+pub use in_memory::*;
+pub use noops::*;
+pub use panics::*;
+pub use wrapup::*;
diff --git a/crates/domain/src/testing/noops.rs b/crates/domain/src/testing/noops.rs
new file mode 100644
index 0000000..383c5d3
--- /dev/null
+++ b/crates/domain/src/testing/noops.rs
@@ -0,0 +1,191 @@
+use std::sync::{Arc, Mutex};
+
+use async_trait::async_trait;
+
+use crate::{
+ errors::DomainError,
+ events::DomainEvent,
+ ports::{EventPublisher, ObjectStorage},
+ value_objects::UserId,
+};
+
+// ── NoopEventPublisher ────────────────────────────────────────────────────────
+
+pub struct NoopEventPublisher {
+ pub events: Mutex>,
+}
+
+impl NoopEventPublisher {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ events: Mutex::new(vec![]),
+ })
+ }
+
+ pub fn published(&self) -> Vec {
+ self.events.lock().unwrap().clone()
+ }
+}
+
+#[async_trait]
+impl EventPublisher for NoopEventPublisher {
+ async fn publish(&self, event: &DomainEvent) -> Result<(), DomainError> {
+ self.events.lock().unwrap().push(event.clone());
+ Ok(())
+ }
+}
+
+// ── NoopObjectStorage ──────────────────────────────────────────────────────────
+
+pub struct NoopObjectStorage;
+
+#[async_trait]
+impl ObjectStorage for NoopObjectStorage {
+ async fn store(&self, key: &str, _image_bytes: &[u8]) -> Result {
+ Ok(format!("noop://{key}"))
+ }
+
+ async fn get(&self, _key: &str) -> Result, DomainError> {
+ Ok(vec![])
+ }
+
+ async fn get_stream(
+ &self,
+ _key: &str,
+ ) -> Result>, DomainError>
+ {
+ Ok(Box::pin(futures::stream::empty()))
+ }
+
+ async fn delete(&self, _key: &str) -> Result<(), DomainError> {
+ Ok(())
+ }
+}
+
+// ── NoopRemoteWatchlistRepository ─────────────────────────────────────────────
+
+pub struct NoopRemoteWatchlistRepository;
+
+#[async_trait]
+impl crate::ports::RemoteWatchlistRepository for NoopRemoteWatchlistRepository {
+ async fn save(&self, _: crate::models::RemoteWatchlistEntry) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn get_by_actor_url(
+ &self,
+ _: &str,
+ ) -> Result, DomainError> {
+ Ok(vec![])
+ }
+ async fn remove_all_by_actor(&self, _: &str) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn get_by_derived_uuid(
+ &self,
+ _: uuid::Uuid,
+ ) -> Result, DomainError> {
+ Ok(vec![])
+ }
+}
+
+// ── NoopSocialQueryPort ───────────────────────────────────────────────────────
+
+pub struct NoopSocialQueryPort;
+
+#[async_trait]
+impl crate::ports::SocialQueryPort for NoopSocialQueryPort {
+ async fn get_accepted_following_urls(&self, _: uuid::Uuid) -> Result, DomainError> {
+ Ok(vec![])
+ }
+ async fn list_all_followed_remote_actors(
+ &self,
+ ) -> Result, DomainError> {
+ Ok(vec![])
+ }
+ async fn count_following(&self, _: uuid::Uuid) -> Result {
+ Ok(0)
+ }
+ async fn count_accepted_followers(&self, _: uuid::Uuid) -> Result {
+ Ok(0)
+ }
+ async fn get_pending_followers(
+ &self,
+ _: uuid::Uuid,
+ ) -> Result, DomainError> {
+ Ok(vec![])
+ }
+}
+
+// ── NoopGoalRepository ────────────────────────────────────────────────────────
+
+pub struct NoopGoalRepository;
+
+#[async_trait]
+impl crate::ports::GoalRepository for NoopGoalRepository {
+ async fn save(&self, _: &crate::models::Goal) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn update(&self, _: &crate::models::Goal) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn delete(
+ &self,
+ _: &crate::value_objects::GoalId,
+ _: &UserId,
+ ) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn find_by_user_and_year(
+ &self,
+ _: &UserId,
+ _: u16,
+ ) -> Result, DomainError> {
+ Ok(None)
+ }
+ async fn list_for_user(&self, _: &UserId) -> Result, DomainError> {
+ Ok(vec![])
+ }
+ async fn count_reviews_in_year(&self, _: &UserId, _: u16) -> Result {
+ Ok(0)
+ }
+}
+
+// ── NoopUserSettingsRepository ────────────────────────────────────────────────
+
+pub struct NoopUserSettingsRepository;
+
+#[async_trait]
+impl crate::ports::UserSettingsRepository for NoopUserSettingsRepository {
+ async fn get(&self, user_id: &UserId) -> Result {
+ Ok(crate::models::UserSettings::new(user_id.clone()))
+ }
+ async fn save(&self, _: &crate::models::UserSettings) -> Result<(), DomainError> {
+ Ok(())
+ }
+}
+
+// ── NoopRemoteGoalRepository ──────────────────────────────────────────────────
+
+pub struct NoopRemoteGoalRepository;
+
+#[async_trait]
+impl crate::ports::RemoteGoalRepository for NoopRemoteGoalRepository {
+ async fn save(&self, _: crate::models::RemoteGoalEntry) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn update_by_ap_id(&self, _: &str, _: u32, _: u32) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
+ Ok(())
+ }
+ async fn get_by_actor_url(
+ &self,
+ _: &str,
+ ) -> Result, DomainError> {
+ Ok(vec![])
+ }
+}
diff --git a/crates/domain/src/testing/panics.rs b/crates/domain/src/testing/panics.rs
new file mode 100644
index 0000000..2d3bb36
--- /dev/null
+++ b/crates/domain/src/testing/panics.rs
@@ -0,0 +1,405 @@
+use async_trait::async_trait;
+
+use crate::{
+ errors::DomainError,
+ models::{
+ AnnotatedRow, DiaryEntry, DiaryFilter, EntityType, ExportFormat, ExternalPersonId,
+ FeedEntry, FieldMapping, FileFormat, ImportError, ImportProfile, ImportSession,
+ IndexableDocument, MovieProfile, MovieStats, ParsedFile, Person, PersonCredits, PersonId,
+ ReviewHistory, SearchQuery, SearchResults, UserStats, UserTrends,
+ collections::{PageParams, Paginated},
+ },
+ ports::{
+ DiaryExporter, DiaryRepository, DocumentParser, FeedSortBy, FollowingFilter,
+ ImportProfileRepository, ImportSessionRepository, MovieProfileRepository, PersonCommand,
+ PersonQuery, PosterFetcherClient, SearchCommand, SearchPort, StatsRepository,
+ UserProfileFieldsRepository,
+ },
+ value_objects::{ImportProfileId, ImportSessionId, MovieId, PosterUrl, UserId},
+};
+
+// ── PanicDiaryRepository ──────────────────────────────────────────────────────
+
+pub struct PanicDiaryRepository;
+
+#[async_trait]
+impl DiaryRepository for PanicDiaryRepository {
+ async fn query_diary(&self, _: &DiaryFilter) -> Result, DomainError> {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn query_activity_feed(
+ &self,
+ _: &PageParams,
+ ) -> Result, DomainError> {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn query_activity_feed_filtered(
+ &self,
+ _: &PageParams,
+ _: &FeedSortBy,
+ _: Option<&str>,
+ _: Option<&FollowingFilter>,
+ ) -> Result, DomainError> {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn get_review_history(&self, _: &MovieId) -> Result {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn get_user_history(&self, _: &UserId) -> Result, DomainError> {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn get_movie_stats(&self, _: &MovieId) -> Result {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn get_movie_social_feed(
+ &self,
+ _: &MovieId,
+ _: &PageParams,
+ ) -> Result, DomainError> {
+ panic!("PanicDiaryRepository called")
+ }
+ async fn count_local_posts(&self) -> Result {
+ panic!("PanicDiaryRepository called")
+ }
+}
+
+pub struct PanicStatsRepository;
+
+#[async_trait]
+impl StatsRepository for PanicStatsRepository {
+ async fn get_user_stats(&self, _: &UserId) -> Result {
+ panic!("PanicStatsRepository called")
+ }
+ async fn get_user_trends(&self, _: &UserId) -> Result {
+ panic!("PanicStatsRepository called")
+ }
+}
+
+pub struct PanicImportSessionRepository;
+
+#[async_trait]
+impl ImportSessionRepository for PanicImportSessionRepository {
+ async fn create(&self, _: &ImportSession) -> Result<(), DomainError> {
+ panic!("PanicImportSessionRepository called")
+ }
+ async fn get(
+ &self,
+ _: &ImportSessionId,
+ _: &UserId,
+ ) -> Result, DomainError> {
+ panic!("PanicImportSessionRepository called")
+ }
+ async fn update(&self, _: &ImportSession) -> Result<(), DomainError> {
+ panic!("PanicImportSessionRepository called")
+ }
+ async fn delete(&self, _: &ImportSessionId) -> Result<(), DomainError> {
+ panic!("PanicImportSessionRepository called")
+ }
+ async fn delete_expired(&self) -> Result {
+ panic!("PanicImportSessionRepository called")
+ }
+ async fn delete_expired_for_user(&self, _: &UserId) -> Result<(), DomainError> {
+ panic!("PanicImportSessionRepository called")
+ }
+}
+
+pub struct PanicImportProfileRepository;
+
+#[async_trait]
+impl ImportProfileRepository for PanicImportProfileRepository {
+ async fn save(&self, _: &ImportProfile) -> Result<(), DomainError> {
+ panic!("PanicImportProfileRepository called")
+ }
+ async fn list_for_user(&self, _: &UserId) -> Result, DomainError> {
+ panic!("PanicImportProfileRepository called")
+ }
+ async fn get(
+ &self,
+ _: &ImportProfileId,
+ _: &UserId,
+ ) -> Result, DomainError> {
+ panic!("PanicImportProfileRepository called")
+ }
+ async fn delete(&self, _: &ImportProfileId) -> Result<(), DomainError> {
+ panic!("PanicImportProfileRepository called")
+ }
+}
+
+pub struct PanicMovieProfileRepository;
+
+#[async_trait]
+impl MovieProfileRepository for PanicMovieProfileRepository {
+ async fn upsert(&self, _: &MovieProfile) -> Result<(), DomainError> {
+ panic!("PanicMovieProfileRepository called")
+ }
+ async fn get_by_movie_id(&self, _: &MovieId) -> Result, DomainError> {
+ panic!("PanicMovieProfileRepository called")
+ }
+ async fn list_stale(&self) -> Result, DomainError> {
+ panic!("PanicMovieProfileRepository called")
+ }
+}
+
+pub struct PanicPersonCommand;
+
+#[async_trait]
+impl PersonCommand for PanicPersonCommand {
+ async fn upsert_batch(&self, _: &[Person]) -> Result<(), DomainError> {
+ panic!("PanicPersonCommand called")
+ }
+ async fn backfill_from_credits_batch(&self, _: u32) -> Result<(u64, bool), DomainError> {
+ panic!("PanicPersonCommand called")
+ }
+}
+
+pub struct PanicPersonQuery;
+
+#[async_trait]
+impl PersonQuery for PanicPersonQuery {
+ async fn get_by_id(&self, _: &PersonId) -> Result, DomainError> {
+ panic!("PanicPersonQuery called")
+ }
+ async fn get_by_external_id(
+ &self,
+ _: &ExternalPersonId,
+ ) -> Result, DomainError> {
+ panic!("PanicPersonQuery called")
+ }
+ async fn get_credits(&self, _: &PersonId) -> Result {
+ panic!("PanicPersonQuery called")
+ }
+ async fn list_orphaned_persons(&self) -> Result, DomainError> {
+ panic!("PanicPersonQuery called")
+ }
+ async fn list_page(&self, _: u32, _: u32) -> Result, DomainError> {
+ panic!("PanicPersonQuery called")
+ }
+}
+
+pub struct PanicSearchPort;
+
+#[async_trait]
+impl SearchPort for PanicSearchPort {
+ async fn search(&self, _: &SearchQuery) -> Result {
+ Ok(SearchResults {
+ movies: Paginated {
+ items: vec![],
+ total_count: 0,
+ limit: 10,
+ offset: 0,
+ },
+ people: Paginated {
+ items: vec![],
+ total_count: 0,
+ limit: 10,
+ offset: 0,
+ },
+ })
+ }
+}
+
+pub struct PanicSearchCommand;
+
+#[async_trait]
+impl SearchCommand for PanicSearchCommand {
+ async fn index(&self, _: IndexableDocument) -> Result<(), DomainError> {
+ panic!("PanicSearchCommand called")
+ }
+ async fn remove(&self, _: EntityType, _: &str) -> Result<(), DomainError> {
+ panic!("PanicSearchCommand called")
+ }
+}
+
+pub struct PanicPosterFetcher;
+
+#[async_trait]
+impl PosterFetcherClient for PanicPosterFetcher {
+ async fn fetch_poster_bytes(&self, _: &PosterUrl) -> Result, DomainError> {
+ panic!("PanicPosterFetcher called")
+ }
+}
+
+pub struct PanicDiaryExporter;
+
+#[async_trait]
+impl DiaryExporter for PanicDiaryExporter {
+ async fn serialize_entries(
+ &self,
+ _: &[DiaryEntry],
+ _: ExportFormat,
+ ) -> Result, DomainError> {
+ panic!("PanicDiaryExporter called")
+ }
+}
+
+pub struct PanicDocumentParser;
+
+impl DocumentParser for PanicDocumentParser {
+ fn parse(&self, _: &[u8], _: FileFormat) -> Result {
+ panic!("PanicDocumentParser called")
+ }
+ fn apply_mapping(&self, _: &ParsedFile, _: &[FieldMapping]) -> Vec {
+ panic!("PanicDocumentParser called")
+ }
+}
+
+pub struct PanicRemoteWatchlistRepository;
+
+#[async_trait]
+impl crate::ports::RemoteWatchlistRepository for PanicRemoteWatchlistRepository {
+ async fn save(&self, _: crate::models::RemoteWatchlistEntry) -> Result<(), DomainError> {
+ panic!("PanicRemoteWatchlistRepository called")
+ }
+ async fn remove_by_ap_id(&self, _: &str, _: &str) -> Result<(), DomainError> {
+ panic!("PanicRemoteWatchlistRepository called")
+ }
+ async fn get_by_actor_url(
+ &self,
+ _: &str,
+ ) -> Result, DomainError> {
+ panic!("PanicRemoteWatchlistRepository called")
+ }
+ async fn remove_all_by_actor(&self, _: &str) -> Result<(), DomainError> {
+ panic!("PanicRemoteWatchlistRepository called")
+ }
+ async fn get_by_derived_uuid(
+ &self,
+ _: uuid::Uuid,
+ ) -> Result, DomainError> {
+ panic!("PanicRemoteWatchlistRepository called")
+ }
+}
+
+pub struct PanicProfileFieldsRepo;
+
+#[async_trait]
+impl UserProfileFieldsRepository for PanicProfileFieldsRepo {
+ async fn get_fields(
+ &self,
+ _: &UserId,
+ ) -> Result, DomainError> {
+ panic!("PanicProfileFieldsRepo called")
+ }
+ async fn set_fields(
+ &self,
+ _: &UserId,
+ _: Vec,
+ ) -> Result<(), DomainError> {
+ panic!("PanicProfileFieldsRepo called")
+ }
+}
+
+pub struct PanicSocialQueryPort;
+
+#[async_trait]
+impl crate::ports::SocialQueryPort for PanicSocialQueryPort {
+ async fn get_accepted_following_urls(&self, _: uuid::Uuid) -> Result, DomainError> {
+ panic!("PanicSocialQueryPort called")
+ }
+ async fn list_all_followed_remote_actors(
+ &self,
+ ) -> Result, DomainError> {
+ panic!("PanicSocialQueryPort called")
+ }
+ async fn count_following(&self, _: uuid::Uuid) -> Result {
+ panic!("PanicSocialQueryPort called")
+ }
+ async fn count_accepted_followers(&self, _: uuid::Uuid) -> Result {
+ panic!("PanicSocialQueryPort called")
+ }
+ async fn get_pending_followers(
+ &self,
+ _: uuid::Uuid,
+ ) -> Result, DomainError> {
+ panic!("PanicSocialQueryPort called")
+ }
+}
+
+pub struct PanicWatchEventRepository;
+
+#[async_trait]
+impl crate::ports::WatchEventRepository for PanicWatchEventRepository {
+ async fn save(&self, _: &crate::models::WatchEvent) -> Result<(), DomainError> {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn update_status(
+ &self,
+ _: &crate::value_objects::WatchEventId,
+ _: crate::models::WatchEventStatus,
+ ) -> Result<(), DomainError> {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn list_pending(
+ &self,
+ _: &UserId,
+ ) -> Result, DomainError> {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn get_by_id(
+ &self,
+ _: &crate::value_objects::WatchEventId,
+ ) -> Result, DomainError> {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn get_by_ids(
+ &self,
+ _: &[crate::value_objects::WatchEventId],
+ ) -> Result, DomainError> {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn update_status_batch(
+ &self,
+ _: &[crate::value_objects::WatchEventId],
+ _: crate::models::WatchEventStatus,
+ ) -> Result {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn find_duplicate(
+ &self,
+ _: &UserId,
+ _: &str,
+ _: chrono::NaiveDateTime,
+ ) -> Result {
+ panic!("PanicWatchEventRepository called")
+ }
+ async fn delete_non_pending_older_than(
+ &self,
+ _: chrono::NaiveDateTime,
+ ) -> Result {
+ panic!("PanicWatchEventRepository called")
+ }
+}
+
+pub struct PanicWebhookTokenRepository;
+
+#[async_trait]
+impl crate::ports::WebhookTokenRepository for PanicWebhookTokenRepository {
+ async fn save(&self, _: &crate::models::WebhookToken) -> Result<(), DomainError> {
+ panic!("PanicWebhookTokenRepository called")
+ }
+ async fn find_by_token_hash(
+ &self,
+ _: &str,
+ ) -> Result, DomainError> {
+ panic!("PanicWebhookTokenRepository called")
+ }
+ async fn list_by_user(
+ &self,
+ _: &UserId,
+ ) -> Result, DomainError> {
+ panic!("PanicWebhookTokenRepository called")
+ }
+ async fn delete(
+ &self,
+ _: &crate::value_objects::WebhookTokenId,
+ _: &UserId,
+ ) -> Result<(), DomainError> {
+ panic!("PanicWebhookTokenRepository called")
+ }
+ async fn touch_last_used(
+ &self,
+ _: &crate::value_objects::WebhookTokenId,
+ ) -> Result<(), DomainError> {
+ panic!("PanicWebhookTokenRepository called")
+ }
+}
diff --git a/crates/domain/src/testing/wrapup.rs b/crates/domain/src/testing/wrapup.rs
new file mode 100644
index 0000000..4d09369
--- /dev/null
+++ b/crates/domain/src/testing/wrapup.rs
@@ -0,0 +1,247 @@
+use std::sync::{Arc, Mutex};
+
+use async_trait::async_trait;
+use uuid::Uuid;
+
+use crate::{errors::DomainError, ports::WrapUpRepository, value_objects::WrapUpId};
+
+// ── PanicWrapUpStatsQuery ───────────────────────────────────────────────────
+
+pub struct PanicWrapUpStatsQuery;
+
+#[async_trait]
+impl crate::ports::WrapUpStatsQuery for PanicWrapUpStatsQuery {
+ async fn get_reviews_with_profiles(
+ &self,
+ _: &crate::models::wrapup::WrapUpScope,
+ _: &crate::models::wrapup::DateRange,
+ ) -> Result, DomainError> {
+ unimplemented!("WrapUpStatsQuery not wired")
+ }
+}
+
+// ── InMemoryWrapUpStatsQuery ────────────────────────────────────────────────
+
+pub struct InMemoryWrapUpStatsQuery {
+ pub rows: Mutex>,
+}
+
+impl InMemoryWrapUpStatsQuery {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ rows: Mutex::new(Vec::new()),
+ })
+ }
+
+ pub fn with_rows(rows: Vec) -> Arc {
+ Arc::new(Self {
+ rows: Mutex::new(rows),
+ })
+ }
+}
+
+#[async_trait]
+impl crate::ports::WrapUpStatsQuery for InMemoryWrapUpStatsQuery {
+ async fn get_reviews_with_profiles(
+ &self,
+ scope: &crate::models::wrapup::WrapUpScope,
+ range: &crate::models::wrapup::DateRange,
+ ) -> Result, DomainError> {
+ let rows = self.rows.lock().unwrap();
+ let filtered: Vec<_> = rows
+ .iter()
+ .filter(|r| {
+ let date = r.watched_at.date();
+ date >= range.start() && date < range.end()
+ })
+ .filter(|r| match scope {
+ crate::models::wrapup::WrapUpScope::User(uid) => r.user_id == *uid,
+ crate::models::wrapup::WrapUpScope::Global => true,
+ })
+ .cloned()
+ .collect();
+ Ok(filtered)
+ }
+}
+
+// ── InMemoryWrapUpRepository ────────────────────────────────────────────────
+
+pub struct InMemoryWrapUpRepository {
+ pub store: Mutex>,
+}
+
+impl InMemoryWrapUpRepository {
+ pub fn new() -> Arc {
+ Arc::new(Self {
+ store: Mutex::new(Vec::new()),
+ })
+ }
+}
+
+#[async_trait]
+impl WrapUpRepository for InMemoryWrapUpRepository {
+ async fn create(
+ &self,
+ record: &crate::models::wrapup::WrapUpRecord,
+ ) -> Result<(), DomainError> {
+ self.store.lock().unwrap().push(record.clone());
+ Ok(())
+ }
+
+ async fn update_status(
+ &self,
+ id: &WrapUpId,
+ status: &crate::models::wrapup::WrapUpStatus,
+ error: Option<&str>,
+ ) -> Result<(), DomainError> {
+ let mut store = self.store.lock().unwrap();
+ if let Some(rec) = store.iter_mut().find(|r| r.id == *id) {
+ rec.status = status.clone();
+ rec.error_message = error.map(|s| s.to_string());
+ Ok(())
+ } else {
+ Err(DomainError::NotFound("wrapup record".into()))
+ }
+ }
+
+ async fn set_complete(
+ &self,
+ id: &WrapUpId,
+ report: &crate::models::wrapup::WrapUpReport,
+ ) -> Result<(), DomainError> {
+ let mut store = self.store.lock().unwrap();
+ if let Some(rec) = store.iter_mut().find(|r| r.id == *id) {
+ rec.status = crate::models::wrapup::WrapUpStatus::Ready;
+ rec.report = Some(report.clone());
+ rec.completed_at = Some(chrono::Utc::now().naive_utc());
+ Ok(())
+ } else {
+ Err(DomainError::NotFound("wrapup record".into()))
+ }
+ }
+
+ async fn get_by_id(
+ &self,
+ id: &WrapUpId,
+ ) -> Result, DomainError> {
+ Ok(self
+ .store
+ .lock()
+ .unwrap()
+ .iter()
+ .find(|r| r.id == *id)
+ .cloned())
+ }
+
+ async fn list_for_user(
+ &self,
+ user_id: Uuid,
+ ) -> Result, DomainError> {
+ Ok(self
+ .store
+ .lock()
+ .unwrap()
+ .iter()
+ .filter(|r| r.user_id == Some(user_id))
+ .cloned()
+ .collect())
+ }
+
+ async fn list_global(&self) -> Result, DomainError> {
+ Ok(self
+ .store
+ .lock()
+ .unwrap()
+ .iter()
+ .filter(|r| r.user_id.is_none())
+ .cloned()
+ .collect())
+ }
+
+ async fn find_existing(
+ &self,
+ user_id: Option,
+ start: chrono::NaiveDate,
+ end: chrono::NaiveDate,
+ ) -> Result, DomainError> {
+ Ok(self
+ .store
+ .lock()
+ .unwrap()
+ .iter()
+ .find(|r| r.user_id == user_id && r.start_date == start && r.end_date == end)
+ .cloned())
+ }
+
+ async fn delete(&self, id: &WrapUpId) -> Result<(), DomainError> {
+ self.store.lock().unwrap().retain(|r| r.id != *id);
+ Ok(())
+ }
+
+ async fn delete_failed_older_than(
+ &self,
+ before: chrono::NaiveDateTime,
+ ) -> Result {
+ let mut store = self.store.lock().unwrap();
+ let before_len = store.len();
+ store.retain(|r| {
+ !(r.status == crate::models::wrapup::WrapUpStatus::Failed && r.created_at < before)
+ });
+ Ok((before_len - store.len()) as u64)
+ }
+}
+
+// ── PanicWrapUpRepository ──────────────────────────────────────────────────
+
+pub struct PanicWrapUpRepository;
+
+#[async_trait]
+impl WrapUpRepository for PanicWrapUpRepository {
+ async fn create(&self, _: &crate::models::wrapup::WrapUpRecord) -> Result<(), DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn update_status(
+ &self,
+ _: &WrapUpId,
+ _: &crate::models::wrapup::WrapUpStatus,
+ _: Option<&str>,
+ ) -> Result<(), DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn set_complete(
+ &self,
+ _: &WrapUpId,
+ _: &crate::models::wrapup::WrapUpReport,
+ ) -> Result<(), DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn get_by_id(
+ &self,
+ _: &WrapUpId,
+ ) -> Result, DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn list_for_user(
+ &self,
+ _: Uuid,
+ ) -> Result, DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn list_global(&self) -> Result, DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn find_existing(
+ &self,
+ _: Option,
+ _: chrono::NaiveDate,
+ _: chrono::NaiveDate,
+ ) -> Result, DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn delete(&self, _: &WrapUpId) -> Result<(), DomainError> {
+ panic!("PanicWrapUpRepository called")
+ }
+ async fn delete_failed_older_than(&self, _: chrono::NaiveDateTime) -> Result {
+ panic!("PanicWrapUpRepository called")
+ }
+}
diff --git a/crates/presentation/src/handlers/api.rs b/crates/presentation/src/handlers/api.rs
deleted file mode 100644
index 0089e30..0000000
--- a/crates/presentation/src/handlers/api.rs
+++ /dev/null
@@ -1,1706 +0,0 @@
-use axum::{
- Json,
- extract::{Multipart, Path, Query, State},
- http::StatusCode,
- response::IntoResponse,
-};
-use uuid::Uuid;
-
-use std::str::FromStr;
-
-use application::{
- auth::{
- commands::RegisterCommand, login as login_uc, queries::LoginQuery, register as register_uc,
- },
- diary::{
- commands::{DeleteReviewCommand, MovieInput, SyncPosterCommand},
- delete_review, export_diary as export_diary_uc, get_activity_feed as get_feed_uc,
- get_diary, get_movie_social_page, get_review_history, log_review,
- queries::{
- ExportQuery, GetActivityFeedQuery, GetMovieSocialPageQuery, GetReviewHistoryQuery,
- },
- },
- movies::{get_movies, queries::GetMoviesQuery, sync_poster},
- person::{get as get_person, get_credits as get_person_credits},
- search::execute as search_uc,
- users::{
- get_profile as get_user_profile_uc, get_users,
- queries::{GetUserProfileQuery, GetUsersQuery},
- update_profile, update_profile_fields,
- },
- watchlist::{
- add as add_to_watchlist,
- commands::{AddToWatchlistCommand, RemoveFromWatchlistCommand},
- get as get_watchlist, is_on as is_on_watchlist,
- queries::{GetWatchlistQuery, IsOnWatchlistQuery},
- remove as remove_from_watchlist,
- },
-};
-use domain::{
- models::{ExportFormat, PersonId, collections::PageParams},
- services::review_history::Trend,
- value_objects::UserId,
-};
-
-use crate::{
- errors::ApiError,
- extractors::AuthenticatedUser,
- forms::{LogReviewData, to_diary_query},
- state::AppState,
-};
-use api_types::search::{
- CastCreditDto, CrewCreditDto, MovieSearchHitDto, PaginatedMovieHits, PaginatedPersonHits,
- PersonCreditsDto, PersonDto, PersonSearchHitDto, SearchQueryParams, SearchResponse,
-};
-use api_types::{
- ActivityFeedQueryParams, ActivityFeedResponse, AddToWatchlistRequest, CastMemberDto,
- CreateGoalRequest, CrewMemberDto, DiaryQueryParams, DiaryResponse, DirectorStatDto,
- ExportQueryParams, GenreDto, GoalDto, GoalsResponse, KeywordDto, LogReviewRequest,
- LoginRequest, LoginResponse, MonthActivityDto, MonthlyRatingDto, MovieDetailResponse,
- MovieProfileResponse, MovieStatsDto, MoviesQueryParams, MoviesResponse, PaginationQueryParams,
- ProfileResponse, RegisterRequest, ReviewHistoryResponse, SocialFeedResponse, SocialReviewDto,
- UpdateGoalRequest, UpdateUserSettingsRequest, UserProfileQueryParams, UserProfileResponse,
- UserSettingsDto, UserStatsDto, UserSummaryDto, UserTrendsDto, UsersResponse, WatchlistEntryDto,
- WatchlistResponse, WatchlistStatusResponse,
-};
-#[cfg(feature = "federation")]
-use api_types::{
- ActorListResponse, ActorUrlRequest, AddBlockedDomainRequest, BlockedActorResponse,
- BlockedDomainResponse, FollowRequest, RemoteActorDto,
-};
-
-#[utoipa::path(
- get, path = "/api/v1/diary",
- params(DiaryQueryParams),
- responses(
- (status = 200, body = DiaryResponse),
- (status = 401, description = "Unauthorized"),
- ),
- security(("bearer_auth" = []))
-)]
-pub async fn get_diary(
- State(state): State,
- Query(params): Query,
-) -> Result, ApiError> {
- let page = get_diary::execute(&state.app_ctx, to_diary_query(params)).await?;
-
- Ok(Json(DiaryResponse {
- items: page.items.iter().map(entry_to_dto).collect(),
- total_count: page.total_count,
- limit: page.limit,
- offset: page.offset,
- }))
-}
-
-#[utoipa::path(
- get, path = "/api/v1/movies",
- params(MoviesQueryParams),
- responses(
- (status = 200, body = MoviesResponse),
- )
-)]
-pub async fn list_movies(
- State(state): State,
- Query(params): Query,
-) -> Result, ApiError> {
- let page = get_movies::execute(
- &state.app_ctx,
- GetMoviesQuery {
- limit: params.limit,
- offset: params.offset,
- search: params.search,
- genre: params.genre,
- language: params.language,
- },
- )
- .await?;
-
- Ok(Json(MoviesResponse {
- items: page.items.iter().map(summary_to_dto).collect(),
- total_count: page.total_count,
- limit: page.limit,
- offset: page.offset,
- }))
-}
-
-#[utoipa::path(
- get, path = "/api/v1/movies/{id}/history",
- params(("id" = Uuid, Path, description = "Movie ID")),
- responses(
- (status = 200, body = ReviewHistoryResponse),
- (status = 404, description = "Movie not found"),
- )
-)]
-pub async fn get_review_history(
- State(state): State,
- Path(movie_id): Path