BackupDataSource

internal class BackupDataSource(selfUserId: UserId, userDAO: UserDAO, messageDAO: MessageDAO, conversationDAO: ConversationDAO, reactionDAO: ReactionDAO, userMapper: UserMapper = userMapper(), conversationMapper: ConversationMapper = conversationMapper(selfUserId), messageMapper: MessageMapper = messageMapper(selfUserId), idMapper: IdMapper = MapperProvider.idMapper()) : BackupRepository

Constructors

constructor(selfUserId: UserId, userDAO: UserDAO, messageDAO: MessageDAO, conversationDAO: ConversationDAO, reactionDAO: ReactionDAO, userMapper: UserMapper = userMapper(), conversationMapper: ConversationMapper = conversationMapper(selfUserId), messageMapper: MessageMapper = messageMapper(selfUserId), idMapper: IdMapper = MapperProvider.idMapper())

open suspend override fun getConversations(): List<Conversation>

open suspend override fun getMessages(pageSize: Int = DEFAULT_PAGE_SIZE): Flow<PagedData<Message.Standalone>>

open suspend override fun getReactions(pageSize: Int = DEFAULT_PAGE_SIZE): Flow<PagedData<MessageReactions>>

open suspend override fun getUsers(): List<OtherUser>

open suspend override fun insertConversations(conversations: List<Conversation>): Either<StorageFailure, Unit>

open suspend override fun insertMessages(messages: List<Message.Standalone>): Either<StorageFailure, Unit>

open suspend override fun insertReactions(reactions: List<MessageReactions>): Either<StorageFailure, Unit>

open suspend override fun insertUsers(users: List<OtherUser>): Either<StorageFailure, Unit>