2018-11-08 18:08:14 +00:00
|
|
|
package im.vector.matrix.android.internal.session.room.send
|
|
|
|
|
2018-11-09 13:06:23 +00:00
|
|
|
import androidx.work.*
|
2018-11-08 18:08:14 +00:00
|
|
|
import im.vector.matrix.android.api.session.room.SendService
|
|
|
|
import im.vector.matrix.android.api.util.Cancelable
|
|
|
|
import im.vector.matrix.android.internal.util.CancelableWork
|
2018-11-09 13:06:23 +00:00
|
|
|
import im.vector.matrix.android.internal.util.WorkerParamsFactory
|
2018-11-08 18:08:14 +00:00
|
|
|
import java.util.concurrent.TimeUnit
|
|
|
|
|
2018-11-09 13:06:23 +00:00
|
|
|
private const val SEND_WORK = "SEND_WORK"
|
2018-11-08 18:08:14 +00:00
|
|
|
|
2018-11-13 09:48:05 +00:00
|
|
|
internal class DefaultSendService(private val roomId: String) : SendService {
|
2018-11-08 18:08:14 +00:00
|
|
|
|
|
|
|
private val sendConstraints = Constraints.Builder()
|
|
|
|
.setRequiredNetworkType(NetworkType.CONNECTED)
|
|
|
|
.build()
|
|
|
|
|
|
|
|
override fun sendTextMessage(text: String): Cancelable {
|
|
|
|
|
2018-11-13 09:48:05 +00:00
|
|
|
val sendContentWorkerParams = SendEventWorker.Params(roomId, text)
|
2018-11-09 13:06:23 +00:00
|
|
|
val workData = WorkerParamsFactory.toData(sendContentWorkerParams)
|
2018-11-08 18:08:14 +00:00
|
|
|
|
2018-11-09 13:06:23 +00:00
|
|
|
val sendWork = OneTimeWorkRequestBuilder<SendEventWorker>()
|
2018-11-08 18:08:14 +00:00
|
|
|
.setConstraints(sendConstraints)
|
|
|
|
.setInputData(workData)
|
|
|
|
.setBackoffCriteria(BackoffPolicy.LINEAR, 10_000, TimeUnit.MILLISECONDS)
|
|
|
|
.build()
|
|
|
|
|
|
|
|
val work = WorkManager.getInstance()
|
2018-11-09 13:06:23 +00:00
|
|
|
.beginUniqueWork(SEND_WORK, ExistingWorkPolicy.APPEND, sendWork)
|
2018-11-08 18:08:14 +00:00
|
|
|
.enqueue()
|
|
|
|
|
|
|
|
return CancelableWork(work)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|