2022-01-14 06:56:15 +01:00
|
|
|
package org.thoughtcrime.securesms.repository
|
|
|
|
|
|
|
|
import org.session.libsession.database.MessageDataProvider
|
2022-03-04 07:46:39 +01:00
|
|
|
import org.session.libsession.messaging.messages.Destination
|
|
|
|
import org.session.libsession.messaging.messages.control.MessageRequestResponse
|
2022-01-14 06:56:15 +01:00
|
|
|
import org.session.libsession.messaging.messages.control.UnsendRequest
|
|
|
|
import org.session.libsession.messaging.messages.signal.OutgoingTextMessage
|
|
|
|
import org.session.libsession.messaging.messages.visible.OpenGroupInvitation
|
|
|
|
import org.session.libsession.messaging.messages.visible.VisibleMessage
|
2022-08-10 10:17:48 +02:00
|
|
|
import org.session.libsession.messaging.open_groups.OpenGroupApi
|
2022-01-14 06:56:15 +01:00
|
|
|
import org.session.libsession.messaging.sending_receiving.MessageSender
|
|
|
|
import org.session.libsession.snode.SnodeAPI
|
|
|
|
import org.session.libsession.utilities.Address
|
|
|
|
import org.session.libsession.utilities.GroupUtil
|
|
|
|
import org.session.libsession.utilities.TextSecurePreferences
|
|
|
|
import org.session.libsession.utilities.recipients.Recipient
|
|
|
|
import org.session.libsignal.utilities.toHexString
|
|
|
|
import org.thoughtcrime.securesms.database.DraftDatabase
|
|
|
|
import org.thoughtcrime.securesms.database.LokiMessageDatabase
|
|
|
|
import org.thoughtcrime.securesms.database.LokiThreadDatabase
|
|
|
|
import org.thoughtcrime.securesms.database.MmsDatabase
|
2022-03-04 07:46:39 +01:00
|
|
|
import org.thoughtcrime.securesms.database.MmsSmsDatabase
|
2022-01-14 06:56:15 +01:00
|
|
|
import org.thoughtcrime.securesms.database.RecipientDatabase
|
2022-03-04 07:46:39 +01:00
|
|
|
import org.thoughtcrime.securesms.database.SessionJobDatabase
|
2022-01-14 06:56:15 +01:00
|
|
|
import org.thoughtcrime.securesms.database.SmsDatabase
|
|
|
|
import org.thoughtcrime.securesms.database.ThreadDatabase
|
|
|
|
import org.thoughtcrime.securesms.database.model.MessageRecord
|
2022-03-04 07:46:39 +01:00
|
|
|
import org.thoughtcrime.securesms.database.model.ThreadRecord
|
2022-01-14 06:56:15 +01:00
|
|
|
import javax.inject.Inject
|
|
|
|
import kotlin.coroutines.resume
|
|
|
|
import kotlin.coroutines.resumeWithException
|
|
|
|
import kotlin.coroutines.suspendCoroutine
|
|
|
|
|
|
|
|
interface ConversationRepository {
|
Performance improvements and bug fixes (#869)
* refactor: fail on testSnode instead of recursively using up snode list. add call timeout on http client
* refactor: refactoring batch message receives and pollers
* refactor: reduce thread utils pool count to a 2 thread fixed pool. Do a check against pubkey instead of room names for oxenHostedOpenGroup
* refactor: caching lib with potential loader fixes and no-cache for giphy
* refactor: remove store and instead use ConcurrentHashMap with a backing update coroutine
* refactor: queue trim thread jobs instead of add every message processed
* fix: wrapping auth token and initial sync for open groups in a threadutils queued runnable, getting initial sync times down
* fix: fixing the user contacts cache in ConversationAdapter.kt
* refactor: improve polling and initial sync, move group joins from config messages into a background job fetching image.
* refactor: improving the job queuing for open groups, replacing placeholder avatar generation with a custom glide loader and archiving initial sync of open groups
* feat: add OpenGroupDeleteJob.kt
* feat: add open group delete job to process deletions after batch adding
* feat: add vacuum and fix job queue re-adding jobs forever, only try to set message hash values in DB if they have changed
* refactor: remove redundant inflation for profile image views throughout app
* refactor(wip): reducing layout inflation and starting to refactor the open group deletion issues taking a long time
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* fix: group deletion optimisation
* build: bump build number
* build: bump build number and fix batch message receive retry logic
* fix: clear out open group deletes
* fix: update visible ConversationAdapter.kt binding for initial contact fetching and better traces for debugging background jobs
* fix: add in check for / force sync latest encryption key pair from linked devices if we already have that closed group
* Rename .java to .kt
* refactor: change MmsDatabase to kotlin to make list operations easier
* fix: nullable type
* fix: compilation issues and constants in .kt instead of .java
* fix: bug fix expiration timer on closed group recipient
* feat: use the job queue properly across executors
* feat: start on open group dispatcher-specific logic, probably a queue factory based on openGroupId if that is the same across new message and deletion jobs to ensure consistent entry and removal
* refactor: removing redundant code and fixing jobqueue per opengroup
* fix: allow attachments in note to self
* fix: make the minWidth in quote view bind max of text / title and body, wrapped ?
* fix: fixing up layouts and code view layouts
* fix: remove TODO, remove timestamp binding
* feat: fix view logic, avatars and padding, downloading attachments lazily (on bind), fixing potential crash, add WindowDebouncer.kt
* fix: NPE on viewModel recipient from removed thread while tearing down the Recipient observer in ConversationActivityV2.kt
* refactor: replace conversation notification debouncer handler with handlerthread, same as conversation list debouncer
* refactor: UI for groups and poller improvements
* fix: revert some changes in poller
* feat: add header back in for message requests
* refactor: remove Trace calls, add more conditions to the HomeDiffUtil for updating more efficiently
* feat: try update the home adapter if we get a profile picture modified event
* feat: bump build numbers
* fix: try to start with list in homeViewModel if we don't have already, render quotes to be width of attachment slide view instead of fixed
* fix: set channel to be conflated instead of no buffer
* fix: set unreads based off last local user message vs incrementing unreads to be all amount
* feat: add profile update flag, update build number
* fix: link preview thumbnails download on bind
* fix: centercrop placeholder in glide request
* feat: recycle the contact selection list and profile image in unbind
* fix: try to prevent user KP crash at weird times
* fix: remove additional log, improve attachment download success rate, fix share logs dialog issue
2022-06-08 09:12:34 +02:00
|
|
|
fun maybeGetRecipientForThreadId(threadId: Long): Recipient?
|
2022-01-14 06:56:15 +01:00
|
|
|
fun saveDraft(threadId: Long, text: String)
|
|
|
|
fun getDraft(threadId: Long): String?
|
|
|
|
fun inviteContacts(threadId: Long, contacts: List<Recipient>)
|
2022-09-13 07:06:46 +02:00
|
|
|
fun setBlocked(recipient: Recipient, blocked: Boolean)
|
2022-01-14 06:56:15 +01:00
|
|
|
fun deleteLocally(recipient: Recipient, message: MessageRecord)
|
2022-03-09 23:54:18 +01:00
|
|
|
fun setApproved(recipient: Recipient, isApproved: Boolean)
|
2022-01-14 06:56:15 +01:00
|
|
|
|
|
|
|
suspend fun deleteForEveryone(
|
|
|
|
threadId: Long,
|
|
|
|
recipient: Recipient,
|
|
|
|
message: MessageRecord
|
|
|
|
): ResultOf<Unit>
|
|
|
|
|
|
|
|
fun buildUnsendRequest(recipient: Recipient, message: MessageRecord): UnsendRequest?
|
|
|
|
|
|
|
|
suspend fun deleteMessageWithoutUnsendRequest(
|
|
|
|
threadId: Long,
|
|
|
|
messages: Set<MessageRecord>
|
|
|
|
): ResultOf<Unit>
|
|
|
|
|
|
|
|
suspend fun banUser(threadId: Long, recipient: Recipient): ResultOf<Unit>
|
|
|
|
|
|
|
|
suspend fun banAndDeleteAll(threadId: Long, recipient: Recipient): ResultOf<Unit>
|
2022-03-04 07:46:39 +01:00
|
|
|
|
2022-09-13 07:06:46 +02:00
|
|
|
suspend fun deleteThread(threadId: Long): ResultOf<Unit>
|
|
|
|
|
2022-03-04 07:46:39 +01:00
|
|
|
suspend fun deleteMessageRequest(thread: ThreadRecord): ResultOf<Unit>
|
|
|
|
|
|
|
|
suspend fun clearAllMessageRequests(): ResultOf<Unit>
|
|
|
|
|
|
|
|
suspend fun acceptMessageRequest(threadId: Long, recipient: Recipient): ResultOf<Unit>
|
|
|
|
|
2022-09-13 07:06:46 +02:00
|
|
|
fun declineMessageRequest(threadId: Long)
|
2022-03-04 07:46:39 +01:00
|
|
|
|
|
|
|
fun hasReceived(threadId: Long): Boolean
|
|
|
|
|
2022-01-14 06:56:15 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
class DefaultConversationRepository @Inject constructor(
|
|
|
|
private val textSecurePreferences: TextSecurePreferences,
|
|
|
|
private val messageDataProvider: MessageDataProvider,
|
|
|
|
private val threadDb: ThreadDatabase,
|
|
|
|
private val draftDb: DraftDatabase,
|
|
|
|
private val lokiThreadDb: LokiThreadDatabase,
|
|
|
|
private val smsDb: SmsDatabase,
|
|
|
|
private val mmsDb: MmsDatabase,
|
2022-03-04 07:46:39 +01:00
|
|
|
private val mmsSmsDb: MmsSmsDatabase,
|
2022-01-14 06:56:15 +01:00
|
|
|
private val recipientDb: RecipientDatabase,
|
2022-03-04 07:46:39 +01:00
|
|
|
private val lokiMessageDb: LokiMessageDatabase,
|
|
|
|
private val sessionJobDb: SessionJobDatabase
|
2022-01-14 06:56:15 +01:00
|
|
|
) : ConversationRepository {
|
|
|
|
|
Performance improvements and bug fixes (#869)
* refactor: fail on testSnode instead of recursively using up snode list. add call timeout on http client
* refactor: refactoring batch message receives and pollers
* refactor: reduce thread utils pool count to a 2 thread fixed pool. Do a check against pubkey instead of room names for oxenHostedOpenGroup
* refactor: caching lib with potential loader fixes and no-cache for giphy
* refactor: remove store and instead use ConcurrentHashMap with a backing update coroutine
* refactor: queue trim thread jobs instead of add every message processed
* fix: wrapping auth token and initial sync for open groups in a threadutils queued runnable, getting initial sync times down
* fix: fixing the user contacts cache in ConversationAdapter.kt
* refactor: improve polling and initial sync, move group joins from config messages into a background job fetching image.
* refactor: improving the job queuing for open groups, replacing placeholder avatar generation with a custom glide loader and archiving initial sync of open groups
* feat: add OpenGroupDeleteJob.kt
* feat: add open group delete job to process deletions after batch adding
* feat: add vacuum and fix job queue re-adding jobs forever, only try to set message hash values in DB if they have changed
* refactor: remove redundant inflation for profile image views throughout app
* refactor(wip): reducing layout inflation and starting to refactor the open group deletion issues taking a long time
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* fix: group deletion optimisation
* build: bump build number
* build: bump build number and fix batch message receive retry logic
* fix: clear out open group deletes
* fix: update visible ConversationAdapter.kt binding for initial contact fetching and better traces for debugging background jobs
* fix: add in check for / force sync latest encryption key pair from linked devices if we already have that closed group
* Rename .java to .kt
* refactor: change MmsDatabase to kotlin to make list operations easier
* fix: nullable type
* fix: compilation issues and constants in .kt instead of .java
* fix: bug fix expiration timer on closed group recipient
* feat: use the job queue properly across executors
* feat: start on open group dispatcher-specific logic, probably a queue factory based on openGroupId if that is the same across new message and deletion jobs to ensure consistent entry and removal
* refactor: removing redundant code and fixing jobqueue per opengroup
* fix: allow attachments in note to self
* fix: make the minWidth in quote view bind max of text / title and body, wrapped ?
* fix: fixing up layouts and code view layouts
* fix: remove TODO, remove timestamp binding
* feat: fix view logic, avatars and padding, downloading attachments lazily (on bind), fixing potential crash, add WindowDebouncer.kt
* fix: NPE on viewModel recipient from removed thread while tearing down the Recipient observer in ConversationActivityV2.kt
* refactor: replace conversation notification debouncer handler with handlerthread, same as conversation list debouncer
* refactor: UI for groups and poller improvements
* fix: revert some changes in poller
* feat: add header back in for message requests
* refactor: remove Trace calls, add more conditions to the HomeDiffUtil for updating more efficiently
* feat: try update the home adapter if we get a profile picture modified event
* feat: bump build numbers
* fix: try to start with list in homeViewModel if we don't have already, render quotes to be width of attachment slide view instead of fixed
* fix: set channel to be conflated instead of no buffer
* fix: set unreads based off last local user message vs incrementing unreads to be all amount
* feat: add profile update flag, update build number
* fix: link preview thumbnails download on bind
* fix: centercrop placeholder in glide request
* feat: recycle the contact selection list and profile image in unbind
* fix: try to prevent user KP crash at weird times
* fix: remove additional log, improve attachment download success rate, fix share logs dialog issue
2022-06-08 09:12:34 +02:00
|
|
|
override fun maybeGetRecipientForThreadId(threadId: Long): Recipient? {
|
|
|
|
return threadDb.getRecipientForThreadId(threadId)
|
2022-01-14 06:56:15 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
override fun saveDraft(threadId: Long, text: String) {
|
|
|
|
if (text.isEmpty()) return
|
|
|
|
val drafts = DraftDatabase.Drafts()
|
|
|
|
drafts.add(DraftDatabase.Draft(DraftDatabase.Draft.TEXT, text))
|
|
|
|
draftDb.insertDrafts(threadId, drafts)
|
|
|
|
}
|
|
|
|
|
|
|
|
override fun getDraft(threadId: Long): String? {
|
|
|
|
val drafts = draftDb.getDrafts(threadId)
|
|
|
|
draftDb.clearDrafts(threadId)
|
|
|
|
return drafts.find { it.type == DraftDatabase.Draft.TEXT }?.value
|
|
|
|
}
|
|
|
|
|
|
|
|
override fun inviteContacts(threadId: Long, contacts: List<Recipient>) {
|
|
|
|
val openGroup = lokiThreadDb.getOpenGroupChat(threadId) ?: return
|
|
|
|
for (contact in contacts) {
|
|
|
|
val message = VisibleMessage()
|
|
|
|
message.sentTimestamp = System.currentTimeMillis()
|
|
|
|
val openGroupInvitation = OpenGroupInvitation()
|
|
|
|
openGroupInvitation.name = openGroup.name
|
|
|
|
openGroupInvitation.url = openGroup.joinURL
|
|
|
|
message.openGroupInvitation = openGroupInvitation
|
|
|
|
val outgoingTextMessage = OutgoingTextMessage.fromOpenGroupInvitation(
|
|
|
|
openGroupInvitation,
|
|
|
|
contact,
|
|
|
|
message.sentTimestamp
|
|
|
|
)
|
Performance improvements and bug fixes (#869)
* refactor: fail on testSnode instead of recursively using up snode list. add call timeout on http client
* refactor: refactoring batch message receives and pollers
* refactor: reduce thread utils pool count to a 2 thread fixed pool. Do a check against pubkey instead of room names for oxenHostedOpenGroup
* refactor: caching lib with potential loader fixes and no-cache for giphy
* refactor: remove store and instead use ConcurrentHashMap with a backing update coroutine
* refactor: queue trim thread jobs instead of add every message processed
* fix: wrapping auth token and initial sync for open groups in a threadutils queued runnable, getting initial sync times down
* fix: fixing the user contacts cache in ConversationAdapter.kt
* refactor: improve polling and initial sync, move group joins from config messages into a background job fetching image.
* refactor: improving the job queuing for open groups, replacing placeholder avatar generation with a custom glide loader and archiving initial sync of open groups
* feat: add OpenGroupDeleteJob.kt
* feat: add open group delete job to process deletions after batch adding
* feat: add vacuum and fix job queue re-adding jobs forever, only try to set message hash values in DB if they have changed
* refactor: remove redundant inflation for profile image views throughout app
* refactor(wip): reducing layout inflation and starting to refactor the open group deletion issues taking a long time
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* refactor(wip): refactoring group deletion to not iterate through and delete messages individually
* fix: group deletion optimisation
* build: bump build number
* build: bump build number and fix batch message receive retry logic
* fix: clear out open group deletes
* fix: update visible ConversationAdapter.kt binding for initial contact fetching and better traces for debugging background jobs
* fix: add in check for / force sync latest encryption key pair from linked devices if we already have that closed group
* Rename .java to .kt
* refactor: change MmsDatabase to kotlin to make list operations easier
* fix: nullable type
* fix: compilation issues and constants in .kt instead of .java
* fix: bug fix expiration timer on closed group recipient
* feat: use the job queue properly across executors
* feat: start on open group dispatcher-specific logic, probably a queue factory based on openGroupId if that is the same across new message and deletion jobs to ensure consistent entry and removal
* refactor: removing redundant code and fixing jobqueue per opengroup
* fix: allow attachments in note to self
* fix: make the minWidth in quote view bind max of text / title and body, wrapped ?
* fix: fixing up layouts and code view layouts
* fix: remove TODO, remove timestamp binding
* feat: fix view logic, avatars and padding, downloading attachments lazily (on bind), fixing potential crash, add WindowDebouncer.kt
* fix: NPE on viewModel recipient from removed thread while tearing down the Recipient observer in ConversationActivityV2.kt
* refactor: replace conversation notification debouncer handler with handlerthread, same as conversation list debouncer
* refactor: UI for groups and poller improvements
* fix: revert some changes in poller
* feat: add header back in for message requests
* refactor: remove Trace calls, add more conditions to the HomeDiffUtil for updating more efficiently
* feat: try update the home adapter if we get a profile picture modified event
* feat: bump build numbers
* fix: try to start with list in homeViewModel if we don't have already, render quotes to be width of attachment slide view instead of fixed
* fix: set channel to be conflated instead of no buffer
* fix: set unreads based off last local user message vs incrementing unreads to be all amount
* feat: add profile update flag, update build number
* fix: link preview thumbnails download on bind
* fix: centercrop placeholder in glide request
* feat: recycle the contact selection list and profile image in unbind
* fix: try to prevent user KP crash at weird times
* fix: remove additional log, improve attachment download success rate, fix share logs dialog issue
2022-06-08 09:12:34 +02:00
|
|
|
smsDb.insertMessageOutbox(-1, outgoingTextMessage, message.sentTimestamp!!, true)
|
2022-01-14 06:56:15 +01:00
|
|
|
MessageSender.send(message, contact.address)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-09-13 07:06:46 +02:00
|
|
|
override fun setBlocked(recipient: Recipient, blocked: Boolean) {
|
|
|
|
recipientDb.setBlocked(recipient, blocked)
|
2022-01-14 06:56:15 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
override fun deleteLocally(recipient: Recipient, message: MessageRecord) {
|
|
|
|
buildUnsendRequest(recipient, message)?.let { unsendRequest ->
|
|
|
|
textSecurePreferences.getLocalNumber()?.let {
|
|
|
|
MessageSender.send(unsendRequest, Address.fromSerialized(it))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
messageDataProvider.deleteMessage(message.id, !message.isMms)
|
|
|
|
}
|
|
|
|
|
2022-03-09 23:54:18 +01:00
|
|
|
override fun setApproved(recipient: Recipient, isApproved: Boolean) {
|
|
|
|
recipientDb.setApproved(recipient, isApproved)
|
|
|
|
}
|
|
|
|
|
2022-01-14 06:56:15 +01:00
|
|
|
override suspend fun deleteForEveryone(
|
|
|
|
threadId: Long,
|
|
|
|
recipient: Recipient,
|
|
|
|
message: MessageRecord
|
|
|
|
): ResultOf<Unit> = suspendCoroutine { continuation ->
|
|
|
|
buildUnsendRequest(recipient, message)?.let { unsendRequest ->
|
|
|
|
MessageSender.send(unsendRequest, recipient.address)
|
|
|
|
}
|
|
|
|
val openGroup = lokiThreadDb.getOpenGroupChat(threadId)
|
|
|
|
if (openGroup != null) {
|
|
|
|
lokiMessageDb.getServerID(message.id, !message.isMms)?.let { messageServerID ->
|
2022-08-10 10:17:48 +02:00
|
|
|
OpenGroupApi.deleteMessage(messageServerID, openGroup.room, openGroup.server)
|
2022-01-14 06:56:15 +01:00
|
|
|
.success {
|
|
|
|
messageDataProvider.deleteMessage(message.id, !message.isMms)
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
messageDataProvider.deleteMessage(message.id, !message.isMms)
|
|
|
|
messageDataProvider.getServerHashForMessage(message.id)?.let { serverHash ->
|
|
|
|
var publicKey = recipient.address.serialize()
|
|
|
|
if (recipient.isClosedGroupRecipient) {
|
|
|
|
publicKey = GroupUtil.doubleDecodeGroupID(publicKey).toHexString()
|
|
|
|
}
|
|
|
|
SnodeAPI.deleteMessage(publicKey, listOf(serverHash))
|
|
|
|
.success {
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
override fun buildUnsendRequest(recipient: Recipient, message: MessageRecord): UnsendRequest? {
|
|
|
|
if (recipient.isOpenGroupRecipient) return null
|
|
|
|
messageDataProvider.getServerHashForMessage(message.id) ?: return null
|
|
|
|
val unsendRequest = UnsendRequest()
|
|
|
|
if (message.isOutgoing) {
|
|
|
|
unsendRequest.author = textSecurePreferences.getLocalNumber()
|
|
|
|
} else {
|
|
|
|
unsendRequest.author = message.individualRecipient.address.contactIdentifier()
|
|
|
|
}
|
|
|
|
unsendRequest.timestamp = message.timestamp
|
|
|
|
|
|
|
|
return unsendRequest
|
|
|
|
}
|
|
|
|
|
|
|
|
override suspend fun deleteMessageWithoutUnsendRequest(
|
|
|
|
threadId: Long,
|
|
|
|
messages: Set<MessageRecord>
|
|
|
|
): ResultOf<Unit> = suspendCoroutine { continuation ->
|
|
|
|
val openGroup = lokiThreadDb.getOpenGroupChat(threadId)
|
|
|
|
if (openGroup != null) {
|
|
|
|
val messageServerIDs = mutableMapOf<Long, MessageRecord>()
|
|
|
|
for (message in messages) {
|
|
|
|
val messageServerID =
|
|
|
|
lokiMessageDb.getServerID(message.id, !message.isMms) ?: continue
|
|
|
|
messageServerIDs[messageServerID] = message
|
|
|
|
}
|
|
|
|
for ((messageServerID, message) in messageServerIDs) {
|
2022-08-10 10:17:48 +02:00
|
|
|
OpenGroupApi.deleteMessage(messageServerID, openGroup.room, openGroup.server)
|
2022-01-14 06:56:15 +01:00
|
|
|
.success {
|
|
|
|
messageDataProvider.deleteMessage(message.id, !message.isMms)
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
for (message in messages) {
|
|
|
|
if (message.isMms) {
|
|
|
|
mmsDb.deleteMessage(message.id)
|
|
|
|
} else {
|
|
|
|
smsDb.deleteMessage(message.id)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}
|
|
|
|
|
|
|
|
override suspend fun banUser(threadId: Long, recipient: Recipient): ResultOf<Unit> =
|
|
|
|
suspendCoroutine { continuation ->
|
|
|
|
val sessionID = recipient.address.toString()
|
|
|
|
val openGroup = lokiThreadDb.getOpenGroupChat(threadId)!!
|
2022-08-10 10:17:48 +02:00
|
|
|
OpenGroupApi.ban(sessionID, openGroup.room, openGroup.server)
|
2022-01-14 06:56:15 +01:00
|
|
|
.success {
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
override suspend fun banAndDeleteAll(threadId: Long, recipient: Recipient): ResultOf<Unit> =
|
|
|
|
suspendCoroutine { continuation ->
|
|
|
|
val sessionID = recipient.address.toString()
|
|
|
|
val openGroup = lokiThreadDb.getOpenGroupChat(threadId)!!
|
2022-08-10 10:17:48 +02:00
|
|
|
OpenGroupApi.banAndDeleteAll(sessionID, openGroup.room, openGroup.server)
|
2022-01-14 06:56:15 +01:00
|
|
|
.success {
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-09-13 07:06:46 +02:00
|
|
|
override suspend fun deleteThread(threadId: Long): ResultOf<Unit> {
|
|
|
|
sessionJobDb.cancelPendingMessageSendJobs(threadId)
|
|
|
|
threadDb.deleteConversation(threadId)
|
|
|
|
return ResultOf.Success(Unit)
|
|
|
|
}
|
|
|
|
|
2022-03-04 07:46:39 +01:00
|
|
|
override suspend fun deleteMessageRequest(thread: ThreadRecord): ResultOf<Unit> {
|
|
|
|
sessionJobDb.cancelPendingMessageSendJobs(thread.threadId)
|
2022-09-13 07:06:46 +02:00
|
|
|
threadDb.deleteConversation(thread.threadId)
|
2022-03-04 07:46:39 +01:00
|
|
|
return ResultOf.Success(Unit)
|
|
|
|
}
|
|
|
|
|
|
|
|
override suspend fun clearAllMessageRequests(): ResultOf<Unit> {
|
|
|
|
threadDb.readerFor(threadDb.unapprovedConversationList).use { reader ->
|
|
|
|
while (reader.next != null) {
|
|
|
|
deleteMessageRequest(reader.current)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return ResultOf.Success(Unit)
|
|
|
|
}
|
|
|
|
|
|
|
|
override suspend fun acceptMessageRequest(threadId: Long, recipient: Recipient): ResultOf<Unit> = suspendCoroutine { continuation ->
|
|
|
|
recipientDb.setApproved(recipient, true)
|
|
|
|
val message = MessageRequestResponse(true)
|
|
|
|
MessageSender.send(message, Destination.from(recipient.address))
|
|
|
|
.success {
|
|
|
|
threadDb.setHasSent(threadId, true)
|
|
|
|
continuation.resume(ResultOf.Success(Unit))
|
|
|
|
}.fail { error ->
|
|
|
|
continuation.resumeWithException(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-09-13 07:06:46 +02:00
|
|
|
override fun declineMessageRequest(threadId: Long) {
|
|
|
|
sessionJobDb.cancelPendingMessageSendJobs(threadId)
|
|
|
|
threadDb.deleteConversation(threadId)
|
2022-03-04 07:46:39 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
override fun hasReceived(threadId: Long): Boolean {
|
|
|
|
val cursor = mmsSmsDb.getConversation(threadId, true)
|
|
|
|
mmsSmsDb.readerFor(cursor).use { reader ->
|
|
|
|
while (reader.next != null) {
|
|
|
|
if (!reader.current.isOutgoing) {
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
2022-01-14 06:56:15 +01:00
|
|
|
}
|