rfq

type AcceptHtlcEvent struct {

	// Htlc is the intercepted HTLC.
	Htlc lndclient.InterceptedHtlc

	// Policy is the policy with which the HTLC is compliant.
	Policy Policy
	// contains filtered or unexported fields
}

type AssetForwardPolicy struct {
	// contains filtered or unexported fields
}

type AssetPurchasePolicy struct {

	// AssetSpecifier is the identifier for the specific asset or asset
	// group to which this policy applies.
	AssetSpecifier asset.Specifier

	// AcceptedQuoteId is the ID of the accepted quote.
	AcceptedQuoteId rfqmsg.ID

	// CurrentAssetAmountMsat is the total amount that is held currently in
	// accepted HTLCs.
	CurrentAmountMsat lnwire.MilliSatoshi

	// BidAssetRate is the quote's asset to BTC conversion rate.
	BidAssetRate rfqmath.BigIntFixedPoint

	// PaymentMaxAmt is the maximum agreed BTC payment.
	PaymentMaxAmt lnwire.MilliSatoshi

	// ExecutionPolicy is the execution policy from the original
	// request (annotation only; not enforced at the HTLC level).
	ExecutionPolicy fn.Option[rfqmsg.ExecutionPolicy]
	// contains filtered or unexported fields
}

type AssetRateQuery struct {
	// AssetSpecifier identifies the asset being queried.
	AssetSpecifier asset.Specifier

	// Direction specifies whether we want to buy or sell the asset.
	Direction AssetTransferDirection

	// Intent specifies the purpose of the query (e.g., paying an invoice,
	// receiving payment, etc.). This determines the context for pricing.
	Intent PriceQueryIntent

	// AssetAmount is an optional constraint on the asset amount.
	AssetAmount fn.Option[uint64]

	// PaymentAmount is an optional constraint on the payment amount.
	PaymentAmount fn.Option[lnwire.MilliSatoshi]

	// PeerID is an optional peer identifier for peer-specific pricing.
	PeerID fn.Option[route.Vertex]

	// RateHint is an optional rate hint to guide pricing.
	RateHint fn.Option[rfqmsg.AssetRate]

	// OracleMetadata is optional metadata to pass to the price oracle.
	OracleMetadata fn.Option[string]

	// Expiry is an optional expiry time for the rate query.
	Expiry fn.Option[time.Time]
}

type AssetSalePolicy struct {
	// AssetSpecifier is the identifier for the specific asset or asset
	// group to which this policy applies.
	AssetSpecifier asset.Specifier

	// AcceptedQuoteId is the unique identifier of the RFQ session quote
	// accept message that the policy is associated with.
	AcceptedQuoteId rfqmsg.ID

	// MaxOutboundAssetAmount represents the maximum asset amount permitted
	// by policy for outbound transactions. It sets an upper limit on the
	// amount of assets this node is willing to divest within the remit of
	// the policy.
	MaxOutboundAssetAmount uint64

	// CurrentAssetAmountMsat is the total amount that is held currently in
	// accepted HTLCs.
	CurrentAmountMsat lnwire.MilliSatoshi

	// AskAssetRate is the quote's asking asset unit to BTC conversion rate.
	AskAssetRate rfqmath.BigIntFixedPoint

	// NoOpHTLCs is a boolean indicating whether the daemon configuration
	// wants us to produce NoOp HTLCs.
	NoOpHTLCs bool

	// ExecutionPolicy is the execution policy from the original
	// request (annotation only; not enforced at the HTLC level).
	ExecutionPolicy fn.Option[rfqmsg.ExecutionPolicy]
	// contains filtered or unexported fields
}

type AssetTransferDirection uint8

type BuyAcceptMap map[SerialisedScid]rfqmsg.BuyAccept

type BuyOffer struct {
	// AssetID represents the identifier of the subject asset.
	AssetID *asset.ID

	// AssetGroupKey is the public group key of the subject asset.
	AssetGroupKey *btcec.PublicKey

	// MaxUnits is the maximum amount of the asset which this node is
	// willing to purchase.
	MaxUnits uint64
}

