library / io.getstream.chat.android.livedata.repository / MessageRepository

MessageRepository

class MessageRepository

Constructors

<init>

 MessageRepository(messageDao: MessageDao, cacheSize: Int = 100, currentUser: User, client: ChatClient)

Properties

cacheSize

 var cacheSize: Int

client

 var client: ChatClient

currentUser

 var currentUser: User

messageCache

 var messageCache: LruCache<String, MessageEntity>

messageDao

 var messageDao: MessageDao

Functions

deleteChannelMessagesBefore

 suspend fun deleteChannelMessagesBefore(cid: String, hideMessagesBefore: Date): Unit

insert

 suspend fun insert(messageEntities: List<MessageEntity>, cache: Boolean = false): Unit
suspend fun insert(messageEntity: MessageEntity, cache: Boolean = false): Unit

insertMessage

 suspend fun insertMessage(message: Message, cache: Boolean = false): Unit

insertMessages

 suspend fun insertMessages(messages: List<Message>, cache: Boolean = false): Unit

retryMessages

 suspend fun retryMessages(): List<MessageEntity>

select

 suspend fun select(messageId: String): MessageEntity?
suspend fun select(messageIds: List<String>): List<MessageEntity>

selectSyncNeeded

 suspend fun selectSyncNeeded(): List<MessageEntity>