|
|
|
@ -128,7 +128,8 @@ namespace Squidex.Infrastructure.CQRS.Commands |
|
|
|
eventDataFormatter.Setup(x => x.ToEventData(It.Is<Envelope<IEvent>>(e => e.Payload == event1), commitId)).Returns(eventData1); |
|
|
|
eventDataFormatter.Setup(x => x.ToEventData(It.Is<Envelope<IEvent>>(e => e.Payload == event2), commitId)).Returns(eventData2); |
|
|
|
|
|
|
|
eventStore.Setup(x => x.AppendEventsAsync(commitId, streamName, 122, It.Is<IEnumerable<EventData>>(e => e.Count() == 2))).Returns(Task.FromResult(true)).Verifiable(); |
|
|
|
eventStore.Setup(x => x.AppendEventsAsync(commitId, streamName, 122, It.Is<IEnumerable<EventData>>(e => e.Count() == 2))) |
|
|
|
.Returns(Task.FromResult(true)).Verifiable(); |
|
|
|
|
|
|
|
domainObject.AddEvent(event1); |
|
|
|
domainObject.AddEvent(event2); |
|
|
|
@ -155,7 +156,8 @@ namespace Squidex.Infrastructure.CQRS.Commands |
|
|
|
eventDataFormatter.Setup(x => x.ToEventData(It.Is<Envelope<IEvent>>(e => e.Payload == event1), commitId)).Returns(eventData1); |
|
|
|
eventDataFormatter.Setup(x => x.ToEventData(It.Is<Envelope<IEvent>>(e => e.Payload == event2), commitId)).Returns(eventData2); |
|
|
|
|
|
|
|
eventStore.Setup(x => x.AppendEventsAsync(commitId, streamName, 122, new List<EventData> { eventData1, eventData2 })).Throws(new WrongEventVersionException(1, 2)).Verifiable(); |
|
|
|
eventStore.Setup(x => x.AppendEventsAsync(commitId, streamName, 122, new List<EventData> { eventData1, eventData2 })) |
|
|
|
.Throws(new WrongEventVersionException(1, 2)).Verifiable(); |
|
|
|
|
|
|
|
domainObject.AddEvent(event1); |
|
|
|
domainObject.AddEvent(event2); |
|
|
|
|