akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

channeldb/channel: add serialization for single funder funding txn

Browse Source
This commit is contained in:
Conner Fromknecht 2018-03-10 17:28:11 -08:00
parent b635b83abd
commit db88c82169
No known key found for this signature in database
GPG Key ID: 39DE78FBE6ACB0EF
1 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
channeldb/channel.go
View File

@ -403,6 +403,14 @@ type OpenChannel struct {
// failures and reforward HTLCs that were not fully processed. // failures and reforward HTLCs that were not fully processed.
Packager FwdPackager Packager FwdPackager
// FundingTxn is the transaction containing this channel's funding
// outpoint. Upon restarts, this txn will be rebroadcast if the channel
// is found to be pending.
//
// NOTE: This value will only be populated for single-funder channels
// for which we are the initiator.
FundingTxn *wire.MsgTx
// TODO(roasbeef): eww // TODO(roasbeef): eww
Db *DB Db *DB
@ -1797,6 +1805,13 @@ func putChanInfo(chanBucket *bolt.Bucket, channel *OpenChannel) error {
return err return err
} }
// For single funder channels that we initiated, write the funding txn.
if channel.ChanType == SingleFunder && channel.IsInitiator {
if err := writeElement(&w, channel.FundingTxn); err != nil {
return err
}
}
writeChanConfig := func(b io.Writer, c *ChannelConfig) error { writeChanConfig := func(b io.Writer, c *ChannelConfig) error {
return writeElements(b, return writeElements(b,
c.DustLimit, c.MaxPendingAmount, c.ChanReserve, c.MinHTLC, c.DustLimit, c.MaxPendingAmount, c.ChanReserve, c.MinHTLC,
@ -1898,6 +1913,13 @@ func fetchChanInfo(chanBucket *bolt.Bucket, channel *OpenChannel) error {
return err return err
} }
// For single funder channels that we initiated, read the funding txn.
if channel.ChanType == SingleFunder && channel.IsInitiator {
if err := readElement(r, &channel.FundingTxn); err != nil {
return err
}
}
readChanConfig := func(b io.Reader, c *ChannelConfig) error { readChanConfig := func(b io.Reader, c *ChannelConfig) error {
return readElements(b, return readElements(b,
&c.DustLimit, &c.MaxPendingAmount, &c.ChanReserve, &c.DustLimit, &c.MaxPendingAmount, &c.ChanReserve,