سلام وقت بخیر ، توی پروژه Api ما از GUID استفاده نکردیم و id هامون وابسته به دیتابیسه ، پس طبیعتا تا وقتی که saveChagne فرخوانی نشه id پر نمیشه

و اگر توی پیام نیاز به id باشه حتما باید بعد از SaveChanges اون Event ساخته بشه

کار دقیقا همون هیچ فرقی نکرده و ربطی به RabbitMq نداره مشکلی که الان هست id کاربره و تنها راه اش هم اینه بعد SaveChanges فراخوانی بشه یا اینکه از Hi/LO استفاده کنید بعد context.Add رو صدا بزنید بعد  Event رو به AggregateRoot اضافه کنید  

سلام استاد

الان من اومدم اینکار رو کردم درسته؟

public async Task<OperationResult<string>> Handle(ForgotPasswordCommand request, CancellationToken cancellationToken)
{
    var user = await _userRepository.GetTracking(request.UserId);
    if (user == null)
        return OperationResult<string>.NotFound();
    
    if (user.IsActive == false)
        return OperationResult<string>.Error("حساب کاربری شما غیرفعال شده است");

    //var newPassword = CodeGenerator.GeneratePassword();
    const string newPassword = "12345";
    user.ChangePassword(Sha256Hasher.Hash(newPassword));
    await _userRepository.Save();
    #region Publish Send Sms or Email

    _eventBus.Publish(new UserForgotPasswordIntegrationEvent()
    {
        Id = user.Id,
        Mobile = user.Mobile,
        Password = newPassword,
        Message = $"آموز گرامی {user.Name} {user.Family} کلمه عبور شما به {newPassword} تغییر پیدا کرد.",
    }, "", Exchanges.UserExchange, ExchangeType.Fanout);

    #endregion
    return OperationResult<string>.Success(user.Mobile,$"کلمه عبور شما به {newPassword} تغییر پیدا کرد");
}

و بعد اومدم توی razorpage داخل فولدر infrastructure ایونت هندلر هامو گذاشتم و کانسوم کردم مثل زیر:

public class UserForgotPasswordEventHandler : BackgroundService
{
    private readonly IEventBus _eventBus;
    private string _queueName = "userForgotPassword";
    private readonly ILogger<UserForgotPasswordEventHandler> _logger;
    private readonly IServiceScopeFactory _serviceFactory;
    public UserForgotPasswordEventHandler(IEventBus eventBus, ILogger<UserForgotPasswordEventHandler> logger, IServiceScopeFactory serviceFactory)
    {
        _eventBus = eventBus;
        _logger = logger;
        _serviceFactory = serviceFactory;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var connection = _eventBus.Connection;
        var serviceScope = _serviceFactory.CreateScope();

        var notificationFacade = serviceScope.ServiceProvider.GetRequiredService<INotificationFacade>();
        var smsService = serviceScope.ServiceProvider.GetRequiredService<ISmsService>();

        var model = connection.CreateModel();
        model.ExchangeDeclare(Exchanges.UserExchange, ExchangeType.Fanout, true, false, null);
        model.QueueDeclare(_queueName, true, false, false, null);
        model.QueueBind(_queueName, Exchanges.UserExchange, "", null);

        var consumer = new EventingBasicConsumer(model);
        consumer.Received += async (sender, args) =>
        {
            try
            {
                var resultJson = Encoding.UTF8.GetString(args.Body.ToArray());
                var result = JsonConvert.DeserializeObject<UserForgotPasswordIntegrationEvent>(resultJson);

                //send notification
                await notificationFacade.Create(new CreateNotificationCommand(result.Id, "تغییر کلمه عبور", result.Message));
                //send sms
                smsService.SendUserPasswordSms(result.Mobile, result.Password);
                
                model.BasicAck(args.DeliveryTag, false);
            }
            catch (Exception e)
            {
                _logger.LogError(e, e.Message);
            }
        };
        model.BasicConsume(consumer, _queueName, false);
    }
}

که اینجا هم نوتیفی و هم sms میدم بهش

درسته؟

سلام بله پیاده سازی مشکلی نداره ولی میتونید handler هاتونو ببرید توی Infrustructure

خب اونجوری به facade دسترسی نداریم استاد

راستی استاد برای ارسال ایمیل و sms توی اون handler که داریم نوتیفیکیشن میفرستیم همونجا انجام میدیم؟

ینی منظورم اینجاس

try
            {
                var resultJson = Encoding.UTF8.GetString(args.Body.ToArray());
                var result = JsonConvert.DeserializeObject<UserForgotPasswordIntegrationEvent>(resultJson);

                //send notification
                await notificationFacade.Create(new CreateNotificationCommand(result.Id, "تغییر کلمه عبور", result.Message));
                
                
                                //اینجا


                //send sms
                smsService.SendUserPasswordSms(result.Mobile, result.Password);
                
                //تا اینجا


                




                model.BasicAck(args.DeliveryTag, false);
            }
            catch (Exception e)
            {
                _logger.LogError(e, e.Message);
            }

ممنون استاد

خیلی لطف کردید