TheArchive/session-android
1
0
Fork 0
mirror of https://github.com/oxen-io/session-android.git synced 2025-06-08 20:18:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle GV2 sync messages.

Browse Source
This commit is contained in:
Alan Evans 2020-08-31 12:07:03 -03:00 committed by GitHub
parent e316a70b6c
commit e8be1ad752
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 33 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
app/src/main/java/org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java
View File

@ -14,7 +14,6 @@ import com.annimon.stream.Collectors;
import com.annimon.stream.Stream; import com.annimon.stream.Stream;
import org.signal.zkgroup.VerificationFailedException; import org.signal.zkgroup.VerificationFailedException;
import org.signal.zkgroup.groups.GroupMasterKey;
import org.signal.zkgroup.profiles.ProfileKey; import org.signal.zkgroup.profiles.ProfileKey;
import org.thoughtcrime.securesms.ApplicationContext; import org.thoughtcrime.securesms.ApplicationContext;
import org.thoughtcrime.securesms.attachments.Attachment; import org.thoughtcrime.securesms.attachments.Attachment;
@ -346,10 +345,9 @@ public final class PushProcessMessageJob extends BaseJob {
boolean isGv2Message = groupId.isPresent() && groupId.get().isV2(); boolean isGv2Message = groupId.isPresent() && groupId.get().isV2();
if (isGv2Message) { if (isGv2Message) {
GroupMasterKey groupMasterKey = message.getGroupContext().get().getGroupV2().get().getMasterKey(); GroupId.V2 groupIdV2 = groupId.get().requireV2();
GroupId.V2 groupIdV2 = groupId.get().requireV2();
if (!groupV2PreProcessMessage(content, groupMasterKey, message.getGroupContext().get().getGroupV2().get())) { if (!updateGv2GroupFromServerOrP2PChange(content, message.getGroupContext().get().getGroupV2().get())) {
Log.i(TAG, "Ignoring GV2 message for group we are not currently in " + groupIdV2); Log.i(TAG, "Ignoring GV2 message for group we are not currently in " + groupIdV2);
return; return;
} }
@ -434,18 +432,20 @@ public final class PushProcessMessageJob extends BaseJob {
} }
/** /**
* Attempts to update the group to the version mentioned in the message. * Attempts to update the group to the revision mentioned in the message.
* If the local version is at least that it will not check the server. * If the local version is at least the revision in the message it will not query the server.
* If the message includes a signed change proto that is sufficient (i.e. local revision is only
* 1 revision behind), it will also not query the server in this case.
* *
* @return false iff self is not a current member of the group. * @return false iff needed to query the server and was not able to because self is not a current
* member of the group.
*/ */
private boolean groupV2PreProcessMessage(@NonNull SignalServiceContent content, private boolean updateGv2GroupFromServerOrP2PChange(@NonNull SignalServiceContent content,
@NonNull GroupMasterKey groupMasterKey, @NonNull SignalServiceGroupV2 groupV2)
@NonNull SignalServiceGroupV2 groupV2)
throws IOException, GroupChangeBusyException throws IOException, GroupChangeBusyException
{ {
try { try {
GroupManager.updateGroupFromServer(context, groupMasterKey, groupV2.getRevision(), content.getTimestamp(), groupV2.getSignedGroupChange()); GroupManager.updateGroupFromServer(context, groupV2.getMasterKey(), groupV2.getRevision(), content.getTimestamp(), groupV2.getSignedGroupChange());
return true; return true;
} catch (GroupNotAMemberException e) { } catch (GroupNotAMemberException e) {
Log.w(TAG, "Ignoring message for a group we're not in"); Log.w(TAG, "Ignoring message for a group we're not in");
@ -898,25 +898,28 @@ public final class PushProcessMessageJob extends BaseJob {
private void handleSynchronizeSentMessage(@NonNull SignalServiceContent content, private void handleSynchronizeSentMessage(@NonNull SignalServiceContent content,
@NonNull SentTranscriptMessage message) @NonNull SentTranscriptMessage message)
throws StorageFailedException, BadGroupIdException, VerificationFailedException, IOException, InvalidGroupStateException throws StorageFailedException, BadGroupIdException, IOException, GroupChangeBusyException
{ {
try { try {
GroupDatabase groupDatabase = DatabaseFactory.getGroupDatabase(context); GroupDatabase groupDatabase = DatabaseFactory.getGroupDatabase(context);
Long threadId = null; long threadId = -1;
if (message.isRecipientUpdate()) { if (message.isRecipientUpdate()) {
handleGroupRecipientUpdate(message); handleGroupRecipientUpdate(message);
} else if (message.getMessage().isEndSession()) { } else if (message.getMessage().isEndSession()) {
threadId = handleSynchronizeSentEndSessionMessage(message); threadId = handleSynchronizeSentEndSessionMessage(message);
} else if (message.getMessage().isGroupV1Update()) { } else if (message.getMessage().isGroupV1Update()) {
threadId = GroupV1MessageProcessor.process(context, content, message.getMessage(), true); Long gv1ThreadId = GroupV1MessageProcessor.process(context, content, message.getMessage(), true);
threadId = gv1ThreadId == null ? -1 : gv1ThreadId;
} else if (message.getMessage().isGroupV2Update()) {
handleSynchronizeSentGv2Update(content, message);
threadId = DatabaseFactory.getThreadDatabase(context).getThreadIdFor(getSyncMessageDestination(message));
} else if (message.getMessage().isExpirationUpdate()) { } else if (message.getMessage().isExpirationUpdate()) {
threadId = handleSynchronizeSentExpirationUpdate(message); threadId = handleSynchronizeSentExpirationUpdate(message);
} else if (message.getMessage().getReaction().isPresent()) { } else if (message.getMessage().getReaction().isPresent()) {
handleReaction(content, message.getMessage()); handleReaction(content, message.getMessage());
threadId = DatabaseFactory.getThreadDatabase(context).getThreadIdFor(getSyncMessageDestination(message)); threadId = DatabaseFactory.getThreadDatabase(context).getThreadIdFor(getSyncMessageDestination(message));
threadId = threadId != -1 ? threadId : null;
} else if (message.getMessage().getRemoteDelete().isPresent()) { } else if (message.getMessage().getRemoteDelete().isPresent()) {
handleRemoteDelete(content, message.getMessage()); handleRemoteDelete(content, message.getMessage());
} else if (message.getMessage().getAttachments().isPresent() || message.getMessage().getQuote().isPresent() || message.getMessage().getPreviews().isPresent() || message.getMessage().getSticker().isPresent() || message.getMessage().isViewOnce()) { } else if (message.getMessage().getAttachments().isPresent() || message.getMessage().getQuote().isPresent() || message.getMessage().getPreviews().isPresent() || message.getMessage().getSticker().isPresent() || message.getMessage().isViewOnce()) {
@ -925,7 +928,8 @@ public final class PushProcessMessageJob extends BaseJob {
threadId = handleSynchronizeSentTextMessage(message); threadId = handleSynchronizeSentTextMessage(message);
} }
if (message.getMessage().getGroupContext().isPresent() && groupDatabase.isUnknownGroup(GroupUtil.idFromGroupContext(message.getMessage().getGroupContext().get()))) { handleUnknownGroupMessage(content, message.getMessage().getGroupContext().get()); if (message.getMessage().getGroupContext().isPresent() && groupDatabase.isUnknownGroup(GroupUtil.idFromGroupContext(message.getMessage().getGroupContext().get()))) {
handleUnknownGroupMessage(content, message.getMessage().getGroupContext().get());
} }
if (message.getMessage().getProfileKey().isPresent()) { if (message.getMessage().getProfileKey().isPresent()) {
@ -936,7 +940,7 @@ public final class PushProcessMessageJob extends BaseJob {
} }
} }
if (threadId != null) { if (threadId != -1) {
DatabaseFactory.getThreadDatabase(context).setRead(threadId, true); DatabaseFactory.getThreadDatabase(context).setRead(threadId, true);
ApplicationDependencies.getMessageNotifier().updateNotification(context); ApplicationDependencies.getMessageNotifier().updateNotification(context);
} }
@ -947,6 +951,18 @@ public final class PushProcessMessageJob extends BaseJob {
} }
} }
private void handleSynchronizeSentGv2Update(@NonNull SignalServiceContent content,
@NonNull SentTranscriptMessage message)
throws IOException, GroupChangeBusyException
{
SignalServiceGroupV2 signalServiceGroupV2 = message.getMessage().getGroupContext().get().getGroupV2().get();
GroupId.V2 groupIdV2 = GroupId.v2(signalServiceGroupV2.getMasterKey());
if (!updateGv2GroupFromServerOrP2PChange(content, signalServiceGroupV2)) {
Log.i(TAG, "Ignoring GV2 message for group we are not currently in " + groupIdV2);
}
}
private void handleSynchronizeRequestMessage(@NonNull RequestMessage message) private void handleSynchronizeRequestMessage(@NonNull RequestMessage message)
{ {
if (message.isContactsRequest()) { if (message.isContactsRequest()) {