Trigger azure function when new event is commited

[Taha-Seddik]

Hi,
I successfully made persistance of events in event store db using
UseEventStoreEventStore(...) on EventFlowOptions
Now I wanna trigger an azure function when I get a new commited event
How could I do this with EventFlow ?
Thanks in advance

[ProH4Ck]

Hi, for this kind of tasks, I use Subscribers. Here is the docs: https://docs.geteventflow.net/Subscribers.html.

[Taha-Seddik]

@ProH4Ck thanks and inside that subscriber I make a http call to azure function for example ?

[ProH4Ck]

Yes! This is a sample subscriber from my latest project used to send emails:

public class ReservationConfirmedEventSubscriber
        : ISubscribeSynchronousTo<ReservationAggregate, ReservationId, ReservationCreatedEvent>
    {
        private readonly IQueryProcessor _queryProcessor;
        private readonly IEmailService _emailService;
        private readonly IUserInfoService _userInfoService;

        public ReservationConfirmedEventSubscriber(IQueryProcessor queryProcessor, IEmailService emailService,
            IUserInfoService userInfoService)
        {
            _queryProcessor = queryProcessor;
            _emailService = emailService;
            _userInfoService = userInfoService;
        }

        public async Task HandleAsync(
            IDomainEvent<ReservationAggregate, ReservationId, ReservationCreatedEvent> domainEvent,
            CancellationToken cancellationToken)
        {
            // get show
            ShowReadModel showData =
                await _queryProcessor.ProcessAsync(
                    new ReadModelByIdQuery<ShowReadModel>(domainEvent.AggregateEvent.Show),
                    cancellationToken);

            // get movie
            MovieReadModel movieData =
                await _queryProcessor.ProcessAsync(new ReadModelByIdQuery<MovieReadModel>(showData.MovieId),
                    cancellationToken);

            // get user info
            User userData = await _userInfoService.GetUserInfo(domainEvent.AggregateEvent.UserId);
            string mail = await _userInfoService.GetUserMail(domainEvent.AggregateEvent.UserId);

            var emailData = new ReservationConfirmationData();

<< OMITTED CODE >>

            await _emailService.SendReservationConfirmationEmail(mail, emailData);
        }
    }

[Taha-Seddik]

cool ! thanks man