Connect to sqlite db

[rainman-wf]

Hi! I spent a lot of time and effort to connect to the database using the Room library. What I need it for...
I need to get data from the group_messages and group tables in real time. The Room library allows me to do this using kotlin flow. This approach helps to get rid of unnecessary intermediate objects and code.

@Dao
interface MsgDao {

    @Query("SELECT * FROM group_messages")
    fun getAllMessages(): Flow<List<GroupMessage>>

    @Query("SELECT * FROM group_messages WHERE group_id = :groupId")
    fun getMessagesByConversationId(groupId: ByteArray) : Flow<List<GroupMessage>>

    @Query("SELECT * FROM groups")
    fun getAllConversations(): Flow<List<Group>>

}

I have achieved a stable connection and real-time data acquisition, but...

I found that no new messages are being added to the table. I've tried calling the sync() and syncAllConversations() methods, but even that doesn't update the data in the tables. I receive updated data only after restarting the application. I use the Room library in read only mode.
What needs to be done so that new data gets into the table dynamically?

[mchenani]

Hi! thanks for reporting the issue, have you tried to use stream functions already exist in the sdk to get what you need in real-time?
list of the conversations in real-time: https://xmtp.github.io/xmtp-android/library/org.xmtp.android.library/-conversations/stream.html
all messages: https://xmtp.github.io/xmtp-android/library/org.xmtp.android.library/-conversations/stream-all-messages.html
a group/dm messages: https://xmtp.github.io/xmtp-android/library/org.xmtp.android.library/-conversation/stream-messages.html

[rainman-wf]

Hi! Yes, I tried it. It works, but this approach makes me to write additional intermediate code. I have to stack different types of messages, filter and sort them myself. I was surprised by the fact that the messages do not immediately get into the database, but only at the initialization stage of the client. The sync() and syncAllClonversations() methods also do not add messages to the database.

In addition, I need to connect to the database to implementation chats or specific messages deleting. Since there are no ready-made methods in the SDK, I had to write custom codecs that trigger the deletion of a conversation with the entire message history, or the deletion of specific messages. Our application provides for the immediate deletion of a message in case of an erroneous sending.