type BuyOrder struct {
	// AssetSpecifier is the asset that the buyer is interested in.
	AssetSpecifier asset.Specifier

	// AssetMaxAmt is the maximum amount of the asset that the provider must
	// be willing to offer.
	AssetMaxAmt uint64

	// AssetMinAmt is an optional minimum asset amount for the order.
	AssetMinAmt fn.Option[uint64]

	// AssetRateLimit is an optional minimum acceptable rate (asset
	// units per BTC) for the order.
	AssetRateLimit fn.Option[rfqmath.BigIntFixedPoint]

	// ExecutionPolicy is an optional execution policy (IOC or
	// FOK) for the order.
	ExecutionPolicy fn.Option[rfqmsg.ExecutionPolicy]

	// Expiry is the time at which the order expires.
	Expiry time.Time

	// Peer is the peer that the buy order is intended for. This field is
	// optional.
	//
	// TODO(ffranr): Currently, this field must be specified. In the future,
	//  the negotiator should be able to determine the optimal peer.
	Peer fn.Option[route.Vertex]

	// PriceOracleMetadata is an optional text field that can be used to
	// provide additional metadata about the buy order to the price
	// oracle. This can include information about the wallet end user that
	// initiated the transaction, or any authentication information that the
	// price oracle can use to give out a more accurate (or discount) asset
	// rate. The maximum length of this field is 32'768 bytes.
	PriceOracleMetadata string
}

type ChanIntention uint8

type ChannelLister interface {
	// ListChannels returns a list of channels that are available for
	// routing.
	ListChannels(ctx context.Context, activeOnly, publicOnly bool,
		_ ...lndclient.ListChannelsOption) ([]lndclient.ChannelInfo,
		error)
}

type CliConfig struct {
	PriceOracleAddress string `` /* 215-byte string literal not displayed */

	// PortfolioPilotAddress is the portfolio pilot gRPC server address.
	PortfolioPilotAddress string `long:"portfoliopilotaddress" description:"Portfolio pilot gRPC server address (portfoliopilotrpc://<hostname>:<port>)"`

	PriceOracleTLSDisable bool `long:"priceoracletlsdisable" description:"Disable TLS for price oracle communication."`

	PriceOracleTLSInsecure bool `long:"priceoracletlsinsecure" description:"Disable price oracle certificate verification."`

	PriceOracleTLSNoSystemCAs bool `` /* 144-byte string literal not displayed */

	PriceOracleTLSCertPath string `` /* 145-byte string literal not displayed */

	PriceOracleMacaroonPath string `long:"priceoraclemacaroonpath" description:"Path to the macaroon to use when connecting to the price oracle gRPC server."`

	SendPriceHint bool `` /* 214-byte string literal not displayed */

	PriceOracleSendPeerId bool `` /* 227-byte string literal not displayed */

	PriceOracleDisableNodeId bool `` /* 232-byte string literal not displayed */

	AcceptPriceDeviationPpm uint64 `` /* 132-byte string literal not displayed */

	SkipQuoteAcceptVerify bool `long:"skipquoteacceptverify" description:"Skip verification of quote accept messages returned by RFQ peer"`

	MockOracleAssetsPerBTC uint64 `` /* 270-byte string literal not displayed */

	// TODO(ffranr): Remove in favour of MockOracleAssetsPerBTC.
	MockOracleSatsPerAsset uint64 `` /* 289-byte string literal not displayed */
}

type ForwardInput struct {
	// OpenedAt is the time when the forward was initiated.
	OpenedAt time.Time

	// SettledAt is the time when the forward settled (if any).
	SettledAt fn.Option[time.Time]

	// FailedAt is the time when the forward failed (if any).
	FailedAt fn.Option[time.Time]

	// RfqID is the RFQ session identifier for this forward.
	RfqID rfqmsg.ID

	// ChanIDIn is the short channel ID of the incoming channel.
	ChanIDIn uint64

	// ChanIDOut is the short channel ID of the outgoing channel.
	ChanIDOut uint64

	// HtlcID is the HTLC ID on the incoming channel.
	HtlcID uint64

	// AssetAmt is the asset amount involved in this swap.
	AssetAmt uint64

	// AmtInMsat is the actual amount received on the incoming channel in
	// millisatoshis.
	AmtInMsat uint64

	// AmtOutMsat is the actual amount sent on the outgoing channel in
	// millisatoshis.
	AmtOutMsat uint64
}

type ForwardStore interface {
	// UpsertForward inserts or updates a forwarding event record in the
	// database.
	UpsertForward(ctx context.Context, input ForwardInput) error

	// PendingForwards retrieves forwards that haven't settled or failed.
	PendingForwards(ctx context.Context) ([]ForwardInput, error)

	// QueryForwardsWithCount retrieves forwarding event records matching
	// the given filters along with the total count.
	QueryForwardsWithCount(ctx context.Context,
		params QueryForwardsParams) ([]ForwardingEvent, int64, error)
}

type ForwardingEvent struct {
	// OpenedAt is the time when the forward was initiated.
	OpenedAt time.Time

	// SettledAt is the time when the forward settled (nil if not settled).
	SettledAt *time.Time

	// FailedAt is the time when the forward failed (nil if not failed).
	FailedAt *time.Time

	// RfqID is the RFQ session identifier.
	RfqID rfqmsg.ID

	// ChanIDIn is the short channel ID of the incoming channel.
	ChanIDIn uint64

	// ChanIDOut is the short channel ID of the outgoing channel.
	ChanIDOut uint64

	// HtlcID is the HTLC ID on the incoming channel.
	HtlcID uint64

	// AssetAmt is the asset amount involved in this swap.
	AssetAmt uint64

	// AmtInMsat is the actual amount received on the incoming channel in
	// millisatoshis.
	AmtInMsat uint64

	// AmtOutMsat is the actual amount sent on the outgoing channel in
	// millisatoshis.
	AmtOutMsat uint64

	// PolicyType indicates whether this was a sale or purchase from the
	// edge node's perspective.
	PolicyType RfqPolicyType

	// Peer is the counterparty peer's public key.
	Peer route.Vertex

	// AssetSpecifier identifies the specific asset or asset group (if set).
	AssetSpecifier asset.Specifier

	// Rate is the exchange rate used for this forward.
	Rate rfqmath.BigIntFixedPoint
}

type GroupLookup interface {
	// QueryAssetGroupByID fetches the group information of an asset, if it
	// belongs in a group.
	QueryAssetGroupByID(context.Context, asset.ID) (*asset.AssetGroup,
		error)
}

type HtlcInterceptor interface {
	// InterceptHtlcs intercepts HTLCs, using the handling function provided
	// to respond to HTLCs.
	InterceptHtlcs(context.Context, lndclient.HtlcInterceptHandler) error
}

type HtlcSubscriber interface {
	// SubscribeHtlcEvents subscribes to a stream of events related to
	// HTLC updates.
	SubscribeHtlcEvents(ctx context.Context) (<-chan *routerrpc.HtlcEvent,
		<-chan error, error)

	// LookupHtlcResolution retrieves the final resolution for an HTLC.
	LookupHtlcResolution(ctx context.Context, chanID uint64,
		htlcID uint64) (*lnrpc.LookupHtlcResolutionResponse, error)
}

type InboundPolicyFetcher func(ctx context.Context, chanID uint64,
	remotePubStr string) (*lnrpc.RoutingPolicy, error)

type IncomingRejectQuoteEvent struct {

	// Reject is the rejected quote.
	rfqmsg.Reject
	// contains filtered or unexported fields
}

type InternalPortfolioPilot struct {
	// contains filtered or unexported fields
}

type InternalPortfolioPilotConfig struct {
	// PriceOracle supplies pricing data. If nil, the pilot rejects requests
	// as the oracle is considered unavailable.
	PriceOracle PriceOracle

	// ForwardPeerIDToOracle controls whether the requesting peer ID is sent
	// to the oracle for peer-specific pricing. Disabling this avoids
	// sharing caller identity with the oracle.
	ForwardPeerIDToOracle bool

	// AcceptPriceDeviationPpm specifies the maximum allowable price
	// deviation in parts per million (PPM) when verifying accepted quotes.
	// This defines the tolerance threshold for comparing peer quotes
	// against oracle prices.
	AcceptPriceDeviationPpm uint64

	// MinAssetRatesExpiryLifetime specifies the minimum lifetime in
	// seconds for an asset rate expiry to be considered valid.
	MinAssetRatesExpiryLifetime uint64
}

type InvalidQuoteRespEvent struct {

	// QuoteResponse is the quote response received from the peer which was
	// deemed invalid.
	QuoteResponse rfqmsg.QuoteResponse

	// Status is the status of the quote response.
	Status QuoteRespStatus
	// contains filtered or unexported fields
}

type Manager struct {

	// ContextGuard provides a wait group and main quit channel that can be
	// used to create guarded contexts.
	*fn.ContextGuard
	// contains filtered or unexported fields
}

type ManagerCfg struct {
	// PeerMessenger is the peer messenger. This component provides the RFQ
	// manager with the ability to send and receive raw peer messages.
	PeerMessenger PeerMessenger

	// HtlcInterceptor is the HTLC interceptor. This component is used to
	// intercept and accept/reject HTLCs.
	HtlcInterceptor HtlcInterceptor

	// HtlcSubscriber is a subscriber that is used to retrieve live HTLC
	// event updates.
	HtlcSubscriber HtlcSubscriber

	// PriceOracle is the price oracle that the RFQ manager will use to
	// 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

	// GroupLookup is an interface that helps us querry asset groups by
	// asset IDs.
	GroupLookup GroupLookup

	// AliasManager is the SCID alias manager. This component is injected
	// into the manager once lnd and tapd are hooked together.
	AliasManager ScidAliasManager

	// AuxChannelNegotiator is responsible for producing the extra tlv blob
	// that is encapsulated in the init and reestablish peer messages. This
	// helps us communicate custom feature bits with our peer.
	AuxChanNegotiator *tapfeatures.AuxChannelNegotiator

	// PolicyStore provides persistence for agreed RFQ policies.
	PolicyStore PolicyStore

	// ForwardStore provides persistence for forwarding events. This is
	// used for edge node accounting. If nil, forwarding event logging is
	// disabled.
	ForwardStore ForwardStore

	// AcceptPriceDeviationPpm is the price deviation in
	// parts per million that is accepted by the RFQ negotiator.
	//
	// Example: 50,000 ppm => price deviation is set to 5% .
	AcceptPriceDeviationPpm uint64

	// SkipQuoteAcceptVerify is a flag that, when set, will cause the
	// RFQ negotiator to skip verification on incoming quote accept
	// messages (this means that the price oracle will not be queried).
	SkipQuoteAcceptVerify bool

	// NoOpHTLCs is a boolean indicating whether the daemon configuration
	// wants us to produce NoOp HTLCs.
	NoOpHTLCs bool

	// SendPriceHint is a flag that, if set, will send a price hint to the
	// peer when requesting a quote.
	SendPriceHint bool

	// SendPeerId is a flag that, if set, will send the peer ID (public
	// key of the peer) to the price oracle when requesting a price rate.
	SendPeerId bool

	// ErrChan is the main error channel which will be used to report back
	// critical errors to the main server.
	ErrChan chan<- error
}

type MockPriceOracle struct {
	// Mock is the underlying mock object used to track method invocations
	// in tests.
	mock.Mock
	// contains filtered or unexported fields
}

type Negotiator struct {

	// ContextGuard provides a wait group and main quit channel that can be
	// used to create guarded contexts.
	*fn.ContextGuard
	// contains filtered or unexported fields
}

type NegotiatorCfg struct {
	// PriceOracle is the price oracle that the negotiator will use to
	// 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

	// AcceptPriceDeviationPpm specifies the maximum allowable price
	// deviation in parts per million (PPM). This parameter defines the
	// threshold for the price returned by the price oracle service,
	// indicating how much it can deviate from a peer's quote accept price
	// for the node to consider using the accepted quote.
	AcceptPriceDeviationPpm uint64

	// SkipQuoteAcceptVerify is a flag that, if set, will skip the
	// verification process when validating an incoming quote accept
	// message. This is useful for testing purposes.
	SkipQuoteAcceptVerify bool

	// SendPriceHint is a flag that, if set, will send a price hint to the
	// peer when requesting a quote.
	SendPriceHint bool

	// SendPeerId is a flag that, if set, will send the peer ID (public
	// key of the peer) to the price oracle when requesting a price rate.
	SendPeerId bool

	// ErrChan is a channel that is populated with errors by this subsystem.
	ErrChan chan<- error
}

type OracleAddr = url.URL

type OracleError struct {
	// Code is a code which uniquely identifies the error type.
	Code OracleErrorCode

	// Msg is a human-readable error message.
	Msg string
}

type OracleErrorCode uint8

type OracleResponse struct {
	// AssetRate is the asset to BTC rate. Other asset in the transfer is
	// assumed to be BTC and therefore not included in the response.
	AssetRate rfqmsg.AssetRate

	// Err is an optional error returned by the price oracle service.
	Err *OracleError
}

type Order interface {
	// GetAssetSpecifier returns the asset specifier for this order.
	GetAssetSpecifier() asset.Specifier

	// GetPeer returns the optional peer for this order.
	GetPeer() fn.Option[route.Vertex]

	// GetPriceOracleMetadata returns the price oracle metadata for this
	// order.
	GetPriceOracleMetadata() string

	// GetExpiry returns the expiry time for this order.
	GetExpiry() time.Time
}

type OrderHandler struct {

	// ContextGuard provides a wait group and main quit channel that can be
	// used to create guarded contexts.
	*fn.ContextGuard
	// contains filtered or unexported fields
}

type OrderHandlerCfg struct {
	// CleanupInterval is the interval at which the order handler cleans up
	// expired accepted quotes from its local cache.
	CleanupInterval time.Duration

	// HtlcInterceptor is the HTLC interceptor. This component is used to
	// intercept and accept/reject HTLCs.
	HtlcInterceptor HtlcInterceptor

	// AliasManager is the SCID alias manager. This component is used to add
	// and remove SCID aliases.
	AliasManager ScidAliasManager

	// AcceptHtlcEvents is a channel that receives accepted HTLCs.
	AcceptHtlcEvents chan<- *AcceptHtlcEvent

	// HtlcSubscriber is a subscriber that is used to retrieve live HTLC
	// event updates.
	HtlcSubscriber HtlcSubscriber

	// SpecifierChecker is an interface that contains methods for
	// checking certain properties related to asset specifiers.
	SpecifierChecker rfqmsg.SpecifierChecker

	// NoOpHTLCs is a boolean indicating whether the daemon configuration
	// wants us to produce NoOp HTLCs.
	NoOpHTLCs bool

	// AuxChannelNegotiator is responsible for producing the extra tlv blob
	// that is encapsulated in the init and reestablish peer messages. This
	// helps us communicate custom feature bits with our peer.
	AuxChanNegotiator *tapfeatures.AuxChannelNegotiator

	// ErrChan is the main error channel that is used to propagate critical
	// errors back to the parent manager/server.
	ErrChan chan<- error

	// PolicyStore persists agreed RFQ policies.
	PolicyStore PolicyStore

	// ForwardStore persists forwarding events for accounting.
	// If nil, forwarding event logging is disabled.
	ForwardStore ForwardStore
}

type PeerAcceptedBuyQuoteEvent struct {

	// BuyAccept is the accepted asset buy quote.
	rfqmsg.BuyAccept
	// contains filtered or unexported fields
}

type PeerAcceptedSellQuoteEvent struct {

	// SellAccept is the accepted asset sell quote.
	rfqmsg.SellAccept
	// contains filtered or unexported fields
}

type PeerChanMap map[route.Vertex][]TapChannel

type PeerMessenger interface {
	// SubscribeCustomMessages creates a subscription to raw messages
	// received from our peers.
	SubscribeCustomMessages(
		ctx context.Context) (<-chan lndclient.CustomMessage,
		<-chan error, error)

	// SendCustomMessage sends a raw message to a peer.
	SendCustomMessage(context.Context, lndclient.CustomMessage) error
}

type Policy interface {
	// CheckHtlcCompliance returns an error if the given HTLC intercept
	// descriptor does not satisfy the subject policy.
	CheckHtlcCompliance(ctx context.Context, htlc lndclient.InterceptedHtlc,
		specifierChecker rfqmsg.SpecifierChecker) error

	// Expiry returns the policy's expiry time as a unix timestamp.
	Expiry() uint64

	// HasExpired returns true if the policy has expired.
	HasExpired() bool

	// Scid returns the serialised short channel ID (SCID) of the channel to
	// which the policy applies.
	Scid() uint64

	// RfqID returns the RFQ session identifier for this policy.
	RfqID() rfqmsg.ID

	// TrackAcceptedHtlc makes the policy aware of this new accepted HTLC.
	// This is important in cases where the set of existing HTLCs may affect
	// whether the next compliance check passes.
	TrackAcceptedHtlc(circuitKey models.CircuitKey, amt lnwire.MilliSatoshi)

	// UntrackHtlc stops tracking the uniquely identified HTLC.
	UntrackHtlc(circuitKey models.CircuitKey)

	// GenerateInterceptorResponse generates an interceptor response for the
	// HTLC interceptor from the policy.
	GenerateInterceptorResponse(
		lndclient.InterceptedHtlc) (*lndclient.InterceptedHtlcResponse,
		error)
}

type PolicyStore interface {
	// StoreSalePolicy stores an asset sale policy.
	StoreSalePolicy(ctx context.Context, accept rfqmsg.BuyAccept) error

	// StorePurchasePolicy stores an asset purchase policy.
	StorePurchasePolicy(ctx context.Context, accept rfqmsg.SellAccept) error

	// FetchAcceptedQuotes fetches all non-expired accepted quotes.
	// Returns sale policies as buy accepts, purchase policies as
	// sell accepts, peer-accepted buy quotes, and peer-accepted
	// sell quotes separately.
	FetchAcceptedQuotes(ctx context.Context) ([]rfqmsg.BuyAccept,
		[]rfqmsg.SellAccept, []rfqmsg.BuyAccept,
		[]rfqmsg.SellAccept, error)

	// StorePeerAcceptedBuyQuote persists a peer-accepted buy quote
	// for historical SCID-to-peer lookup.
	StorePeerAcceptedBuyQuote(ctx context.Context,
		accept rfqmsg.BuyAccept) error

	// StorePeerAcceptedSellQuote persists a peer-accepted sell
	// quote for restart continuity.
	StorePeerAcceptedSellQuote(ctx context.Context,
		accept rfqmsg.SellAccept) error

	// LookUpScid looks up the peer associated with the given SCID from
	// persisted peer-accepted buy quote policies.
	LookUpScid(ctx context.Context, scid uint64) (route.Vertex, error)
}

type PortfolioPilot interface {
	// ResolveRequest resolves a quote request by returning either an
	// acceptable asset rate or a quote rejection error. Errors are reserved
	// for unexpected failures while evaluating the request.
	ResolveRequest(context.Context, rfqmsg.Request) (ResolveResp,
		error)

	// VerifyAcceptQuote verifies that an accepted quote from a peer meets
	// acceptable conditions.
	VerifyAcceptQuote(context.Context, rfqmsg.Accept) (QuoteRespStatus,
		error)

	// QueryAssetRates returns current asset rate information for a given
	// asset and direction. Can be used for rate discovery, outgoing RFQ
	// request construction, or general pricing information.
	QueryAssetRates(context.Context, AssetRateQuery) (rfqmsg.AssetRate,
		error)

	// Close releases any resources held by the portfolio pilot.
	Close() error
}

type PortfolioPilotAddr = url.URL

type PriceOracle interface {
	// QuerySellPrice returns the sell price for a given asset amount. The
	// sell price is the amount the oracle suggests a peer should accept
	// from another peer to provide the specified asset amount.
	QuerySellPrice(ctx context.Context, assetSpecifier asset.Specifier,
		assetMaxAmt fn.Option[uint64],
		paymentMaxAmt fn.Option[lnwire.MilliSatoshi],
		assetRateHint fn.Option[rfqmsg.AssetRate],
		counterparty fn.Option[route.Vertex], metadata string,
		intent PriceQueryIntent) (*OracleResponse, error)

	// QueryBuyPrice returns the buy price for a given asset amount. The buy
	// price is the amount the oracle suggests a peer should pay to another
	// peer to receive the specified asset amount.
	QueryBuyPrice(ctx context.Context, assetSpecifier asset.Specifier,
		assetMaxAmt fn.Option[uint64],
		paymentMaxAmt fn.Option[lnwire.MilliSatoshi],
		assetRateHint fn.Option[rfqmsg.AssetRate],
		counterparty fn.Option[route.Vertex], metadata string,
		intent PriceQueryIntent) (*OracleResponse, error)
}

type PriceQueryIntent uint8

type QueryForwardsParams struct {
	// MinTimestamp filters forwarding events to those settled at or after
	// this time.
	// None means no lower bound.
	MinTimestamp fn.Option[time.Time]

	// MaxTimestamp filters forwarding events to those settled at or before
	// this
	// time. None means no upper bound.
	MaxTimestamp fn.Option[time.Time]

	// Peer filters forwarding events to those with this counterparty.
	// Nil means no filter.
	Peer *route.Vertex

	// AssetSpecifier filters forwarding events to those involving this
	// asset or
	// asset group. Nil means no filter.
	AssetSpecifier *asset.Specifier

	// Limit is the maximum number of records to return.
	Limit int32

	// Offset is the number of records to skip (for pagination).
	Offset int32
}

type QuoteRespStatus uint8

type ResolveResp struct {
	// contains filtered or unexported fields
}

type RfqPolicyType string

type RpcPortfolioPilot struct {
	// contains filtered or unexported fields
}

type RpcPriceOracle struct {
	// contains filtered or unexported fields
}

type ScidAliasManager interface {
	// AddLocalAlias adds a database mapping from the passed alias to the
	// passed base SCID.
	AddLocalAlias(ctx context.Context, alias,
		baseScid lnwire.ShortChannelID) error

	// DeleteLocalAlias removes a mapping from the database and the
	// Manager's maps.
	DeleteLocalAlias(ctx context.Context, alias,
		baseScid lnwire.ShortChannelID) error

	// FetchBaseAlias finds the base channel ID for a given alias. This scid
	// will correspond to the real channel scid that is used to identify the
	// channel.
	FetchBaseAlias(ctx context.Context,
		alias lnwire.ShortChannelID) (lnwire.ShortChannelID, error)
}

type SellAcceptMap map[SerialisedScid]rfqmsg.SellAccept

type SellOffer struct {
	// AssetID represents the identifier of the subject asset.
	AssetID *asset.ID

	// AssetGroupKey is the public group key of the subject asset.
	AssetGroupKey *btcec.PublicKey

	// MaxUnits is the maximum amount of the asset under offer.
	MaxUnits uint64
}

type SellOrder struct {
	// AssetSpecifier is the asset that the seller is interested in.
	AssetSpecifier asset.Specifier

	// PaymentMaxAmt is the maximum msat amount that the responding peer
	// must agree to pay.
	PaymentMaxAmt lnwire.MilliSatoshi

	// PaymentMinAmt is an optional minimum msat amount for the order.
	PaymentMinAmt fn.Option[lnwire.MilliSatoshi]

	// AssetRateLimit is an optional maximum acceptable rate (asset
	// units per BTC) for the order.
	AssetRateLimit fn.Option[rfqmath.BigIntFixedPoint]

	// ExecutionPolicy is an optional execution policy (IOC or
	// FOK) for the order.
	ExecutionPolicy fn.Option[rfqmsg.ExecutionPolicy]

	// Expiry is the time at which the order expires.
	Expiry time.Time

	// Peer is the peer that the buy order is intended for. This field is
	// optional.
	Peer fn.Option[route.Vertex]

	// PriceOracleMetadata is an optional text field that can be used to
	// provide additional metadata about the sell order to the price
	// oracle. This can include information about the wallet end user that
	// initiated the transaction, or any authentication information that the
	// price oracle can use to give out a more accurate (or discount) asset
	// rate. The maximum length of this field is 32'768 bytes.
	PriceOracleMetadata string
}

type SerialisedScid = rfqmsg.SerialisedScid

type StreamHandler struct {

	// ContextGuard provides a wait group and main quit channel that can be
	// used to create guarded contexts.
	*fn.ContextGuard
	// contains filtered or unexported fields
}

type StreamHandlerCfg struct {
	// PeerMessenger is the peer messenger. This component provides the RFQ
	// manager with the ability to send and receive raw peer messages.
	PeerMessenger PeerMessenger

	// IncomingMessages is a channel which is populated with incoming
	// (received) RFQ messages. These messages have been extracted from the
	// raw peer wire messages by the stream handler service.
	IncomingMessages chan<- rfqmsg.IncomingMsg
}

type TLSConfig struct {
	// Disabled indicates that we should not use TLS.
	Disabled bool

	// InsecureSkipVerify disables certificate verification.
	InsecureSkipVerify bool

	// TrustSystemRootCAs indicates whether or not to use the operating
	// system's root certificate authority list.
	TrustSystemRootCAs bool

	// CustomCertificates contains PEM data for additional root CA and
	// self-signed certificates to trust.
	CustomCertificates []byte
}

type TapChannel struct {
	// Specifier is the asset Specifier that is satisfied by this channels'
	// assets.
	Specifier asset.Specifier

	// ChannelInfo is the information about the channel the asset is
	// committed to.
	ChannelInfo lndclient.ChannelInfo

	// AssetInfo contains the asset related info of the channel.
	AssetInfo rfqmsg.JsonAssetChannel
}