diff --git a/ocp/worker/swap/integration.go b/ocp/worker/swap/integration.go index 2b1a6b9..78d8cb4 100644 --- a/ocp/worker/swap/integration.go +++ b/ocp/worker/swap/integration.go @@ -9,5 +9,5 @@ import ( // Integration allows for notifications based on events processed by the swap worker type Integration interface { - OnSwapFinalized(ctx context.Context, owner *common.Account, isBuy bool, currencyName string, region currency.Code, valueReceived float64) error + OnSwapFinalized(ctx context.Context, owner *common.Account, isBuy bool, mint *common.Account, currencyName string, region currency.Code, valueReceived float64) error } diff --git a/ocp/worker/swap/util.go b/ocp/worker/swap/util.go index c322346..61f213c 100644 --- a/ocp/worker/swap/util.go +++ b/ocp/worker/swap/util.go @@ -361,7 +361,7 @@ func (p *runtime) notifySwapFinalized(ctx context.Context, swapRecord *swap.Reco ).Float64() } - return p.integration.OnSwapFinalized(ctx, owner, isBuy, targetCurrencyMetadataRecord.Name, currencyCode, valueReceived) + return p.integration.OnSwapFinalized(ctx, owner, isBuy, targetMint, targetCurrencyMetadataRecord.Name, currencyCode, valueReceived) } func (p *runtime) markNonceReleasedDueToSubmittedTransaction(ctx context.Context, record *swap.Record) error {