vrr/Flocon
2
0
Fork 0
mirror of https://github.com/openflocon/Flocon.git synced 2026-05-22 04:33:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Feat log db query (#471)

Browse source 
Co-authored-by: Florent Champigny <florent@bere.al>
This commit is contained in:
Florent CHAMPIGNY 2025-12-30 15:02:29 +01:00 • committed by GitHub
parent 20b7b7b29c
commit 24bb623ebd
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
48 changed files with 8659 additions and 129 deletions
Download patch file Download diff file Expand all files Collapse all files

26
FloconDesktop/data/remote/src/commonMain/kotlin/com/flocon/data/remote/database/datasource/QueryDatabaseRemoteDataSourceImpl.kt
View file

@ -5,6 +5,7 @@ import com.flocon.data.remote.database.mapper.decodeDeviceDatabases
import com.flocon.data.remote.database.mapper.decodeReceivedQuery
import com.flocon.data.remote.database.models.DatabaseExecuteSqlResponseDataModel
import com.flocon.data.remote.database.models.DatabaseOutgoingQueryMessage
import com.flocon.data.remote.database.models.DatabaseQueryLogModel
import com.flocon.data.remote.database.models.ResponseAndRequestIdDataModel
import com.flocon.data.remote.database.models.toDeviceDatabasesDomain
import com.flocon.data.remote.models.FloconOutgoingMessageDataModel
@ -17,6 +18,7 @@ import io.github.openflocon.domain.common.Either
import io.github.openflocon.domain.common.Failure
import io.github.openflocon.domain.common.Success
import io.github.openflocon.domain.database.models.DatabaseExecuteSqlResponseDomainModel
import io.github.openflocon.domain.database.models.DatabaseQueryLogDomainModel
import io.github.openflocon.domain.database.models.DeviceDataBaseDomainModel
import io.github.openflocon.domain.database.models.DeviceDataBaseId
import io.github.openflocon.domain.database.models.ResponseAndRequestIdDomainModel
@ -84,6 +86,30 @@ class QueryDatabaseRemoteDataSourceImpl(
override fun getDeviceDatabases(message: FloconIncomingMessageDomainModel): List<DeviceDataBaseDomainModel> = toDeviceDatabasesDomain(json.decodeDeviceDatabases(message.body).orEmpty())
override fun getReceiveQuery(message: FloconIncomingMessageDomainModel): ResponseAndRequestIdDomainModel? = json.decodeReceivedQuery(message.body)?.toDomain()
override fun getQueryLogs(
message: FloconIncomingMessageDomainModel,
): DatabaseQueryLogDomainModel? {
return json.decodeFromString<DatabaseQueryLogModel>(message.body)?.let {
val upperQuery = it.sqlQuery.trim().uppercase()
val isTransaction = upperQuery == "BEGIN TRANSACTION" ||
upperQuery == "COMMIT" ||
upperQuery == "ROLLBACK" ||
upperQuery == "END TRANSACTION" ||
upperQuery == "TRANSACTION SUCCESSFUL" ||
upperQuery == "BEGIN IMMEDIATE TRANSACTION"
DatabaseQueryLogDomainModel(
dbName = it.dbName,
sqlQuery = it.sqlQuery,
bindArgs = it.bindArgs.orEmpty(),
timestamp = it.timestamp,
isTransaction = isTransaction,
appInstance = message.appInstance,
)
}
}
}
// TODO internal

11
FloconDesktop/data/remote/src/commonMain/kotlin/com/flocon/data/remote/database/models/DatabaseQueryLogModel.kt Normal file
View file

@ -0,0 +1,11 @@
package com.flocon.data.remote.database.models
import kotlinx.serialization.Serializable
@Serializable
data class DatabaseQueryLogModel(
val dbName: String,
val sqlQuery: String,
val bindArgs: List<String>?,
val timestamp: Long,
)