devscout-rs 0.5.0

Fast code index for C# and TypeScript codebases -- map, find, refs, impact from the CLI.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

// A classic (non-primary) consumer: fields assigned from ctor parameters,
// consuming via a base class, and a publish call sitting inside a private
// helper method rather than in Consume itself.
namespace Courier.Api.Consumers;

using Courier.Api.Messaging.Events;
using Courier.Api.Messaging.Messages;
using Courier.Api.Repositories;
using Courier.Framework;

public sealed class DeliveryScheduledConsumer : BaseConsumer<DeliveryScheduled>
{
    private readonly IParcelRepository _repository;
    private readonly IPublishEndpoint _bus;

    public DeliveryScheduledConsumer(IParcelRepository repository, IPublishEndpoint bus)
    {
        _repository = repository ?? throw new ArgumentNullException(nameof(repository));
        _bus = bus;
    }

    public override Task Consume(DeliveryScheduled message) => NotifyLost(new ParcelLostEvent(message.ParcelId));

    private Task NotifyLost(ParcelLostEvent evt)
    {
        _ = _repository.Find(evt.ParcelId.GetHashCode());
        return _bus.Publish<ParcelLostEvent>(evt);
    }
}