|
|
@ -12,6 +12,7 @@ import org.session.libsession.messaging.messages.Message
|
|
|
|
import org.session.libsession.messaging.messages.visible.VisibleMessage
|
|
|
|
import org.session.libsession.messaging.messages.visible.VisibleMessage
|
|
|
|
import org.session.libsession.messaging.sending_receiving.MessageSender
|
|
|
|
import org.session.libsession.messaging.sending_receiving.MessageSender
|
|
|
|
import org.session.libsession.messaging.utilities.Data
|
|
|
|
import org.session.libsession.messaging.utilities.Data
|
|
|
|
|
|
|
|
import org.session.libsession.snode.OnionRequestAPI
|
|
|
|
import org.session.libsignal.utilities.Log
|
|
|
|
import org.session.libsignal.utilities.Log
|
|
|
|
|
|
|
|
|
|
|
|
class MessageSendJob(val message: Message, val destination: Destination) : Job {
|
|
|
|
class MessageSendJob(val message: Message, val destination: Destination) : Job {
|
|
|
@ -72,6 +73,9 @@ class MessageSendJob(val message: Message, val destination: Destination) : Job {
|
|
|
|
if (exception is MessageSender.Error) {
|
|
|
|
if (exception is MessageSender.Error) {
|
|
|
|
if (!exception.isRetryable) { this.handlePermanentFailure(exception) }
|
|
|
|
if (!exception.isRetryable) { this.handlePermanentFailure(exception) }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (exception is OnionRequestAPI.HTTPRequestFailedAtDestinationException && exception.statusCode == 429) {
|
|
|
|
|
|
|
|
this.handlePermanentFailure(exception)
|
|
|
|
|
|
|
|
}
|
|
|
|
this.handleFailure(exception)
|
|
|
|
this.handleFailure(exception)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|