mirror of
https://code.briarproject.org/briar/briar.git
synced 2026-02-22 15:49:53 +01:00
Add an event for received setup messages
This commit is contained in:
@@ -31,6 +31,8 @@ import org.briarproject.briar.api.remotewipe.MessageEncoder;
|
|||||||
import org.briarproject.briar.api.remotewipe.MessageParser;
|
import org.briarproject.briar.api.remotewipe.MessageParser;
|
||||||
import org.briarproject.briar.api.remotewipe.RemoteWipeManager;
|
import org.briarproject.briar.api.remotewipe.RemoteWipeManager;
|
||||||
import org.briarproject.briar.api.remotewipe.RemoteWipeMessageHeader;
|
import org.briarproject.briar.api.remotewipe.RemoteWipeMessageHeader;
|
||||||
|
import org.briarproject.briar.api.remotewipe.RemoteWipeReceivedEvent;
|
||||||
|
import org.briarproject.briar.api.socialbackup.ShardReceivedEvent;
|
||||||
import org.briarproject.briar.client.ConversationClientImpl;
|
import org.briarproject.briar.client.ConversationClientImpl;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
@@ -122,8 +124,12 @@ public class RemoteWipeManagerImpl extends ConversationClientImpl
|
|||||||
MessageType type = MessageType.fromValue(body.getLong(0).intValue());
|
MessageType type = MessageType.fromValue(body.getLong(0).intValue());
|
||||||
if (type == SETUP) {
|
if (type == SETUP) {
|
||||||
messageTracker.trackIncomingMessage(txn, m);
|
messageTracker.trackIncomingMessage(txn, m);
|
||||||
// message.getGroupId turn into contactid
|
ContactId contactId = getContactId(txn, m.getGroupId());
|
||||||
// txn.attach event
|
|
||||||
|
MessageStatus status = db.getMessageStatus(txn, contactId,
|
||||||
|
m.getId());
|
||||||
|
txn.attach(new RemoteWipeReceivedEvent(
|
||||||
|
createMessageHeader(m, meta, status), contactId));
|
||||||
} else if (type == WIPE) {
|
} else if (type == WIPE) {
|
||||||
if (!remoteWipeIsSetup(txn)) return false;
|
if (!remoteWipeIsSetup(txn)) return false;
|
||||||
if (clock.currentTimeMillis() - m.getTimestamp() > MAX_MESSAGE_AGE)
|
if (clock.currentTimeMillis() - m.getTimestamp() > MAX_MESSAGE_AGE)
|
||||||
|
|||||||
Reference in New Issue
Block a user