2019-10-01 16:12:37 +10:00
|
|
|
package org.thoughtcrime.securesms.loki
|
|
|
|
|
|
|
|
import android.content.Context
|
|
|
|
import android.os.Handler
|
|
|
|
import android.os.Looper
|
2019-10-02 12:20:18 +10:00
|
|
|
import nl.komponents.kovenant.Promise
|
|
|
|
import nl.komponents.kovenant.deferred
|
2019-10-01 16:12:37 +10:00
|
|
|
import org.thoughtcrime.securesms.ApplicationContext
|
2019-10-02 14:22:09 +10:00
|
|
|
import org.thoughtcrime.securesms.database.DatabaseFactory
|
2019-10-01 16:12:37 +10:00
|
|
|
import org.thoughtcrime.securesms.logging.Log
|
|
|
|
import org.whispersystems.libsignal.util.guava.Optional
|
|
|
|
import org.whispersystems.signalservice.api.crypto.UnidentifiedAccessPair
|
|
|
|
import org.whispersystems.signalservice.api.messages.SignalServiceDataMessage
|
|
|
|
import org.whispersystems.signalservice.api.push.SignalServiceAddress
|
|
|
|
import org.whispersystems.signalservice.loki.api.LokiPairingAuthorisation
|
|
|
|
|
2019-10-02 12:20:18 +10:00
|
|
|
fun sendAuthorisationMessage(context: Context, contactHexEncodedPublicKey: String, authorisation: LokiPairingAuthorisation): Promise<Unit, Exception> {
|
2019-10-02 14:22:09 +10:00
|
|
|
val messageSender = ApplicationContext.getInstance(context).communicationModule.provideSignalMessageSender()
|
|
|
|
val address = SignalServiceAddress(contactHexEncodedPublicKey)
|
|
|
|
val message = SignalServiceDataMessage.newBuilder().withBody("").withPairingAuthorisation(authorisation)
|
2019-10-02 12:20:18 +10:00
|
|
|
|
2019-10-02 14:22:09 +10:00
|
|
|
// A REQUEST should always act as a friend request. A GRANT should always be replying back as a normal message.
|
|
|
|
if (authorisation.type == LokiPairingAuthorisation.Type.REQUEST) {
|
|
|
|
val preKeyBundle = DatabaseFactory.getLokiPreKeyBundleDatabase(context).generatePreKeyBundle(address.number)
|
|
|
|
message.asFriendRequest(true).withPreKeyBundle(preKeyBundle)
|
|
|
|
}
|
|
|
|
|
|
|
|
return try {
|
|
|
|
Log.d("Loki", "Sending authorisation message to $contactHexEncodedPublicKey")
|
|
|
|
val result = messageSender.sendMessage(0, address, Optional.absent<UnidentifiedAccessPair>(), message.build())
|
|
|
|
if (result.success == null) {
|
|
|
|
val exception = when {
|
|
|
|
result.isNetworkFailure -> "Failed to send authorisation message because of a Network Error"
|
|
|
|
else -> "Failed to send authorisation message"
|
2019-10-02 12:20:18 +10:00
|
|
|
}
|
|
|
|
|
2019-10-02 14:22:09 +10:00
|
|
|
throw Exception(exception)
|
2019-10-01 16:12:37 +10:00
|
|
|
}
|
2019-10-02 14:22:09 +10:00
|
|
|
Promise.ofSuccess(Unit)
|
|
|
|
} catch (e: Exception) {
|
|
|
|
Log.d("Loki", "Failed to send authorisation message to: $contactHexEncodedPublicKey.")
|
|
|
|
Promise.ofFail(e)
|
2019-10-01 16:12:37 +10:00
|
|
|
}
|
|
|
|
}
|