Prepare xStringService except Controllers ...

This commit is contained in:
2026-05-24 22:46:25 +03:30
parent b44c014de8
commit 30b3e80a8d
9 changed files with 433 additions and 34 deletions
-5
View File
@@ -1,5 +0,0 @@
namespace xStringService.Constants
{
public enum XStringHubAction
{ }
}
-3
View File
@@ -1,3 +0,0 @@
namespace xStringService.Constants {
public class xStringServiceConstants { }
}
+140 -19
View File
@@ -2,7 +2,19 @@ using System;
using Microsoft.Extensions.DependencyInjection;
using xExceptions.Constants;
using xCommons.Extensions;
using xDataService.Constants;
using xDataService.Db;
using xDataService.DI;
using xDataService.Models;
using xStringService.Helpers;
using xCommons.Helpers;
using Microsoft.AspNetCore.Builder;
using xStringService.Interfaces.Dtos;
using xStringService.Providers.Dtos;
using xStringService.Interfaces.Entities;
using xStringService.Providers.Entities;
using xPushService.Helpers;
using xPushService.DI;
namespace xStringService.DI
{
@@ -12,20 +24,83 @@ namespace xStringService.DI
/// Register Service ...
/// </summary>
/// <param name="services"></param>
/// <param name="config"></param>
/// <param name="repositoryType"></param>
/// <param name="lifeTime"></param>
public static void AddXStringService(
this IServiceCollection services,
ServiceLifetime lifeTime
XRepositoryType repositoryType,
ServiceLifetime lifeTime = ServiceLifetime.Scoped
)
{
AddStringService(
services,
lifeTime
contextType: null,
services: services,
lifeTime: lifeTime,
repositoryType: repositoryType
);
}
/// <summary>
/// Register Service ...
/// </summary>
/// <typeparam name="TContext"></typeparam>
/// <param name="services"></param>
/// <param name="repositoryType"></param>
/// <param name="lifeTime"></param>
public static void AddXStringService<TContext>(
this IServiceCollection services,
XRepositoryType repositoryType,
ServiceLifetime lifeTime = ServiceLifetime.Scoped
)
where TContext : XDbContext
{
AddStringService(
services: services,
lifeTime: lifeTime,
contextType: typeof(TContext),
repositoryType: repositoryType
);
}
/// <summary>
/// Use XStringService Middleware ...
/// </summary>
/// <param name="app"></param>
/// <param name="isDevelopmentEnvironment"></param>
public static void UseXStringService(
this IApplicationBuilder app,
bool isDevelopmentEnvironment = false
)
{
//
#region Using XString Hubs ...
//
var pushHelper = new XPushServiceHelper();
//
pushHelper.AddHub<XStringDtoHub>("stringDto");
pushHelper.AddHub<XStringEntityHub>("stringEntity");
//
app.UseXPushService(pushHelper);
#endregion
//
// Using XString Repository Descriptor ...
if (!descriptor.IsNull())
{
//
app.UseXRepository(
descriptor: descriptor,
isDevelopmentEnvironment: isDevelopmentEnvironment
);
}
}
//
#region Private ...
private static XRepositoryDescriptor descriptor = null;
/// <summary>
/// a LogTag for Service ...
/// </summary>
@@ -44,10 +119,14 @@ namespace xStringService.DI
/// Register Service ...
/// </summary>
/// <param name="services"></param>
/// <param name="repositoryType"></param>
/// <param name="contextType"></param>
/// <param name="lifeTime"></param>
private static void AddStringService(
IServiceCollection services,
ServiceLifetime lifeTime
XRepositoryType repositoryType,
Type contextType = null,
ServiceLifetime lifeTime = ServiceLifetime.Scoped
)
{
//
@@ -59,7 +138,7 @@ namespace xStringService.DI
if (!isServicesExists)
{
//
Log("AddStringService failed, services not provided ...");
Log("Service Registration failed, services not provided ...");
throw exception;
}
@@ -69,28 +148,70 @@ namespace xStringService.DI
if (!isLifetimeExists)
{
//
Log("AddStringService failed, lifetime not provided ...");
Log("Service Registration failed, lifetime not provided ...");
throw exception;
}
//
// Check Repository Exists ...
var isRepositoryExists = !services
.GetRegisteredService<IXStringRepository>()
.IsNull();
if (!isRepositoryExists)
// Validate Repository Type ...
var isRepositoryTypeValid =
(repositoryType == XRepositoryType.EF &&
!contextType.IsNull()) ||
((repositoryType == XRepositoryType.Mongo ||
repositoryType == XRepositoryType.InMemory) &&
contextType.IsNull());
if (!isRepositoryTypeValid)
{
//
Log("AddStringService failed, IXStringRepository not provided ...");
throw exception;
Log("Service Registration failed, Invalid Repository Type and Context Type ...");
throw exception;
}
// //
// // Main Provider ...
// services.Add(new ServiceDescriptor(typeof(IXStringProvider), typeof(XStringProvider), lifeTime));
//
Log("AddStringService Succeed ...");
switch(repositoryType)
{
//
case XRepositoryType.EF:
//
descriptor = typeof(XStringServiceHelper)
.InvokeGenericMethod<XRepositoryDescriptor>(
methodName: "GetXStringEfRepositoryDescriptor",
runtimeType: contextType,
args: null
);
break;
//
case XRepositoryType.Mongo:
descriptor = XStringServiceHelper.GetXStringMongoRepositoryDescriptor();
break;
//
case XRepositoryType.InMemory:
descriptor = XStringServiceHelper.GetXStringInMemoryRepositoryDescriptor();
break;
}
//
services.AddXRepository(
lifeTime: lifeTime,
descriptor: descriptor
);
//
// Register Dto Services ...
services.Add(
new ServiceDescriptor(typeof(IXStringServiceProvider), typeof(XStringServiceProvider), lifeTime)
);
services.Add(
new ServiceDescriptor(typeof(IXStringRepositoryService), typeof(XStringRepositoryService), lifeTime)
);
services.Add(
new ServiceDescriptor(typeof(IXStringRepositoryProvider), typeof(XStringRepositoryProvider), lifeTime)
);
//
Log("Service Regitration Succeed ...");
}
#endregion
}
-3
View File
@@ -1,3 +0,0 @@
namespace xStringService.Extensions {
public static class xStringServiceExtensions { }
}
+281
View File
@@ -0,0 +1,281 @@
using GraphQL.Types;
using MongoDB.Bson.Serialization.Serializers;
using xDataHelper.Providers.GraphQL;
using xDataService.Db;
using xDataService.Models;
using xDataService.Providers;
using xStringService.Interfaces;
using xStringService.Interfaces.Entities;
using xStringService.Models.Entities;
using xStringService.Providers.Entities;
using xStringService.Providers.GraphQL;
namespace xStringService.Helpers
{
public static class XStringServiceHelper
{
//
#region EF Repository Descriptor Provider(s) ...
public static XEFRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringEFRepository<TContext>,
TContext
> GetXStringEfRepositoryDescriptor<TContext>()
where TContext : XDbContext
{
//
var result = new XEFRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringEFRepository<TContext>,
TContext
>();
//
return result;
}
public static XEFRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringEFRepository<TContext>,
TContext,
IXStringSeeder,
TSeederImplementation
> GetXStringEfRepositoryDescriptor<TContext, TSeederImplementation>()
where TContext : XDbContext
where TSeederImplementation : XBaseDbSeeder<XString, int>
{
//
var result = new XEFRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringEFRepository<TContext>,
TContext,
IXStringSeeder,
TSeederImplementation
>();
//
return result;
}
#endregion
//
#region Mongo Repository Descriptor Provider(s) ...
public static XMongoRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringMongoRepository
> GetXStringMongoRepositoryDescriptor()
{
//
var result = new XMongoRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringMongoRepository
>();
//
return result;
}
public static XMongoRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringMongoRepository,
IXStringSeeder,
TSeederImplementation
> GetXStringMongoRepositoryDescriptor<TSeederImplementation>()
where TSeederImplementation : XBaseDbSeeder<XString, int>
{
//
var result = new XMongoRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringMongoRepository,
IXStringSeeder,
TSeederImplementation
>();
//
return result;
}
#endregion
//
#region InMemory Repository Descriptor Provider(s) ...
public static XInMemoryRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringInMemoryRepository
> GetXStringInMemoryRepositoryDescriptor()
{
//
var result = new XInMemoryRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringInMemoryRepository
>();
//
return result;
}
public static XInMemoryRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringInMemoryRepository,
IXStringSeeder,
TSeederImplementation
> GetXStringInMemoryRepositoryDescriptor<TSeederImplementation>()
where TSeederImplementation : XBaseDbSeeder<XString, int>
{
//
var result = new XInMemoryRepositoryDescriptor<
XString,
int,
IXStringKeyGenerator,
XStringKeyGenerator,
IXStringRepositoryEvents,
XStringRepositoryEvents,
XStringGraphType,
IntGraphType,
XStringGraphQuery,
IXStringGraphQLTypeHelper,
XStringGraphQLTypeHelper,
XStringGraphSchema,
IXStringRepository,
XStringInMemoryRepository,
IXStringSeeder,
TSeederImplementation
>();
//
return result;
}
#endregion
}
}
+8
View File
@@ -0,0 +1,8 @@
using xDataService.Interfaces;
using xStringService.Models.Entities;
namespace xStringService.Interfaces
{
public interface IXStringSeeder : IXBaseDbSeeder<XString, int>
{}
}
+2 -2
View File
@@ -7,10 +7,10 @@ using xStringService.Models.Entities;
namespace xStringService.Providers.Entities
{
public class XStringEFRepository<TContext> : XBaseEFRepository<XString, int, TContext>
public class XStringEFRepository<TContext> : XBaseEFRepository<XString, int, TContext>, IXStringRepository
where TContext : XDbContext
{
protected XStringEFRepository(
public XStringEFRepository(
IXUnitOfWorks<TContext> unitOfWorks,
XDataServiceConfiguration configuration,
IXStringKeyGenerator keyGenerator = null,
@@ -5,9 +5,9 @@ using xStringService.Models.Entities;
namespace xStringService.Providers.Entities
{
public class XStringInMemoeryRepository : XBaseInMemoryRepository<XString, int>, IXStringRepository
public class XStringInMemoryRepository : XBaseInMemoryRepository<XString, int>, IXStringRepository
{
public XStringInMemoeryRepository(
public XStringInMemoryRepository(
XDataServiceConfiguration configuration,
IXStringKeyGenerator keyGenerator = null,
IXStringRepositoryEvents baseRepositoryEvents = null