Skip to content

Commit da2f4c6

Browse files
committed
Add per-peer profit scoring
1 parent f777814 commit da2f4c6

File tree

3 files changed

+1157
-1
lines changed

3 files changed

+1157
-1
lines changed

eclair-core/src/main/scala/fr/acinq/eclair/Setup.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ import fr.acinq.eclair.payment.offer.{DefaultOfferHandler, OfferManager}
4444
import fr.acinq.eclair.payment.receive.PaymentHandler
4545
import fr.acinq.eclair.payment.relay.{AsyncPaymentTriggerer, PostRestartHtlcCleaner, Relayer}
4646
import fr.acinq.eclair.payment.send.{Autoprobe, PaymentInitiator}
47+
import fr.acinq.eclair.profit.PeerScorer
4748
import fr.acinq.eclair.reputation.ReputationRecorder
4849
import fr.acinq.eclair.router._
4950
import fr.acinq.eclair.tor.{Controller, TorProtocolHandler}
@@ -400,8 +401,8 @@ class Setup(val datadir: File,
400401
_ = for (i <- 0 until config.getInt("autoprobe-count")) yield system.actorOf(SimpleSupervisor.props(Autoprobe.props(nodeParams, router, paymentInitiator), s"payment-autoprobe-$i", SupervisorStrategy.Restart))
401402

402403
balanceActor = system.spawn(BalanceActor(bitcoinClient, nodeParams.channelConf.minDepth, channelsListener, nodeParams.balanceCheckInterval), name = "balance-actor")
403-
404404
postman = system.spawn(Behaviors.supervise(Postman(nodeParams, switchboard, router.toTyped, register, offerManager)).onFailure(typed.SupervisorStrategy.restart), name = "postman")
405+
peerScorer = system.spawn(Behaviors.supervise(PeerScorer(nodeParams.db.audit, channels)).onFailure(typed.SupervisorStrategy.restart), name = "peer-scorer")
405406

406407
kit = Kit(
407408
nodeParams = nodeParams,

0 commit comments

Comments
 (0)