Repository pattern implemented

H_PLUS_Sports/Controllers/SalespersonsController.cs

@@ -1,32 +1,32 @@
-using System.Linq;
-using System.Threading.Tasks;
+using System.Threading.Tasks;
+using H_Plus_Sports.Contracts;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.EntityFrameworkCore;
 using H_Plus_Sports.Models;
 
-namespace HPlusSportsAPI.Controllers
+namespace H_Plus_Sports.Controllers
 {
     [Produces("application/json")]
     [Route("api/Salespersons")]
     public class SalespersonsController : Controller
     {
-        private readonly H_Plus_SportsContext _context;
+        private readonly ISalespersonRepository _salespeople;
 
-        public SalespersonsController(H_Plus_SportsContext context)
+        public SalespersonsController(ISalespersonRepository salespeople)
         {
-            _context = context;
+            _salespeople = salespeople;
         }
 
-        private bool SalespersonExists(int id)
+        private async Task<bool> SalespersonExists(int id)
         {
-            return _context.Salesperson.Any(e => e.SalespersonId == id);
+            return await _salespeople.Exists(id);
         }
 
         [HttpGet]
         [Produces(typeof(DbSet<Salesperson>))]
         public IActionResult GetSalesperson()
         {
-            return new ObjectResult(_context.Salesperson);
+            return new ObjectResult(_salespeople.GetAll());
         }
 
         [HttpGet("{id}")]
@@ -38,7 +38,7 @@ namespace HPlusSportsAPI.Controllers
                 return BadRequest(ModelState);
             }
 
-            var salesperson = await _context.Salesperson.SingleOrDefaultAsync(m => m.SalespersonId == id);
+            var salesperson = await _salespeople.Find(id);
 
             if (salesperson == null)
             {
@@ -62,22 +62,20 @@ namespace HPlusSportsAPI.Controllers
                 return BadRequest();
             }
 
-            _context.Entry(salesperson).State = EntityState.Modified;
-
             try
             {
-                await _context.SaveChangesAsync();
+                await _salespeople.Update(salesperson);
                 return Ok(salesperson);
             }
             catch (DbUpdateConcurrencyException)
             {
-                if (!SalespersonExists(id))
+                if (!await SalespersonExists(id))
                 {
                     return NotFound();
                 }
                 else
                 {
-                    throw;
+                    return BadRequest();
                 }
             }
         }
@@ -91,8 +89,21 @@ namespace HPlusSportsAPI.Controllers
                 return BadRequest(ModelState);
             }
 
-            _context.Salesperson.Add(salesperson);
-            await _context.SaveChangesAsync();
+            try
+            {
+                await _salespeople.Add(salesperson);
+            }
+            catch (DbUpdateException)
+            {
+                if (!await SalespersonExists(salesperson.SalespersonId))
+                {
+                    return NotFound();
+                }
+                else
+                {
+                    return BadRequest();
+                }
+            }
 
             return CreatedAtAction("GetSalesperson", new { id = salesperson.SalespersonId }, salesperson);
         }
@@ -106,16 +117,14 @@ namespace HPlusSportsAPI.Controllers
                 return BadRequest(ModelState);
             }
 
-            var salesperson = await _context.Salesperson.SingleOrDefaultAsync(m => m.SalespersonId == id);
-            if (salesperson == null)
+            if (!await SalespersonExists(id))
             {
                 return NotFound();
             }
 
-            _context.Salesperson.Remove(salesperson);
-            await _context.SaveChangesAsync();
+            await _salespeople.Remove(id);
 
-            return Ok(salesperson);
+            return Ok();
         }
     }
 }