mirror of
https://github.com/oxen-io/session-android.git
synced 2024-12-01 05:55:18 +00:00
42f1baaf61
We have to make some changes, and it's gotten to the point where maintaining it as a separate library is more hassle than it's worth, especially with Google releasing WorkManager as the preferred job scheduling library.
110 lines
4.3 KiB
Java
110 lines
4.3 KiB
Java
package org.thoughtcrime.securesms.jobs;
|
|
|
|
|
|
import android.content.Context;
|
|
import android.util.Log;
|
|
|
|
import org.thoughtcrime.securesms.database.Address;
|
|
import org.thoughtcrime.securesms.database.DatabaseFactory;
|
|
import org.thoughtcrime.securesms.database.GroupDatabase;
|
|
import org.thoughtcrime.securesms.database.GroupDatabase.GroupRecord;
|
|
import org.thoughtcrime.securesms.dependencies.InjectableType;
|
|
import org.thoughtcrime.securesms.jobmanager.JobParameters;
|
|
import org.thoughtcrime.securesms.jobmanager.requirements.NetworkRequirement;
|
|
import org.thoughtcrime.securesms.util.GroupUtil;
|
|
import org.whispersystems.libsignal.util.guava.Optional;
|
|
import org.whispersystems.signalservice.api.SignalServiceMessageSender;
|
|
import org.whispersystems.signalservice.api.crypto.UntrustedIdentityException;
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceAttachment;
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceAttachmentStream;
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceDataMessage;
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceGroup;
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceGroup.Type;
|
|
import org.whispersystems.signalservice.api.push.SignalServiceAddress;
|
|
import org.whispersystems.signalservice.api.push.exceptions.PushNetworkException;
|
|
|
|
import java.io.ByteArrayInputStream;
|
|
import java.io.IOException;
|
|
import java.util.LinkedList;
|
|
import java.util.List;
|
|
|
|
import javax.inject.Inject;
|
|
|
|
public class PushGroupUpdateJob extends ContextJob implements InjectableType {
|
|
|
|
private static final String TAG = PushGroupUpdateJob.class.getSimpleName();
|
|
|
|
private static final long serialVersionUID = 0L;
|
|
|
|
@Inject transient SignalServiceMessageSender messageSender;
|
|
|
|
private final String source;
|
|
private final byte[] groupId;
|
|
|
|
|
|
public PushGroupUpdateJob(Context context, String source, byte[] groupId) {
|
|
super(context, JobParameters.newBuilder()
|
|
.withPersistence()
|
|
.withRequirement(new NetworkRequirement(context))
|
|
.withRetryCount(50)
|
|
.create());
|
|
|
|
this.source = source;
|
|
this.groupId = groupId;
|
|
}
|
|
|
|
@Override
|
|
public void onAdded() {}
|
|
|
|
@Override
|
|
public void onRun() throws IOException, UntrustedIdentityException {
|
|
GroupDatabase groupDatabase = DatabaseFactory.getGroupDatabase(context);
|
|
Optional<GroupRecord> record = groupDatabase.getGroup(GroupUtil.getEncodedId(groupId, false));
|
|
SignalServiceAttachment avatar = null;
|
|
|
|
if (record == null) {
|
|
Log.w(TAG, "No information for group record info request: " + new String(groupId));
|
|
return;
|
|
}
|
|
|
|
if (record.get().getAvatar() != null) {
|
|
avatar = SignalServiceAttachmentStream.newStreamBuilder()
|
|
.withContentType("image/jpeg")
|
|
.withStream(new ByteArrayInputStream(record.get().getAvatar()))
|
|
.withLength(record.get().getAvatar().length)
|
|
.build();
|
|
}
|
|
|
|
List<String> members = new LinkedList<>();
|
|
|
|
for (Address member : record.get().getMembers()) {
|
|
members.add(member.serialize());
|
|
}
|
|
|
|
SignalServiceGroup groupContext = SignalServiceGroup.newBuilder(Type.UPDATE)
|
|
.withAvatar(avatar)
|
|
.withId(groupId)
|
|
.withMembers(members)
|
|
.withName(record.get().getTitle())
|
|
.build();
|
|
|
|
SignalServiceDataMessage message = SignalServiceDataMessage.newBuilder()
|
|
.asGroupMessage(groupContext)
|
|
.withTimestamp(System.currentTimeMillis())
|
|
.build();
|
|
|
|
messageSender.sendMessage(new SignalServiceAddress(source), message);
|
|
}
|
|
|
|
@Override
|
|
public boolean onShouldRetry(Exception e) {
|
|
Log.w(TAG, e);
|
|
return e instanceof PushNetworkException;
|
|
}
|
|
|
|
@Override
|
|
public void onCanceled() {
|
|
|
|
}
|
|
}
|