Put in CRUD functionality

Readme.md

@@ -2,7 +2,9 @@
 
 # Mailboxes microservice
 
-Provides an API to manage Postfix virtual mailboxes and aliases
+Provides an API to manage Postfix virtual mailboxes and aliases.
+
+Quickly knocked together to get the job done.
 
 ## Setup
 

src/Robware.Api.Mailboxes/Controllers/AliasController.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.Mvc;
+using Robware.Api.Mailboxes.Models;
 using Robware.Mailboxes;
 using System.Linq;
 using System.Threading.Tasks;
@@ -6,7 +7,7 @@ using System.Threading.Tasks;
 namespace Robware.Api.Mailboxes.Controllers {
 	[ApiController]
 	[Route("[controller]")]
-	public class AliasController {
+	public class AliasController : ControllerBase {
 		private readonly IAliases _aliases;
 
 		public AliasController(IAliases aliases) {
@@ -15,5 +16,17 @@ namespace Robware.Api.Mailboxes.Controllers {
 
 		[HttpGet(nameof(List))]
 		public async Task<ActionResult<Alias[]>> List() => (await _aliases.GetAll()).ToArray();
+
+		[HttpPatch(nameof(Enable))]
+		public async Task<ActionResult> Enable(int id) => (await _aliases.Enable(id)) ? NoContent() : BadRequest();
+
+		[HttpPatch(nameof(Disable))]
+		public async Task<ActionResult> Disable(int id) => (await _aliases.Disable(id)) ? NoContent() : BadRequest();
+
+		[HttpPost(nameof(Create))]
+		public async Task<ActionResult> Create(NewAlias alias) => (await _aliases.Create(alias.Source, alias.Destination, alias.Active) > 0) ? NoContent() : BadRequest();
+
+		[HttpDelete(nameof(Delete))]
+		public async Task<ActionResult> Delete(int id) => (await _aliases.Delete(id)) ? NoContent() : BadRequest();
 	}
 }

src/Robware.Api.Mailboxes/Models/NewAlias.cs

@@ -0,0 +1,7 @@
+namespace Robware.Api.Mailboxes.Models {
+	public class NewAlias {
+		public string Source { get; set; }
+		public string Destination { get; set; }
+		public bool Active { get; set; }
+	}
+}

src/Robware.Mailboxes.Data/AliasRepository.cs

@@ -1,5 +1,6 @@
 using Dapper;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace Robware.Mailboxes.Data {
@@ -15,5 +16,39 @@ namespace Robware.Mailboxes.Data {
 			var result = await connection.QueryAsync<Alias>(query);
 			return result;
 		}
+
+		private async Task<bool> SetActive(int id, int active)
+		{
+			const string query = "UPDATE virtual_aliases SET active = @active WHERE id = @id;";
+			try {
+				using var connection = _dbProvider.NewConnection();
+				connection.Open();
+				await connection.ExecuteAsync(query, new {active, id});
+			}
+			catch {
+				return false;
+			}
+			return true;
+		}
+
+		public async Task<bool> Enable(int id) => await SetActive(id, 1);
+
+		public async Task<bool> Disable(int id) => await SetActive(id, 0);
+		
+		public async Task<int> Create(string source, string destination, bool active) {
+			const string query = "INSERT INTO virtual_aliases (domain_id, source, destination, active) VALUES (1, @source, @destination, @active); SELECT CAST(LAST_INSERT_ID() as int)";
+			using var connection = _dbProvider.NewConnection();
+			connection.Open();
+			var result = await connection.QueryAsync<int>(query, new {source, destination, active = active ? 1 : 0});
+			return result.Single();
+		}
+
+		public async Task<bool> Delete(int id) {
+			const string query = "DELETE FROM virtual_aliases WHERE id = @id;";
+			using var connection = _dbProvider.NewConnection();
+			connection.Open();
+			await connection.ExecuteAsync(query, new {id});
+			return true;
+		}
 	}
 }

src/Robware.Mailboxes/IAliases.cs

@@ -5,5 +5,9 @@ namespace Robware.Mailboxes
 {
 	public interface IAliases {
 		Task<IEnumerable<Alias>> GetAll();
+		Task<bool> Enable(int id);
+		Task<bool> Disable(int id);
+		Task<int> Create(string source, string destination, bool active);
+		Task<bool> Delete(int id);
 	}
 }