add crud model

Author: thangchung

restclient.http

@@ -1,22 +1,37 @@
-###
 @host = http://localhost:5002
-GET {{host}}/api/products HTTP/1.1
+
+###
+POST {{host}}/api/products-query HTTP/1.1
 content-type: {{contentType}}
 
 {
+  "includes": ["Returns", "Code"],
   "filters": [
-    {
-      "fieldName": "Quantity",
-      "comparision": ">",
-      "fieldValue": "1000"
-    },
     {
       "fieldName": "Name",
       "comparision": "Contains",
-      "fieldValue": "adipiscing"
+      "fieldValue": "test product"
     }
   ],
   "sorts": ["nameDesc"],
   "page": 1,
   "pageSize": 20
 }
+
+###
+@id = 23537dac-303f-446f-be2a-1dbea22b3eba
+GET {{host}}/api/products/{{id}} HTTP/1.1
+content-type: {{contentType}}
+
+###
+POST {{host}}/api/products HTTP/1.1
+content-type: {{contentType}}
+
+{
+  "model": {
+    "name": "test product 1",
+    "quantity": 1,
+    "cost": 1000,
+    "productCodeName": "pcode"
+  }
+}

src/BuildingBlocks/N8T.Core/Domain/ICommand.cs

@@ -0,0 +1,8 @@
+using MediatR;
+
+namespace N8T.Core.Domain
+{
+    public interface ICommand<out T> : IRequest<T>
+    {
+    }
+}

src/BuildingBlocks/N8T.Core/Domain/ICrudModel.cs

@@ -0,0 +1,43 @@
+#nullable enable
+using System.Collections.Generic;
+
+namespace N8T.Core.Domain
+{
+    public interface ICrudModel
+    {
+    }
+
+    public interface ICreateModel<T> : ICrudModel
+    {
+        public T Model { get; init; }
+    }
+
+    public interface IUpdateModel<T> : ICrudModel
+    {
+        public T Model { get; init; }
+    }
+
+    public interface IDeleteModel<TId> : ICrudModel where TId : struct
+    {
+        public TId Id { get; init; }
+    }
+
+    public interface IListQueryModel : ICrudModel
+    {
+        public List<string> Includes { get; init; }
+        public List<FilterModel> Filters { get; init; }
+        public List<string> Sorts { get; init; }
+        public int Page { get; init; }
+        public int PageSize { get; init; }
+    }
+
+    public interface IItemQueryModel<TId> : ICrudModel where TId : struct
+    {
+        public List<string> Includes { get; init; }
+        public TId Id { get; init; }
+    }
+
+    public record FilterModel(string FieldName, string Comparision, string FieldValue);
+
+    public record ResultModel<T>(T Data, bool IsError = false, string? ErrorMessage = default);
+}

src/BuildingBlocks/N8T.Core/Domain/IQuery.cs

@@ -0,0 +1,8 @@
+using MediatR;
+
+namespace N8T.Core.Domain
+{
+    public interface IQuery<out T> : IRequest<T>
+    {
+    }
+}

src/BuildingBlocks/N8T.Infrastructure.App/Dtos/ProductDto.cs

@@ -2,7 +2,7 @@
 
 namespace N8T.Infrastructure.App.Dtos
 {
-    public class ProductDto
+    public record ProductDto
     {
         public Guid Id { get; init; }
         public string Name { get; init; } = default!;

src/BuildingBlocks/N8T.Infrastructure.EfCore/ITxRequest.cs

@@ -32,7 +32,9 @@ public async Task<TEntity> FindOneAsync(ISpecification<TEntity> spec)
         {
             await using var dbContext = _dbContextFactory.CreateDbContext();
 
-            return await dbContext.Set<TEntity>().Where(spec.Criteria).SingleOrDefaultAsync();
+            var specificationResult = GetQuery(dbContext.Set<TEntity>(), spec);
+
+            return await specificationResult.FirstOrDefaultAsync();
         }
 
         public async Task<List<TEntity>> FindAsync(ISpecification<TEntity> spec)
@@ -112,7 +114,7 @@ private static IQueryable<TEntity> GetQuery(IQueryable<TEntity> inputQuery,
 
             if (specification.IsPagingEnabled)
             {
-                query = query.Skip(specification.Skip)
+                query = query.Skip(specification.Skip - 1)
                     .Take(specification.Take);
             }
 
@@ -155,7 +157,7 @@ private static IQueryable<TEntity> GetQuery(IQueryable<TEntity> inputQuery,
 
             if (specification.IsPagingEnabled)
             {
-                query = query.Skip(specification.Skip)
+                query = query.Skip(specification.Skip - 1)
                     .Take(specification.Take);
             }
 

src/BuildingBlocks/N8T.Infrastructure.EfCore/Repository.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Data;
+using System.Diagnostics;
 using System.Linq;
 using System.Text.Json;
 using System.Threading;
@@ -11,6 +12,9 @@
 
 namespace N8T.Infrastructure.EfCore
 {
+    public interface ITxRequest { }
+
+    //[DebuggerStepThrough]
     public class TxBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
         where TRequest : notnull, IRequest<TResponse>
         where TResponse : notnull

src/BuildingBlocks/N8T.Infrastructure.EfCore/TxBehavior.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Diagnostics;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
@@ -8,6 +9,7 @@
 
 namespace N8T.Infrastructure.Validator
 {
+    [DebuggerStepThrough]
     public class RequestValidationBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
         where TRequest : notnull, IRequest<TResponse>
         where TResponse : notnull 

src/BuildingBlocks/N8T.Infrastructure/Validator/RequestValidationBehavior.cs

@@ -0,0 +1,18 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using N8T.Infrastructure.Endpoint;
+using ProductService.Application.Commands;
+
+namespace ProductService.Api.Endpoints
+{
+    public class CreateProduct : BaseAsyncEndpoint
+    {
+        [HttpPost("/api/products")]
+        public async Task<ActionResult> HandleAsync([FromBody] CreateProductRequest model,
+            CancellationToken cancellationToken = new())
+        {
+            return Ok(await Mediator.Send(model, cancellationToken));
+        }
+    }
+}