Fly.Shared.Core 1.0.2

Fly.Shared.Core

Core shared library for building FlyOS-compatible business app microservices on .NET 9.

Installation

<PackageReference Include="Fly.Shared.Core" Version="1.*" />

What's Included

Quick Start

Service Registration

var builder = WebApplication.CreateBuilder(args);

// Registers TenantContext, IFlyCache (Redis), IHttpContextAccessor, MemoryCache
builder.Services.AddFlyCore();

// Add your DbContext using the shared multi-tenant base
builder.Services.AddDbContext<MyAppDbContext>(options =>
    options.UseNpgsql(builder.Configuration.GetConnectionString("Default")));

var app = builder.Build();

// Resolves tenant from JWT sub-claim and populates ITenantContext
app.UseMiddleware<TenantMiddleware>();
app.UseMiddleware<CorrelationIdMiddleware>();
app.MapControllers();
app.Run();

Multi-Tenant Entity

using Fly.Shared.Core.MultiTenancy;

public class Project : TenantEntity
{
    public string Name { get; set; } = string.Empty;
    public bool IsActive { get; set; } = true;
}

Multi-Tenant DbContext

using Fly.Shared.Core.MultiTenancy;

public class MyAppDbContext : MultiTenantDbContext
{
    public MyAppDbContext(DbContextOptions<MyAppDbContext> options, ITenantContext tenant)
        : base(options, tenant) { }

    public DbSet<Project> Projects => Set<Project>();
}

MultiTenantDbContext automatically applies a global query filter e.TenantId == currentTenantId on all TenantEntity sets, and stamps TenantId on SaveChanges.

API Response Envelope

[ApiController]
[Route("api/projects")]
public class ProjectsController : ControllerBase
{
    [HttpGet]
    public IActionResult GetAll()
    {
        var projects = _service.GetAll();
        return Ok(ApiResponse<List<ProjectDto>>.Ok(projects));
    }

    [HttpPost]
    public IActionResult Create(CreateProjectRequest req)
    {
        if (!ModelState.IsValid)
            return BadRequest(ApiResponse.Fail("VALIDATION_ERROR", "Invalid input"));

        var project = _service.Create(req);
        return Created($"api/projects/{project.Id}", ApiResponse<ProjectDto>.Ok(project));
    }
}

Caching

public class ProjectService
{
    private readonly IFlyCache _cache;

    public async Task<Project?> GetByIdAsync(Guid id)
    {
        return await _cache.GetOrSetAsync(
            $"project:{id}",
            () => _db.Projects.FindAsync(id).AsTask(),
            TimeSpan.FromMinutes(15));
    }
}

Configuration

Add to appsettings.json:

{
  "Redis": {
    "ConnectionString": "localhost:6379"
  }
}

Dependencies

• Microsoft.AspNetCore.App (framework reference)
• Microsoft.EntityFrameworkCore 9.x
• Microsoft.EntityFrameworkCore.Relational 9.x
• Microsoft.Extensions.Caching.StackExchangeRedis 9.x
• StackExchange.Redis 2.x
• FluentValidation.AspNetCore 11.x
• OpenTelemetry.Extensions.Hosting 1.x
• OpenTelemetry.Instrumentation.AspNetCore 1.x

Related Packages

• Fly.Shared.Messaging — MassTransit/RabbitMQ wiring and platform event contracts. Depends on this package.