Format code

Author: sushant-at-nitor

packages/api/src/endpoints/books/create.rs

@@ -3,8 +3,7 @@ use std::sync::Arc;
 use warp::Filter;
 
 use application::books::{
-  BookService,
-  command_handlers::{CreateBookCommandHandler, CreateBookCommandHandlerTrait},
+  BookService, CreateBookCommandHandler, CreateBookCommandHandlerTrait,
 };
 use domain::commands::CreateBookCommand;
 

packages/api/src/endpoints/books/delete.rs

@@ -3,8 +3,7 @@ use std::sync::Arc;
 use warp::Filter;
 
 use application::books::{
-  BookService,
-  command_handlers::{DeleteBookCommandHandler, DeleteBookCommandHandlerTrait},
+  BookService, DeleteBookCommandHandler, DeleteBookCommandHandlerTrait,
 };
 use domain::commands::DeleteBookCommand;
 

packages/api/src/endpoints/books/get_by_id.rs

@@ -3,10 +3,7 @@ use std::sync::Arc;
 use warp::Filter;
 
 use application::books::{
-  query_handlers::get_by_id_handler::{
-    GetBookByIdQueryHandler, GetBookByIdQueryHandlerTrait,
-  },
-  service::BookService,
+  BookService, GetBookByIdQueryHandler, GetBookByIdQueryHandlerTrait,
 };
 use domain::queries::GetBookByIdQuery;
 

packages/api/src/endpoints/books/update.rs

@@ -3,7 +3,7 @@ use std::sync::Arc;
 use warp::Filter;
 
 use application::books::{
-  BookService, UpdateBookCommandHandlerTrait, command_handlers::UpdateBookCommandHandler
+  BookService, UpdateBookCommandHandler, UpdateBookCommandHandlerTrait,
 };
 use domain::commands::UpdateBookCommand;
 

packages/application/src/books/query_handlers/mod.rs

@@ -1,5 +1,7 @@
 pub mod get_all_handler;
 pub mod get_by_id_handler;
+pub mod list_handler;
 
 pub use get_all_handler::*;
-pub use get_by_id_handler::*;
+pub use get_by_id_handler::*;
+pub use list_handler::*;

packages/application/src/books/service.rs

@@ -6,7 +6,8 @@ use sea_orm::DbErr;
 #[async_trait]
 pub trait BookService: Send + Sync {
   async fn get_all(&self) -> Result<Vec<Book>, DbErr>;
-  async fn list(&self, page: u64, page_size: u64) -> Result<Paged<Book>, DbErr>;
+  async fn list(&self, page: u64, page_size: u64)
+  -> Result<Paged<Book>, DbErr>;
   async fn get_by_id(&self, id: i32) -> Result<Option<Book>, DbErr>;
   async fn get_available(&self) -> Result<Vec<Book>, DbErr>;
   async fn search(&self, query: BookQuery) -> Result<Vec<Book>, DbErr>;

packages/common/src/lib.rs

@@ -1,7 +1,7 @@
 pub mod app_error;
-pub mod server_error;
 pub mod paged;
+pub mod server_error;
 
 pub use app_error::*;
+pub use paged::*;
 pub use server_error::*;
-pub use paged::*;

packages/database/src/lib.rs

@@ -1,4 +1,4 @@
 pub mod database;
 pub mod migrations;
 
-pub use database::Database;
+pub use database::Database;

packages/database/src/migrations/book.rs

@@ -5,45 +5,45 @@ pub struct Migration;
 
 #[async_trait::async_trait]
 impl MigrationTrait for Migration {
-    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
-        manager
-            .create_table(
-                Table::create()
-                    .table("books")
-                    .if_not_exists()
-                    .col(
-                        ColumnDef::new(Book::Id)
-                            .integer()
-                            .not_null()
-                            .primary_key()
-                            .auto_increment(),
-                    )
-                    .col(ColumnDef::new(Book::Title).string().not_null())
-                    .col(ColumnDef::new(Book::Author).string().not_null())
-                    .col(ColumnDef::new(Book::Isbn).string().unique_key())
-                    .col(ColumnDef::new(Book::TotalCopies).integer().not_null())
-                    .col(ColumnDef::new(Book::AvailableCopies).integer().not_null())
-                    .col(ColumnDef::new(Book::PublishedYear).integer().null())
-                    .to_owned(),
-            )
-            .await
-    }
+  async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+    manager
+      .create_table(
+        Table::create()
+          .table("books")
+          .if_not_exists()
+          .col(
+            ColumnDef::new(Book::Id)
+              .integer()
+              .not_null()
+              .primary_key()
+              .auto_increment(),
+          )
+          .col(ColumnDef::new(Book::Title).string().not_null())
+          .col(ColumnDef::new(Book::Author).string().not_null())
+          .col(ColumnDef::new(Book::Isbn).string().unique_key())
+          .col(ColumnDef::new(Book::TotalCopies).integer().not_null())
+          .col(ColumnDef::new(Book::AvailableCopies).integer().not_null())
+          .col(ColumnDef::new(Book::PublishedYear).integer().null())
+          .to_owned(),
+      )
+      .await
+  }
 
-    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
-        manager
-            .drop_table(Table::drop().table(Book::Table).to_owned())
-            .await
-    }
+  async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+    manager
+      .drop_table(Table::drop().table(Book::Table).to_owned())
+      .await
+  }
 }
 
 #[derive(Iden)]
 enum Book {
-    Table,
-    Id,
-    Title,
-    Author,
-    Isbn,
-    TotalCopies,
-    AvailableCopies,
-    PublishedYear,
+  Table,
+  Id,
+  Title,
+  Author,
+  Isbn,
+  TotalCopies,
+  AvailableCopies,
+  PublishedYear,
 }

packages/domain/src/queries/book.rs

@@ -8,6 +8,12 @@ pub struct GetBookByIdQuery {
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct GetAllBooksQuery;
 
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct ListBooks {
+  pub page: u64,
+  pub page_size: u64,
+}
+
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct GetAvailableBooksQuery;