Mirrors/SnapEnhance
1
0
Fork 0
mirror of https://github.com/rhunk/SnapEnhance.git synced 2025-05-29 13:00:17 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(bridge/messagelogger): database connection leak

Browse Source
This commit is contained in:
rhunk 2023-10-27 03:23:31 +02:00
parent ead9e7830b
commit 6c18f98839
1 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
common/src/main/kotlin/me/rhunk/snapenhance/common/bridge/wrapper/MessageLoggerWrapper.kt
View File

@ -10,18 +10,31 @@ import java.util.UUID
class MessageLoggerWrapper( class MessageLoggerWrapper(
private val databaseFile: File private val databaseFile: File
): MessageLoggerInterface.Stub() { ): MessageLoggerInterface.Stub() {
private lateinit var database: SQLiteDatabase private var _database: SQLiteDatabase? = null
private val database get() = synchronized(this) {
_database?.takeIf { it.isOpen } ?: run {
_database?.close()
val openedDatabase = SQLiteDatabase.openDatabase(databaseFile.absolutePath, null, SQLiteDatabase.CREATE_IF_NECESSARY or SQLiteDatabase.OPEN_READWRITE)
SQLiteDatabaseHelper.createTablesFromSchema(openedDatabase, mapOf(
"messages" to listOf(
"id INTEGER PRIMARY KEY",
"conversation_id VARCHAR",
"message_id BIGINT",
"message_data BLOB"
)
))
_database = openedDatabase
openedDatabase
}
}
protected fun finalize() {
_database?.close()
}
fun init() { fun init() {
database = SQLiteDatabase.openDatabase(databaseFile.absolutePath, null, SQLiteDatabase.CREATE_IF_NECESSARY or SQLiteDatabase.OPEN_READWRITE)
SQLiteDatabaseHelper.createTablesFromSchema(database, mapOf(
"messages" to listOf(
"id INTEGER PRIMARY KEY",
"conversation_id VARCHAR",
"message_id BIGINT",
"message_data BLOB"
)
))
} }
override fun getLoggedIds(conversationId: Array<String>, limit: Int): LongArray { override fun getLoggedIds(conversationId: Array<String>, limit: Int): LongArray {