logic/com.wire.kalium.logic.data.conversation.folders/ConversationFolderDataSource

ConversationFolderDataSource

internal class ConversationFolderDataSource(conversationFolderDAO: ConversationFolderDAO, userPropertiesApi: PropertiesApi, selfUserId: QualifiedID, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId)) : ConversationFolderRepository

Constructors

internal constructor(conversationFolderDAO: ConversationFolderDAO, userPropertiesApi: PropertiesApi, selfUserId: QualifiedID, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId))

Functions

addConversationToFolder

open suspend override fun addConversationToFolder(conversationId: QualifiedID, folderId: String): Either<CoreFailure, Unit>

addFolder

open suspend override fun addFolder(folder: ConversationFolder): Either<CoreFailure, Unit>

fetchConversationFolders

open suspend override fun fetchConversationFolders(): Either<CoreFailure, Unit>

getFavoriteConversationFolder

open suspend override fun getFavoriteConversationFolder(): Either<CoreFailure, ConversationFolder>

observeConversationsFromFolder

open override fun observeConversationsFromFolder(folderId: String): Flow<List<ConversationDetailsWithEvents>>

observeFolders

open override fun observeFolders(): Flow<Either<CoreFailure, List<ConversationFolder>>>

removeConversationFromFolder

open suspend override fun removeConversationFromFolder(conversationId: QualifiedID, folderId: String, isFavorite: Boolean = false): Either<CoreFailure, Unit>

removeFolder

open suspend override fun removeFolder(folderId: String): Either<CoreFailure, Unit>

syncConversationFoldersFromLocal

open suspend override fun syncConversationFoldersFromLocal(): Either<CoreFailure, Unit>

updateConversationFolders

open suspend override fun updateConversationFolders(folderWithConversations: List<FolderWithConversations>): Either<CoreFailure, Unit>