stream-chat-android-client/io.getstream.chat.android.client.persistance.repository/RepositoryFacade

RepositoryFacade

class RepositoryFacade : UserRepository, ChannelRepository, ReactionRepository, MessageRepository, ChannelConfigRepository, QueryChannelsRepository, ThreadsRepository, SyncStateRepository

Types

Companion

object Companion

Functions

clear

open suspend override fun clear()

Clear users of this repository.

deleteChannel

open suspend override fun deleteChannel(cid: String)

Deletes a Channel by the cid.

deleteChannelMessage

open suspend override fun deleteChannelMessage(message: Message)

Deletes a Message from a Channel.messages.

deleteChannelMessagesBefore

open suspend override fun deleteChannelMessagesBefore(cid: String, hideMessagesBefore: Date)

Deletes channel messages before hideMessagesBefore and removes channel from the cache.

enrichChannel

@VisibleForTesting

fun Channel.enrichChannel(messageMap: Map<String, List<Message>>, defaultConfig: Config): Channel

insertChannel

open suspend override fun insertChannel(channel: Channel)

Inserts a Channel

insertChannels

open suspend override fun insertChannels(channels: Collection<Channel>)

Inserts many Channels.

insertMessage

open suspend override fun insertMessage(message: Message)

Inserts a messages.

insertMessages

open suspend override fun insertMessages(messages: List<Message>)

Inserts many messages.

insertReaction

open suspend override fun insertReaction(reaction: Reaction)

Inserts a reaction.

insertThreads

open suspend override fun insertThreads(threads: List<Thread>)

Inserts the given list of Thread.

markMessageAsDeleted

suspend fun markMessageAsDeleted(message: Message)

selectChannels

open suspend override fun selectChannels(channelCIDs: List<String>): List<Channel>

Select channels by full channel IDs Channel.cid

suspend fun selectChannels(channelIds: List<String>, pagination: AnyChannelPaginationRequest?): List<Channel>

setHiddenForChannel

open suspend override fun setHiddenForChannel(cid: String, hidden: Boolean)

open suspend override fun setHiddenForChannel(cid: String, hidden: Boolean, hideMessagesBefore: Date)

Sets the Channel.hidden for a channel.

storeStateForChannel

suspend fun storeStateForChannel(channel: Channel)

storeStateForChannels

suspend fun storeStateForChannels(channels: Collection<Channel>)

updateMembersForChannel

open suspend override fun updateMembersForChannel(cid: String, members: List<Member>)

Updates the members of a Channel

Inherited functions

cacheChannelConfigs

open suspend override fun cacheChannelConfigs()

Caches in memory data from DB.

deleteChannelMessages

open suspend override fun deleteChannelMessages(cid: String)

Deletes all messages from a channel.

deleteChannelThreads

open suspend override fun deleteChannelThreads(cid: String)

Deletes all threads from a channel.

deleteReaction

open suspend override fun deleteReaction(reaction: Reaction)

Deletes a reaction.

evictChannel

open suspend override fun evictChannel(cid: String)

Evict a Channel from the repository.

evictMessage

open suspend override fun evictMessage(messageId: String)

Evicts a message from the repository.

evictMessages

open suspend override fun evictMessages()

Evict messages from the repository.

insertChannelConfig

open suspend override fun insertChannelConfig(config: ChannelConfig)

Writes ChannelConfig

insertChannelConfigs

open suspend override fun insertChannelConfigs(configs: Collection<ChannelConfig>)

Writes many ChannelConfig

insertCurrentUser

open suspend override fun insertCurrentUser(user: User)

Inserts the current user of the SDK.

insertQueryChannels

open suspend override fun insertQueryChannels(queryChannelsSpec: QueryChannelsSpec)

Inserts a query channels.

insertSyncState

open suspend override fun insertSyncState(syncState: SyncState)

Inserts a sync state.

insertThreadOrder

open suspend override fun insertThreadOrder(id: String, order: List<String>)

Inserts the order in which local threads should be displayed.

insertUser

open suspend override fun insertUser(user: User)

Inserts a users.

insertUsers

open suspend override fun insertUsers(users: Collection<User>)

Insert many users.

observeLatestUsers

open override fun observeLatestUsers(): StateFlow<Map<String, User>>

Returns flow of latest updated users.

selectAllCids

open suspend override fun selectAllCids(): List<String>

Selects all channels' cids.

selectBy

