another shot #12

samples/Customer/CustomerService.Application/CustomerService.Application.csproj → samples/Customer/CustomerService.Api/CustomerService.Api.csproj

@@ -3,6 +3,7 @@
   <PropertyGroup>
     <TargetFramework>net6.0</TargetFramework>
     <LangVersion>preview</LangVersion>
+    <RootNamespace>CustomerService.Application</RootNamespace>
   </PropertyGroup>
 
   <ItemGroup>

samples/Customer/CustomerService.Application/Program.cs → samples/Customer/CustomerService.Api/Program.cs

@@ -11,7 +11,7 @@
 var builder = WebApplication.CreateBuilder(args);
 
 builder.Services.AddCore(builder.Configuration, typeof(Anchor))
-    .AddPostgresDbContext<MainDbContext, CustomerService.Infrastructure.Anchor>(
+    .AddPostgresDbContext<MainDbContext>(
         builder.Configuration.GetConnectionString("postgres"),
         svc => svc.AddRepository(typeof(Repository<>)))
     .AddRestClient(typeof(ICountryApi), AppConsts.SettingAppName,

samples/Customer/CustomerService.Application/V1/TransactionalOutboxProcesssor.cs → samples/Customer/CustomerService.Api/V1/TransactionalOutboxProcessor.cs

@@ -9,11 +9,11 @@ namespace CustomerService.Application.V1
 {
     [ApiVersionNeutral]
     [ApiExplorerSettings(IgnoreApi = true)]
-    public class TransactionalOutboxProcesssor : BaseController
+    public class TransactionalOutboxProcessor : BaseController
     {
         private readonly ITransactionalOutboxProcessor _outboxProcessor;
 
-        public TransactionalOutboxProcesssor(ITransactionalOutboxProcessor outboxProcessor)
+        public TransactionalOutboxProcessor(ITransactionalOutboxProcessor outboxProcessor)
         {
             _outboxProcessor = outboxProcessor ?? throw new ArgumentNullException(nameof(outboxProcessor));
         }

samples/Customer/CustomerService.AppCore/Anchor.cs

@@ -0,0 +1,4 @@
+namespace CustomerService.Application.V1
+{
+    public struct Anchor { }
+}

samples/Customer/CustomerService.Core/CustomerService.Core.csproj → samples/Customer/CustomerService.AppCore/CustomerService.AppCore.csproj

@@ -4,6 +4,7 @@
     <TargetFramework>net6.0</TargetFramework>
     <LangVersion>preview</LangVersion>
     <Nullable>enable</Nullable>
+    <RootNamespace>CustomerService.Core</RootNamespace>
   </PropertyGroup>
 
   <ItemGroup>

samples/Customer/CustomerService.Infrastructure/Extensions.cs

@@ -0,0 +1,71 @@
+using System;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Mvc.ApiExplorer;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using N8T.Infrastructure;
+using N8T.Infrastructure.Bus;
+using N8T.Infrastructure.EfCore;
+using N8T.Infrastructure.Swagger;
+using N8T.Infrastructure.TransactionalOutbox;
+using N8T.Infrastructure.Validator;
+using ProductService.Infrastructure.Data;
+using AppCoreAnchor = ProductService.AppCore.Anchor;
+
+namespace ProductService.Infrastructure
+{
+    public static class Extensions
+    {
+        private const string CorsName = "api";
+        private const string DbName = "postgres";
+
+        public static IServiceCollection AddCoreServices(this IServiceCollection services,
+            IConfiguration config, IWebHostEnvironment env, Type apiType)
+        {
+            services.AddCors(options =>
+            {
+                options.AddPolicy(CorsName, policy =>
+                {
+                    policy.AllowAnyOrigin().AllowAnyHeader().AllowAnyMethod();
+                });
+            });
+
+            services.AddHttpContextAccessor();
+            services.AddCustomMediatR(new[] {typeof(AppCoreAnchor)});
+            services.AddCustomValidators(new[] {typeof(AppCoreAnchor)});
+            services.AddDaprClient();
+            services.AddControllers().AddMessageBroker(config);
+            services.AddTransactionalOutbox(config);
+            services.AddSwagger(apiType);
+
+            services.AddPostgresDbContext<MainDbContext>(
+                config.GetConnectionString(DbName),
+                svc => svc.AddRepository(typeof(Repository<>)));
+
+            return services;
+        }
+
+        public static IApplicationBuilder UseCoreApplication(this WebApplication app, IWebHostEnvironment env)
+        {
+            if (env.IsDevelopment())
+            {
+                app.UseDeveloperExceptionPage();
+            }
+
+            app.UseCors(CorsName);
+            app.UseRouting();
+            app.UseCloudEvents();
+
+            app.UseEndpoints(endpoints =>
+            {
+                endpoints.MapSubscribeHandler();
+                endpoints.MapDefaultControllerRoute();
+            });
+
+            var provider = app.Services.GetService<IApiVersionDescriptionProvider>();
+            return app.UseSwagger(provider);
+        }
+    }
+}

samples/DataContracts/CoolStore.AppContracts/Dtos/CountryDto.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace CoolStore.AppContracts.Dtos
+{
+    public class CountryDto
+    {
+        public string Name { get; set; }
+        public Guid Id { get; set; }
+        public DateTime Created { get; set; }
+        public DateTime? Updated { get; set; }
+    }
+}

samples/DataContracts/CoolStore.AppContracts/Dtos/CreditCardDto.cs

@@ -0,0 +1,15 @@
+using System;
+
+namespace CoolStore.AppContracts.Dtos
+{
+    public class CreditCardDto
+    {
+        public string NameOnCard { get; set; }
+        public string CardNumber { get; set; }
+        public bool Active { get; set; }
+        public DateTime Expiry { get; set; }
+        public Guid Id { get; set; }
+        public DateTime Created { get; set; }
+        public DateTime? Updated { get; set; }
+    }
+}

samples/DataContracts/CoolStore.AppContracts/Dtos/CustomerDto.cs

@@ -0,0 +1,16 @@
+using System;
+
+namespace CoolStore.AppContracts.Dtos
+{
+    public class CustomerDto
+    {
+        public string FirstName { get; set; }
+        public string LastName { get; set; }
+        public string Email { get; set; }
+        public decimal Balance { get; set; }
+        public Guid CountryId { get; set; }
+        public Guid Id { get; set; }
+        public DateTime Created { get; set; }
+        public DateTime? Updated { get; set; }
+    }
+}

samples/DataContracts/CoolStore.AppContracts/Dtos/ProductCodeDto.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace CoolStore.AppContracts.Dtos
+{
+    public class ProductCodeDto
+    {
+        public string Name { get; set; }
+        public Guid Id { get; set; }
+        public DateTime Created { get; set; }
+        public DateTime? Updated { get; set; }
+    }
+}

samples/DataContracts/CoolStore.AppContracts/Dtos/ProductDto.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+
+namespace CoolStore.AppContracts.Dtos
+{
+    public class ProductDto
+    {
+        public string Name { get; set; }
+        public bool Active { get; set; }
+        public int Quantity { get; set; }
+        public decimal Cost { get; set; }
+        public Guid ProductCodeId { get; set; }
+        public ProductCodeDto Code { get; set; }
+        public IEnumerable<ReturnDto> Returns { get; set; }
+        public Guid Id { get; set; }
+        public DateTime Created { get; set; }
+        public DateTime? Updated { get; set; }
+    }
+}