Cart-Order repos added

Author: mehmetozkaya

AspnetRunBasics/Repositories/CartRepository.cs

@@ -0,0 +1,85 @@
+using AspnetRunBasics.Data;
+using AspnetRunBasics.Entities;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.Repositories
+{
+    public class CartRepository : ICartRepository
+    {
+        protected readonly AspnetRunContext _dbContext;
+
+        public CartRepository(AspnetRunContext dbContext)
+        {
+            _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+        }
+
+        public async Task<Cart> GetCartByUserName(string userName)
+        {
+            var cart =  _dbContext.Carts
+                        .Include(c => c.Items)
+                        .FirstOrDefault(c => c.UserName == userName);
+
+            if (cart != null)
+                return cart;
+
+            // if it is first attempt create new
+            var newCart = new Cart
+            {
+                UserName = userName
+            };
+
+            _dbContext.Carts.Add(newCart);
+            await _dbContext.SaveChangesAsync();
+            return newCart;
+        }
+
+        public async Task AddItem(string userName, int productId)
+        {
+            var cart = await GetCartByUserName(userName);
+
+            cart.Items.Add(
+                    new CartItem
+                    {
+                        Id = productId,
+                        Color = "Black",
+                        Price = 10,
+                        Quantity = 1
+                    }
+                );
+
+            _dbContext.Entry(cart).State = EntityState.Modified;
+            await _dbContext.SaveChangesAsync();
+        }
+
+        public async Task RemoveItem(int cartId, int cartItemId)
+        {
+            var cart = _dbContext.Carts
+                       .Include(c => c.Items)
+                       .FirstOrDefault(c => c.Id == cartId);
+
+            if (cart != null)
+            {
+                var removedItem = cart.Items.FirstOrDefault(x => x.Id == cartItemId);
+                cart.Items.Remove(removedItem);
+
+                _dbContext.Entry(cart).State = EntityState.Modified;
+                await _dbContext.SaveChangesAsync();
+            }                
+
+        }
+
+        public async Task ClearCart(string userName)
+        {
+            var cart = await GetCartByUserName(userName);
+
+            cart.Items.Clear();
+
+            _dbContext.Entry(cart).State = EntityState.Modified;
+            await _dbContext.SaveChangesAsync();
+        }      
+    }
+}

AspnetRunBasics/Repositories/ContactRepository.cs

@@ -0,0 +1,38 @@
+using AspnetRunBasics.Data;
+using AspnetRunBasics.Entities;
+using System;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.Repositories
+{
+    public class ContactRepository : IContactRepository
+    {
+        protected readonly AspnetRunContext _dbContext;
+
+        public ContactRepository(AspnetRunContext dbContext)
+        {
+            _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+        }
+
+        public async Task<Contact> SendMessage(Contact contact)
+        {
+            _dbContext.Contacts.Add(contact);
+            await _dbContext.SaveChangesAsync();
+            return contact;
+        }
+
+        public async Task<Contact> Subscribe(string address)
+        {
+            // implement your business logic
+            var newContact = new Contact();
+            newContact.Email = address;
+            newContact.Message = address;
+            newContact.Name = address;
+
+            _dbContext.Contacts.Add(newContact);
+            await _dbContext.SaveChangesAsync();
+
+            return newContact;
+        }
+    }
+}

AspnetRunBasics/Repositories/ICategoryRepository.cs

@@ -5,6 +5,6 @@ namespace AspnetRunBasics.Repositories
 {
     public interface IOrderRepository
     {
-        Task<Order> CheckOut(Order orderModel);
+        Task<Order> CheckOut(Order order);
     }
 }

AspnetRunBasics/Repositories/ICartRepository.cs renamed to AspnetRunBasics/Repositories/Interfaces/ICartRepository.cs

@@ -0,0 +1,24 @@
+using AspnetRunBasics.Data;
+using AspnetRunBasics.Entities;
+using System;
+using System.Threading.Tasks;
+
+namespace AspnetRunBasics.Repositories
+{
+    public class OrderRepository : IOrderRepository
+    {
+        protected readonly AspnetRunContext _dbContext;
+
+        public OrderRepository(AspnetRunContext dbContext)
+        {
+            _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+        }
+
+        public async Task<Order> CheckOut(Order order)
+        {
+            _dbContext.Orders.Add(order);
+            await _dbContext.SaveChangesAsync();
+            return order;            
+        }
+    }
+}

AspnetRunBasics/Repositories/IContactRepository.cs renamed to AspnetRunBasics/Repositories/Interfaces/IContactRepository.cs

@@ -0,0 +1,72 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using AspnetRunBasics.Data;
+using AspnetRunBasics.Entities;
+using Microsoft.EntityFrameworkCore;
+
+namespace AspnetRunBasics.Repositories
+{
+    public class ProductRepository : IProductRepository
+    {
+        protected readonly AspnetRunContext _dbContext;
+
+        public ProductRepository(AspnetRunContext dbContext)
+        {
+            _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+        }
+
+        public async Task<IEnumerable<Product>> GetProductListAsync()
+        {
+            return await _dbContext.Products.ToListAsync();
+        }
+
+        public async Task<Product> GetProductByIdAsync(int id)
+        {
+            return await _dbContext.Products
+                .Include(p => p.Category)
+                .FirstOrDefaultAsync(p => p.Id == id);
+        }
+
+        public async Task<IEnumerable<Product>> GetProductByNameAsync(string name)
+        {
+            return await _dbContext.Products
+                    .Include(p => p.Category)
+                    .Where(p => string.IsNullOrEmpty(name) || p.Name.ToLower().Contains(name.ToLower()))
+                    .OrderBy(p => p.Name)
+                    .ToListAsync();
+        }
+
+        public async Task<IEnumerable<Product>> GetProductByCategoryAsync(int categoryId)
+        {
+            return await _dbContext.Products
+                .Where(x => x.CategoryId == categoryId)
+                .ToListAsync();
+        }
+
+        public async Task<Product> AddAsync(Product product)
+        {
+            _dbContext.Products.Add(product);
+            await _dbContext.SaveChangesAsync();
+            return product;
+        }
+
+        public async Task UpdateAsync(Product product)
+        {
+            _dbContext.Entry(product).State = EntityState.Modified;
+            await _dbContext.SaveChangesAsync();
+        }
+
+        public async Task DeleteAsync(Product product)
+        {
+            _dbContext.Products.Remove(product);
+            await _dbContext.SaveChangesAsync();
+        }
+
+        public async Task<IEnumerable<Category>> GetCategories()
+        {
+            return await _dbContext.Categories.ToListAsync();
+        }
+    }
+}