BROKERS: Insert Book

LibraryManagement.Api/Brokers/Storages/StorageBroker.ReaderBook.cs → LibraryManagement.Api/Brokers/Storages/IStorageBroker.Book.cs

@@ -3,13 +3,12 @@
 // Free To Use To Build Reliable Library Management Solutions
 //-----------------------------------------------------------
 
-using LibraryManagement.Api.Models.Foundations.ReaderBooks;
-using Microsoft.EntityFrameworkCore;
+using LibraryManagement.Api.Models.Foundations.Books;
 
 namespace LibraryManagement.Api.Brokers.Storages
 {
-    public partial class StorageBroker
+    public partial interface IStorageBroker
     {
-        public DbSet<ReaderBook> ReaderBooks { get; set; }
+        ValueTask<Book> InsertBookAsync(Book book);
     }
 }

LibraryManagement.Api/Brokers/Storages/IStorageBroker.cs

@@ -0,0 +1,10 @@
+//-----------------------------------------------------------
+// Copyright (c) Coalition of Good-Hearted Engineers
+// Free To Use To Build Reliable Library Management Solutions
+//-----------------------------------------------------------
+
+namespace LibraryManagement.Api.Brokers.Storages
+{
+    public partial interface IStorageBroker
+    { }
+}

LibraryManagement.Api/Brokers/Storages/StorageBroker.Book.cs

@@ -11,5 +11,8 @@ namespace LibraryManagement.Api.Brokers.Storages
     public partial class StorageBroker
     {
         public DbSet<Book> Books { get; set; }
+
+        public async ValueTask<Book> InsertBookAsync(Book book) =>
+            await InsertAsync(book);
     }
 }

LibraryManagement.Api/Brokers/Storages/StorageBroker.cs

@@ -9,7 +9,7 @@
 
 namespace LibraryManagement.Api.Brokers.Storages
 {
-    public partial class StorageBroker : EFxceptionsContext
+    public partial class StorageBroker : EFxceptionsContext, IStorageBroker
     {
         private readonly IConfiguration configuration;
 
@@ -19,6 +19,15 @@
             this.Database.Migrate();
         }
 
+        public async ValueTask<T> InsertAsync<T>(T @object)
+        {
+            var broker = new StorageBroker(this.configuration);
+            broker.Entry(@object).State = EntityState.Added;
+            await broker.SaveChangesAsync();
+
+            return @object;
+        }
+
         protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
         {
             string connectionString =