3️⃣ Publish/Subscribe Pattern 📣📡(بخش سوم)

🔍 تفاوت اصلی Publish/Subscribe با Point To Point Async Integration

🔧 How it works:

✅ Benefits:

❌ Drawbacks:

🎯 Use cases:

4️⃣ Outbox Pattern 📤📦(بخش چهارم)

🔧 How it works:

✅ Benefits:

❌ Drawbacks:

🎯 Use cases:

🧠 4️⃣2️⃣ سؤال مهم مصاحبه برای Software Architect

🎯 جمع‌بندی

چگونه با GitHub Actions و NET. یک CI/CD Pipeline بسازیم

ءContinuous Integration و Continuous Delivery چیست؟

ءContinuous Integration با GitHub Actions

name: Build & Test 🧪

on:
  push:
    branches:
      - main

env:
  DOTNET_VERSION: '7.0.x'

jobs:
  build:
    runs-on: ubuntu-latest

    steps:
      - uses: actions/checkout@v3

      - name: Setup .NET 📦
        uses: actions/setup-dotnet@v3
        with:
          dotnet-version: ${{ env.DOTNET_VERSION }}

      - name: Install dependencies 📂
        run: dotnet restore WebApi

      - name: Build 🧱
        run: dotnet build WebApi --configuration Release --no-restore

      - name: Test 🧪
        run: dotnet test WebApi --configuration Release --no-build

ءContinuous Delivery به Azure با GitHub Actions ☁️

name: Publish 🚀

on:
  push:
    branches:
      - main

env:
  AZURE_WEBAPP_NAME: web-api
  AZURE_WEBAPP_PACKAGE_PATH: './publish'
  DOTNET_VERSION: '7.0.x'

jobs:
  build:
    runs-on: ubuntu-latest

    steps:
      - uses: actions/checkout@v3

      - name: Setup .NET 📦
        uses: actions/setup-dotnet@v3
        with:
          dotnet-version: ${{ env.DOTNET_VERSION }}

      - name: Build and Publish 📂
        run: |
          dotnet restore WebApi
          dotnet build WebApi -c Release --no-restore
          dotnet publish WebApi -c Release --no-build
            --output '${{ env.AZURE_WEBAPP_PACKAGE_PATH }}'

      - name: Deploy to Azure 🌌
        uses: azure/webapps-deploy@v2
        with:
          app-name: ${{ env.AZURE_WEBAPP_NAME }}
          publish-profile: ${{ secrets.AZURE_PUBLISH_PROFILE }}
          package: '${{ env.AZURE_WEBAPP_PACKAGE_PATH }}'

جمع‌بندی 🧩

ءServer-Sent Events در ASP.NET Core و NET 10. 📡🚀

🤔 چرا SSE به‌جای SignalR؟

ءSSE متفاوت است، چون:

✨ ساده‌ترین Endpoint برای Server-Sent Events

app.MapGet("orders/realtime", (
  ChannelReader<OrderPlacement> channelReader,
  CancellationToken cancellationToken) =>
{
  // 1. ReadAllAsync یک IAsyncEnumerable برمی‌گرداند
  // 2. Results.ServerSentEvents به مرورگر می‌گوید: «این اتصال را باز نگه دار»
  // 3. به محض ورود داده‌ی جدید به Channel، داده به کلاینت Push می‌شود
  return Results.ServerSentEvents(
        channelReader.ReadAllAsync(cancellationToken),
        eventType: "orders");
});

🔍 وقتی کلاینت این Endpoint را صدا می‌زند چه اتفاقی می‌افتد؟

🧠 نکته‌ی پایانی

مدیریت رویدادهای از‌دست‌رفته (Handling Missed Events) 🔄📡

app.MapGet("orders/realtime/with-replays", (
  ChannelReader<OrderPlacement> channelReader,
  OrderEventBuffer eventBuffer,
  [FromHeader(Name = "Last-Event-ID")] string? lastEventId,
  CancellationToken cancellationToken) =>
{
  async IAsyncEnumerable<SseItem<OrderPlacement>> StreamEvents()
  {
    // 1. بازپخش رویدادهای از‌دست‌رفته از buffer
    if (!string.IsNullOrWhiteSpace(lastEventId))
    {
      var missedEvents = eventBuffer.GetEventsAfter(lastEventId);
      foreach (var missedEvent in missedEvents)
      {
        yield return missedEvent;
      }
    }

    // 2. استریم رویدادهای جدید به‌محض ورود به Channel
    await foreach (var order in channelReader.ReadAllAsync(cancellationToken))
    {
      var sseItem = eventBuffer.Add(order); // Buffer یک ID یکتا اختصاص می‌دهد
      yield return sseItem;
    }
  }

  return TypedResults.ServerSentEvents(StreamEvents(), "orders");
});

فیلتر کردن Server-Sent Events بر اساس کاربر 👤🔐

app.MapGet("orders/realtime", (
  ChannelReader<OrderPlacement> channelReader,
  IUserContext userContext, // کانتکست تزریق‌شده شامل اطلاعات کاربر
  CancellationToken cancellationToken) =>
{
  // UserId از JWT توسط IUserContext استخراج می‌شود
  var currentUserId = userContext.UserId;

  async IAsyncEnumerable<OrderPlacement> GetUserOrders()
  {
    await foreach (var order in channelReader.ReadAllAsync(cancellationToken))
    {
      // فقط داده‌های متعلق به کاربر احراز هویت‌شده ارسال می‌شود
      if (order.CustomerId == currentUserId)
      {
        yield return order;
      }
    }
  }

  return Results.ServerSentEvents(GetUserOrders(), "orders");
})
.RequireAuthorization(); // Authorization استاندارد ASP.NET Core

⚠️ نکته مهم:

مصرف Server-Sent Events در JavaScript 🌐🧠

const eventSource = new EventSource('/orders/realtime/with-replays');

// گوش دادن به event type مشخص‌شده در C#
eventSource.addEventListener('orders', (event) => {
  const payload = JSON.parse(event.data);
  console.log(New Order ${event.lastEventId}:, payload.data);
});

// وقتی اتصال برقرار می‌شود
eventSource.onopen = () => {
  console.log('Connection opened');
};

// پیام‌های عمومی (در صورت وجود)
eventSource.onmessage = (event) => {
  console.log('Received message:', event);
};

// مدیریت خطا و reconnect
eventSource.onerror = () => {
  if (eventSource.readyState === EventSource.CONNECTING) {
    console.log('Reconnecting...');
  }
};