Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion CallbackHander.Testing/TestData.cs
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ public static CallbackMessageAggregate RecordedCallbackMessageAggregate()
{
CallbackMessageAggregate aggregate = new();
aggregate.RecordCallback(TestData.CallbackId, TestData.TypeString, (MessageFormat)TestData.MessageFormat,
TestData.CallbackMessage, TestData.Reference, TestData.Destinations, EstateReference, MerchantReference);
TestData.CallbackMessage, TestData.Destinations,(TestData.Reference, EstateReference, MerchantReference));

return aggregate;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@ public async Task<Result> RecordCallback(CallbackCommands.RecordCallbackCommand
DomainServiceHelper.HandleGetAggregateResult(getResult, command.CallbackId, false);

CallbackMessageAggregate aggregate = callbackMessageAggregateResult.Data;
Result stateResult = aggregate.RecordCallback(command.CallbackId, command.TypeString, command.MessageFormat, command.CallbackMessage, command.Reference, command.Destinations,
Guid.Parse(estateReference), Guid.Parse(merchantReference));
Result stateResult = aggregate.RecordCallback(command.CallbackId, command.TypeString, command.MessageFormat, command.CallbackMessage, command.Destinations,
(command.Reference, Guid.Parse(estateReference), Guid.Parse(merchantReference)));
if (stateResult.IsFailed)
return stateResult;
return await this.AggregateRepository.SaveChanges(aggregate, cancellationToken);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ public void CallbackMessageAggregate_RecordCallback_CallbackIsRecorded()
{
CallbackMessageAggregate aggregate = new();

Result result = aggregate.RecordCallback(TestData.CallbackId, TestData.TypeString, MessageFormat.JSON, TestData.CallbackMessage, TestData.Reference, TestData.Destinations,
TestData.EstateReference, TestData.MerchantReference);
Result result = aggregate.RecordCallback(TestData.CallbackId, TestData.TypeString, MessageFormat.JSON, TestData.CallbackMessage, TestData.Destinations,
(TestData.Reference, TestData.EstateReference, TestData.MerchantReference));
result.IsSuccess.ShouldBeTrue();

aggregate.ShouldSatisfyAllConditions(() => aggregate.CallbackMessage.ShouldBe(TestData.CallbackMessage),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,12 +54,10 @@ public static Result RecordCallback(this CallbackMessageAggregate aggregate,
String typeString,
MessageFormat messageFormat,
String callbackMessage,
String reference,
String[] destinations,
Guid estateId,
Guid merchantId) {
(String reference, Guid estateId, Guid merchantId) referenceFields) {
foreach (String destination in destinations) {
CallbackReceivedEvent callbackReceivedEvent = new (aggregateId, typeString, (Int32)messageFormat, callbackMessage, reference, destination, estateId, merchantId);
CallbackReceivedEvent callbackReceivedEvent = new (aggregateId, typeString, (Int32)messageFormat, callbackMessage, referenceFields.reference, destination, referenceFields.estateId, referenceFields.merchantId);

aggregate.ApplyAndAppend(callbackReceivedEvent);
}
Expand Down
Loading