Log balance estimate updates (#2994)

thomash-acinq · web-flow · commit b6aa4cc8eccf · 2025-02-04T15:41:08.000+01:00
This will allow us to try different algorithms to estimate the balance and evaluate them on historical data.
diff --git a/eclair-core/src/main/scala/fr/acinq/eclair/router/BalanceEstimate.scala b/eclair-core/src/main/scala/fr/acinq/eclair/router/BalanceEstimate.scala
@@ -284,6 +284,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima
   )
 
   def channelCouldSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {
+    log.info("channelCouldSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)
     get(hop.nodeId, hop.nextNodeId).foreach { balance =>
       val estimatedProbability = balance.canSend(amount, TimestampSecond.now())
       Monitoring.Metrics.remoteEdgeRelaySuccess(estimatedProbability)
@@ -292,6 +293,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima
   }
 
   def channelCouldNotSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {
+    log.info("channelCouldNotSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)
     get(hop.nodeId, hop.nextNodeId).foreach { balance =>
       val estimatedProbability = balance.canSend(amount, TimestampSecond.now())
       Monitoring.Metrics.remoteEdgeRelayFailure(estimatedProbability)
@@ -300,6 +302,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima
   }
 
   def channelDidSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {
+    log.info("channelDidSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)
     get(hop.nodeId, hop.nextNodeId).foreach { balance =>
       val estimatedProbability = balance.canSend(amount, TimestampSecond.now())
       Monitoring.Metrics.remoteEdgeRelaySuccess(estimatedProbability)

Original file line number	Diff line number	Diff line change
`@@ -284,6 +284,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima`
`284`	`284`	`)`
`285`	`285`
`286`	`286`	`def channelCouldSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {`
	`287`	`+ log.info("channelCouldSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)`
`287`	`288`	`get(hop.nodeId, hop.nextNodeId).foreach { balance =>`
`288`	`289`	`val estimatedProbability = balance.canSend(amount, TimestampSecond.now())`
`289`	`290`	`Monitoring.Metrics.remoteEdgeRelaySuccess(estimatedProbability)`
`@@ -292,6 +293,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima`
`292`	`293`	`}`
`293`	`294`
`294`	`295`	`def channelCouldNotSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {`
	`296`	`+ log.info("channelCouldNotSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)`
`295`	`297`	`get(hop.nodeId, hop.nextNodeId).foreach { balance =>`
`296`	`298`	`val estimatedProbability = balance.canSend(amount, TimestampSecond.now())`
`297`	`299`	`Monitoring.Metrics.remoteEdgeRelayFailure(estimatedProbability)`
`@@ -300,6 +302,7 @@ case class BalancesEstimates(balances: Map[(PublicKey, PublicKey), BalanceEstima`
`300`	`302`	`}`
`301`	`303`
`302`	`304`	`def channelDidSend(hop: ChannelHop, amount: MilliSatoshi)(implicit log: LoggingAdapter): BalancesEstimates = {`
	`305`	`+ log.info("channelDidSend: amount={} scid={} from={} to={}", amount, hop.shortChannelId, hop.nodeId, hop.nextNodeId)`
`303`	`306`	`get(hop.nodeId, hop.nextNodeId).foreach { balance =>`
`304`	`307`	`val estimatedProbability = balance.canSend(amount, TimestampSecond.now())`
`305`	`308`	`Monitoring.Metrics.remoteEdgeRelaySuccess(estimatedProbability)`