empathicqubit/Signal-Android
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Fix retry issues with RotateProfileKeyJob.

Browse source
This commit is contained in:
Greyson Parrelli 2020-07-19 10:38:57 -04:00
parent 5468f1705c
commit 6a9476c6d0
3 changed files with 12 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
app/src/main/java/org/thoughtcrime/securesms/jobs/ProfileUploadJob.java
View file

@ -19,6 +19,8 @@ import org.thoughtcrime.securesms.util.TextSecurePreferences;
import org.whispersystems.signalservice.api.SignalServiceAccountManager;
import org.whispersystems.signalservice.api.util.StreamDetails;
import java.util.concurrent.TimeUnit;
public final class ProfileUploadJob extends BaseJob {
private static final String TAG = Log.tag(ProfileUploadJob.class);
@ -34,9 +36,9 @@ public final class ProfileUploadJob extends BaseJob {
this(new Job.Parameters.Builder()
.addConstraint(NetworkConstraint.KEY)
.setQueue(QUEUE)
.setLifespan(Parameters.IMMORTAL)
.setLifespan(TimeUnit.DAYS.toMillis(30))
.setMaxAttempts(Parameters.UNLIMITED)
.setMaxInstances(1)
.setMaxInstances(2)
.build());
}

1
app/src/main/java/org/thoughtcrime/securesms/jobs/RefreshAttributesJob.java
View file

@ -31,6 +31,7 @@ public class RefreshAttributesJob extends BaseJob {
this(new Job.Parameters.Builder()
.addConstraint(NetworkConstraint.KEY)
.setQueue("RefreshAttributesJob")
.setMaxInstances(2)
.build());
}

25
app/src/main/java/org/thoughtcrime/securesms/jobs/RotateProfileKeyJob.java
View file

@ -26,9 +26,7 @@ public class RotateProfileKeyJob extends BaseJob {
public RotateProfileKeyJob() {
this(new Job.Parameters.Builder()
.setQueue("__ROTATE_PROFILE_KEY__")
.addConstraint(NetworkConstraint.KEY)
.setMaxAttempts(25)
.setMaxInstances(1)
.setMaxInstances(2)
.build());
}
@ -47,21 +45,13 @@ public class RotateProfileKeyJob extends BaseJob {
}
@Override
public void onRun() throws Exception {
SignalServiceAccountManager accountManager = ApplicationDependencies.getSignalServiceAccountManager();
RecipientDatabase recipientDatabase = DatabaseFactory.getRecipientDatabase(context);
ProfileKey profileKey = ProfileKeyUtil.createNew();
Recipient self = Recipient.self();
public void onRun() {
ProfileKey newProfileKey = ProfileKeyUtil.createNew();
Recipient self = Recipient.self();
recipientDatabase.setProfileKey(self.getId(), profileKey);
try (StreamDetails avatarStream = AvatarHelper.getSelfProfileAvatarStream(context)) {
accountManager.setVersionedProfile(self.getUuid().get(),
profileKey,
Recipient.self().getProfileName().serialize(),
avatarStream);
}
DatabaseFactory.getRecipientDatabase(context).setProfileKey(self.getId(), newProfileKey);
ApplicationDependencies.getJobManager().add(new ProfileUploadJob());
ApplicationDependencies.getJobManager().add(new RefreshAttributesJob());
updateProfileKeyOnAllV2Groups();
@ -77,12 +67,11 @@ public class RotateProfileKeyJob extends BaseJob {
@Override
public void onFailure() {
}
@Override
protected boolean onShouldRetry(@NonNull Exception exception) {
return exception instanceof PushNetworkException;
return false;
}
public static final class Factory implements Job.Factory<RotateProfileKeyJob> {