A3.Backend.Persistence 4.1.0

A3.Backend.Persistence

Librería NuGet para acceso a base de datos MySQL del sistema Genie (A3), implementando los patrones Repository y Unit of Work sobre Entity Framework Core 8.

Tabla de contenidos

• Requisitos
• Instalación
• Arquitectura
• Contextos de base de datos
• Registro en DI
• Uso básico
• Conexiones dinámicas (multi-tenant)
• Consultas paralelas
• Referencia de la interfaz Repository
• Modelos por contexto

Requisitos

Instalación

dotnet add package A3.Backend.Persistence

Arquitectura

El proyecto expone 6 contextos independientes, cada uno con su propio stack de Repository + UnitOfWork + Factory.

A3.Backend.Persistence
├── Context/
│   ├── Admin/          → GenieAdminContext
│   ├── Operations/     → GenieOperationsContext
│   ├── Templates/      → GenieTemplatesContext
│   ├── DBManager/      → GenieDBManagerContext
│   ├── Registry/       → RegistryContext
│   └── TrxFraud/       → GenieBackendTrxFraudReviewContext
│
├── Models/             → Entidades EF por contexto
│
├── Repository/
│   ├── IUnitOfWorkFactory<TUnitOfWork>
│   ├── Admin/          → IAdminRepository, IAdminUnitOfWork, AdminUnitOfWorkFactory
│   ├── Operations/     → IOperationsRepository, IOperationsUnitOfWork, OperationsUnitOfWorkFactory
│   ├── Templates/      → ITemplatesRepository, ITemplatesUnitOfWork, TemplatesUnitOfWorkFactory
│   ├── DBManager/      → IDbManagerRepository, IDbManagerUnitOfWork, DbManagerUnitOfWorkFactory
│   ├── Registry/       → IRegistryRepository, IRegistryUnitOfWork, RegistryUnitOfWorkFactory
│   └── TrxFraud/       → ITrxFraudRepository, ITrxFraudUnitOfWork, TrxFraudUnitOfWorkFactory
│
└── Utils/
    └── Utils.cs        → DiffDates(DateTime, DateTime)

Tipos de conexión por contexto

Operations y Templates aceptan una connection string en runtime, lo que permite soporte multi-tenant (una BD por cliente).

Contextos de base de datos

Registro en DI

Contextos estáticos (Admin, DBManager, Registry, TrxFraud)

using A3.Backend.Persistence.Context.Admin;
using A3.Backend.Persistence.Repository;
using A3.Backend.Persistence.Repository.Admin;
using Microsoft.EntityFrameworkCore;

// Registrar UnitOfWork como Scoped para uso normal
services.AddScoped<IAdminUnitOfWork>(sp =>
{
    var optionsBuilder = new DbContextOptionsBuilder<GenieAdminContext>();
    optionsBuilder.UseMySQL(configuration.GetConnectionString("AdminConnection"));
    return new AdminUnitOfWork(new GenieAdminContext(optionsBuilder.Options));
});

// Registrar Factory como Singleton para uso paralelo
services.AddSingleton<IUnitOfWorkFactory<IAdminUnitOfWork>>(sp =>
{
    var optionsBuilder = new DbContextOptionsBuilder<GenieAdminContext>();
    optionsBuilder.UseMySQL(configuration.GetConnectionString("AdminConnection"));
    return new AdminUnitOfWorkFactory(optionsBuilder.Options);
});

Contextos dinámicos (Operations, Templates)

using A3.Backend.Persistence.Repository.Operations;

// Factory que recibe la connection string en runtime
services.AddTransient<Func<string, IOperationsUnitOfWork>>(sp =>
    connectionString => new OperationsUnitOfWork(connectionString));

Uso básico

public class UserService
{
    private readonly IAdminUnitOfWork _uow;

    public UserService(IAdminUnitOfWork uow) => _uow = uow;

    public User? GetById(int id)
        => _uow.Repository<User>().Get(id);

    public IEnumerable<User> GetActive()
        => _uow.Repository<User>().Find(u => u.Active == true);

    public void Create(User user)
    {
        _uow.Repository<User>().Add(user);
        _uow.Save();
    }

    public async Task<int> UpdateEmailAsync(int id, string email)
        => _uow.Repository<User>().UpdateRange(
            u => u.Id == id,
            s => s.SetProperty(u => u.Email, email));
}

Conexiones dinámicas (multi-tenant)

Para Operations y Templates, la connection string se resuelve en runtime por cliente/tenant:

public class TransactionService
{
    private readonly Func<string, IOperationsUnitOfWork> _uowFactory;

    public TransactionService(Func<string, IOperationsUnitOfWork> uowFactory)
        => _uowFactory = uowFactory;

    public Transaction? GetTransaction(string tenantConnectionString, int id)
    {
        using var uow = _uowFactory(tenantConnectionString);
        return uow.Repository<Transaction>().Get(id);
    }
}

O directamente con la factory:

