nihilist/haveno
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

open dispute on trade thread

Browse Source
This commit is contained in:
woodser 2024-01-21 07:59:40 -05:00
parent 892eaa440a
commit 6dc9842253
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/main/java/haveno/core/api/CoreDisputesService.java
View File

@ -1,6 +1,8 @@
package haveno.core.api; package haveno.core.api;
import com.google.inject.name.Named; import com.google.inject.name.Named;
import haveno.common.ThreadUtils;
import haveno.common.crypto.KeyRing; import haveno.common.crypto.KeyRing;
import haveno.common.crypto.PubKeyRing; import haveno.common.crypto.PubKeyRing;
import haveno.common.handlers.FaultHandler; import haveno.common.handlers.FaultHandler;
@ -81,7 +83,8 @@ public class CoreDisputesService {
Trade trade = tradeManager.getOpenTrade(tradeId).orElseThrow(() -> Trade trade = tradeManager.getOpenTrade(tradeId).orElseThrow(() ->
new IllegalArgumentException(format("trade with id '%s' not found", tradeId))); new IllegalArgumentException(format("trade with id '%s' not found", tradeId)));
synchronized (trade) { // open dispute on trade thread
ThreadUtils.execute(() -> {
Offer offer = trade.getOffer(); Offer offer = trade.getOffer();
if (offer == null) throw new IllegalStateException(format("offer with tradeId '%s' is null", tradeId)); if (offer == null) throw new IllegalStateException(format("offer with tradeId '%s' is null", tradeId));
@ -96,7 +99,7 @@ public class CoreDisputesService {
// one for the opener, the other for the peer, see sendPeerOpenedDisputeMessage. // one for the opener, the other for the peer, see sendPeerOpenedDisputeMessage.
disputeManager.sendDisputeOpenedMessage(dispute, false, trade.getSelf().getUpdatedMultisigHex(), resultHandler, faultHandler); disputeManager.sendDisputeOpenedMessage(dispute, false, trade.getSelf().getUpdatedMultisigHex(), resultHandler, faultHandler);
tradeManager.requestPersistence(); tradeManager.requestPersistence();
} }, trade.getId());
} }
public Dispute createDisputeForTrade(Trade trade, Offer offer, PubKeyRing pubKey, boolean isMaker, boolean isSupportTicket) { public Dispute createDisputeForTrade(Trade trade, Offer offer, PubKeyRing pubKey, boolean isMaker, boolean isSupportTicket) {