diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/BuyerSendPaymentSentMessage.java b/core/src/main/java/haveno/core/trade/protocol/tasks/BuyerSendPaymentSentMessage.java index 095f18b19b..b98f2f03cb 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/BuyerSendPaymentSentMessage.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/BuyerSendPaymentSentMessage.java @@ -38,16 +38,13 @@ import java.util.concurrent.TimeUnit; import haveno.common.Timer; import haveno.common.UserThread; -import haveno.common.crypto.PubKeyRing; import haveno.common.taskrunner.TaskRunner; import haveno.core.network.MessageState; import haveno.core.trade.HavenoUtils; import haveno.core.trade.Trade; import haveno.core.trade.messages.PaymentSentMessage; import haveno.core.trade.messages.TradeMailboxMessage; -import haveno.core.trade.protocol.TradePeer; import haveno.core.util.JsonUtil; -import haveno.network.p2p.NodeAddress; import javafx.beans.value.ChangeListener; import lombok.EqualsAndHashCode; import lombok.extern.slf4j.Slf4j; @@ -74,18 +71,6 @@ public abstract class BuyerSendPaymentSentMessage extends SendMailboxMessageTask super(taskHandler, trade); } - protected abstract TradePeer getReceiver(); - - @Override - protected NodeAddress getReceiverNodeAddress() { - return getReceiver().getNodeAddress(); - } - - @Override - protected PubKeyRing getReceiverPubKeyRing() { - return getReceiver().getPubKeyRing(); - } - @Override protected void run() { try { diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/SellerSendPaymentReceivedMessage.java b/core/src/main/java/haveno/core/trade/protocol/tasks/SellerSendPaymentReceivedMessage.java index 0881db3a7b..5a53eb6515 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/SellerSendPaymentReceivedMessage.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/SellerSendPaymentReceivedMessage.java @@ -38,7 +38,6 @@ import com.google.common.base.Charsets; import haveno.common.Timer; import haveno.common.UserThread; -import haveno.common.crypto.PubKeyRing; import haveno.common.crypto.Sig; import haveno.common.taskrunner.TaskRunner; import haveno.core.account.sign.SignedWitness; @@ -49,9 +48,7 @@ import haveno.core.trade.SellerTrade; import haveno.core.trade.Trade; import haveno.core.trade.messages.PaymentReceivedMessage; import haveno.core.trade.messages.TradeMailboxMessage; -import haveno.core.trade.protocol.TradePeer; import haveno.core.util.JsonUtil; -import haveno.network.p2p.NodeAddress; import javafx.beans.value.ChangeListener; import lombok.EqualsAndHashCode; import lombok.extern.slf4j.Slf4j; @@ -79,18 +76,6 @@ public abstract class SellerSendPaymentReceivedMessage extends SendMailboxMessag public SellerSendPaymentReceivedMessage(TaskRunner taskHandler, Trade trade) { super(taskHandler, trade); } - - protected abstract TradePeer getReceiver(); - - @Override - protected NodeAddress getReceiverNodeAddress() { - return getReceiver().getNodeAddress(); - } - - @Override - protected PubKeyRing getReceiverPubKeyRing() { - return getReceiver().getPubKeyRing(); - } @Override protected void run() { diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/SendDepositsConfirmedMessage.java b/core/src/main/java/haveno/core/trade/protocol/tasks/SendDepositsConfirmedMessage.java index 9419fd0d7c..2962df712e 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/SendDepositsConfirmedMessage.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/SendDepositsConfirmedMessage.java @@ -21,15 +21,12 @@ import java.util.concurrent.TimeUnit; import haveno.common.Timer; import haveno.common.UserThread; -import haveno.common.crypto.PubKeyRing; import haveno.common.taskrunner.TaskRunner; import haveno.core.network.MessageState; import haveno.core.trade.HavenoUtils; import haveno.core.trade.Trade; import haveno.core.trade.messages.DepositsConfirmedMessage; import haveno.core.trade.messages.TradeMailboxMessage; -import haveno.core.trade.protocol.TradePeer; -import haveno.network.p2p.NodeAddress; import lombok.extern.slf4j.Slf4j; /** @@ -65,18 +62,6 @@ public abstract class SendDepositsConfirmedMessage extends SendMailboxMessageTas } } - protected abstract TradePeer getReceiver(); - - @Override - protected NodeAddress getReceiverNodeAddress() { - return getReceiver().getNodeAddress(); - } - - @Override - protected PubKeyRing getReceiverPubKeyRing() { - return getReceiver().getPubKeyRing(); - } - @Override protected TradeMailboxMessage getMailboxMessage(String tradeId) { if (message == null) { diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java b/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java index b2f708394b..51d3344014 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java @@ -20,6 +20,7 @@ package haveno.core.trade.protocol.tasks; import haveno.common.crypto.PubKeyRing; import haveno.common.taskrunner.TaskRunner; import haveno.core.trade.Trade; +import haveno.core.trade.protocol.TradePeer; import haveno.network.p2p.NodeAddress; import haveno.network.p2p.SendMailboxMessageListener; import haveno.network.p2p.mailbox.MailboxMessage; @@ -31,12 +32,14 @@ public abstract class SendMailboxMessageTask extends TradeTask { super(taskHandler, trade); } + protected abstract TradePeer getReceiver(); + protected NodeAddress getReceiverNodeAddress() { - return trade.getTradePeer().getNodeAddress(); + return getReceiver().getNodeAddress(); } protected PubKeyRing getReceiverPubKeyRing() { - return trade.getTradePeer().getPubKeyRing(); + return getReceiver().getPubKeyRing(); } protected abstract MailboxMessage getMailboxMessage(String tradeId); diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/mediation/SendMediatedPayoutTxPublishedMessage.java b/core/src/main/java/haveno/core/trade/protocol/tasks/mediation/SendMediatedPayoutTxPublishedMessage.java index 6444d9a92a..ceee7aba2c 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/mediation/SendMediatedPayoutTxPublishedMessage.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/mediation/SendMediatedPayoutTxPublishedMessage.java @@ -21,6 +21,7 @@ import haveno.common.taskrunner.TaskRunner; import haveno.core.support.dispute.mediation.MediationResultState; import haveno.core.trade.Trade; import haveno.core.trade.messages.TradeMailboxMessage; +import haveno.core.trade.protocol.TradePeer; import haveno.core.trade.protocol.tasks.SendMailboxMessageTask; import lombok.extern.slf4j.Slf4j; @@ -31,6 +32,11 @@ public class SendMediatedPayoutTxPublishedMessage extends SendMailboxMessageTask super(taskHandler, trade); } + @Override + protected TradePeer getReceiver() { + return trade.getTradePeer(); + } + @Override protected TradeMailboxMessage getMailboxMessage(String id) { throw new RuntimeException("SendMediatedPayoutTxPublishedMessage.getMessage(id) not implemented for xmr");