Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
public class AddToCartHandler : ICancellableAsyncRequestHandler<AddToCart, Unit>
private readonly IMediator _mediator;
private readonly MusicStoreContext _dbContext;
public AddToCartHandler(IMediator mediator, MusicStoreContext dbContext)
_mediator = mediator;
_dbContext = dbContext;
public async Task<Unit> Handle(AddToCart message, CancellationToken cancellationToken)
// Retrieve the album from the database
var addedAlbum = await _dbContext.Albums
.SingleAsync(album => album.AlbumId == message.AlbumId, cancellationToken);
// Add it to the shopping cart
var cart = Models.ShoppingCart.GetCart(_dbContext, message.CartId);
await cart.AddToCart(addedAlbum);
await _dbContext.SaveChangesAsync(cancellationToken);
_mediator.Publish(new AlbumAddedToCart(addedAlbum.AlbumId));
return Unit.Value;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment