rfq: integrate PortfolioPilot into negotiator and manager configuration

- Add PortfolioPilot to Negotiator and Manager structs.
- Use internal implementation of PortfolioPilot if not specified.

Author: ffranr

rfq/manager.go

@@ -101,6 +101,10 @@ type ManagerCfg struct {
 	// determine whether a quote is accepted or rejected.
 	PriceOracle PriceOracle
 
+	// PortfolioPilot is the portfolio pilot that will make financial
+	// decisions based on RFQ requests.
+	PortfolioPilot PortfolioPilot
+
 	// ChannelLister is the channel lister that the RFQ manager will use to
 	// determine the available channels for routing.
 	ChannelLister ChannelLister
@@ -267,6 +271,7 @@ func (m *Manager) startSubsystems(ctx context.Context) error {
 	// Initialise and start the quote negotiator.
 	m.negotiator, err = NewNegotiator(NegotiatorCfg{
 		PriceOracle:               m.cfg.PriceOracle,
+		PortfolioPilot:            m.cfg.PortfolioPilot,
 		OutgoingMessages:          m.outgoingMessages,
 		AcceptPriceDeviationPpm:   m.cfg.AcceptPriceDeviationPpm,
 		SkipAcceptQuotePriceCheck: m.cfg.SkipAcceptQuotePriceCheck,

rfq/negotiator.go

@@ -33,6 +33,9 @@ type NegotiatorCfg struct {
 	// determine whether a quote is accepted or rejected.
 	PriceOracle PriceOracle
 
+	// PortfolioPilot makes financial decisions when evaluating quotes.
+	PortfolioPilot PortfolioPilot
+
 	// OutgoingMessages is a channel which is populated with outgoing peer
 	// messages. These are messages which are destined to be sent to peers.
 	OutgoingMessages chan<- rfqmsg.OutgoingMsg
@@ -93,6 +96,18 @@ type Negotiator struct {
 
 // NewNegotiator creates a new quote negotiator.
 func NewNegotiator(cfg NegotiatorCfg) (*Negotiator, error) {
+	// If the portfolio pilot is not specified, then we will use the
+	// internal portfolio pilot.
+	if cfg.PortfolioPilot == nil {
+		cfgPortfolioPilot := InternalPortfolioPilotConfig{
+			PriceOracle:           cfg.PriceOracle,
+			ForwardPeerIDToOracle: cfg.SendPeerId,
+		}
+		cfg.PortfolioPilot = NewInternalPortfolioPilot(
+			cfgPortfolioPilot,
+		)
+	}
+
 	return &Negotiator{
 		cfg: cfg,