67 lines
2.3 KiB
Java
67 lines
2.3 KiB
Java
package org.thoughtcrime.securesms.jobs;
|
|
|
|
import android.content.Context;
|
|
import android.util.Log;
|
|
|
|
import org.thoughtcrime.securesms.dependencies.InjectableType;
|
|
import org.whispersystems.jobqueue.JobParameters;
|
|
import org.whispersystems.jobqueue.requirements.NetworkRequirement;
|
|
import org.whispersystems.textsecure.api.TextSecureMessageSender;
|
|
import org.whispersystems.textsecure.api.push.PushAddress;
|
|
import org.whispersystems.textsecure.api.push.exceptions.NonSuccessfulResponseCodeException;
|
|
import org.whispersystems.textsecure.api.push.exceptions.PushNetworkException;
|
|
|
|
import java.io.IOException;
|
|
|
|
import javax.inject.Inject;
|
|
|
|
import static org.thoughtcrime.securesms.dependencies.TextSecureCommunicationModule.TextSecureMessageSenderFactory;
|
|
|
|
public class DeliveryReceiptJob extends ContextJob implements InjectableType {
|
|
|
|
private static final String TAG = DeliveryReceiptJob.class.getSimpleName();
|
|
|
|
@Inject transient TextSecureMessageSenderFactory messageSenderFactory;
|
|
|
|
private final String destination;
|
|
private final long timestamp;
|
|
private final String relay;
|
|
|
|
public DeliveryReceiptJob(Context context, String destination, long timestamp, String relay) {
|
|
super(context, JobParameters.newBuilder()
|
|
.withRequirement(new NetworkRequirement(context))
|
|
.withPersistence()
|
|
.withRetryCount(50)
|
|
.create());
|
|
|
|
this.destination = destination;
|
|
this.timestamp = timestamp;
|
|
this.relay = relay;
|
|
}
|
|
|
|
@Override
|
|
public void onAdded() {}
|
|
|
|
@Override
|
|
public void onRun() throws IOException {
|
|
Log.w("DeliveryReceiptJob", "Sending delivery receipt...");
|
|
TextSecureMessageSender messageSender = messageSenderFactory.create(null);
|
|
PushAddress pushAddress = new PushAddress(-1, destination, 1, relay);
|
|
|
|
messageSender.sendDeliveryReceipt(pushAddress, timestamp);
|
|
}
|
|
|
|
@Override
|
|
public void onCanceled() {
|
|
Log.w(TAG, "Failed to send receipt after retry exhausted!");
|
|
}
|
|
|
|
@Override
|
|
public boolean onShouldRetry(Exception exception) {
|
|
Log.w(TAG, exception);
|
|
if (exception instanceof NonSuccessfulResponseCodeException) return false;
|
|
if (exception instanceof PushNetworkException) return true;
|
|
|
|
return false;
|
|
}
|
|
}
|