testframework

type BitcoinNode struct {
	*DaemonProcess
	*RpcProxy

	DataDir     string
	ConfigFile  string
	RpcPort     int
	RpcUser     string
	RpcPassword string
	WalletName  string

	ZmqPubRawTx    string
	ZmqPubRawBlock string
}

type CLightningNode struct {
	*DaemonProcess
	*CLightningProxy

	DataDir    string
	ConfigFile string
	Port       int
	Info       *glightning.NodeInfo
	// contains filtered or unexported fields
}

type CLightningProxy struct {
	Rpc *glightning.Lightning
	// contains filtered or unexported fields
}

type DaemonProcess struct {
	CmdLine []string
	Cmd     *exec.Cmd
	StdOut  *lockedWriter
	StdErr  *lockedWriter
	// contains filtered or unexported fields
}

type IdGetter interface {
	NextId() int
}

type IntIdGetter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type LightningNode interface {
	Address() (addr string)
	Id() (id string)

	// GetBtcBalanceSat returns the total amount of sats on the nodes
	// wallet.
	GetBtcBalanceSat() (sats uint64, err error)
	// GetChannelBalanceSat returns the confirmed balance of a channel.
	// scid is given clightning style i.e `100x0x1`.
	GetChannelBalanceSat(scid string) (sats uint64, err error)
	// GetScid returns the short channel id with a peer in clightning style
	// i.e. `100x0x1`.
	GetScid(peer LightningNode) (scid string, err error)

	Connect(peer LightningNode, waitForConnection bool) error
	FundWallet(sats uint64, mineBlock bool) (addr string, err error)
	OpenChannel(peer LightningNode, capacity uint64, connect, confirm, waitForChannelActive bool) (scid string, err error)

	IsBlockHeightSynced() (bool, error)
	IsChannelActive(scid string) (bool, error)
	IsConnected(peer LightningNode) (bool, error)

	AddInvoice(amtSat uint64, desc, label string) (payreq string, err error)
	PayInvoice(payreq string) error
	SendPay(bolt11, scid string) error

	// GetLatestInvoice returns the latest invoice from the stack of created
	// invoices.
	GetLatestInvoice() (payreq string, err error)
	GetMemoFromPayreq(payreq string) (memo string, err error)

	Run(waitForReady, swaitForBitcoinSynced bool) error
	Stop() error
}

type LiquidNode struct {
	*DaemonProcess
	*RpcProxy

	DataDir     string
	ConfigFile  string
	Port        int
	RpcPort     int
	RpcUser     string
	RpcPassword string
	WalletName  string
	Network     string
	// contains filtered or unexported fields
}

type LndNode struct {
	*DaemonProcess
	*LndRpcClient

	DataDir      string
	ConfigFile   string
	RpcPort      int
	ListenPort   int
	TlsPath      string
	MacaroonPath string
	Info         *lnrpc.GetInfoResponse
	// contains filtered or unexported fields
}

type LndRpcClient struct {
	Rpc   lnrpc.LightningClient
	RpcV2 routerrpc.RouterClient
	// contains filtered or unexported fields
}

type PortMap struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RpcProxy struct {
	Rpc jsonrpc.RPCClient
	// contains filtered or unexported fields
}

type WaitFunc func() bool

type WaitFuncWithErr func() (bool, error)