kopia lustrzana https://github.com/ryukoposting/Signal-Android
126 wiersze
4.0 KiB
Java
126 wiersze
4.0 KiB
Java
package org.thoughtcrime.securesms.jobs;
|
|
|
|
import android.content.Context;
|
|
import android.support.annotation.NonNull;
|
|
import android.support.annotation.Nullable;
|
|
import android.telephony.SmsMessage;
|
|
import android.util.Log;
|
|
|
|
import org.thoughtcrime.securesms.database.DatabaseFactory;
|
|
import org.thoughtcrime.securesms.database.MessagingDatabase.InsertResult;
|
|
import org.thoughtcrime.securesms.database.SmsDatabase;
|
|
import org.thoughtcrime.securesms.jobs.requirements.MasterSecretRequirement;
|
|
import org.thoughtcrime.securesms.jobs.requirements.SqlCipherMigrationRequirement;
|
|
import org.thoughtcrime.securesms.notifications.MessageNotifier;
|
|
import org.thoughtcrime.securesms.recipients.Recipient;
|
|
import org.thoughtcrime.securesms.sms.IncomingTextMessage;
|
|
import org.thoughtcrime.securesms.util.TextSecurePreferences;
|
|
import org.whispersystems.jobqueue.JobParameters;
|
|
import org.whispersystems.libsignal.util.guava.Optional;
|
|
|
|
import java.util.LinkedList;
|
|
import java.util.List;
|
|
|
|
public class SmsReceiveJob extends ContextJob {
|
|
|
|
private static final long serialVersionUID = 1L;
|
|
|
|
private static final String TAG = SmsReceiveJob.class.getSimpleName();
|
|
|
|
private final @Nullable Object[] pdus;
|
|
private final int subscriptionId;
|
|
|
|
public SmsReceiveJob(@NonNull Context context, @Nullable Object[] pdus, int subscriptionId) {
|
|
super(context, JobParameters.newBuilder()
|
|
.withPersistence()
|
|
.withWakeLock(true)
|
|
.withRequirement(new SqlCipherMigrationRequirement(context))
|
|
.create());
|
|
|
|
this.pdus = pdus;
|
|
this.subscriptionId = subscriptionId;
|
|
}
|
|
|
|
@Override
|
|
public void onAdded() {}
|
|
|
|
@Override
|
|
public void onRun() throws MigrationPendingException {
|
|
Log.w(TAG, "onRun()");
|
|
|
|
Optional<IncomingTextMessage> message = assembleMessageFragments(pdus, subscriptionId);
|
|
|
|
if (message.isPresent() && !isBlocked(message.get())) {
|
|
Optional<InsertResult> insertResult = storeMessage(message.get());
|
|
|
|
if (insertResult.isPresent()) {
|
|
MessageNotifier.updateNotification(context, insertResult.get().getThreadId());
|
|
}
|
|
} else if (message.isPresent()) {
|
|
Log.w(TAG, "*** Received blocked SMS, ignoring...");
|
|
} else {
|
|
Log.w(TAG, "*** Failed to assemble message fragments!");
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onCanceled() {
|
|
|
|
}
|
|
|
|
@Override
|
|
public boolean onShouldRetry(Exception exception) {
|
|
return exception instanceof MigrationPendingException;
|
|
}
|
|
|
|
private boolean isBlocked(IncomingTextMessage message) {
|
|
if (message.getSender() != null) {
|
|
Recipient recipient = Recipient.from(context, message.getSender(), false);
|
|
return recipient.isBlocked();
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
private Optional<InsertResult> storeMessage(IncomingTextMessage message) throws MigrationPendingException {
|
|
SmsDatabase database = DatabaseFactory.getSmsDatabase(context);
|
|
database.ensureMigration();
|
|
|
|
if (TextSecurePreferences.getNeedsSqlCipherMigration(context)) {
|
|
throw new MigrationPendingException();
|
|
}
|
|
|
|
if (message.isSecureMessage()) {
|
|
IncomingTextMessage placeholder = new IncomingTextMessage(message, "");
|
|
Optional<InsertResult> insertResult = database.insertMessageInbox(placeholder);
|
|
database.markAsLegacyVersion(insertResult.get().getMessageId());
|
|
|
|
return insertResult;
|
|
} else {
|
|
return database.insertMessageInbox(message);
|
|
}
|
|
}
|
|
|
|
private Optional<IncomingTextMessage> assembleMessageFragments(@Nullable Object[] pdus, int subscriptionId) {
|
|
if (pdus == null) {
|
|
return Optional.absent();
|
|
}
|
|
|
|
List<IncomingTextMessage> messages = new LinkedList<>();
|
|
|
|
for (Object pdu : pdus) {
|
|
messages.add(new IncomingTextMessage(context, SmsMessage.createFromPdu((byte[])pdu), subscriptionId));
|
|
}
|
|
|
|
if (messages.isEmpty()) {
|
|
return Optional.absent();
|
|
}
|
|
|
|
return Optional.of(new IncomingTextMessage(messages));
|
|
}
|
|
|
|
private class MigrationPendingException extends Exception {
|
|
|
|
}
|
|
}
|