مپ کردن اسرار به یک POCO 🔗

{
  "Movies:ConnectionString": "Server=(localdb)\\mssqllocaldb;Database=Movie-1;Trusted_Connection=True;MultipleActiveResultSets=true",
  "Movies:ServiceApiKey": "12345"
}

var moviesConfig = 
    Configuration.GetSection("Movies").Get<MovieSettings>();
var _moviesApiKey = moviesConfig.ServiceApiKey;

public class MovieSettings
{
    public string ConnectionString { get; set; }
    public string ServiceApiKey { get; set; }
}

جایگزینی رشته با اسرار 🛠️

using System.Data.SqlClient;

var builder = WebApplication.CreateBuilder(args);

var conStrBuilder = new SqlConnectionStringBuilder(
        builder.Configuration.GetConnectionString("Movies"));
conStrBuilder.Password = builder.Configuration["DbPassword"];
var connection = conStrBuilder.ConnectionString;

var app = builder.Build();
app.MapGet("/", () => connection);
app.Run();

📑 دستورات CLI

Install-Package Microsoft.Extensions.Configuration
Install-Package Microsoft.Extensions.Configuration.UserSecrets

dotnet add package Microsoft.Extensions.Configuration
dotnet add package Microsoft.Extensions.Configuration.UserSecrets

using Microsoft.Extensions.Configuration;

class Program
{
    static void Main(string[] args)
    {
        IConfigurationRoot config = new ConfigurationBuilder()
            .AddUserSecrets<Program>()
            .Build();

        Console.WriteLine(config["AppSecret"]);
    }
}

#programming_memes
#fun

🚀 چرا Connection String رو مستقیم تو appsettings.json نگذاریم؟

dotnet add package Azure.Extensions.AspNetCore.Configuration.Secrets
dotnet add package Azure.Identity

<PropertyGroup>
  <UserSecretsId>{GUID}</UserSecretsId>
</PropertyGroup>

dotnet user-secrets set "DbConnection" "Server=.;Database=Test;User Id=sa;Password=1234"

az group create --name "MyGroup" --location "westeurope"
az keyvault create --name "myvault123" --resource-group "MyGroup" --location "westeurope"

az keyvault secret set --vault-name "myvault123" --name "DbConnection" --value "Server=sql.example.com;Database=Prod;..."

builder.Configuration.AddAzureKeyVault(
    new Uri($"https://{builder.Configuration["KeyVaultName"]}.vault.azure.net/"),
    new ClientCertificateCredential(
        builder.Configuration["AzureADDirectoryId"],
        builder.Configuration["AzureADApplicationId"],
        x509Certificate));

builder.Configuration.AddAzureKeyVault(
    new Uri($"https://{builder.Configuration["KeyVaultName"]}.vault.azure.net/"),
    new DefaultAzureCredential());

📌 بهترین نکات امنیتی

🔖 هشتگ‌ها:
#CSharp #ASPNetCore #Azure #KeyVault #CodeSafety #MicrosoftAzure #ConnectionString

📌الگوی Saga چی هست و چرا بهش نیاز داریم؟
[Saga distributed transactions pattern]

📍زمینه و مشکل (Context and problem)

⚖️تراکنش‌ها باید به اصول ACID پایبند باشند:

🏗چالش‌ها در معماری‌های مایکروسرویس
(Challenges in microservices architectures)

💡راهکار (Solution)

🔑 مفاهیم کلیدی در الگوی Saga
(Key concepts in the Saga pattern)

تراکنش‌های قابل جبران (Compensable Transactions):

تراکنش محوری (Pivot Transaction):

تراکنش‌های قابل تکرار (Retryable Transactions):

رویکردهای پیاده‌سازی Saga
(Saga implementation approaches)

1️⃣ Choreography

2️⃣ Orchestration

🛠مشکلات و ملاحظات
(Problems and considerations)

⚠️ناهنجاری‌های داده‌ای در Saga
(Potential data anomalies in sagas)

🛡راهکارهای جلوگیری از ناهنجاری‌ها
(Strategies to address data anomalies)

📌زمان استفاده از این الگو
(When to use this pattern)

🔖 هشتگ‌ها:
#Microservices #SagaPattern #SoftwareArchitecture

استفاده از چند EF Core DbContext در یک برنامه

📌 چرا از چندین DbContext استفاده کنیم؟

⚙️ ایجاد چندین DbContext در یک برنامه

