swapper

Documentation

Index

• Constants
• type InProgressRedeem
• type Redeemer
  • func NewRedeemer(ssClient lnrpc.LightningClient, ssRouterClient routerrpc.RouterClient, ...) *Redeemer
  • func (r *Redeemer) RedeemWithFees(preimage []byte, targetConf int32, satPerVbyte int64) (string, error)
  • func (r *Redeemer) RedeemWithinBlocks(preimage []byte, blocks int32) (string, error)
  • func (r *Redeemer) Start(ctx context.Context)
• type Server
  • func NewServer(network *chaincfg.Params, redisPool *redis.Pool, ...) *Server
  • func (s *Server) AddFundInit(ctx context.Context, in *breez.AddFundInitRequest) (*breez.AddFundInitReply, error)
  • func (s *Server) AddFundInitLegacy(ctx context.Context, in *breez.AddFundInitRequest) (*breez.AddFundInitReply, error)
  • func (s *Server) AddFundStatus(ctx context.Context, in *breez.AddFundStatusRequest) (*breez.AddFundStatusReply, error)
  • func (s *Server) GetReverseRoutingNode(ctx context.Context, in *breez.GetReverseRoutingNodeRequest) (*breez.GetReverseRoutingNodeReply, error)
  • func (s *Server) GetSwapPayment(ctx context.Context, in *breez.GetSwapPaymentRequest) (*breez.GetSwapPaymentReply, error)
  • func (s *Server) GetSwapPaymentLegacy(ctx context.Context, in *breez.GetSwapPaymentRequest) (*breez.GetSwapPaymentReply, error)
  • func (s *Server) RedeemSwapPayment(ctx context.Context, in *breez.RedeemSwapPaymentRequest) (*breez.RedeemSwapPaymentReply, error)
  • func (s *Server) RedeemSwapPayments()

Constants

const MinConfirmations = 6

const SwapLockTime = 288

Types

type InProgressRedeem

type InProgressRedeem struct {
	PaymentHash        string
	Preimage           *string
	LockHeight         int32
	ConfirmationHeight int32
	Utxos              []string
	RedeemTxids        []string
}

type Redeemer

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

func NewRedeemer

func NewRedeemer(
	ssClient lnrpc.LightningClient,
	ssRouterClient routerrpc.RouterClient,
	subswapClient submarineswaprpc.SubmarineSwapperClient,
	updateSubswapTxid func(paymentHash, txid string) error,
	updateSubswapPreimage func(paymentHash, paymentPreimage string) error,
	getInProgressRedeems func(blockheight int32) ([]*InProgressRedeem, error),
	setSubswapConfirmed func(paymentHash string) error,
) *Redeemer

func (*Redeemer) RedeemWithFees

func (r *Redeemer) RedeemWithFees(preimage []byte, targetConf int32, satPerVbyte int64) (string, error)

func (*Redeemer) RedeemWithinBlocks

func (r *Redeemer) RedeemWithinBlocks(preimage []byte, blocks int32) (string, error)

func (*Redeemer) Start

func (r *Redeemer) Start(ctx context.Context)

type Server

type Server struct {
	breez.UnimplementedSwapperServer
	// contains filtered or unexported fields
}

Server implements lsp grpc functions

func NewServer

func NewServer(
	network *chaincfg.Params,
	redisPool *redis.Pool,
	client, ssClient lnrpc.LightningClient,
	subswapClient submarineswaprpc.SubmarineSwapperClient,
	redeemer *Redeemer,
	walletKitClient walletrpc.WalletKitClient,
	ssRouterClient routerrpc.RouterClient,
	insertSubswapPayment func(paymentHash, paymentRequest string, lockheight, confirmationheight int32, utxos []string) error,
	updateSubswapPreimage func(paymentHash, paymentPreimage string) error,
	hasFilteredAddress func(addrs []string) (bool, error),
) *Server

func (*Server) AddFundInit

func (s *Server) AddFundInit(ctx context.Context, in *breez.AddFundInitRequest) (*breez.AddFundInitReply, error)

func (*Server) AddFundInitLegacy

func (s *Server) AddFundInitLegacy(ctx context.Context, in *breez.AddFundInitRequest) (*breez.AddFundInitReply, error)

func (*Server) AddFundStatus

func (s *Server) AddFundStatus(ctx context.Context, in *breez.AddFundStatusRequest) (*breez.AddFundStatusReply, error)

func (*Server) GetReverseRoutingNode

func (s *Server) GetReverseRoutingNode(ctx context.Context, in *breez.GetReverseRoutingNodeRequest) (*breez.GetReverseRoutingNodeReply, error)

func (*Server) GetSwapPayment

func (s *Server) GetSwapPayment(ctx context.Context, in *breez.GetSwapPaymentRequest) (*breez.GetSwapPaymentReply, error)

func (*Server) GetSwapPaymentLegacy

func (s *Server) GetSwapPaymentLegacy(ctx context.Context, in *breez.GetSwapPaymentRequest) (*breez.GetSwapPaymentReply, error)

func (*Server) RedeemSwapPayment

func (s *Server) RedeemSwapPayment(ctx context.Context, in *breez.RedeemSwapPaymentRequest) (*breez.RedeemSwapPaymentReply, error)

func (*Server) RedeemSwapPayments

func (s *Server) RedeemSwapPayments()