From f9aa02ec1a4c24e80a206857d4f68198bb027bb4 Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Mon, 11 Nov 2024 01:12:29 +0800
Subject: HALF WORK: 2024.12.19

Re-organize file structure.
---
 .../Crud/CrudWebApplicationExtensions.cs           | 101 +++++++++++++++++++++
 1 file changed, 101 insertions(+)
 create mode 100644 dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs

(limited to 'dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs')

diff --git a/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
new file mode 100644
index 0000000..8942979
--- /dev/null
+++ b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
@@ -0,0 +1,101 @@
+namespace CrupestApi.Commons.Crud;
+
+public static class CrudWebApplicationExtensions
+{
+    public static WebApplication UseCrudCore(this WebApplication app)
+    {
+        app.Use(async (context, next) =>
+        {
+            try
+            {
+                await next();
+            }
+            catch (EntityNotExistException)
+            {
+                await context.ResponseMessageAsync("Requested entity does not exist.", StatusCodes.Status404NotFound);
+            }
+            catch (UserException e)
+            {
+                await context.ResponseMessageAsync(e.Message);
+            }
+        });
+
+        return app;
+    }
+
+    public static WebApplication MapCrud<TEntity>(this WebApplication app, string path, string? permission) where TEntity : class
+    {
+        app.MapGet(path, async (context) =>
+        {
+            if (!context.RequirePermission(permission)) return;
+            var crudService = context.RequestServices.GetRequiredService<CrudService<TEntity>>();
+            var entityJsonHelper = context.RequestServices.GetRequiredService<EntityJsonHelper<TEntity>>();
+            var allEntities = crudService.GetAll();
+            await context.ResponseJsonAsync(allEntities.Select(e => entityJsonHelper.ConvertEntityToDictionary(e)));
+        });
+
+        app.MapGet(path + "/{key}", async (context) =>
+        {
+            if (!context.RequirePermission(permission)) return;
+            var crudService = context.RequestServices.GetRequiredService<CrudService<TEntity>>();
+            var entityJsonHelper = context.RequestServices.GetRequiredService<EntityJsonHelper<TEntity>>();
+            var key = context.Request.RouteValues["key"]?.ToString();
+            if (key == null)
+            {
+                await context.ResponseMessageAsync("Please specify a key in path.");
+                return;
+            }
+
+            var entity = crudService.GetByKey(key);
+            await context.ResponseJsonAsync(entityJsonHelper.ConvertEntityToDictionary(entity));
+        });
+
+        app.MapPost(path, async (context) =>
+        {
+            if (!context.RequirePermission(permission)) return;
+            var crudService = context.RequestServices.GetRequiredService<CrudService<TEntity>>();
+            var entityJsonHelper = context.RequestServices.GetRequiredService<EntityJsonHelper<TEntity>>();
+            var jsonDocument = await context.Request.ReadJsonAsync();
+            var key = crudService.Create(entityJsonHelper.ConvertJsonToEntityForInsert(jsonDocument.RootElement));
+            await context.ResponseJsonAsync(entityJsonHelper.ConvertEntityToDictionary(crudService.GetByKey(key)));
+        });
+
+        app.MapPatch(path + "/{key}", async (context) =>
+        {
+            if (!context.RequirePermission(permission)) return;
+            var key = context.Request.RouteValues["key"]?.ToString();
+            var crudService = context.RequestServices.GetRequiredService<CrudService<TEntity>>();
+            var entityJsonHelper = context.RequestServices.GetRequiredService<EntityJsonHelper<TEntity>>();
+            if (key == null)
+            {
+                await context.ResponseMessageAsync("Please specify a key in path.");
+                return;
+            }
+
+            var jsonDocument = await context.Request.ReadJsonAsync();
+            var entity = entityJsonHelper.ConvertJsonToEntityForUpdate(jsonDocument.RootElement, out var updateBehavior);
+            var newKey = crudService.UpdateByKey(key, entity, updateBehavior);
+            await context.ResponseJsonAsync(entityJsonHelper.ConvertEntityToDictionary(crudService.GetByKey(newKey)));
+        });
+
+        app.MapDelete(path + "/{key}", async (context) =>
+        {
+            if (!context.RequirePermission(permission)) return;
+            var crudService = context.RequestServices.GetRequiredService<CrudService<TEntity>>();
+            var key = context.Request.RouteValues["key"]?.ToString();
+            if (key == null)
+            {
+                await context.ResponseMessageAsync("Please specify a key in path.");
+                return;
+            }
+
+            var deleted = crudService.DeleteByKey(key);
+            if (deleted)
+                await context.ResponseMessageAsync("Deleted.", StatusCodes.Status200OK);
+            else
+                await context.ResponseMessageAsync("Not exist.", StatusCodes.Status200OK);
+        });
+
+        return app;
+    }
+}
-- 
cgit v1.2.3