mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2025-03-12 19:01:39 +01:00
Code Issues Projects Releases Wiki Activity

Add details when logging channel database error

Browse source
This commit is contained in:
Dominique Padiou 2024-11-21 12:15:38 +01:00
parent b9109a99dd
commit 0b04706de0
No known key found for this signature in database
GPG key ID: 574C8C6A1673E987
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
eclair-core/src/main/scala/fr/acinq/eclair/db/sqlite/SqliteChannelsDb.scala
View file

@ -17,7 +17,6 @@
package fr.acinq.eclair.db.sqlite
import java.sql.{Connection, Statement}
import fr.acinq.bitcoin.scala.ByteVector32
import fr.acinq.eclair.CltvExpiry
import fr.acinq.eclair.channel.HasCommitments
@ -25,6 +24,7 @@ import fr.acinq.eclair.db.ChannelsDb
import fr.acinq.eclair.db.Monitoring.Metrics.withMetrics
import fr.acinq.eclair.wire.ChannelCodecs.stateDataCodec
import grizzled.slf4j.Logging
import scodec.bits.BitVector
import scala.collection.immutable.Queue
@ -98,7 +98,10 @@ class SqliteChannelsDb(sqlite: Connection) extends ChannelsDb with Logging {
override def listLocalChannels(): Seq[HasCommitments] = withMetrics("channels/list-local-channels") {
using(sqlite.createStatement) { statement =>
val rs = statement.executeQuery("SELECT data FROM local_channels WHERE is_closed=0")
codecSequence(rs, stateDataCodec, onError = { message => logger.error(message) })
codecSequence(rs, stateDataCodec, onError = { message =>
logger.error(s"cannot read local channels data: data=${BitVector(rs.getBytes("data")).toHex}")
logger.error(message)
})
}
}