mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-19 01:41:11 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add removeMailboxMsg with MailboxMessage as argument

Browse Source
This commit is contained in:
chimp1984 2021-01-12 13:24:42 -05:00
parent 32aeda7468
commit 3875bd85d1
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
p2p/src/main/java/bisq/network/p2p/mailbox/MailboxMessageService.java
View File

@ -266,11 +266,22 @@ public class MailboxMessageService implements SetupListener, RequestDataManager.
* @param decryptedMessageWithPubKey The DecryptedMessageWithPubKey to be removed
*/
public void removeMailboxMsg(DecryptedMessageWithPubKey decryptedMessageWithPubKey) {
NetworkEnvelope networkEnvelope = decryptedMessageWithPubKey.getNetworkEnvelope();
if (networkEnvelope instanceof MailboxMessage) {
removeMailboxMsg((MailboxMessage) networkEnvelope);
}
}
/**
* The mailboxMessage has been applied and we remove it from our local storage and from the network.
*
* @param mailboxMessage The MailboxMessage to be removed
*/
public void removeMailboxMsg(MailboxMessage mailboxMessage) {
if (isBootstrapped) {
// We need to delay a bit to not get a ConcurrentModificationException as we might iterate over
// mailboxMessageList while getting called.
UserThread.execute(() -> {
MailboxMessage mailboxMessage = (MailboxMessage) decryptedMessageWithPubKey.getNetworkEnvelope();
String uid = mailboxMessage.getUid();
// We called removeMailboxEntryFromNetwork at processMyMailboxItem,
@ -287,7 +298,7 @@ public class MailboxMessageService implements SetupListener, RequestDataManager.
});
} else {
// In case the network was not ready yet we try again later
UserThread.runAfter(() -> removeMailboxMsg(decryptedMessageWithPubKey), 30);
UserThread.runAfter(() -> removeMailboxMsg(mailboxMessage), 30);
}
}