open suspend override fun selectBy(filter: FilterObject, querySort: QuerySorter<Channel>): QueryChannelsSpec?

Selects by a filter and query sort.

selectChannel

open suspend override fun selectChannel(cid: String): Channel?

Select channel by full channel ID Channel.cid

selectChannelCidsBySyncNeeded

open suspend override fun selectChannelCidsBySyncNeeded(limit: Int): List<String>

Read which channel cids need sync.

selectChannelConfig

open override fun selectChannelConfig(channelType: String): ChannelConfig?

Select the ChannelConfig for a channel type.

selectChannelsSyncNeeded

open suspend override fun selectChannelsSyncNeeded(limit: Int): List<Channel>

Read which channels need sync.

selectMembersForChannel

open suspend override fun selectMembersForChannel(cid: String): List<Member>

Reads the member list of a channel.

selectMessage

open suspend override fun selectMessage(messageId: String): Message?

Reads the message with passed ID.

selectMessageBySyncState

open suspend override fun selectMessageBySyncState(syncStatus: SyncStatus): List<Message>

Selects all message of a SyncStatus

selectMessageIdsBySyncState

open suspend override fun selectMessageIdsBySyncState(syncStatus: SyncStatus): List<String>

Selects all message ids of a SyncStatus

selectMessages

open suspend override fun selectMessages(messageIds: List<String>): List<Message>

Selects messages by IDs.

selectMessagesForChannel

open suspend override fun selectMessagesForChannel(cid: String, pagination: AnyChannelPaginationRequest?): List<Message>

Select messages for a channel in a desired page.

selectMessagesForThread

open suspend override fun selectMessagesForThread(messageId: String, limit: Int): List<Message>

Select messages for a thread in a desired page.

selectMessagesWithPoll

open suspend override fun selectMessagesWithPoll(pollId: String): List<Message>

Selects all messages with a poll with the passed ID.

selectReactionById

open suspend override fun selectReactionById(id: Int): Reaction?

Selects reaction with specified id.

selectReactionIdsBySyncStatus

open suspend override fun selectReactionIdsBySyncStatus(syncStatus: SyncStatus): List<Int>

Selects all reaction ids with specific SyncStatus.

selectReactionsByIds

open suspend override fun selectReactionsByIds(ids: List<Int>): List<Reaction>

Selects all reactions with specified ids

selectReactionsBySyncStatus

open suspend override fun selectReactionsBySyncStatus(syncStatus: SyncStatus): List<Reaction>

Selects all reactions with specific SyncStatus

selectSyncState

open suspend override fun selectSyncState(userId: String): SyncState?

Selects a sync state.

selectThread

open suspend override fun selectThread(id: String): Thread?

Retrieves the Thread identified by id.

selectThreadOrder

open suspend override fun selectThreadOrder(id: String): List<String>

Retrieves the order in which local threads should be displayed.

selectThreads

open suspend override fun selectThreads(ids: List<String>): List<Thread>

Retrieves all Threads identified by the supplied ids.

selectUser

open suspend override fun selectUser(userId: String): User?

Selects a user by id.

selectUserReactionsToMessage

open suspend override fun selectUserReactionsToMessage(messageId: String, userId: String): List<Reaction>

Selects all current user reactions of a message.

selectUserReactionToMessage

open suspend override fun selectUserReactionToMessage(reactionType: String, messageId: String, userId: String): Reaction?

Selects the reaction of given type to the message if exists.

selectUsers

open suspend override fun selectUsers(ids: List<String>): List<User>

setChannelDeletedAt

open suspend override fun setChannelDeletedAt(cid: String, deletedAt: Date)

Sets the Channel.deleteAt for a channel.

updateChannelMessage

open suspend override fun updateChannelMessage(message: Message)

Updates a Message from a Channel.messages.

updateLastMessageForChannel

open suspend override fun updateLastMessageForChannel(cid: String, lastMessage: Message)

Updates the last message for a Channel

updateReactionsForMessageByDeletedDate

open suspend override fun updateReactionsForMessageByDeletedDate(userId: String, messageId: String, deletedAt: Date)

Updates the Reaction.deletedAt for reactions of a message.

upsertMessageInThread

open suspend override fun upsertMessageInThread(message: Message)

Upsert a Message in the corresponding thread (if such exists).

upsertMessagesInThread

open suspend override fun upsertMessagesInThread(messages: List<Message>)

Upsert a list of Messages in the corresponding thread (if such exists).