lnd

type Config struct {
	LNClientType                 string  `envconfig:"LN_CLIENT_TYPE" default:"lnd"` //lnd, lnd_cluster, eclair
	LNDAddress                   string  `envconfig:"LND_ADDRESS" required:"true"`
	LNDMacaroonFile              string  `envconfig:"LND_MACAROON_FILE"`
	LNDCertFile                  string  `envconfig:"LND_CERT_FILE"`
	LNDMacaroonHex               string  `envconfig:"LND_MACAROON_HEX"`
	LNDCertHex                   string  `envconfig:"LND_CERT_HEX"`
	LNDClusterLivenessPeriod     int     `envconfig:"LND_CLUSTER_LIVENESS_PERIOD" default:"10"`
	LNDClusterActiveChannelRatio float64 `envconfig:"LND_CLUSTER_ACTIVE_CHANNEL_RATIO" default:"0.5"`
	LNDClusterPubkeys            string  `envconfig:"LND_CLUSTER_PUBKEYS"` //comma-seperated list of public keys of the cluster
}

type LNDCluster struct {
	Nodes               []LightningClientWrapper
	ActiveNode          LightningClientWrapper
	ActiveChannelRatio  float64
	Logger              *lecho.Logger
	LivenessCheckPeriod int
}

type LNDWrapper struct {
	IdentityPubkey string
	// contains filtered or unexported fields
}

type LNDoptions struct {
	Address      string
	CertFile     string
	CertHex      string
	MacaroonFile string
	MacaroonHex  string
}

type LNPayReq struct {
	PayReq  *lnrpc.PayReq
	Keysend bool
}

type LightningClientWrapper interface {
	ListChannels(ctx context.Context, req *lnrpc.ListChannelsRequest, options ...grpc.CallOption) (*lnrpc.ListChannelsResponse, error)
	SendPaymentSync(ctx context.Context, req *lnrpc.SendRequest, options ...grpc.CallOption) (*lnrpc.SendResponse, error)
	AddInvoice(ctx context.Context, req *lnrpc.Invoice, options ...grpc.CallOption) (*lnrpc.AddInvoiceResponse, error)
	SubscribeInvoices(ctx context.Context, req *lnrpc.InvoiceSubscription, options ...grpc.CallOption) (SubscribeInvoicesWrapper, error)
	SubscribePayment(ctx context.Context, req *routerrpc.TrackPaymentRequest, options ...grpc.CallOption) (SubscribePaymentWrapper, error)
	GetInfo(ctx context.Context, req *lnrpc.GetInfoRequest, options ...grpc.CallOption) (*lnrpc.GetInfoResponse, error)
	DecodeBolt11(ctx context.Context, bolt11 string, options ...grpc.CallOption) (*lnrpc.PayReq, error)
	IsIdentityPubkey(pubkey string) (isOurPubkey bool)
	GetMainPubkey() (pubkey string)
}

type SubscribeInvoicesWrapper interface {
	Recv() (*lnrpc.Invoice, error)
}

type SubscribePaymentWrapper interface {
	Recv() (*lnrpc.Payment, error)
}