public class CatalogDbContext : DbContext
{
    public DbSet<Product> Products { get; set; }
    public DbSet<Category> Categories { get; set; }
}

public class OrderDbContext : DbContext
{
    public DbSet<Order> Orders { get; set; }
    public DbSet<LineItem> LineItems { get; set; }
}

services.AddDbContext<CatalogDbContext>(options =>
    options.UseSqlServer("CONNECTION_STRING"));

services.AddDbContext<OrderDbContext>(options =>
    options.UseSqlServer("CONNECTION_STRING"));

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.HasDefaultSchema("catalog");
}

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.HasDefaultSchema("order");
}

⚠️ محدودیت‌ها در استفاده از چندین DbContext

services.AddDbContext<CatalogDbContext>(options =>
    options.UseSqlServer(
        "CONNECTION_STRING",
        o => o.MigrationsHistoryTable(
            tableName: HistoryRepository.DefaultTableName,
            schema: "catalog")));

✅ مزایای استفاده از چندین DbContext

🔖هشتگ‌ها:
#DotNet #EFCore #CSharp #DbContext #ModularMonolith #EntityFramework #DatabaseDesign

💡 نکته عملکردی C#/.NET – آرایه‌های Inline 🔥

✅ چند مزیت آرایه‌های Inline:

🔖هشتگ‌ها:
#csharp #dotnet #programming #softwareengineering #softwaredevelopment

📨 معماری رویدادمحور (Event-Driven Architecture) در NET. با RabbitMQ

📌 سناریوی ما

🐳 اجرای RabbitMQ با Docker

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4-management

🛠 مفاهیم پایه RabbitMQ

💡 نکته: در RabbitMQ، تولیدکنندگان هرگز مستقیماً به یک صف ارسال نمی‌کنند، بلکه به یک Exchange ارسال می‌کنند. Exchange تعیین می‌کند که پیام به کدام صف یا صف‌ها برود.

