Reo.Core.ExternalReference 10.0.202

Reo.Core.ExternalReference

Описание пакета

Reo.Core.ExternalReference — это библиотека для управления связями между внутренними объектами и внешними ресурсами в распределённых системах. Пакет предоставляет модели данных, события и константы для обработки связей через очереди сообщений, например, для синхронизации данных между сервисами.

Основные компоненты

1. ExternalReferenceDto

• Описание: Содержит данные для идентификации связи между внутренним объектом и внешним ресурсом.
• Свойства:
  • ObjectId — идентификатор внутреннего объекта.
  • ExternalId — идентификатор внешнего объекта.
  • Type — тип связи (например, InvestProject).
  • UserId — идентификатор пользователя, инициировавшего связь.

2. ExternalReferenceEvent

• Описание: Модель события для передачи информации о создании или удалении связи через очередь.
• Свойства:
  • IsDelete — флаг, указывающий на удаление связи.
  • Использует IntegrationEvent<ExternalReferenceDto> для передачи данных.

3. ExternalReferenceType

• Описание: Перечисление типов объектов, с которыми устанавливается связь.
• Значения:
  • InvestProject — проект инвестирования.

4. ExternalReferenceQueueNames

• Описание: Константы для имен очередей, используемых для обработки событий.
• Пример:
  • FsObjectRef — очередь для создания связей с объектами инфраструктуры.

Требования

• .NET версия: .NET 8.0
• Зависимости:
  • Reo.Core.Queue.Abstractions — для работы с очередями сообщений.

Установка

dotnet add package Reo.Core.ExternalReference

или через NuGet:

Install-Package Reo.Core.ExternalReference

Настройка

1. Регистрация в DI (ASP.NET Core):

   services.AddHostedService<ExternalReferenceQueueHandler>();
   

2. Настройка очередей:

   services.Configure<QueueOptions>(options => {
       options.QueueNames.Add(ExternalReferenceQueueNames.FsObjectRef);
   });
   

Использование

Пример: Создание события связи

var dto = new ExternalReferenceDto
{
    ObjectId = Guid.NewGuid(),
    ExternalId = Guid.NewGuid(),
    Type = ExternalReferenceType.InvestProject,
    UserId = Guid.NewGuid()
};

var @event = new ExternalReferenceEvent
{
    IsDelete = false,
    Data = dto
};

// Отправка в очередь
await queueClient.SendAsync(@event, ExternalReferenceQueueNames.FsObjectRef);

Пример: Обработка события

public class ExternalReferenceQueueHandler : IHostedService
{
    public async Task StartAsync(CancellationToken cancellationToken)
    {
        await HandleEventAsync(new ExternalReferenceEvent());
    }

    private async Task HandleEventAsync(ExternalReferenceEvent @event)
    {
        if (@event.IsDelete)
        {
            // Логика удаления связи
        }
        else
        {
            // Логика создания связи
        }
    }
}

Лицензия

Данный пакет распространяется под лицензией MIT.