aboutsummaryrefslogtreecommitdiff
path: root/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
diff options
context:
space:
mode:
authorcrupest <crupest@outlook.com>2024-11-11 01:12:29 +0800
committerYuqian Yang <crupest@crupest.life>2024-12-19 21:42:01 +0800
commita7fb0508867ee53934be18a6606aa8bc12c2645b (patch)
tree5994f0a62733b13f9f330e3515260ae20dc4a0bd /docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
parent7692763f83ad1be735b0b9e9ab0af8ce666d8de8 (diff)
downloadcrupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.tar.gz
crupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.tar.bz2
crupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.zip
HALF WORK: 2024.12.19
Re-organize file structure.
Diffstat (limited to 'docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs')
-rw-r--r--docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs101
1 files changed, 0 insertions, 101 deletions
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
deleted file mode 100644
index 8942979..0000000
--- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudWebApplicationExtensions.cs
+++ /dev/null
@@ -1,101 +0,0 @@
-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;
- }
-}