var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.QueueDeclareAsync(
    queue: "orders",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

var orderPlaced = new OrderPlaced
{
    OrderId = Guid.NewGuid(),
    Total = 99.99,
    CreatedAt = DateTime.UtcNow
};
var message = JsonSerializer.Serialize(orderPlaced);
var body = Encoding.UTF8.GetBytes(message);

await channel.BasicPublishAsync(
    exchange: string.Empty,
    routingKey: "orders",
    mandatory: true,
    basicProperties: new BasicProperties { Persistent = true },
    body: body);

Console.WriteLine($"Sent: {message}");

📌 نکات مهم:

var factory = new ConnectionFactory() { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.QueueDeclareAsync(
    queue: "orders",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

var consumer = new AsyncEventingBasicConsumer(channel);
consumer.ReceivedAsync += async (sender, eventArgs) =>
{
    byte[] body = eventArgs.Body.ToArray();
    string message = Encoding.UTF8.GetString(body);
    var orderPlaced = JsonSerializer.Deserialize<OrderPlaced>(message);

    Console.WriteLine($"Received: OrderPlaced - {orderPlaced.OrderId}");

    await ((AsyncEventingBasicConsumer)sender)
        .Channel.BasicAckAsync(eventArgs.DeliveryTag, multiple: false);
};
await channel.BasicConsumeAsync("orders", autoAck: false, consumer);

Console.WriteLine("Waiting for messages...");

📌 نکات مهم:

await channel.ExchangeDeclareAsync(
    exchange: "orders",
    durable: true,
    autoDelete: false,
    type: ExchangeType.Fanout);

await channel.BasicPublishAsync(
    exchange: "orders",
    routingKey: string.Empty,
    mandatory: true,
    basicProperties: new BasicProperties { Persistent = true },
    body: body);

await channel.ExchangeDeclareAsync(
    exchange: "orders",
    durable: true,
    autoDelete: false,
    type: ExchangeType.Fanout);

await channel.QueueDeclareAsync(
    queue: "orders-consumer-1",
    durable: true,
    exclusive: false,
    autoDelete: false,
    arguments: null);

await channel.QueueBindAsync("orders-consumer-1", "orders", string.Empty);

🏷 هشتگ‌ها:
#RabbitMQ #DotNet #EventDrivenArchitecture #MessageBroker

🚀 جادوی async/await در #C:

1️⃣ داستان سرآشپز صبور (آنالوژی) 👨‍🍳

2️⃣ کلمات کلیدی جادویی: async, await, Task ✨

3️⃣ مثال عملی: دانلود کردن یک فایل

// ❌ این متد نخ اصلی رو برای ۵ ثانیه قفل می‌کنه!
public void DownloadFile()
{
    Thread.Sleep(5000); // شبیه‌سازی یک عملیات زمان‌بر و مسدودکننده
    Console.WriteLine("Download complete.");
}

// ✅ این متد نخ اصلی رو آزاد می‌کنه و برنامه پاسخگو باقی می‌مونه
public async Task DownloadFileAsync()
{
    // await کنترل رو به بیرون برمی‌گردونه و منتظر می‌مونه
    await Task.Delay(5000); // شبیه‌سازی یک عملیات غیرهمزمان
    Console.WriteLine("Download complete.");
}

🔖 هشتگ‌ها:
#CSharp #Programming #Developer #DotNet #Async #Await #Concurrency

کتابخانه جدید کشینگ 🆕
HybridCache در ASP.NET Core

HybridCache چیست؟ 🤔

1️⃣ کشینگ دو سطحی (L1/L2)

2️⃣ محافظت در برابر cache stampede
(زمانی که درخواست‌های زیادی به یکباره به کش خالی برخورد می‌کنند)

3️⃣ نامعتبرسازی کش بر اساس تگ

4️⃣ سریال‌سازی قابل پیکربندی

5️⃣ معیارها و مانیتورینگ

نصب HybridCache 📦

builder.Services.AddHybridCache(options =>
{
    // حداکثر اندازه آیتم‌های کش شده
    options.MaximumPayloadBytes = 1024 * 1024 * 10; // 10MB
    options.MaximumKeyLength = 512;
    
    // تایم‌اوت‌های پیش‌فرض
    options.DefaultEntryOptions = new HybridCacheEntryOptions
    {
        Expiration = TimeSpan.FromMinutes(30),
        LocalCacheExpiration = TimeSpan.FromMinutes(30)
    };
});

builder.Services.AddHybridCache()
    .AddSerializer<CustomType, CustomSerializer>();

استفاده از HybridCache 👨‍💻

گرفتن یا ایجاد ورودی‌های کش 🔎

app.MapGet("/products/{id}", async (
    int id,
    HybridCache cache,
    ProductDbContext db,
    CancellationToken ct) =>
{
    var product = await cache.GetOrCreateAsync(
        $"product-{id}",
        async token =>
        {
            return await db.Products
                .Include(p => p.Category)
                .FirstOrDefaultAsync(p => p.Id == id, token);
        },
        cancellationToken: ct
    );
    
    return product is null ? Results.NotFound() : Results.Ok(product);
});

تنظیم مستقیم ورودی‌های کش ✍️

app.MapPut("/products/{id}", async (int id, Product product, HybridCache cache) =>
{
    // ابتدا دیتابیس را به‌روزرسانی کنید
    await UpdateProductInDatabase(product);
    
    // سپس کش را با انقضای سفارشی به‌روزرسانی کنید
    var options = new HybridCacheEntryOptions
    {
        Expiration = TimeSpan.FromHours(1),
        LocalCacheExpiration = TimeSpan.FromMinutes(30)
    };
    
    await cache.SetAsync(
        $"product-{id}",
        product,
        options
    );
    
    return Results.NoContent();
});

استفاده از تگ‌های کش 🏷

app.MapGet("/categories/{id}/products", async (...) =>
{
    var tags = [$"category-{id}", "products"];
    
    var products = await cache.GetOrCreateAsync(
        $"products-by-category-{id}",
        async token => { /* ... fetch products ... */ },
        tags: tags,
        cancellationToken: ct
    );
    
    return Results.Ok(products);
});

// Endpoint برای نامعتبر کردن تمام محصولات در یک دسته‌بندی
app.MapPost("/categories/{id}/invalidate", async (id, cache, ct) =>
{
    await cache.RemoveByTagAsync($"category-{id}", ct);
    return Results.NoContent();
});

📍تگ‌ها برای موارد زیر مفید هستند:

حذف ورودی‌های تکی 🗑

app.MapDelete("/products/{id}", async (int id, HybridCache cache) =>
{
    // ابتدا از دیتابیس حذف کنید
    await DeleteProductFromDatabase(id);
    
    // سپس از کش حذف کنید
    await cache.RemoveAsync($"product-{id}");
    
    return Results.NoContent();
});

افزودن Redis به عنوان کش L2 🔥

// افزودن Redis
builder.Services.AddStackExchangeRedisCache(options =>
{
    options.Configuration = "your-redis-connection-string";
});
// افزودن HybridCache - به طور خودکار از Redis به عنوان L2 استفاده خواهد کرد
builder.Services.AddHybridCache();

خلاصه 📝

🔖 هشتگ‌ها:
#CSharp #Programming #Developer #DotNet #HybridCache

مدیریت خطای سراسری در ASP.NET Core: از Middleware تا Handlerهای مدرن 🚨

مدیریت خطای مبتنی بر Middleware 📜

internal sealed class GlobalExceptionHandlerMiddleware(
    RequestDelegate next,
    ILogger<GlobalExceptionHandlerMiddleware> logger)
{
    public async Task InvokeAsync(HttpContext context)
    {
        try
        {
            await next(context);
        }
        catch (Exception ex)
        {
            logger.LogError(ex, "Unhandled exception occurred");
            
            // حتماً قبل از نوشتن در بدنه پاسخ، کد وضعیت را تنظیم کنید
            context.Response.StatusCode = ex switch
            {
                ApplicationException => StatusCodes.Status400BadRequest,
                _ => StatusCodes.Status500InternalServerError
            };
            
            await context.Response.WriteAsJsonAsync(
                new ProblemDetails
                {
                    Type = ex.GetType().Name,
                    Title = "An error occured",
                    Detail = ex.Message
                });
        }
    }
}

app.UseMiddleware<GlobalExceptionHandlerMiddleware>();

معرفی IProblemDetailsService 📄

// ...
catch (Exception ex)
{
    logger.LogError(ex, "Unhandled exception occurred");

    context.Response.StatusCode = ex switch
    {
        ApplicationException => StatusCodes.Status400BadRequest,
        _ => StatusCodes.Status500InternalServerError
    };

    await problemDetailsService.TryWriteAsync(new ProblemDetailsContext
    {
        HttpContext = context,
        Exception = ex,
        ProblemDetails = new ProblemDetails
        {
            Type = ex.GetType().Name,
            Title = "An error occured",
            Detail = ex.Message
        }
    });
}
// ...

روش مدرن: IExceptionHandler ✨

internal sealed class GlobalExceptionHandler(
    IProblemDetailsService problemDetailsService,
    ILogger<GlobalExceptionHandler> logger) : IExceptionHandler
{
    public async ValueTask<bool> TryHandleAsync(
        HttpContext httpContext,
        Exception exception,
        CancellationToken cancellationToken)
    {
        logger.LogError(exception, "Unhandled exception occurred");

httpContext.Response.StatusCode = exception switch
        {
            ApplicationException => StatusCodes.Status400BadRequest,
            _ => StatusCodes.Status500InternalServerError
        };

        return await problemDetailsService.TryWriteAsync(new ProblemDetailsContext
        {
            // ...
        });
    }
}

builder.Services.AddExceptionHandler<GlobalExceptionHandler>();
builder.Services.AddProblemDetails();

// و در پایپ‌لاین شما
app.UseExceptionHandler();

زنجیره‌ای کردن Exception Handlerها ⛓️

builder.Services.AddExceptionHandler<ValidationExceptionHandler>();
builder.Services.AddExceptionHandler<GlobalExceptionHandler>();

internal sealed class ValidationExceptionHandler(
    IProblemDetailsService problemDetailsService,
    ILogger<ValidationExceptionHandler> logger) : IExceptionHandler
{
    public async ValueTask<bool> TryHandleAsync(
        HttpContext httpContext,
        Exception exception,
        CancellationToken cancellationToken)
    {
        if (exception is not ValidationException validationException)
        {
            return false;
        }

        logger.LogError(exception, "Unhandled exception occurred");

        httpContext.Response.StatusCode = StatusCodes.Status400BadRequest;
        
        var context = new ProblemDetailsContext { /* ... */ };

        var errors = validationException.Errors
            .GroupBy(e => e.PropertyName)
            .ToDictionary(
                g => g.Key.ToLowerInvariant(),
                g => g.Select(e => e.ErrorMessage).ToArray()
            );
            
        context.ProblemDetails.Extensions.Add("errors", errors);
        
        return await problemDetailsService.TryWriteAsync(context);
    }
}

نکته کلیدی؟ 🔑

🔖 هشتگ‌ها:
#CSharp #DotNet #ErrorHandling #ExceptionHandling #SoftwareArchitecture