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.