ConversationRepository

class ConversationRepository(conversationDao: ConversationDao, val di: DI) : DIAware

Repository for managing conversations. Handles retrieval, creation, updating, and user status tracking for conversations.

Constructors

constructor(conversationDao: ConversationDao, di: DI)

open override val di: DI

Kodein DI container for dependency injection.

open val diContext: DIContext<*>

open val diTrigger: DITrigger?

Returns a Flow emitting the list of all conversations.

Retrieves a conversation by its unique ID.

Retrieves an existing conversation or creates a new one if it does not exist.

suspend fun markAsRead(conversationId: String)

Marks a conversation as read by clearing its unread count.

suspend fun updateUserStatus(userUuid: String, isOnline: Boolean, userAddress: String?)

Updates a user's online status and associated address.

suspend fun updateWithMessage(conversationId: String, message: Message)

Updates the conversation with the latest message. Increments unread count if the message is from another user.