var factory = new OperationsUnitOfWorkFactory(tenantConnectionString);
using var uow = factory.Create();
var transactions = uow.Repository<Transaction>().GetAll();

Consultas paralelas

⚠️ DbContext no es thread-safe. Para consultas paralelas siempre usar la Factory para crear un contexto por hilo.

Contextos estáticos

public async Task<List<User>> GetUsersParallelAsync(
    IUnitOfWorkFactory<IAdminUnitOfWork> factory,
    List<int> ids)
{
    var tasks = ids.Select(id => Task.Run(() =>
    {
        using var uow = factory.Create();
        return uow.Repository<User>().Get(id);
    }));

    return (await Task.WhenAll(tasks)).Where(u => u != null).ToList()!;
}

Contextos dinámicos (multi-tenant en paralelo)

public async Task<Dictionary<string, List<Transaction>>> GetAllTenantsAsync(
    Dictionary<string, string> tenantConnections)
{
    var tasks = tenantConnections.Select(async kvp =>
    {
        var factory = new OperationsUnitOfWorkFactory(kvp.Value);
        using var uow = factory.Create();
        var data = uow.Repository<Transaction>().GetAll().ToList();
        return new { Tenant = kvp.Key, Data = data };
    });

    var results = await Task.WhenAll(tasks);
    return results.ToDictionary(r => r.Tenant, r => r.Data);
}

Consultas mixtas (Admin + Operations en paralelo)

public async Task<(User user, List<Transaction> transactions)> GetReportAsync(
    IUnitOfWorkFactory<IAdminUnitOfWork> adminFactory,
    string operationsConnStr,
    int userId)
{
    var userTask = Task.Run(() =>
    {
        using var uow = adminFactory.Create();
        return uow.Repository<User>().Get(userId);
    });

    var trxTask = Task.Run(() =>
    {
        var factory = new OperationsUnitOfWorkFactory(operationsConnStr);
        using var uow = factory.Create();
        return uow.Repository<Transaction>().Find(t => t.UserId == userId).ToList();
    });

    await Task.WhenAll(userTask, trxTask);
    return (await userTask, await trxTask);
}

Referencia de la interfaz Repository

Todos los repositorios exponen los mismos métodos base:

Métodos específicos por contexto

Admin

Operations

Modelos por contexto

<details> <summary><strong>Admin</strong></summary>

User · UserRole · UserBySubcustomer · UserPasswordHistory · UserBlocked · UserSeed · UsersAttribute · LogUserBlocking · Token · ProjectUserActive · RolesBySubCustomer · ModuleRole · SubModuleRole · Module · SubModule · Endpoint · EndpointsByModule · EndpointsBySubModule · Customer · SubProject · Branch · Place · Address · Location · ConfigurationParameter · SubCustomerConfiguration · LockConfiguration · LockoutPeriod · Country · CountriesNew · City · CitiesNew · StatesNew · NumericalCodeCountry · TechnicianBySubProject · AssingTechnician · TransactionPendigReview · Template · TemplateType · IdentificationType · IdentificationTypeBySubproject · CausalRejection · RiskLevel · Permutation · Step · SubStep · PushDataField · PushDataFieldBySubCustomer · ResultDataField · ResultDataFieldBySubCustomer · LookAndFeelFile · TransactionType · TransactionScore · TransactionScoresBySubproject · Device · Middle · AuthorizedPhone · StatePerson · TransactionState · ScoreScript · ScriptGroup

</details>

<details> <summary><strong>Operations</strong></summary>

Invitation · InvitationDevice · InvitationPerson · InvitationStep · InvitationStepConfig · InvitationTemplate · Person · Enrollment · EnrollmentTemplate · Transaction · TransactionImage · TransactionProperty · TransactionReviewScore · Log · LogEvent · LogImage · ServiceLog · ErrorLog · ExecutionsLog · ApplicationAlert · ApplicationAudit · Otp · PendingAction · HistoricQualification · IdentitiesBySubProject · ResponseControlList · ResponseImage · ReviewExtractDataV2 · ReviewRegula · TemporalData · VwInfoTransaction

</details>

<details> <summary><strong>Templates</strong></summary>

BiometricData

</details>

<details> <summary><strong>DBManager</strong></summary>

AuthorizedApi · Database

</details>

<details> <summary><strong>Registry</strong></summary>

ErrorLog · ExecutionLog

</details>

<details> <summary><strong>TrxFraud</strong></summary>

Transaction · DeviceFingerprint · RiskThreshold · ErrorLog

</details>

Configuración MySQL recomendada

{
  "ConnectionStrings": {
    "AdminConnection":      "server=host;database=admin_db;user=usr;password=***;Max Pool Size=100;",
    "OperationsConnection": "server=host;database=ops_db;user=usr;password=***;Max Pool Size=50;",
    "TemplatesConnection":  "server=host;database=tpl_db;user=usr;password=***;Max Pool Size=50;"
  }
}

Licencia

Consulta el archivo LICENSE.txt para más información.