diff --git a/src/domain/repositories.rs b/src/domain/repositories.rs index 1f9ad5d..ab01a96 100644 --- a/src/domain/repositories.rs +++ b/src/domain/repositories.rs @@ -23,6 +23,7 @@ pub trait RoasterRepository: Send + Sync { async fn list( &self, request: &ListRequest, + search: Option<&str>, ) -> Result, RepositoryError>; async fn update( &self, @@ -35,7 +36,7 @@ pub trait RoasterRepository: Send + Sync { let sort_key = ::default(); let request = ListRequest::::show_all(sort_key, sort_key.default_direction()); - let page = self.list(&request).await?; + let page = self.list(&request, None).await?; Ok(page.items) } @@ -45,7 +46,7 @@ pub trait RoasterRepository: Send + Sync { direction: SortDirection, ) -> Result, RepositoryError> { let request = ListRequest::show_all(sort_key, direction); - let page = self.list(&request).await?; + let page = self.list(&request, None).await?; Ok(page.items) } } @@ -63,6 +64,7 @@ pub trait RoastRepository: Send + Sync { async fn list( &self, request: &ListRequest, + search: Option<&str>, ) -> Result, RepositoryError>; async fn list_by_roaster( &self, @@ -74,7 +76,7 @@ pub trait RoastRepository: Send + Sync { async fn list_all(&self) -> Result, RepositoryError> { let sort_key = ::default(); let request = ListRequest::::show_all(sort_key, sort_key.default_direction()); - let page = self.list(&request).await?; + let page = self.list(&request, None).await?; Ok(page.items) } } @@ -132,6 +134,7 @@ pub trait BagRepository: Send + Sync { &self, filter: BagFilter, request: &ListRequest, + search: Option<&str>, ) -> Result, RepositoryError>; async fn update(&self, id: BagId, changes: UpdateBag) -> Result; async fn delete(&self, id: BagId) -> Result<(), RepositoryError>; @@ -145,6 +148,7 @@ pub trait GearRepository: Send + Sync { &self, filter: GearFilter, request: &ListRequest, + search: Option<&str>, ) -> Result, RepositoryError>; async fn update(&self, id: GearId, changes: UpdateGear) -> Result; async fn delete(&self, id: GearId) -> Result<(), RepositoryError>; @@ -161,6 +165,7 @@ pub trait BrewRepository: Send + Sync { &self, filter: BrewFilter, request: &ListRequest, + search: Option<&str>, ) -> Result, RepositoryError>; async fn delete(&self, id: BrewId) -> Result<(), RepositoryError>; }